Documentation
¶
Overview ¶
Package cronfrontend schedules cron producers and their conversation Sync.
Index ¶
- func ValidateRuntimeDefinitions(workspace, runtimeDir string, channels []string) error
- type Job
- type Manager
- func (m *Manager) Jobs() ([]Job, error)
- func (m *Manager) LoadOneOffCronjob(target string) (protocol.OneOffCronjob, error)
- func (m *Manager) RunOneOffCronjob(ctx context.Context, job *protocol.OneOffCronjob) (protocol.CronRunResult, error)
- func (m *Manager) Start(ctx context.Context) error
- func (m *Manager) Stop(ctx context.Context) error
- type Runner
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateRuntimeDefinitions ¶
ValidateRuntimeDefinitions loads cron definitions from runtimeDir without mutating scheduler state.
Types ¶
type Job ¶
type Job struct {
RelativePath, Agent, TextChannel, Body, Space string
Schedules []string
Upcoming []time.Time
}
Job is the read-only presentation of a loaded definition and its next triggers.
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager loads and runs workspace cron definitions.
func New ¶
func New(workspace, runtimeDir string, channels []string, store cronScheduleStore, run Runner, logger *slog.Logger) *Manager
New constructs a cronjob manager using runtimeDir for effective runtime cron definitions.
func (*Manager) Jobs ¶
Jobs returns loaded definitions and their next triggers in the next day. It neither refreshes scheduler state nor claims any work.
func (*Manager) LoadOneOffCronjob ¶
func (m *Manager) LoadOneOffCronjob(target string) (protocol.OneOffCronjob, error)
LoadOneOffCronjob resolves and loads one live cronjob for a managed Slack thread run.
func (*Manager) RunOneOffCronjob ¶
func (m *Manager) RunOneOffCronjob(ctx context.Context, job *protocol.OneOffCronjob) (protocol.CronRunResult, error)
RunOneOffCronjob waits for a loaded producer and its required Sync.
Source Files
Click to show internal directories.
Click to hide internal directories.