Documentation
¶
Overview ¶
Package scheduler runs TYPE copy pipes on their COPY_SCHEDULE cron expression — the async-execution half of gap #8 that GET /v0/jobs (internal/job) left deferred. It ticks once a minute, re-reading the live PipeRegistry each tick, so a project reload (SIGHUP) picks up schedule additions/edits without any restart or explicit resync logic.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler triggers TYPE copy pipes whose COPY_SCHEDULE is due, via the same RunCopy path POST /v0/pipes/{name}/copy uses (so triggered runs are recorded through EnableJobs identically to on-demand ones).
func New ¶
func New(pipes model.PipeRegistry, copier model.CopyRunner, log *slog.Logger) *Scheduler
New returns a Scheduler. It does nothing until Run is called.
Source Files
Click to show internal directories.
Click to hide internal directories.