function

Mar 27, 2026

Changes in this version

+ type DAGWorkflowInput = payload.DAGWorkflowInput

+ type DataMapping = payload.DataMapping

+ type FunctionDAGNode = payload.FunctionDAGNode

+ type FunctionDAGWorkflowOutput = payload.FunctionDAGWorkflowOutput

+ type FunctionExecutionInput = payload.FunctionExecutionInput

+ type FunctionExecutionOutput = payload.FunctionExecutionOutput

+ type FunctionInputMapping = payload.FunctionInputMapping

+ type FunctionNodeResult = payload.FunctionNodeResult

+ type LoopInput = payload.LoopInput

+ type LoopOutput = payload.LoopOutput

+ type OutputMapping = payload.OutputMapping

+ type ParallelInput = payload.ParallelInput

+ type ParallelOutput = payload.ParallelOutput

+ type ParameterizedLoopInput = payload.ParameterizedLoopInput

+ type PipelineInput = payload.PipelineInput

+ type PipelineOutput = payload.PipelineOutput

Mar 21, 2026

Changes in this version

+ func SetActivityInstrumenter(wrapper func(activityType) activityType)

Mar 9, 2026

Changes in this version

+ func RegisterActivity(w WorkflowRegistrar, activityFn interface{})

+ func RegisterAll(w WorkflowRegistrar, activityFn interface{})

+ func RegisterWorkflows(w WorkflowRegistrar)

+ type FunctionInput struct

+ Args map[string]string

+ Data []byte

+ Env map[string]string

+ WorkDir string

+ type FunctionOutput struct

+ Data []byte

+ Result map[string]string

+ type Handler func(ctx context.Context, input FunctionInput) (*FunctionOutput, error)

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Get(name string) (Handler, error)

+ func (r *Registry) Has(name string) bool

+ func (r *Registry) Register(name string, handler Handler)

+ type WorkflowRegistrar interface

+ RegisterActivityWithOptions func(a interface{}, options activity.RegisterOptions)

+ RegisterWorkflow func(w interface{})