metrics

Documentation

Index

• func AddBytesCounterForTopic(topic string)
• func AddConnectedClientsGauge()
• func AddGauge(name, key string)
• func AddMessageCounterForOpCode(opCode int)
• func MetricsScrapingHandler() http.Handler
• func UpdateBytesCounterForTopic(topic string, bytesCount int)
• func UpdateConnectedClientsGauge(isConnected bool)
• func UpdateGauge(key string, val float64)
• func UpdateMessageCounterForOpCode(opCode, bytesCount int)

Functions

func AddBytesCounterForTopic

func AddBytesCounterForTopic(topic string)

AddBytesCounterForTopic adds number of bytes for topic KPI

func AddConnectedClientsGauge

func AddConnectedClientsGauge()

AddConnectedClientsGauge adds number of connected web-socket clients KPI

func AddGauge

func AddGauge(name, key string)

AddGauge adds metric gauge

func AddMessageCounterForOpCode

func AddMessageCounterForOpCode(opCode int)

AddMessageCounterForOpCode adds number of messages for a specific op-code KPI

func MetricsScrapingHandler

func MetricsScrapingHandler() http.Handler

MetricsScrapingHandler returns Prometheus handler as http handler

func UpdateBytesCounterForTopic

func UpdateBytesCounterForTopic(topic string, bytesCount int)

UpdateBytesCounterForTopic updates number of bytes for topic KPI

func UpdateConnectedClientsGauge

func UpdateConnectedClientsGauge(isConnected bool)

UpdateConnectedClientsGauge updates number of connected web-socket clients KPI

func UpdateGauge

func UpdateGauge(key string, val float64)

UpdateGauge updates metric gauge

func UpdateMessageCounterForOpCode

func UpdateMessageCounterForOpCode(opCode, bytesCount int)

UpdateMessageCounterForOpCode updates number of messages for a specific op-code KPI