Documentation
¶
Index ¶
- type Informer
- type Recorder
- type Registry
- func (m *Registry) DecConcurrentMessageCount(msg *azservicebus.ReceivedMessage)
- func (m *Registry) IncConcurrentMessageCount(msg *azservicebus.ReceivedMessage)
- func (m *Registry) IncMessageDeadlineReachedCount(msg *azservicebus.ReceivedMessage)
- func (m *Registry) IncMessageHandled(msg *azservicebus.ReceivedMessage)
- func (m *Registry) IncMessageLockRenewedFailure(msg *azservicebus.ReceivedMessage)
- func (m *Registry) IncMessageLockRenewedSuccess(msg *azservicebus.ReceivedMessage)
- func (m *Registry) IncMessageReceived(count float64)
- 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 ¶
type Informer struct {
// contains filtered or unexported fields
}
Informer allows to inspect metrics value stored in the registry at runtime
func NewInformer ¶
func NewInformer() *Informer
NewInformer creates an Informer for the current registry
func NewInformerFor ¶ added in v2.6.3
NewInformerFor creates an Informer for the current registry
func (*Informer) GetMessageLockRenewedFailureCount ¶
GetMessageLockRenewedFailureCount retrieves the current value of the MessageLockRenewedFailureCount metric
type Recorder ¶
type Recorder interface {
Init(registerer prom.Registerer)
IncMessageDeadlineReachedCount(msg *azservicebus.ReceivedMessage)
IncMessageLockRenewedFailure(msg *azservicebus.ReceivedMessage)
IncMessageLockRenewedSuccess(msg *azservicebus.ReceivedMessage)
DecConcurrentMessageCount(msg *azservicebus.ReceivedMessage)
IncMessageHandled(msg *azservicebus.ReceivedMessage)
IncMessageReceived(float64)
IncConcurrentMessageCount(msg *azservicebus.ReceivedMessage)
}
Recorder allows to initialize the metric registry and increase/decrease the registered metrics at runtime.
var ( // Metric exposes a Recorder interface to manipulate the Processor metrics. Metric Recorder = metricsRegistry )
type Registry ¶
type Registry struct {
MessageReceivedCount *prom.CounterVec
MessageHandledCount *prom.CounterVec
MessageLockRenewedCount *prom.CounterVec
MessageDeadlineReachedCount *prom.CounterVec
ConcurrentMessageCount *prom.GaugeVec
}
Registry provides the prometheus metrics for the message processor
func NewRegistry ¶ added in v2.6.3
func NewRegistry() *Registry
NewRegistry creates a new Registry with initialized prometheus counter definitions
func (*Registry) DecConcurrentMessageCount ¶
func (m *Registry) DecConcurrentMessageCount(msg *azservicebus.ReceivedMessage)
DecConcurrentMessageCount decreases the concurrent message counter
func (*Registry) IncConcurrentMessageCount ¶
func (m *Registry) IncConcurrentMessageCount(msg *azservicebus.ReceivedMessage)
IncConcurrentMessageCount increases the concurrent message counter
func (*Registry) IncMessageDeadlineReachedCount ¶
func (m *Registry) IncMessageDeadlineReachedCount(msg *azservicebus.ReceivedMessage)
IncMessageDeadlineReachedCount increases the message deadline reached counter
func (*Registry) IncMessageHandled ¶
func (m *Registry) IncMessageHandled(msg *azservicebus.ReceivedMessage)
IncMessageHandled increase the message Handled
func (*Registry) IncMessageLockRenewedFailure ¶
func (m *Registry) IncMessageLockRenewedFailure(msg *azservicebus.ReceivedMessage)
IncMessageLockRenewedFailure increase the message lock renewal failure counter
func (*Registry) IncMessageLockRenewedSuccess ¶
func (m *Registry) IncMessageLockRenewedSuccess(msg *azservicebus.ReceivedMessage)
IncMessageLockRenewedSuccess increase the message lock renewal success counter
func (*Registry) IncMessageReceived ¶
IncMessageReceived increases the message received counter
func (*Registry) Init ¶
func (m *Registry) Init(reg prom.Registerer)
Init registers the counters from the Registry on the prometheus.Registerer
Source Files