metrics

Documentation

Index

• func ConfigMetricInit()
• func LogMetricInit()
• func NatsIncrementMessageCount(subject string)
• func NatsMetricInit()
• func NatsUpdateMessageLatency(subject string, latency int64)
• func NatsUpdateMessageSizeHistogram(subject string, messageSize int)

Functions

func ConfigMetricInit

func ConfigMetricInit()

LogMetricInit function to register log metrics

func LogMetricInit

func LogMetricInit()

LogMetricInit function to register log metrics

func NatsIncrementMessageCount

func NatsIncrementMessageCount(subject string)

NatsIncrementMessageCount increments the count of message for a given NATS subject

func NatsMetricInit

func NatsMetricInit()

NatsMetricInit initialize various metrics for different NATS topics

func NatsUpdateMessageLatency

func NatsUpdateMessageLatency(subject string, latency int64)

NatsUpdateMessageLatency updates the message latency in μs for a given NATS subject

func NatsUpdateMessageSizeHistogram

func NatsUpdateMessageSizeHistogram(subject string, messageSize int)

NatsUpdateMessageSizeHistogram updates the message size histogram for a given NATS subject