From fb9df326d09bbf363f1c2883021cc13506c50302 Mon Sep 17 00:00:00 2001 From: Ulric Qin Date: Tue, 3 May 2022 10:57:05 +0800 Subject: [PATCH] add ack_rate --- inputs/rabbitmq/rabbitmq.go | 37 ++++++++++++++++++++----------------- 1 file changed, 20 insertions(+), 17 deletions(-) diff --git a/inputs/rabbitmq/rabbitmq.go b/inputs/rabbitmq/rabbitmq.go index 8904576..a5c7f6d 100644 --- a/inputs/rabbitmq/rabbitmq.go +++ b/inputs/rabbitmq/rabbitmq.go @@ -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)