Versions in this module Expand all Collapse all v0 v0.3.0 Feb 17, 2026 Changes in this version + type ExporterOptions struct + DurationBuckets []float64 + type MetricsExporter struct + func NewMetricsExporter(namespace string, reg prom.Registerer, opts ExporterOptions) (*MetricsExporter, error) + func (m *MetricsExporter) RecordQueueDepth(runnerName string, depth int) + func (m *MetricsExporter) RecordTaskDuration(runnerName string, priority core.TaskPriority, duration time.Duration) + func (m *MetricsExporter) RecordTaskPanic(runnerName string, panicInfo any) + func (m *MetricsExporter) RecordTaskRejected(runnerName string, reason string) + type PoolSnapshotProvider interface + Stats func() core.PoolStats + type RunnerSnapshotProvider interface + Stats func() core.RunnerStats + type SnapshotPoller struct + func NewSnapshotPoller(reg prom.Registerer, interval time.Duration) (*SnapshotPoller, error) + func (p *SnapshotPoller) AddPool(name string, provider PoolSnapshotProvider) + func (p *SnapshotPoller) AddRunner(name string, provider RunnerSnapshotProvider) + func (p *SnapshotPoller) Start(ctx context.Context) + func (p *SnapshotPoller) Stop()
Go to main page