Documentation
¶
Index ¶
- type Informer
- type Recorder
- type Registry
- func (m *Registry) IncHealthCheckFailureCount(namespace, entity string)
- func (m *Registry) IncHealthCheckSuccessCount(namespace, entity string)
- func (m *Registry) IncSendMessageFailureCount()
- func (m *Registry) IncSendMessageSuccessCount()
- func (m *Registry) Init(reg prom.Registerer)
- func (m *Registry) ResetSendMessageCount()
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 (*Informer) GetHealthCheckFailureCount ¶ added in v2.7.1
GetHealthCheckFailureCount retrieves the current value of the HealthCheckFailureCount metric
func (*Informer) GetHealthCheckSuccessCount ¶ added in v2.7.1
GetHealthCheckSuccessCount retrieves the current value of the HealthCheckSuccessCount metric
func (*Informer) GetSendMessageFailureCount ¶
GetSendMessageFailureCount returns the total number of messages sent by the sender with success == false
type Recorder ¶
type Recorder interface {
Init(registerer prom.Registerer)
IncSendMessageSuccessCount()
IncSendMessageFailureCount()
ResetSendMessageCount()
IncHealthCheckSuccessCount(namespace, entity string)
IncHealthCheckFailureCount(namespace, entity string)
}
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 {
MessageSentCount *prom.CounterVec
HealthCheckCount *prom.CounterVec
}
func (*Registry) IncHealthCheckFailureCount ¶ added in v2.7.1
IncHealthCheckFailureCount increases the connection failure gauge and resets the success gauge
func (*Registry) IncHealthCheckSuccessCount ¶ added in v2.7.1
IncHealthCheckSuccessCount increases the connection success gauge and resets the failure gauge
func (*Registry) IncSendMessageFailureCount ¶
func (m *Registry) IncSendMessageFailureCount()
IncSendMessageFailureCount increases the MessageSentCount metric with success == false
func (*Registry) IncSendMessageSuccessCount ¶
func (m *Registry) IncSendMessageSuccessCount()
IncSendMessageSuccessCount increases the MessageSentCount metric with success == true
func (*Registry) Init ¶
func (m *Registry) Init(reg prom.Registerer)
func (*Registry) ResetSendMessageCount ¶ added in v2.7.2
func (m *Registry) ResetSendMessageCount()
Source Files