runner

package

v1.2.0 Latest Latest Go to latest Published: Oct 18, 2026 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/WhitenWhiten/topophany

Links

Open Source Insights

Documentation ¶

Overview ¶

Package runner provides a bounded, non-overlapping, jittered scheduler. A storage failure stops scheduling rather than silently dropping measurements.

Index ¶

type Probe
type Scheduler
- func New(c model.Config, observer string, workers int, p Probe, sink Sink) (*Scheduler, error)
- func (s *Scheduler) Once(ctx context.Context) error
- func (s *Scheduler) Run(parent context.Context) error
type Sink

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Probe ¶

type Probe func(context.Context, model.Config, model.Check) model.Observation

type Scheduler ¶

type Scheduler struct {
	Config   model.Config
	Observer string
	Workers  int
	Boot     string
	Probe    Probe
	Sink     Sink
	// contains filtered or unexported fields
}

func New ¶

func New(c model.Config, observer string, workers int, p Probe, sink Sink) (*Scheduler, error)

func (*Scheduler) Once ¶

func (s *Scheduler) Once(ctx context.Context) error

func (*Scheduler) Run ¶

func (s *Scheduler) Run(parent context.Context) error

Run is single-owner; do not call Run and Once concurrently on one scheduler.

type Sink ¶

type Sink func(model.Observation) error

Source Files ¶

View all Source files

scheduler.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL