executor

Nov 5, 2025

Changes in this version

+ type BackoffStrategy string

+ const BackoffExponential

+ const BackoffFixed

+ const BackoffLinear

+ type CommandExecutor struct

+ Shell string

+ func NewCommandExecutor() *CommandExecutor

+ func (e *CommandExecutor) CanHandle(action *semantic.SemanticScheduledAction) bool

+ func (e *CommandExecutor) Execute(ctx context.Context, action *semantic.SemanticScheduledAction) (*Result, error)

+ func (e *CommandExecutor) Name() string

+ type ExecuteOptions struct

+ Context context.Context

+ Dependencies []string

+ Hooks *ExecutionHooks

+ RetryPolicy *RetryPolicy

+ Storage Storage

+ type ExecutionError struct

+ Code string

+ Details map[string]interface{}

+ Message string

+ func (e *ExecutionError) Error() string

+ type ExecutionHooks struct

+ AfterExecute func(ctx context.Context, action *semantic.SemanticScheduledAction, result *Result) error

+ BeforeExecute func(ctx context.Context, action *semantic.SemanticScheduledAction) error

+ OnError func(ctx context.Context, action *semantic.SemanticScheduledAction, err error) error

+ type ExecutionStatus string

+ const StatusCancelled

+ const StatusCompleted

+ const StatusFailed

+ const StatusPending

+ const StatusRunning

+ type Executor interface

+ CanHandle func(action *semantic.SemanticScheduledAction) bool

+ Execute func(ctx context.Context, action *semantic.SemanticScheduledAction) (*Result, error)

+ Name func() string

+ type HTTPExecutor struct

+ Client *http.Client

+ func NewHTTPExecutor() *HTTPExecutor

+ func (e *HTTPExecutor) CanHandle(action *semantic.SemanticScheduledAction) bool

+ func (e *HTTPExecutor) Execute(ctx context.Context, action *semantic.SemanticScheduledAction) (*Result, error)

+ func (e *HTTPExecutor) Name() string

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Execute(ctx context.Context, action *semantic.SemanticScheduledAction) (*Result, error)

+ func (r *Registry) Register(executor Executor)

+ type Result struct

+ Duration time.Duration

+ EndTime time.Time

+ Error *ExecutionError

+ Metadata map[string]interface{}

+ Output string

+ StartTime time.Time

+ Status ExecutionStatus

+ type RetryPolicy struct

+ Backoff BackoffStrategy

+ MaxAttempts int

+ type Storage interface

+ Load func(ctx context.Context, actionID string) (*Result, error)

+ Save func(ctx context.Context, actionID string, result *Result) error