metric

Documentation

Index

• Variables

Variables

var (
	MessagePublished = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "message_store_to_the_topic_watcher",
		Help: "The total number succesfully published to the topic watcher",
	})

	MessagePublishedTopic = func(topicName string) *prometheus.CounterVec {
		return prometheus.NewCounterVec(prometheus.CounterOpts{
			Namespace: "worker",
			Subsystem: "dispatch_job",
			Name:      fmt.Sprintf("message_published_%s", topicName),
			Help:      fmt.Sprintf("The total number succesfully published to the topic %s", topicName),
		}, []string{"topic"})
	}

	TotalFlightRequestQueueSubscriber = func(topicName, subscriberName string) *prometheus.GaugeVec {
		return prometheus.NewGaugeVec(prometheus.GaugeOpts{
			Namespace: "request",
			Subsystem: "queue",
			Name:      fmt.Sprintf("total_flight_request_queue_topic_%s_subscriber_%s", topicName, subscriberName),
			Help:      fmt.Sprintf("The current total flight request queue on topic %s subscriber %s", topicName, subscriberName),
		}, []string{"topic", "subscriber"})
	}

	TotalConsumedMessage = func(topicName, subscriberName string) *prometheus.CounterVec {
		return prometheus.NewCounterVec(prometheus.CounterOpts{
			Namespace: "request",
			Subsystem: "message",
			Name:      fmt.Sprintf("total_consumed_message_topic_%s_subscriber_%s", topicName, subscriberName),
			Help:      fmt.Sprintf("The current total consumed message on topic %s subscriber %s", topicName, subscriberName),
		}, []string{"topic", "subscriber"})
	}
)