cronfrontend

package

v0.2.17 Latest Latest Go to latest Published: Oct 28, 2026 License: MIT Imports: 16 Imported by: 0

Details

Package cronfrontend schedules cron producers and their conversation Sync.

This section is empty.

This section is empty.

func ValidateRuntimeDefinitions(workspace, runtimeDir string) error

ValidateRuntimeDefinitions loads cron definitions from runtimeDir without mutating scheduler state.

type Job struct {
	RelativePath, Agent, Body, Space string
	Schedules                        []string
	Upcoming                         []time.Time
}

Job is the read-only presentation of a loaded definition and its next triggers.

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

Manager loads and runs workspace cron definitions.

func New(workspace, runtimeDir string, store cronScheduleStore, run Runner, logger *slog.Logger) *Manager

New constructs a cronjob manager using runtimeDir for effective runtime cron definitions.

func (m *Manager) Jobs() ([]Job, error)

Jobs returns loaded definitions and their next triggers in the next day. It neither refreshes scheduler state nor claims any work.

func (m *Manager) LoadOneOffCronjob(target string) (protocol.OneOffCronjob, error)

LoadOneOffCronjob resolves and loads one live cronjob for a run from Web.

func (m *Manager) RunOneOffCronjob(ctx context.Context, job *protocol.OneOffCronjob) (protocol.CronRunResult, error)

RunOneOffCronjob waits for a loaded producer and its required Sync.

func (m *Manager) Start(ctx context.Context) error

Start loads cron definitions and starts scheduling them.

func (m *Manager) Stop(ctx context.Context) error

Stop shuts the cron manager down.

type Runner interface {
	Run(context.Context, string, string, *backend.RawRunProgress) (protocol.CronRunResult, error)
}

Runner executes a producer through terminal delivery.