Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
917 B · 28 lines
Go
1234567891011121314151617181920212223242526272829package knotstream
import ( "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promauto")
// KnotStream metricsvar ( knotstreamEventsReceived = promauto.NewCounter(prometheus.CounterOpts{ Name: "knotmirror_knotstream_events_received_total", Help: "Total number of events received from knotstream", }) knotstreamEventsProcessed = promauto.NewCounter(prometheus.CounterOpts{ Name: "knotmirror_knotstream_events_processed_total", Help: "Total number of events successfully processed", }) knotstreamEventsSkipped = promauto.NewCounter(prometheus.CounterOpts{ Name: "knotmirror_knotstream_events_skipped_total", Help: "Total number of events skipped (not tracked)", }))
// slurper metricsvar connectedInbound = promauto.NewGauge(prometheus.GaugeOpts{ Name: "knotmirror_connected_inbound", Help: "Number of inbound knotstream we are consuming",})