scheduler

package

v0.1.0 Latest Latest Go to latest Published: Sep 13, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Logger         *slog.Logger
	OnSampleError  func(error)
	InitialBackoff time.Duration
	MaxBackoffCap  time.Duration
}

Config holds optional scheduler behaviour.

type Scheduler struct {
	Interval time.Duration
	Jitter   time.Duration
	Gate     collector.SampleGate
	Config
}

Scheduler drives periodic sampling with interval, jitter, and an optional gate.

func New(interval, jitter time.Duration, gate collector.SampleGate, cfg Config) *Scheduler

New returns a Scheduler with the given configuration. Gate defaults to collector.AlwaysAllow when nil.

func (s *Scheduler) Run(ctx context.Context, fn func(context.Context) error) error

Run ticks on interval, evaluates the gate, and calls fn when permitted. Transient sample errors are logged and retried with exponential backoff.