metrics

var BatchItemsTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "batch_items_total",
		Help: "Total items across all batch requests by service.",
	},
	[]string{LabelServiceID},
)

var BatchRequestsTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "batch_requests_total",
		Help: "Total number of batch requests by service.",
	},
	[]string{LabelServiceID},
)

var BatchSizeLatency = promauto.NewHistogramVec(
	prometheus.HistogramOpts{
		Name:    MetricPrefix + "batch_size_latency_seconds",
		Help:    "Batch request latency in seconds by rpc_type, service_id, and batch_count.",
		Buckets: []float64{0.1, 0.25, 0.5, 1, 2.5, 5, 10, 30, 60},
	},
	[]string{LabelRPCType, LabelServiceID, LabelBatchCount},
)

var BatchSizeTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "batch_size_total",
		Help: "Batch requests by rpc_type, service_id, and batch_count.",
	},
	[]string{LabelRPCType, LabelServiceID, LabelBatchCount},
)

var HealthCheckStatus = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "health_check_status_total",
		Help: "Health check results by domain, rpc_type, service_id, health_check_name, and reputation_signal.",
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelHealthCheckName, LabelReputationSignal},
)

var LatencyReputation = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "latency_reputation_total",
		Help: "Latency categorization by domain, rpc_type, service_id, and latency_signal (Cheetah/Gazelle/Rabbit/Turtle/Snail).",
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelLatencySignal},
)

var ObservationPipeline = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "observation_pipeline_total",
		Help: "Observation pipeline events by domain, rpc_type, service_id, network_type, method, and reputation_signal.",
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelNetworkType, LabelMethod, LabelReputationSignal},
)

var ProbationEventsTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "probation_events_total",
		Help: "Probation events by domain, rpc_type, service_id, and event type (entered/exited/routed).",
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelProbationEvent},
)

var RPCTypeFallbackTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "rpc_type_fallback_total",
		Help: "Count of RPC type fallbacks when supplier doesn't support requested RPC type.",
	},
	[]string{LabelDomain, LabelSupplier, LabelServiceID, "requested_rpc_type", "fallback_rpc_type"},
)

var RelayLatency = promauto.NewHistogramVec(
	prometheus.HistogramOpts{
		Name:    MetricPrefix + "relay_latency_seconds",
		Help:    "Outgoing relay latency in seconds by domain, rpc_type, service_id, status_code, reputation_signal, and request_type.",
		Buckets: []float64{0.05, 0.1, 0.25, 0.5, 1, 2.5, 5, 10, 30},
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelStatusCode, LabelReputationSignal, "request_type"},
)

var RelaysTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "relays_total",
		Help: "Total outgoing relays to suppliers by domain, rpc_type, service_id, status_code, reputation_signal, and request_type.",
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelStatusCode, LabelReputationSignal, "request_type"},
)

var ReputationEndpointLeaderboard = promauto.NewGaugeVec(
	prometheus.GaugeOpts{
		Name: MetricPrefix + "reputation_endpoint_leaderboard",
		Help: "Number of endpoints grouped by domain, rpc_type, service_id, tier_threshold, and session_start_height. Published every 10s as a leaderboard snapshot.",
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelTierThreshold, LabelSessionStartHeight},
)

var ReputationMeanScore = promauto.NewGaugeVec(
	prometheus.GaugeOpts{
		Name: MetricPrefix + "reputation_mean_score",
		Help: "Mean reputation score by domain, service_id, and rpc_type.",
	},
	[]string{LabelDomain, LabelServiceID, LabelRPCType},
)

var RequestBytesReceived = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "request_bytes_received_total",
		Help: "Total bytes received in requests by rpc_type and service_id.",
	},
	[]string{LabelRPCType, LabelServiceID},
)

var RequestLatency = promauto.NewHistogramVec(
	prometheus.HistogramOpts{
		Name:    MetricPrefix + "request_latency_seconds",
		Help:    "Request latency in seconds by domain, rpc_type, service_id, and status_code.",
		Buckets: []float64{0.01, 0.025, 0.05, 0.1, 0.25, 0.5, 1, 2.5, 5, 10},
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelStatusCode},
)

var RequestsTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "requests_total",
		Help: "Total requests by domain, rpc_type, service_id, and status_code.",
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelStatusCode},
)

var ResponseBytesSent = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "response_bytes_sent_total",
		Help: "Total bytes sent in responses by rpc_type and service_id.",
	},
	[]string{LabelRPCType, LabelServiceID},
)

var RetriesDistribution = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "retries_distribution_total",
		Help: "Retry events by domain, rpc_type, service_id, and reason (retry_on_5xx/retry_on_timeout/retry_on_connection).",
	},
	[]string{LabelDomain, LabelRPCType, LabelServiceID, LabelRetryReason},
)

var RetryResultsLatency = promauto.NewHistogramVec(
	prometheus.HistogramOpts{
		Name:    MetricPrefix + "retry_results_latency_seconds",
		Help:    "Retry result latency in seconds by rpc_type, service_id, retry_count, and result.",
		Buckets: []float64{0.1, 0.25, 0.5, 1, 2.5, 5, 10, 30},
	},
	[]string{LabelRPCType, LabelServiceID, LabelRetryCount, LabelResult},
)

var RetryResultsTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "retry_results_total",
		Help: "Retry results by rpc_type, service_id, retry_count, and result (success/failure).",
	},
	[]string{LabelRPCType, LabelServiceID, LabelRetryCount, LabelResult},
)

var SupplierBlacklistTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "supplier_blacklist_total",
		Help: "Suppliers blacklisted by domain, supplier address, service_id, and reason.",
	},
	[]string{LabelDomain, LabelSupplier, LabelServiceID, "reason"},
)

var SupplierNilPubkeyTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "supplier_nil_pubkey_total",
		Help: "Count of times a supplier was found with nil public key (hasn't signed first tx).",
	},
	[]string{LabelSupplier},
)

var SupplierPubkeyCacheEvents = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "supplier_pubkey_cache_events_total",
		Help: "Supplier pubkey cache events: invalidated (on signature failure), recovered (nil -> valid).",
	},
	[]string{LabelSupplier, "event"},
)

var WebsocketConnectionDuration = promauto.NewHistogramVec(
	prometheus.HistogramOpts{
		Name:    MetricPrefix + "websocket_connection_duration_seconds",
		Help:    "WebSocket connection duration in seconds by domain and service_id.",
		Buckets: []float64{1, 5, 10, 30, 60, 300, 600, 1800, 3600},
	},
	[]string{LabelDomain, LabelServiceID},
)

var WebsocketConnectionEventsTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "websocket_connection_events_total",
		Help: "WebSocket connection events by domain, service_id, and event type (established/closed/failed).",
	},
	[]string{LabelDomain, LabelServiceID, "event"},
)

var WebsocketConnectionsActive = promauto.NewGaugeVec(
	prometheus.GaugeOpts{
		Name: MetricPrefix + "websocket_connections_active",
		Help: "Current active WebSocket connections by domain and service_id.",
	},
	[]string{LabelDomain, LabelServiceID},
)

var WebsocketMessagesTotal = promauto.NewCounterVec(
	prometheus.CounterOpts{
		Name: MetricPrefix + "websocket_messages_total",
		Help: "WebSocket messages by domain, service_id, direction (client_to_endpoint/endpoint_to_client), and reputation_signal.",
	},
	[]string{LabelDomain, LabelServiceID, "direction", LabelReputationSignal},
)