A vibe coded tangled fork which supports pijul.
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})