package
1.1.8
Repository: https://github.com/wework/grabbit.git
Documentation: pkg.go.dev

# Functions

AddHandlerMetrics adds a handler to be tracked with metrics.
GetFailureCountByMessageTypeAndHandlerName gets the counter value for the failed handlers' run for a given message type and handler's name.
GetHandlerMetrics gets the metrics handler associated with the handlerName.
GetLatencySampleCountByMessageTypeAndHandlerName gets the summary sample count value for the handlers' run for a given message type and handler's name.
GetRejectedMessagesValue gets the value of the rejected message counter.
GetSagaTimeoutCounterValue gets the counter value of timed out sagas reported to prometheus.
GetSuccessCountByMessageTypeAndHandlerName gets the counter value for the successful handlers' run for a given message type and handler's name.
ReportRejectedMessage reports a message being rejected to the metrics counter.
ResetRejectedMessagesCounter resets the counter intended to be used in tests only.
RunHandlerWithMetric runs a specific handler with metrics being collected and reported to prometheus.

# Variables

No description provided by the author
No description provided by the author
SagaLatencySummary is the prometheus summary for the total duration of a saga.
SagaTimeoutCounter is the prometheus counter counting timed out saga instances.
No description provided by the author

# Structs

HandlerMetrics holds the metrics results for a handler.