model

Documentation

Index

• func DeepMap(input any, transform func(el string) (any, error)) (any, error)
• func GenerateJsonSchema() ([]byte, error)
• func ParseWorkflowSpecYaml(data string) (workflowSpec, error)
• type ExecutionStrategy
• type Workflow
  • func Parse(yamlWorkflow string) (*Workflow, error)
  • func (w *Workflow) Dependents(start string) ([]*step, error)
  • func (w *Workflow) WalkDo(start string, do func(s *step) error) error

Functions

func DeepMap

func DeepMap(input any, transform func(el string) (any, error)) (any, error)

DeepMap recursively applies a transformation function over each string within:

• a map[string]any
• a []any
• a string

func GenerateJsonSchema

func GenerateJsonSchema() ([]byte, error)

func ParseWorkflowSpecYaml

func ParseWorkflowSpecYaml(data string) (workflowSpec, error)

Types

type ExecutionStrategy

type ExecutionStrategy interface {
	Apply(ctx context.Context, l logger.Logger, cap capabilities.CallbackCapability, req capabilities.CapabilityRequest) (values.Value, error)
}

type Workflow

type Workflow struct {
	ID string
	graph.Graph[string, *step]

	Triggers []*triggerCapability

	Spec *workflowSpec
}

Workflow is a directed graph of nodes, where each node is a step.

triggers are special steps that are stored separately, they're treated differently due to their nature of being the starting point of a Workflow.

func Parse

func Parse(yamlWorkflow string) (*Workflow, error)

func (*Workflow) Dependents

func (w *Workflow) Dependents(start string) ([]*step, error)

func (*Workflow) WalkDo

func (w *Workflow) WalkDo(start string, do func(s *step) error) error