Added metric to monitor events channel buffer lenght

client/async.go

@@ -212,6 +212,8 @@ func (a *gRPCClientAsync) sendRoutine() {
 	for {
 		select {
 		case e := <-a.eventsChannel:
+			metrics.AsyncClientEventsChannelLength.WithLabelValues(
+				e.Topic).Set(float64(len(a.eventsChannel)))
 			if len(req.Events) == 0 {
 				a.wg.Add(1)
 			}

metrics/metrics.go

@@ -67,6 +67,16 @@ var (
 		[]string{LabelRoute, LabelTopic, LabelStatus},
 	)
 
+	// AsyncClientEventsChannelLength is the number of current events in the eventsChannel buffer
+	AsyncClientEventsChannelLength = prometheus.NewGaugeVec(prometheus.GaugeOpts{
+		Namespace: metricsNamespace,
+		Subsystem: metricsSubsystem,
+		Name:      "async_events_channel_length",
+		Help:      "the number of current events in the eventsChannel buffer in the async client",
+	},
+		[]string{LabelTopic},
+	)
+
 	// AsyncClientEventsDroppedCounter is the count of requests that were dropped due
 	// to req.Retry > maxRetries. Only available for Async mode
 	AsyncClientEventsDroppedCounter = prometheus.NewCounterVec(prometheus.CounterOpts{
@@ -88,6 +98,7 @@ func RegisterMetrics(configPrefix string, config *viper.Viper) error {
 		ClientRequestsResponseTime,
 		ClientEventsCounter,
 		AsyncClientEventsDroppedCounter,
+		AsyncClientEventsChannelLength,
 	}
 
 	for _, collector := range collectors {