Documentation
¶
Index ¶
- Variables
- func AddHandlerMetrics(handlerName string)
- func GetFailureCountByMessageTypeAndHandlerName(messageType, handlerName string) (float64, error)
- func GetHandlerMetrics(handlerName string) *handlerMetrics
- func GetLatencySampleCountByMessageTypeAndHandlerName(messageType, handlerName string) (*uint64, error)
- func GetRejectedMessagesValue() (float64, error)
- func GetSagaTimeoutCounterValue() (float64, error)
- func GetSuccessCountByMessageTypeAndHandlerName(messageType, handlerName string) (float64, error)
- func ReportRejectedMessage()
- func ResetRejectedMessagesCounter()
- func RunHandlerWithMetric(handleMessage func() error, handlerName, messageType string, ...) error
Constants ¶
This section is empty.
Variables ¶
var SagaTimeoutCounter = newSagaTimeoutCounter()
SagaTimeoutCounter is the prometheus counter counting timed out saga instances
Functions ¶
func AddHandlerMetrics ¶
func AddHandlerMetrics(handlerName string)
AddHandlerMetrics adds a handler to be tracked with metrics
func GetFailureCountByMessageTypeAndHandlerName ¶ added in v1.1.2
GetFailureCountByMessageTypeAndHandlerName gets the counter value for the failed handlers' run for a given message type and handler's name
func GetHandlerMetrics ¶
func GetHandlerMetrics(handlerName string) *handlerMetrics
GetHandlerMetrics gets the metrics handler associated with the handlerName
func GetLatencySampleCountByMessageTypeAndHandlerName ¶ added in v1.1.2
func GetLatencySampleCountByMessageTypeAndHandlerName(messageType, handlerName string) (*uint64, error)
GetLatencySampleCountByMessageTypeAndHandlerName gets the summary sample count value for the handlers' run for a given message type and handler's name
func GetRejectedMessagesValue ¶
GetRejectedMessagesValue gets the value of the rejected message counter
func GetSagaTimeoutCounterValue ¶
GetSagaTimeoutCounterValue gets the counter value of timed out sagas reported to prometheus
func GetSuccessCountByMessageTypeAndHandlerName ¶ added in v1.1.2
GetSuccessCountByMessageTypeAndHandlerName gets the counter value for the successful handlers' run for a given message type and handler's name
func ReportRejectedMessage ¶
func ReportRejectedMessage()
ReportRejectedMessage reports a message being rejected to the metrics counter
func ResetRejectedMessagesCounter ¶ added in v1.1.1
func ResetRejectedMessagesCounter()
ResetRejectedMessagesCounter resets the counter intended to be used in tests only
func RunHandlerWithMetric ¶
func RunHandlerWithMetric(handleMessage func() error, handlerName, messageType string, logger logrus.FieldLogger) error
RunHandlerWithMetric runs a specific handler with metrics being collected and reported to prometheus
Types ¶
This section is empty.