publisher

type Recorder interface {
	Init(registerer prom.Registerer)
	IncConnectionRecoverySuccess(err error)
	IncConnectionRecoveryFailure(err error)
	IncMessagePublishedSuccess(msg *servicebus.Message)
	IncMessagePublishedFailure(msg *servicebus.Message)
}

type Registry struct {
	MessagePublishedCount *prom.CounterVec
	ConnectionRecovery    *prom.CounterVec
}