Documentation ¶
Index ¶
- type Informer
- type Recorder
- type Registry
- func (m *Registry) DecConcurrentMessageCount(msg *servicebus.Message)
- func (m *Registry) IncConcurrentMessageCount(msg *servicebus.Message)
- func (m *Registry) IncMessageDeadlineReachedCount(msg *servicebus.Message)
- func (m *Registry) IncMessageHandled(msg *servicebus.Message)
- func (m *Registry) IncMessageLockRenewedFailure(msg *servicebus.Message)
- func (m *Registry) IncMessageLockRenewedSuccess(msg *servicebus.Message)
- func (m *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.8.3
type Informer struct {
// contains filtered or unexported fields
}
func NewInformer ¶ added in v0.8.3
func NewInformer() *Informer
func (*Informer) GetMessageLockRenewedFailureCount ¶ added in v0.8.3
type Recorder ¶
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) }
var (
Metrics Recorder = metricsRegistry
)
type Registry ¶
type Registry struct { MessageHandledCount *prom.CounterVec MessageLockRenewedCount *prom.CounterVec MessageDeadlineReachedCount *prom.CounterVec ConcurrentMessageCount *prom.GaugeVec ConnectionRecovery *prom.CounterVec }
func (*Registry) DecConcurrentMessageCount ¶
func (m *Registry) DecConcurrentMessageCount(msg *servicebus.Message)
func (*Registry) IncConcurrentMessageCount ¶
func (m *Registry) IncConcurrentMessageCount(msg *servicebus.Message)
func (*Registry) IncMessageDeadlineReachedCount ¶
func (m *Registry) IncMessageDeadlineReachedCount(msg *servicebus.Message)
func (*Registry) IncMessageHandled ¶
func (m *Registry) IncMessageHandled(msg *servicebus.Message)
func (*Registry) IncMessageLockRenewedFailure ¶
func (m *Registry) IncMessageLockRenewedFailure(msg *servicebus.Message)
func (*Registry) IncMessageLockRenewedSuccess ¶
func (m *Registry) IncMessageLockRenewedSuccess(msg *servicebus.Message)
func (*Registry) Init ¶
func (m *Registry) Init(reg prom.Registerer)
Click to show internal directories.
Click to hide internal directories.