automation

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

type DiscardSink struct{}

type ExecuteConfig struct {
	// StreamFn receives each text delta in real time. May be nil.
	StreamFn func(string)
	// ModelOverride specifies a different model for this execution only.
	// Format: "provider:model". Empty means use RunnerConfig.Model.
	ModelOverride string
	// SystemPrompt replaces the entire Seshat default system prompt.
	// Empty means use the default.
	SystemPrompt string
}

type ExecuteFunc func(ctx context.Context, w Workflow, opts Options) (Result, error)

type ExecutionState struct {
	WorkflowName string    `json:"workflow_name"`
	LastRunAt    time.Time `json:"last_run_at"`
	NextRunAt    time.Time `json:"next_run_at,omitempty"`
	LastStatus   string    `json:"last_status"` // "success" | "error" | "running"
	LastError    string    `json:"last_error,omitempty"`
	RunCount     int64     `json:"run_count"`
	SuccessCount int64     `json:"success_count"`
	FailureCount int64     `json:"failure_count"`
	ConsecErrors int       `json:"consec_errors"`
}

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

type ExecutorConfig struct {
	RunnerConfig RunnerConfig
	// Middleware is applied in order (first = outermost wrapper).
	Middleware []Middleware
	// Sinks receive the completed Result after each execution.
	Sinks []Sink
	// State persists execution history. May be nil (no persistence).
	State StateStore
}

type FileSink struct {
	// Dir is the directory where output files are written. Created if absent.
	Dir string
	// Format is "text" (default) or "json".
	Format string
}

type FileStateStore struct {
	Dir string
	// contains filtered or unexported fields
}

type IntervalSchedule struct {
	Interval time.Duration
}

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

type Middleware func(next ExecuteFunc) ExecuteFunc

type MultiSink struct {
	Sinks []Sink
}

type OnceSchedule struct {
	At time.Time
}

type Options struct {
	// Model overrides the Runner's default model for this execution only.
	// Format: "provider:model" (e.g. "anthropic:claude-sonnet-4-6").
	Model string

	// DryRun skips actual LLM execution and returns an empty Result.
	// Useful for validating scheduler configuration without incurring cost.
	DryRun bool

	// Timeout caps the total wall-clock time for the workflow.
	// Zero means no per-execution timeout (context deadline still applies).
	Timeout time.Duration

	// MaxRetries is the number of additional attempts after a failure.
	// Zero means no retry. Used by WithRetry middleware.
	MaxRetries int

	// RetryBackoff is the initial wait between retries (doubles each attempt).
	// Defaults to 5s when zero and MaxRetries > 0.
	RetryBackoff time.Duration

	// Extra holds workflow-specific key-value options that are not part of
	// the standard contract. Workflows may inspect this map for opt-in features.
	Extra map[string]any
}

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

type Result struct {
	WorkflowName string
	StartedAt    time.Time
	FinishedAt   time.Time
	Duration     time.Duration
	Output       string // accumulated text streamed by the agent
	Error        error
	Metadata     map[string]any // arbitrary key-value pairs set by middleware or workflow
}

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

type RunnerConfig struct {
	Model          sdk.ModelIdentifier
	ProviderConfig *providers.Config
	MaxTokens      int
}

type Schedule interface {
	// Next returns the next time the schedule fires after from.
	// Returns the zero Time if the schedule never fires again.
	Next(from time.Time) time.Time
	// String returns a human-readable description of the schedule.
	String() string
}

type ScheduledRun struct {
	WorkflowName string
	Schedule     string
	NextRun      time.Time
}

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

type Sink interface {
	Write(ctx context.Context, r Result) error
}

type StateStore interface {
	Load(ctx context.Context, workflowName string) (*ExecutionState, error)
	Save(ctx context.Context, state ExecutionState) error
	List(ctx context.Context) ([]ExecutionState, error)
	Delete(ctx context.Context, workflowName string) error
}

type StdoutSink struct {
	// Quiet suppresses the footer when true.
	Quiet bool
}

type SystemPrompter interface {
	SystemPrompt() string
}

type WebhookSink struct {
	URL     string
	Headers map[string]string
	// Timeout for the HTTP request. Defaults to 15s.
	Timeout time.Duration
	// contains filtered or unexported fields
}

type Workflow interface {
	Name() string
	Description() string
	Run(ctx context.Context, session *sdk.Session) error
}