A vibe coded tangled fork which supports pijul.
at 30381c8a74e47c864b80604b23ab42f947626fb3 28 lines 917 B view raw
1package knotstream 2 3import ( 4 "github.com/prometheus/client_golang/prometheus" 5 "github.com/prometheus/client_golang/prometheus/promauto" 6) 7 8// KnotStream metrics 9var ( 10 knotstreamEventsReceived = promauto.NewCounter(prometheus.CounterOpts{ 11 Name: "knotmirror_knotstream_events_received_total", 12 Help: "Total number of events received from knotstream", 13 }) 14 knotstreamEventsProcessed = promauto.NewCounter(prometheus.CounterOpts{ 15 Name: "knotmirror_knotstream_events_processed_total", 16 Help: "Total number of events successfully processed", 17 }) 18 knotstreamEventsSkipped = promauto.NewCounter(prometheus.CounterOpts{ 19 Name: "knotmirror_knotstream_events_skipped_total", 20 Help: "Total number of events skipped (not tracked)", 21 }) 22) 23 24// slurper metrics 25var connectedInbound = promauto.NewGauge(prometheus.GaugeOpts{ 26 Name: "knotmirror_connected_inbound", 27 Help: "Number of inbound knotstream we are consuming", 28})