processor

Documentation

Index

• type Informer
  • func NewInformer() *Informer
  • func NewInformerFor(r *Registry) *Informer
  • func (i *Informer) GetHealthCheckFailureCount(namespace, entity, subscription string) (float64, error)
  • func (i *Informer) GetHealthCheckSuccessCount(namespace, entity, subscription string) (float64, error)
  • func (i *Informer) GetMessageLockRenewalTimeoutCount() (float64, error)
  • func (i *Informer) GetMessageLockRenewedFailureCount() (float64, error)
• type Recorder
• type Registry
  • func NewRegistry() *Registry
  • func (m *Registry) DecConcurrentMessageCount(receiverName string, msg *azservicebus.ReceivedMessage)
  • func (m *Registry) IncConcurrentMessageCount(receiverName string, msg *azservicebus.ReceivedMessage)
  • func (m *Registry) IncHealthCheckFailureCount(namespace, entity, subscription string)
  • func (m *Registry) IncHealthCheckSuccessCount(namespace, entity, subscription string)
  • func (m *Registry) IncMessageDeadlineReachedCount(msg *azservicebus.ReceivedMessage)
  • func (m *Registry) IncMessageHandled(receiverName string, msg *azservicebus.ReceivedMessage)
  • func (m *Registry) IncMessageLockRenewalTimeoutCount(msg *azservicebus.ReceivedMessage)
  • func (m *Registry) IncMessageLockRenewedFailure(msg *azservicebus.ReceivedMessage)
  • func (m *Registry) IncMessageLockRenewedSuccess(msg *azservicebus.ReceivedMessage)
  • func (m *Registry) IncMessageReceived(receiverName string, count float64)
  • func (m *Registry) Init(reg prom.Registerer)

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

func NewInformerFor(r *Registry) *Informer

NewInformerFor creates an Informer for the current registry

func (*Informer) GetHealthCheckFailureCount

func (i *Informer) GetHealthCheckFailureCount(namespace, entity, subscription string) (float64, error)

GetHealthCheckFailureCount retrieves the current value of the HealthCheckFailureCount metric

func (*Informer) GetHealthCheckSuccessCount

func (i *Informer) GetHealthCheckSuccessCount(namespace, entity, subscription string) (float64, error)

GetHealthCheckSuccessCount retrieves the current value of the HealthCheckSuccessCount metric

func (*Informer) GetMessageLockRenewalTimeoutCount

func (i *Informer) GetMessageLockRenewalTimeoutCount() (float64, error)

GetMessageLockRenewalTimeoutCount retrieves the current value of the MessageLockRenewalTimeoutCount metric

func (*Informer) GetMessageLockRenewedFailureCount

func (i *Informer) GetMessageLockRenewedFailureCount() (float64, error)

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)
	IncMessageLockRenewalTimeoutCount(msg *azservicebus.ReceivedMessage)
	IncMessageHandled(receiverName string, msg *azservicebus.ReceivedMessage)
	IncMessageReceived(receiverName string, count float64)
	IncHealthCheckSuccessCount(namespace, entity, subscription string)
	IncHealthCheckFailureCount(namespace, entity, subscription string)
	IncConcurrentMessageCount(receiverName string, msg *azservicebus.ReceivedMessage)
	DecConcurrentMessageCount(receiverName string, 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
	MessageLockRenewalTimeoutCount *prom.CounterVec
	MessageDeadlineReachedCount    *prom.CounterVec
	HealthCheckCount               *prom.CounterVec
	ConcurrentMessageCount         *prom.GaugeVec
}

Registry provides the prometheus metrics for the message processor

func NewRegistry

func NewRegistry() *Registry

NewRegistry creates a new Registry with initialized prometheus counter definitions

func (*Registry) DecConcurrentMessageCount

func (m *Registry) DecConcurrentMessageCount(receiverName string, msg *azservicebus.ReceivedMessage)

DecConcurrentMessageCount decreases the concurrent message counter

func (*Registry) IncConcurrentMessageCount

func (m *Registry) IncConcurrentMessageCount(receiverName string, msg *azservicebus.ReceivedMessage)

IncConcurrentMessageCount increases the concurrent message counter

func (*Registry) IncHealthCheckFailureCount

func (m *Registry) IncHealthCheckFailureCount(namespace, entity, subscription string)

IncHealthCheckFailureCount increases the connection failure gauge and resets the success gauge

func (*Registry) IncHealthCheckSuccessCount

func (m *Registry) IncHealthCheckSuccessCount(namespace, entity, subscription string)

IncHealthCheckSuccessCount increases the connection success gauge and resets the failure gauge

func (*Registry) IncMessageDeadlineReachedCount

func (m *Registry) IncMessageDeadlineReachedCount(msg *azservicebus.ReceivedMessage)

IncMessageDeadlineReachedCount increases the message deadline reached counter

func (*Registry) IncMessageHandled

func (m *Registry) IncMessageHandled(receiverName string, msg *azservicebus.ReceivedMessage)

IncMessageHandled increase the message Handled

func (*Registry) IncMessageLockRenewalTimeoutCount

func (m *Registry) IncMessageLockRenewalTimeoutCount(msg *azservicebus.ReceivedMessage)

IncMessageDeadlineReachedCount increases the message deadline reached counter

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

func (m *Registry) IncMessageReceived(receiverName string, count float64)

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