Documentation ¶
Index ¶
Constants ¶
Variables ¶
View Source
var ( DeliveredMessageTotal = promauto.NewCounterVec(prometheus.CounterOpts{ Namespace: "ejaculation_counter", Name: "delivered_message_total", Help: "Total number of messages delivered from message queue.", }, []string{"type"}) DeliveredMessageErrorTotal = promauto.NewCounterVec(prometheus.CounterOpts{ Namespace: "ejaculation_counter", Name: "delivered_message_error_total", Help: "Total number of errors when delivered from message queue.", }, []string{"type"}) )
Functions ¶
func NewReader ¶
func NewReader( exchange string, queueName string, routingKey string, environment config.Environment, ) (service.QueueReader, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.