Documentation ¶
Index ¶
- type Metrics
- func (m *Metrics) FinishNotificationProcessing(notification *sql.ProjectionNotification, success bool)
- func (m *Metrics) QueueNotification(notification *sql.ProjectionNotification)
- func (m *Metrics) ReceivedNotification(isNotification bool)
- func (m *Metrics) RegisterMetrics(registry *prometheus.Registry) error
- func (m *Metrics) StartNotificationProcessing(notification *sql.ProjectionNotification)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
Metrics is an object for exposing prometheus metrics
func NewMetrics ¶
NewMetrics instantiate and return an object of Metrics
func (*Metrics) FinishNotificationProcessing ¶
func (m *Metrics) FinishNotificationProcessing(notification *sql.ProjectionNotification, success bool)
FinishNotificationProcessing is used to observe end time of notification queue and processing time
func (*Metrics) QueueNotification ¶
func (m *Metrics) QueueNotification(notification *sql.ProjectionNotification)
QueueNotification returns http handler for prometheus
func (*Metrics) ReceivedNotification ¶
ReceivedNotification counts received notifications
func (*Metrics) RegisterMetrics ¶
func (m *Metrics) RegisterMetrics(registry *prometheus.Registry) error
RegisterMetrics returns http handler for prometheus
func (*Metrics) StartNotificationProcessing ¶
func (m *Metrics) StartNotificationProcessing(notification *sql.ProjectionNotification)
StartNotificationProcessing is used to record start time of notification processing
Click to show internal directories.
Click to hide internal directories.