libroutine

type Condition func(ctx context.Context) (bool, error)

type Job struct {
	// Name identifies this job in RunResult and error messages.
	Name string
	// Condition, if set, is evaluated before Operation. A false result skips
	// Operation and Next without failing the run.
	Condition Condition
	Operation Operation
	// Next, if set, runs after Operation succeeds.
	Next *Job
}

type LoopConfig struct {
	// Key uniquely identifies the routine and prevents duplicate loops.
	Key string
	// Threshold is the number of consecutive failures before the circuit opens.
	Threshold int
	// ResetTimeout is how long the circuit stays open before half-open.
	ResetTimeout time.Duration
	// Interval is the time between executions.
	Interval time.Duration
	// Operation is the function executed periodically.
	Operation func(ctx context.Context) error
}

type Operation func(ctx context.Context) error

type Routine struct {
	// contains filtered or unexported fields
}

type RunResult struct {
	Name     string
	Skipped  bool
	Err      error
	Duration time.Duration
	// Next is the chained job's result, set only when Next was run.
	Next *RunResult
}

type Runner struct {
	// contains filtered or unexported fields
}

type RunnerOption func(*Runner)

type Schedule interface {
	Next(t time.Time) time.Time
}

type State int