composer

package

Go to main page

Versions in this module

v0

v0.6.9

Nov 28, 2025

v0.6.8

Nov 27, 2025

v0.6.7

Nov 25, 2025

Changes in this version

+ func ValidateOutputConfig(output *config.OutputConfig) error

type WorkflowContext

+ Workflow *WorkflowMetadata

type WorkflowDefinition

+ Output *config.OutputConfig

+ type WorkflowMetadata struct

+ DurationMs int64

+ ID string

+ StartTime time.Time

+ Status WorkflowStatusType

+ StepCount int

v0.6.6

Nov 19, 2025

Changes in this version

type WorkflowStateStore

+ func NewInMemoryStateStore(cleanupInterval, maxAge time.Duration) WorkflowStateStore

v0.6.5

Nov 13, 2025

v0.6.4

Nov 13, 2025

Changes in this version

+ var ErrContentTooLarge = errors.New("response content too large")

+ var ErrElicitationCancelled = errors.New("elicitation request was cancelled by user")

+ var ErrElicitationDeclined = errors.New("elicitation request was declined by user")

+ var ErrElicitationTimeout = errors.New("elicitation request timed out")

+ var ErrSchemaTooDeep = errors.New("schema nesting too deep")

+ var ErrSchemaTooLarge = errors.New("schema too large")

+ type DefaultElicitationHandler struct

+ func NewDefaultElicitationHandler(sdkRequester SDKElicitationRequester) *DefaultElicitationHandler

+ func (h *DefaultElicitationHandler) RequestElicitation(ctx context.Context, workflowID string, stepID string, ...) (*ElicitationResponse, error)

type ElicitationProtocolHandler

+ RequestElicitation func(ctx context.Context, workflowID string, stepID string, ...) (*ElicitationResponse, error)

+ type InMemoryWorkflowStateStore struct

+ func (s *InMemoryWorkflowStateStore) DeleteState(_ context.Context, workflowID string) error

+ func (s *InMemoryWorkflowStateStore) ListActiveWorkflows(_ context.Context) ([]string, error)

+ func (s *InMemoryWorkflowStateStore) LoadState(_ context.Context, workflowID string) (*WorkflowStatus, error)

+ func (s *InMemoryWorkflowStateStore) SaveState(_ context.Context, workflowID string, state *WorkflowStatus) error

+ type SDKElicitationRequester interface

+ RequestElicitation func(ctx context.Context, request mcp.ElicitationRequest) (*mcp.ElicitationResult, error)

type WorkflowStateStore

+ func NewInMemoryWorkflowStateStore() WorkflowStateStore

v0.6.3

Nov 13, 2025

v0.6.2

Nov 10, 2025

v0.6.1

Nov 10, 2025

v0.6.0

Nov 10, 2025

Changes in this version

+ var ErrCircularDependency = errors.New("circular dependency detected")

+ var ErrDependencyNotMet = errors.New("dependency not met")

+ var ErrInvalidWorkflowDefinition = errors.New("invalid workflow definition")

+ var ErrStepFailed = errors.New("step failed")

+ var ErrTemplateExpansion = errors.New("template expansion failed")

+ var ErrToolCallFailed = errors.New("tool call failed")

+ var ErrWorkflowCancelled = errors.New("workflow cancelled")

+ var ErrWorkflowNotFound = errors.New("workflow not found")

+ var ErrWorkflowTimeout = errors.New("workflow timed out")

type Composer

+ func NewWorkflowEngine(rtr router.Router, backendClient vmcp.BackendClient) Composer

type TemplateExpander

+ func NewTemplateExpander() TemplateExpander

+ type ValidationError struct

+ Cause error

+ Field string

+ Message string

+ func NewValidationError(field, message string, cause error) *ValidationError

+ func (e *ValidationError) Error() string

+ func (e *ValidationError) Unwrap() error

type WorkflowContext

+ func (ctx *WorkflowContext) Clone() *WorkflowContext

+ func (ctx *WorkflowContext) GetLastStepOutput() map[string]any

+ func (ctx *WorkflowContext) GetStepResult(stepID string) (*StepResult, bool)

+ func (ctx *WorkflowContext) HasStepCompleted(stepID string) bool

+ func (ctx *WorkflowContext) HasStepFailed(stepID string) bool

+ func (ctx *WorkflowContext) RecordStepFailure(stepID string, err error)

+ func (ctx *WorkflowContext) RecordStepSkipped(stepID string)

+ func (ctx *WorkflowContext) RecordStepStart(stepID string)

+ func (ctx *WorkflowContext) RecordStepSuccess(stepID string, output map[string]any)

+ type WorkflowError struct

+ Cause error

+ Message string

+ StepID string

+ WorkflowID string

+ func NewWorkflowError(workflowID, stepID, message string, cause error) *WorkflowError

+ func (e *WorkflowError) Error() string

+ func (e *WorkflowError) Unwrap() error

v0.5.2

Nov 3, 2025

v0.5.1

Oct 30, 2025

Changes in this version

+ type Composer interface

+ CancelWorkflow func(ctx context.Context, workflowID string) error

+ ExecuteWorkflow func(ctx context.Context, def *WorkflowDefinition, params map[string]any) (*WorkflowResult, error)

+ GetWorkflowStatus func(ctx context.Context, workflowID string) (*WorkflowStatus, error)

+ ValidateWorkflow func(ctx context.Context, def *WorkflowDefinition) error

+ type ElicitationConfig struct

+ Message string

+ OnCancel *ElicitationHandler

+ OnDecline *ElicitationHandler

+ Schema map[string]any

+ Timeout time.Duration

+ type ElicitationHandler struct

+ Action string

+ type ElicitationProtocolHandler interface

+ ReceiveElicitationResponse func(ctx context.Context, workflowID string, stepID string) (*ElicitationResponse, error)

+ SendElicitation func(ctx context.Context, workflowID string, stepID string, ...) error

+ type ElicitationResponse struct

+ Action string

+ Content map[string]any

+ ReceivedAt time.Time

+ type ErrorHandler struct

+ Action string

+ ContinueOnError bool

+ RetryCount int

+ RetryDelay time.Duration

+ type PendingElicitation struct

+ ExpiresAt time.Time

+ Message string

+ Schema map[string]any

+ StepID string

+ type StepResult struct

+ Duration time.Duration

+ EndTime time.Time

+ Error error

+ Output map[string]any

+ RetryCount int

+ StartTime time.Time

+ Status StepStatusType

+ StepID string

+ type StepStatusType string

+ const StepStatusCompleted

+ const StepStatusFailed

+ const StepStatusPending

+ const StepStatusRunning

+ const StepStatusSkipped

+ type StepType string

+ const StepTypeConditional

+ const StepTypeElicitation

+ const StepTypeTool

+ type TemplateExpander interface

+ EvaluateCondition func(ctx context.Context, condition string, workflowCtx *WorkflowContext) (bool, error)

+ Expand func(ctx context.Context, data map[string]any, workflowCtx *WorkflowContext) (map[string]any, error)

+ type WorkflowContext struct

+ Params map[string]any

+ Steps map[string]*StepResult

+ Variables map[string]any

+ WorkflowID string

+ type WorkflowDefinition struct

+ Description string

+ FailureMode string

+ Metadata map[string]string

+ Name string

+ Parameters map[string]any

+ Steps []WorkflowStep

+ Timeout time.Duration

+ type WorkflowResult struct

+ Duration time.Duration

+ EndTime time.Time

+ Error error

+ Metadata map[string]string

+ Output map[string]any

+ StartTime time.Time

+ Status WorkflowStatusType

+ Steps map[string]*StepResult

+ WorkflowID string

+ type WorkflowStateStore interface

+ DeleteState func(ctx context.Context, workflowID string) error

+ ListActiveWorkflows func(ctx context.Context) ([]string, error)

+ LoadState func(ctx context.Context, workflowID string) (*WorkflowStatus, error)

+ SaveState func(ctx context.Context, workflowID string, state *WorkflowStatus) error

+ type WorkflowStatus struct

+ CompletedSteps []string

+ CurrentStep string

+ LastUpdateTime time.Time

+ PendingElicitations []*PendingElicitation

+ StartTime time.Time

+ Status WorkflowStatusType

+ WorkflowID string

+ type WorkflowStatusType string

+ const WorkflowStatusCancelled

+ const WorkflowStatusCompleted

+ const WorkflowStatusFailed

+ const WorkflowStatusPending

+ const WorkflowStatusRunning

+ const WorkflowStatusTimedOut

+ const WorkflowStatusWaitingForElicitation

+ type WorkflowStep struct

+ Arguments map[string]any

+ Condition string

+ DependsOn []string

+ Elicitation *ElicitationConfig

+ ID string

+ Metadata map[string]string

+ OnError *ErrorHandler

+ Timeout time.Duration

+ Tool string

+ Type StepType

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