syncmgr

var (
	// WSSyncConnectionsActive tracks the number of currently active sync
	// WebSocket connections (one per Worker cluster).
	WSSyncConnectionsActive = prometheus.NewGauge(prometheus.GaugeOpts{
		Name: "agentbox_wsproxy_sync_connections_active",
		Help: "Number of active WebSocket sync connections to Worker clusters.",
	})

	// WSSyncReconnectsTotal counts the total number of successful (re)connections
	// to Worker clusters, partitioned by cluster ID.
	WSSyncReconnectsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "agentbox_wsproxy_sync_reconnects_total",
		Help: "Total number of sync WebSocket (re)connections to Worker clusters.",
	}, []string{"cluster"})

	// WSSyncDisconnectsTotal counts the total number of disconnections,
	// partitioned by cluster ID.
	WSSyncDisconnectsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "agentbox_wsproxy_sync_disconnects_total",
		Help: "Total number of sync WebSocket disconnections from Worker clusters.",
	}, []string{"cluster"})

	// WSSyncEventsTotal counts proto events emitted to Worker streams,
	// partitioned by cluster and kind (key_upsert / key_delete /
	// template_upsert / template_delete / cluster_config).
	WSSyncEventsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "agentbox_wsproxy_sync_events_total",
		Help: "Total number of proto sync events emitted to Worker streams.",
	}, []string{"cluster", "kind"})

	// WSSyncEventsDroppedTotal counts events that could not be enqueued onto
	// a cluster's broadcast channel because the buffer was full. A non-zero
	// value indicates the Worker is slow to consume; investigate.
	WSSyncEventsDroppedTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "agentbox_wsproxy_sync_events_dropped_total",
		Help: "Total number of sync events dropped because the per-cluster broadcast buffer was full.",
	}, []string{"cluster", "kind"})

	// WSSyncPingFailuresTotal counts Ping write failures (connection likely dead).
	WSSyncPingFailuresTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "agentbox_wsproxy_sync_ping_failures_total",
		Help: "Total number of WebSocket Ping failures to Worker clusters.",
	}, []string{"cluster"})
)