engine

Aug 20, 2024

Changes in this version

type Workflow

+ Namespaces func() map[string]map[string]*schema.ObjectSchema

Jan 22, 2024

Changes in this version

+ func StepWorkflowPaths(wf *workflow.Workflow) map[string]string

+ func SubworkflowCache(wf *workflow.Workflow, rootDir string) (loadfile.FileCache, error)

Oct 26, 2023

Changes in this version

+ func SupportedVersion(version string) (string, error)

Apr 19, 2023

Changes in this version

+ func NewDefaultStepRegistry(logger log.Logger, deployerRegistry deployerRegistry.Registry, ...) (step.Registry, error)

+ type Workflow interface

+ InputSchema func() schema.Scope

+ Outputs func() map[string]schema.StepOutput

+ Run func(ctx context.Context, input []byte) (outputID string, outputData any, outputIsError bool, err error)

type WorkflowEngine

+ Parse func(workflowContext map[string][]byte, workflowFileName string) (workflow Workflow, err error)

Jan 31, 2023

Changes in this version

+ var DefaultDeployerRegistry = registry.New(deployer.Any(docker.NewFactory()), deployer.Any(kubernetes.NewFactory()))

+ var ErrEmptyWorkflowFile = fmt.Errorf("empty workflow file provided in context")

+ var ErrNoSteps = fmt.Errorf("no steps defined in workflow")

+ var ErrNoWorkflowFile = fmt.Errorf("no workflow file provided in context")

+ var ErrWorkflowAborted = fmt.Errorf("workflow execution aborted")

+ type ErrInvalidInput struct

+ Cause error

+ func (e ErrInvalidInput) Error() string

+ func (e ErrInvalidInput) Unwrap() error

+ type ErrInvalidInputYAML struct

+ Cause error

+ func (e ErrInvalidInputYAML) Error() string

+ func (e ErrInvalidInputYAML) Unwrap() error

+ type ErrInvalidWorkflow struct

+ Cause error

+ func (e ErrInvalidWorkflow) Error() string

+ func (e ErrInvalidWorkflow) Unwrap() error

+ type ErrInvalidWorkflowYAML struct

+ Cause error

+ func (e ErrInvalidWorkflowYAML) Error() string

+ func (e ErrInvalidWorkflowYAML) Unwrap() error

+ type WorkflowEngine interface

+ RunWorkflow func(ctx context.Context, input []byte, files map[string][]byte, ...) (outputData any, err error)

+ func New(config *config.Config, deployerRegistry registry.Registry) (WorkflowEngine, error)