Versions in this module Expand all Collapse all v0 v0.2.0 Jul 14, 2026 Changes in this version + const JobStatusActive + const JobStatusInactive + const JobStatusPaused + const RunStatusError + const RunStatusRunning + const RunStatusSuccess + const TriggerTypeCron + const TriggerTypeInterval + const TriggerTypeOnce + type AgentConfig = automation.AgentConfig + type DBJobStore = automation.DBJobStore + type Job = automation.Job + type JobRun = automation.JobRun + type JobScheduler = automation.JobScheduler + func NewJobScheduler(store JobStore, runner *Runner) *JobScheduler + type JobStatus = automation.JobStatus + type JobStore = automation.JobStore + type RunStatus = automation.RunStatus + type Trigger = automation.Trigger + type TriggerType = automation.TriggerType v0.1.0 Jun 22, 2026 Changes in this version + type CronSchedule = automation.CronSchedule + func Cron(expr string) (*CronSchedule, error) + func MustCron(expr string) *CronSchedule + type DiscardSink = automation.DiscardSink + type ExecuteConfig = automation.ExecuteConfig + type ExecuteFunc = automation.ExecuteFunc + type ExecutionState = automation.ExecutionState + type Executor = automation.Executor + func NewExecutor(cfg ExecutorConfig) (*Executor, error) + type ExecutorConfig = automation.ExecutorConfig + type FileSink = automation.FileSink + type FileStateStore = automation.FileStateStore + func NewFileStateStore(dir string) (*FileStateStore, error) + type IntervalSchedule = automation.IntervalSchedule + func Every(d time.Duration) *IntervalSchedule + type MemoryStateStore = automation.MemoryStateStore + func NewMemoryStateStore() *MemoryStateStore + type Middleware = automation.Middleware + func Chain(mw ...Middleware) Middleware + func WithLogging(l *log.Logger) Middleware + func WithMetrics(fn func(Result)) Middleware + func WithRecovery() Middleware + func WithRetry(n int, b time.Duration) Middleware + func WithTimeout(d time.Duration) Middleware + type ModelIdentifier = sdk.ModelIdentifier + type MultiSink = automation.MultiSink + func NewMultiSink(sinks ...Sink) *MultiSink + type OnceSchedule = automation.OnceSchedule + func Once(at time.Time) *OnceSchedule + type Options = automation.Options + func DefaultOptions() Options + type Registry = automation.Registry + func NewRegistry() *Registry + type Result = automation.Result + type Runner = automation.Runner + func NewRunner(cfg RunnerConfig) (*Runner, error) + type RunnerConfig = automation.RunnerConfig + func RunnerConfigFromEnv(modelRaw string) (RunnerConfig, error) + type Schedule = automation.Schedule + type ScheduledRun = automation.ScheduledRun + type Scheduler = automation.Scheduler + func NewScheduler(e *Executor) *Scheduler + type Sink = automation.Sink + type StateStore = automation.StateStore + type StdoutSink = automation.StdoutSink + type SystemPrompter = automation.SystemPrompter + type WebhookSink = automation.WebhookSink + func NewWebhookSink(url string) *WebhookSink + type Workflow = automation.Workflow
Go to main page