metrics

Dec 2, 2019

Changes in this version

+ var SagaLatencySummary = promauto.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... })

Oct 20, 2019

Changes in this version

+ var OutboxSize = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var PendingMessages = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var SentMessages = promauto.NewGauge(prometheus.GaugeOpts{ ... })

Sep 25, 2019

Changes in this version

+ type HandlerMetrics struct

+ func (hm *HandlerMetrics) GetFailureCount() (float64, error)

+ func (hm *HandlerMetrics) GetLatencySampleCount() (*uint64, error)

+ func (hm *HandlerMetrics) GetSuccessCount() (float64, error)

Sep 17, 2019

Changes in this version

+ func GetFailureCountByMessageTypeAndHandlerName(messageType, handlerName string) (float64, error)

+ func GetLatencySampleCountByMessageTypeAndHandlerName(messageType, handlerName string) (*uint64, error)

+ func GetSuccessCountByMessageTypeAndHandlerName(messageType, handlerName string) (float64, error)

Aug 31, 2019

Changes in this version

+ func ResetRejectedMessagesCounter()

Aug 18, 2019

Changes in this version

+ var SagaTimeoutCounter = newSagaTimeoutCounter()

+ 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