listener

type Informer struct {
	// contains filtered or unexported fields
}

type Recorder interface {
	Init(registerer prom.Registerer)
	IncMessageDeadlineReachedCount(msg *servicebus.Message)
	IncMessageLockRenewedFailure(msg *servicebus.Message)
	IncMessageLockRenewedSuccess(msg *servicebus.Message)
	DecConcurrentMessageCount(msg *servicebus.Message)
	IncMessageHandled(msg *servicebus.Message)
	IncConcurrentMessageCount(msg *servicebus.Message)
}

type Registry struct {
	MessageHandledCount         *prom.CounterVec
	MessageLockRenewedCount     *prom.CounterVec
	MessageDeadlineReachedCount *prom.CounterVec
	ConcurrentMessageCount      *prom.GaugeVec
	ConnectionRecovery          *prom.CounterVec
}