cmd/scollector: RabbitMQ #1202
cmd/scollector: RabbitMQ #1202
Conversation
| @@ -238,6 +238,11 @@ or just one. | |||
| [[HTTPUnit]] | |||
| TOML = "/some/other.toml" | |||
|
|
|||
| RabbitMQ (array of table, keys are URL): RabbitMQ hosts to poll. | |||
There was a problem hiding this comment.
perhaps document that it will check localhost, even with no config given.
|
One of the problems I've encountered is |
|
That would be an acceptable use of an interface{} field. Most others look like they could be mapped into structs. Have you seen this tool: http://mholt.github.io/json-to-go/? |
|
Yeah, seen that, will do some research on how does RMQ output stats in different versions. |
|
@dimamedvedev Also the gojson as a local utility is quite nice https://github.com/ChimeraCoder/gojson , you just do |
d10v
force-pushed
the
collector-rabbitmq
branch
2 times, most recently
from
10de452 to
c65c98d
Compare
|
| Add(&md, p+"message_bytes_ready", q.MessageBytesReady, ts, metadata.Gauge, metadata.Bytes, DescRmqMessageBytesReady) | ||
| Add(&md, p+"message_bytes_unack", q.MessageBytesUnacknowledged, ts, metadata.Gauge, metadata.Bytes, DescRmqMessageBytesUnacknowledged) | ||
| Add(&md, p+"messages_queue_depth", q.Messages, ts, metadata.Gauge, metadata.Message, DescRmqMessages) | ||
| Add(&md, p+"messages_persistent", q.MessagesPersistent, ts, metadata.Gauge, metadata.Message, DescRmqMessagesPersistent) |
There was a problem hiding this comment.
These could be tagged, not 100% sure.
d10v
force-pushed
the
collector-rabbitmq
branch
2 times, most recently
from
1f6af72 to
91de289
Compare
| return nil, err | ||
| } | ||
| var o rmqOverview | ||
| if err := json.NewDecoder(bytes.NewReader(content[:])).Decode(&o); err != nil { |
There was a problem hiding this comment.
You don't even need to read the body prior to this. Just use json.NewDecoder(res.Body)
|
@captncraig updated PR, will squash when ready |
| metadata.Rate, metadata.Message, DescRmqBackingQueueStatusAvgAckIngressRate) | ||
| Add(&md, p+"avg_rate", bqs.AvgAckEgressRate, ts.Copy().Merge(opentsdb.TagSet{"direction": "out"}), | ||
| metadata.Rate, metadata.Message, DescRmqBackingQueueStatusAvgEgressRate) | ||
| Add(&md, p+"avg_rate", bqs.AvgAckEgressRate, ts.Copy().Merge(opentsdb.TagSet{"direction": "in"}), |
There was a problem hiding this comment.
You are adding the same two data points twice, with different tagsets (once with direction and method, once with only direction). This scheme seems like it may cause confusing data conditions. Why Not have just the first two Adds and the last one?
There was a problem hiding this comment.
Oh, my bad, easy to get lost in so many metrics. Used wrong datapoints. Thank you for being thorough.
d10v
force-pushed
the
collector-rabbitmq
branch
from
ab3f1f0 to
98bf1d1
Compare
d10v
force-pushed
the
collector-rabbitmq
branch
from
98bf1d1 to
f74cdf1
Compare
Fairly comprehensive collector for RabbitMQ 3.x Probably needs careful review of metric/tags design.