go-channels-monitor is a utility and service for keeping track of channel capacities and reporting on them.
##Install
$ go get github.com/longshotsyndicate/go-channels-monitor##Usage
boolChannel := make(chan bool, 100)
// add your channel to be monitored, optionally specifying a string instance id for the channel.
//in this example we are registering one of potentially many boolChannel channels, each with an id like "instance-10"
//instances need to be unique for the channel name but not globally unique.
monitor.AddNamed("bool-channel-name", "instance-"+strconv.Itoa(nLogWriters++), boolChannel)
properties := monitor.Get("bool-channel-name", "instance-1")
log.Printf("bool-channel-name len: %d, cap: %d, instance: %s", properties.Len, properties.Cap, properties.Instance)
The service type allows you to query for channel properties.
//async error reporting
errc := make(chan error)
go func() {
for _, err := range errc {
log.Printf("Error: %v", err)
}
}()
//create and start the service that responds with channel properties.
service.New("my-service", ":9999", errc).Start()
###Query Response
Making a GET request on your-ip:9999/channels will result in the following reponse:
{"service":"bool-channel-name",
"channels":{
"foo":{"length":0,"capacity":100, "instance": "instance-1"}
}
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent