exporter

package

v1.1.1 Latest Latest Go to latest Published: Feb 19, 2026 License: MIT Imports: 11 Imported by: 0

Details

The exporter package bridges store snapshots into Prometheus/OpenMetrics output.

SnapshotReader: interface with Snapshot() []store.MetricPoint used as the exporter input contract.
CacheConfig: cache settings (Mode, RefreshInterval, Now) for snapshot refresh behavior.

NewOpenMetricsHandler(reader SnapshotReader) http.Handler: builds a Prometheus registry, registers the snapshot collector, and returns an OpenMetrics-capable HTTP handler.
NewCachedSnapshotReader(source SnapshotReader, cfg CacheConfig) SnapshotReader: wraps a reader with refresh-based caching. In incremental mode, it uses SnapshotCursor/SnapshotDelta when supported by the source.

This section is empty.

This section is empty.

func NewOpenMetricsHandler(reader SnapshotReader) http.Handler

NewOpenMetricsHandler returns a handler that renders store snapshots through the Prometheus OpenMetrics encoder.

type CacheConfig struct {
	Mode            string
	RefreshInterval time.Duration
	Now             func() time.Time
}

CacheConfig configures the snapshot cache used by /metrics rendering.

type CacheStats struct {
	RefreshDuration time.Duration
}

CacheStats contains refresh statistics for exporter cache observability.

type SnapshotReader interface {
	Snapshot() []store.MetricPoint
}

SnapshotReader reads metric snapshots.

func NewCachedSnapshotReader(source SnapshotReader, cfg CacheConfig) SnapshotReader

NewCachedSnapshotReader wraps a snapshot reader with periodic cache refresh.