metrics

Documentation

Index

• Variables
• func AddHandlerMetrics(handlerName string)
• func GetHandlerMetrics(handlerName string) *handlerMetrics
• func GetRejectedMessagesValue() (float64, error)
• func GetSagaTimeoutCounterValue() (float64, error)
• func ReportRejectedMessage()
• func RunHandlerWithMetric(handleMessage func() error, handlerName string, logger logrus.FieldLogger) error

Variables

var SagaTimeoutCounter = newSagaTimeoutCounter()

SagaTimeoutCounter is the prometheus counter counting timed out saga instances

Functions

func AddHandlerMetrics

func AddHandlerMetrics(handlerName string)

AddHandlerMetrics adds a handlere to be tracked with metrics

func GetHandlerMetrics

func GetHandlerMetrics(handlerName string) *handlerMetrics

GetHandlerMetrics gets the metrics handler associated with the handlerName

func GetRejectedMessagesValue

func GetRejectedMessagesValue() (float64, error)

GetRejectedMessagesValue gets the value of the rejected message counter

func GetSagaTimeoutCounterValue

func GetSagaTimeoutCounterValue() (float64, error)

GetSagaTimeoutCounterValue gets the counter value of timed out sagas reported to prometheus

func ReportRejectedMessage

func ReportRejectedMessage()

ReportRejectedMessage reports a message being rejected to the metrics counter

func RunHandlerWithMetric

func RunHandlerWithMetric(handleMessage func() error, handlerName string, logger logrus.FieldLogger) error

RunHandlerWithMetric runs a specific handler with metrics being collected and reported to prometheus