Documentation ¶
Index ¶
- type Informer
- type Recorder
- type Registry
- func (r *Registry) IncConnectionRecoveryFailure(err error)
- func (r *Registry) IncConnectionRecoverySuccess(err error)
- func (r *Registry) IncMessagePublishedFailure(msg *servicebus.Message)
- func (r *Registry) IncMessagePublishedSuccess(msg *servicebus.Message)
- func (r *Registry) Init(reg prom.Registerer)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Informer ¶ added in v0.7.3
type Informer struct {
// contains filtered or unexported fields
}
func NewInformer ¶ added in v0.7.3
func NewInformer() *Informer
func (*Informer) GetConnectionRecoveryFailureCount ¶ added in v0.7.3
type Recorder ¶
type Recorder interface { Init(registerer prom.Registerer) IncConnectionRecoverySuccess(err error) IncConnectionRecoveryFailure(err error) IncMessagePublishedSuccess(msg *servicebus.Message) IncMessagePublishedFailure(msg *servicebus.Message) }
var Metrics Recorder = metricsRegistry
type Registry ¶
type Registry struct { MessagePublishedCount *prom.CounterVec ConnectionRecovery *prom.CounterVec }
func (*Registry) IncConnectionRecoveryFailure ¶
func (*Registry) IncConnectionRecoverySuccess ¶
func (*Registry) IncMessagePublishedFailure ¶
func (r *Registry) IncMessagePublishedFailure(msg *servicebus.Message)
func (*Registry) IncMessagePublishedSuccess ¶
func (r *Registry) IncMessagePublishedSuccess(msg *servicebus.Message)
func (*Registry) Init ¶
func (r *Registry) Init(reg prom.Registerer)
Click to show internal directories.
Click to hide internal directories.