Versions in this module Expand all Collapse all v1 v1.2.11 Aug 28, 2026 Changes in this version + func DispatchID(ctx context.Context) string + func InputAs[T any](node *Node) (T, error) + func InputObject(node *Node) (map[string]any, error) + func InputObjectIfExists(node *Node) (map[string]any, error) v1.2.10-alpha Aug 28, 2026 v1.2.9 Aug 27, 2026 v1.2.8 Aug 24, 2026 Changes in this version + var DefaultRegistry = NewRegistry() + var ErrAlreadyRegistered = errors.New("unit already registered") + func Register(name string, exec Executable) error + func RegisterFactory(name string, factory Factory) error + func RegisterUnit(name string, exec Executable) error + func RegisterUnitFactory(name string, factory Factory) error + type ContextMap map[string]*ExecutionResult + type ControlSignal string + const ControlBreak + const ControlContinue + const ControlGoto + type ControlSignalError struct + Signal ControlSignal + Target string + func (e *ControlSignalError) Error() string + type Executable interface + Execute func(ctx context.Context, state ContextMap, self *Node) (*ExecutionResult, error) + GetUnitMeta func() *Unit + func Find(name string) (Executable, bool) + type ExecutableUnit = Executable + type ExecutionResult struct + Control ControlSignal + ControlTarget string + Data any + DeleteVariables []string + Error string + NodeName string + Raw any + Stream bool + Variables map[string]any + func SimpleResult(data any) *ExecutionResult + type Executor struct + Credentials credential.Resolver + Registry *Registry + func NewExecutor(reg *Registry) *Executor + func NewExecutorWithCredentials(reg *Registry, credentials credential.Resolver) *Executor + func (e *Executor) Execute(ctx context.Context, task executor.ExecuteTask) (executor.ExecuteResult, error) + func (e *Executor) Type() executor.Type + type Factory func() Executable + type Input struct + Data any + DataType string + Slottable bool + type Node struct + ExportFields []string + ID string + Input *Input + Name string + Params map[string]any + type Registration struct + Factory Factory + Name string + type Registry struct + func NewRegistry() *Registry + func (r *Registry) Clone() *Registry + func (r *Registry) Names() []string + func (r *Registry) New(name string) (Executable, bool) + func (r *Registry) Register(name string, factory Factory) error + func (r *Registry) RegisterAll(registrations ...Registration) error + func (r *Registry) RegisterInstance(name string, exec Executable) error + func (r *Registry) RegisterOrReplace(name string, factory Factory) error + func (r *Registry) RegisterUnit(name string, exec Executable) error + func (r *Registry) RegisterUnitFactory(name string, factory Factory) error + func (r *Registry) Registrations() []Registration + type Unit struct + DisplayName string + ErrMsg string + ID string + OutputRef string + Status string + UnitName string v1.0.1-beta Aug 21, 2026
Go to main page