p17860254
/
categraf
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add ack_rate

This commit is contained in:
Ulric Qin 2022-05-03 10:57:05 +08:00
parent 591ec986ab
commit fb9df326d0
1 changed files with 20 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
inputs/rabbitmq/rabbitmq.go
View File

@ -487,23 +487,26 @@ func gatherOverview(ins *Instance, slist *list.SafeList) {
}
fields := map[string]interface{}{
"overview_messages": overview.QueueTotals.Messages,
"overview_messages_ready": overview.QueueTotals.MessagesReady,
"overview_messages_unacked": overview.QueueTotals.MessagesUnacknowledged,
"overview_channels": overview.ObjectTotals.Channels,
"overview_connections": overview.ObjectTotals.Connections,
"overview_consumers": overview.ObjectTotals.Consumers,
"overview_exchanges": overview.ObjectTotals.Exchanges,
"overview_queues": overview.ObjectTotals.Queues,
"overview_messages_acked": overview.MessageStats.Ack,
"overview_messages_delivered": overview.MessageStats.Deliver,
"overview_messages_redelivered": overview.MessageStats.Redeliver,
"overview_messages_delivered_get": overview.MessageStats.DeliverGet,
"overview_messages_published": overview.MessageStats.Publish,
"overview_clustering_listeners": clusteringListeners,
"overview_amqp_listeners": amqpListeners,
"overview_return_unroutable": overview.MessageStats.ReturnUnroutable,
"overview_return_unroutable_rate": overview.MessageStats.ReturnUnroutableDetails.Rate,
"overview_messages": overview.QueueTotals.Messages,
"overview_messages_ready": overview.QueueTotals.MessagesReady,
"overview_messages_unacked": overview.QueueTotals.MessagesUnacknowledged,
"overview_channels": overview.ObjectTotals.Channels,
"overview_connections": overview.ObjectTotals.Connections,
"overview_consumers": overview.ObjectTotals.Consumers,
"overview_exchanges": overview.ObjectTotals.Exchanges,
"overview_queues": overview.ObjectTotals.Queues,
"overview_messages_acked": overview.MessageStats.Ack,
"overview_messages_acked_rate": overview.MessageStats.AckDetails.Rate,
"overview_messages_delivered": overview.MessageStats.Deliver,
"overview_messages_delivered_rate": overview.MessageStats.DeliverDetails.Rate,
"overview_messages_redelivered": overview.MessageStats.Redeliver,
"overview_messages_redelivered_rate": overview.MessageStats.RedeliverDetails.Rate,
"overview_messages_delivered_get": overview.MessageStats.DeliverGet,
"overview_messages_published": overview.MessageStats.Publish,
"overview_clustering_listeners": clusteringListeners,
"overview_amqp_listeners": amqpListeners,
"overview_return_unroutable": overview.MessageStats.ReturnUnroutable,
"overview_return_unroutable_rate": overview.MessageStats.ReturnUnroutableDetails.Rate,
}
inputs.PushSamples(slist, fields, tags)