application

package

Go to main page

Versions in this module

v0

v0.5.0

Mar 30, 2026

Changes in this version

+ var ErrNoStepTypeProvider = errors.New("step type provider not configured")

type ExecutionService

+ func (s *ExecutionService) SetStepTypeProvider(provider ports.StepTypeProvider)

type WorkflowService

+ func (s *WorkflowService) SetValidatorProvider(p ports.WorkflowValidatorProvider)

v0.4.1

Mar 28, 2026

Changes in this version

+ var ErrCircularWorkflowCall = errors.New("circular workflow call detected")

+ var ErrMaxNestingExceeded = errors.New("maximum sub-workflow nesting depth exceeded")

+ var ErrNoAgentRegistry = errors.New("agent registry not configured")

+ var ErrNoOperationProvider = errors.New("operation provider not configured")

+ var ErrPluginDisabled = errors.New("plugin is disabled")

+ var ErrPluginNameEmpty = errors.New("plugin name cannot be empty")

+ var ErrSubWorkflowNotFound = errors.New("sub-workflow not found")

+ var ErrUnknownPlugin = errors.New("unknown plugin")

+ type ContextBuilderFunc func(execCtx *workflow.ExecutionContext) *interpolation.Context

+ type ConversationExecutor interface

+ ExecuteConversation func(ctx context.Context, step *workflow.Step, config *workflow.ConversationConfig, ...) (*workflow.ConversationResult, error)

+ type ConversationManager struct

+ func NewConversationManager(logger ports.Logger, evaluator ports.ExpressionEvaluator, ...) *ConversationManager

+ func (m *ConversationManager) ExecuteConversation(ctx context.Context, step *workflow.Step, config *workflow.ConversationConfig, ...) (*workflow.ConversationResult, error)

+ type DryRunExecutor struct

+ func NewDryRunExecutor(wfSvc *WorkflowService, resolver interpolation.Resolver, ...) *DryRunExecutor

+ func (e *DryRunExecutor) Execute(ctx context.Context, workflowName string, inputs map[string]any) (*workflow.DryRunPlan, error)

+ func (e *DryRunExecutor) SetAWFPaths(paths map[string]string)

+ func (e *DryRunExecutor) SetTemplateService(svc *TemplateService)

+ type ExecutionService struct

+ func NewExecutionService(wfSvc *WorkflowService, executor ports.CommandExecutor, ...) *ExecutionService

+ func NewExecutionServiceWithEvaluator(wfSvc *WorkflowService, executor ports.CommandExecutor, ...) *ExecutionService

+ func (s *ExecutionService) ExecuteSingleStep(ctx context.Context, workflowName string, stepName string, ...) (*SingleStepResult, error)

+ func (s *ExecutionService) HandleMaxIterationFailure(ctx context.Context, result *workflow.LoopResult, step *workflow.Step, ...) (string, error)

+ func (s *ExecutionService) IsProblematicMaxIterationPattern(result *workflow.LoopResult, step *workflow.Step, wf *workflow.Workflow) bool

+ func (s *ExecutionService) ListResumable(ctx context.Context) ([]*workflow.ExecutionContext, error)

+ func (s *ExecutionService) Resume(ctx context.Context, workflowID string, inputOverrides map[string]any) (*workflow.ExecutionContext, error)

+ func (s *ExecutionService) Run(ctx context.Context, workflowName string, inputs map[string]any) (*workflow.ExecutionContext, error)

+ func (s *ExecutionService) RunWithWorkflow(ctx context.Context, wf *workflow.Workflow, inputs map[string]any) (*workflow.ExecutionContext, error)

+ func (s *ExecutionService) SetAWFPaths(paths map[string]string)

+ func (s *ExecutionService) SetAgentRegistry(registry ports.AgentRegistry)

+ func (s *ExecutionService) SetAuditTrailWriter(w ports.AuditTrailWriter)

+ func (s *ExecutionService) SetConversationManager(mgr ConversationExecutor)

+ func (s *ExecutionService) SetEvaluator(evaluator ports.ExpressionEvaluator)

+ func (s *ExecutionService) SetOperationProvider(provider ports.OperationProvider)

+ func (s *ExecutionService) SetOutputWriters(stdout, stderr io.Writer)

+ func (s *ExecutionService) SetPluginService(svc *PluginService)

+ func (s *ExecutionService) SetTemplateService(svc *TemplateService)

+ type HistoryService struct

+ func NewHistoryService(store ports.HistoryStore, logger ports.Logger) *HistoryService

+ func (s *HistoryService) Cleanup(ctx context.Context) (int, error)

+ func (s *HistoryService) Close() error

+ func (s *HistoryService) GetStats(ctx context.Context, filter *workflow.HistoryFilter) (*workflow.HistoryStats, error)

+ func (s *HistoryService) List(ctx context.Context, filter *workflow.HistoryFilter) ([]*workflow.ExecutionRecord, error)

+ func (s *HistoryService) Record(ctx context.Context, record *workflow.ExecutionRecord) error

+ type HookExecutor struct

+ func NewHookExecutor(executor ports.CommandExecutor, logger ports.Logger, ...) *HookExecutor

+ func (h *HookExecutor) ExecuteHooks(ctx context.Context, hook workflow.Hook, intCtx *interpolation.Context, ...) error

+ type InputCollectionService struct

+ func NewInputCollectionService(collector ports.InputCollector, logger ports.Logger) *InputCollectionService

+ func (s *InputCollectionService) CollectMissingInputs(ctx context.Context, wf *workflow.Workflow, providedInputs map[string]any) (map[string]any, error)

+ type InteractiveExecutor struct

+ func NewInteractiveExecutor(wfSvc *WorkflowService, executor ports.CommandExecutor, ...) *InteractiveExecutor

+ func (e *InteractiveExecutor) HandleExecutionError(ctx context.Context, step *workflow.Step, state *workflow.StepState, ...) (string, error)

+ func (e *InteractiveExecutor) HandleNonZeroExit(ctx context.Context, step *workflow.Step, state *workflow.StepState, ...) (string, error)

+ func (e *InteractiveExecutor) HandleSuccess(ctx context.Context, step *workflow.Step, state *workflow.StepState, ...) (string, error)

+ func (e *InteractiveExecutor) Run(ctx context.Context, workflowName string, inputs map[string]any) (*workflow.ExecutionContext, error)

+ func (e *InteractiveExecutor) SetAWFPaths(paths map[string]string)

+ func (e *InteractiveExecutor) SetBreakpoints(breakpoints []string)

+ func (e *InteractiveExecutor) SetOutputWriters(stdout, stderr io.Writer)

+ func (e *InteractiveExecutor) SetTemplateService(svc *TemplateService)

+ type LimitResult struct

+ Output string

+ OutputPath string

+ Stderr string

+ StderrPath string

+ Truncated bool

+ type LoopExecutor struct

+ func NewLoopExecutor(logger ports.Logger, evaluator ports.ExpressionEvaluator, ...) *LoopExecutor

+ func (e *LoopExecutor) BuildBodyStepIndices(body []string) (map[string]int, error)

+ func (e *LoopExecutor) ExecuteForEach(ctx context.Context, wf *workflow.Workflow, step *workflow.Step, ...) (*workflow.LoopResult, error)

+ func (e *LoopExecutor) ExecuteWhile(ctx context.Context, wf *workflow.Workflow, step *workflow.Step, ...) (*workflow.LoopResult, error)

+ func (e *LoopExecutor) ParseItems(itemsStr string) ([]any, error)

+ func (e *LoopExecutor) PopLoopContext(execCtx *workflow.ExecutionContext) *workflow.LoopContext

+ func (e *LoopExecutor) PushLoopContext(execCtx *workflow.ExecutionContext, item any, index int, first, last bool, ...)

+ func (e *LoopExecutor) ResolveMaxIterations(maxIterExpr string, ctx *interpolation.Context) (int, error)

+ type OutputLimiter struct

+ func NewOutputLimiter(config workflow.OutputLimits) *OutputLimiter

+ func (l *OutputLimiter) Apply(output, stderr string) (*LimitResult, error)

+ func (l *OutputLimiter) ShouldLimit(output string) bool

+ func (l *OutputLimiter) Truncate(output string) string

+ type OutputStreamer struct

+ func NewOutputStreamer(config workflow.OutputLimits) *OutputStreamer

+ func (s *OutputStreamer) StreamBoth(output, stderr string) (outputPath, stderrPath string, err error)

+ func (s *OutputStreamer) StreamOutput(content string) (string, error)

+ type ParallelExecutor struct

+ func NewParallelExecutor(logger ports.Logger) *ParallelExecutor

+ func (e *ParallelExecutor) CheckBranchSuccess(branchResult *workflow.BranchResult, firstSuccess *bool, mu *sync.Mutex, ...)

+ func (e *ParallelExecutor) Execute(ctx context.Context, wf *workflow.Workflow, branches []string, ...) (*workflow.ParallelResult, error)

+ func (e *ParallelExecutor) RunBranchWithSemaphore(ctx context.Context, branch string, sem chan struct{}, ...) (*workflow.BranchResult, error)

+ type PluginService struct

+ func NewPluginService(manager ports.PluginManager, stateStore ports.PluginStateStore, ...) *PluginService

+ func (s *PluginService) DisablePlugin(ctx context.Context, name string) error

+ func (s *PluginService) DiscoverPlugins(ctx context.Context) ([]*pluginmodel.PluginInfo, error)

+ func (s *PluginService) EnablePlugin(ctx context.Context, name string) error

+ func (s *PluginService) GetPlugin(name string) (*pluginmodel.PluginInfo, bool)

+ func (s *PluginService) GetPluginConfig(name string) map[string]any

+ func (s *PluginService) InitPlugin(ctx context.Context, name string) error

+ func (s *PluginService) IsPluginEnabled(name string) bool

+ func (s *PluginService) ListDisabledPlugins() []string

+ func (s *PluginService) ListEnabledPlugins() []*pluginmodel.PluginInfo

+ func (s *PluginService) ListPlugins() []*pluginmodel.PluginInfo

+ func (s *PluginService) LoadAndInitPlugin(ctx context.Context, name string) error

+ func (s *PluginService) LoadPlugin(ctx context.Context, name string) error

+ func (s *PluginService) LoadState(ctx context.Context) error

+ func (s *PluginService) RegisterBuiltin(name, description, version string, operations []string)

+ func (s *PluginService) SaveState(ctx context.Context) error

+ func (s *PluginService) SetPluginConfig(ctx context.Context, name string, config map[string]any) error

+ func (s *PluginService) ShutdownAll(ctx context.Context) error

+ func (s *PluginService) ShutdownPlugin(ctx context.Context, name string) error

+ func (s *PluginService) StartupEnabledPlugins(ctx context.Context) error

+ type SingleStepResult struct

+ CompletedAt time.Time

+ Error string

+ ExitCode int

+ Output string

+ StartedAt time.Time

+ Status workflow.ExecutionStatus

+ Stderr string

+ StepName string

+ type StepExecutorFunc func(ctx context.Context, stepName string, intCtx *interpolation.Context) (string, error)

+ type TemplateService struct

+ func NewTemplateService(repo ports.TemplateRepository, logger ports.Logger) *TemplateService

+ func (s *TemplateService) ApplyTemplateFields(step *workflow.Step, templateStep *workflow.Step, params map[string]any) error

+ func (s *TemplateService) ExpandNestedTemplate(ctx context.Context, stepName string, templateStep *workflow.Step, ...) error

+ func (s *TemplateService) ExpandWorkflow(ctx context.Context, wf *workflow.Workflow) error

+ func (s *TemplateService) SelectPrimaryStep(tmpl *workflow.Template) (*workflow.Step, error)

+ func (s *TemplateService) ValidateAndLoadTemplate(ctx context.Context, ref *workflow.WorkflowTemplateRef, ...) (*workflow.Template, error)

+ func (s *TemplateService) ValidateTemplateRef(ctx context.Context, ref *workflow.WorkflowTemplateRef) error

+ type WorkflowService struct

+ func NewWorkflowService(repo ports.WorkflowRepository, store ports.StateStore, ...) *WorkflowService

+ func (s *WorkflowService) GetWorkflow(ctx context.Context, name string) (*workflow.Workflow, error)

+ func (s *WorkflowService) ListWorkflows(ctx context.Context) ([]string, error)

+ func (s *WorkflowService) ValidateWorkflow(ctx context.Context, name string) error

+ func (s *WorkflowService) WorkflowExists(ctx context.Context, name string) (bool, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL