Versions in this module Expand all Collapse all v0 v0.11.2 Aug 12, 2026 Changes in this version + func Run(ctx context.Context, cfg Config, sources []NamedSource, ...) error + type Config struct + NATS NATSConfig + PipelineID string + PollInterval time.Duration + Sources []SourceConfig + StalenessWindows int + func LoadConfig(path string) (Config, error) + func (c Config) Validate() error + type DeltaTracker struct + func NewDeltaTracker(stalenessLimit int, logger *slog.Logger) *DeltaTracker + func (d *DeltaTracker) Step(now time.Time, current map[string]StageMetrics) []core.StageObservation + type FieldConfig struct + Multiplier float64 + Path string + Required bool + type MetricsMask uint16 + const HasArrivals + const HasBlockedNs + const HasBusyNs + const HasCompletions + const HasFailures + const HasIdleNs + const HasQueueDepth + const HasWorkers + type NATSConfig struct + Prefix string + URL string + type NamedSource struct + Type string + URL string + type Source interface + Close func() error + Poll func(ctx context.Context) (map[string]StageMetrics, error) + type SourceConfig struct + Stages []StageExtraction + Timeout time.Duration + Type string + URL string + type StageExtraction struct + Fields map[string]FieldConfig + Name string + Selector string + type StageMetrics struct + Arrivals int64 + BlockedNs int64 + BusyNs int64 + Completions int64 + Failures int64 + IdleNs int64 + Mask MetricsMask + QueueDepth int64 + Workers int64
Go to main page