core

type AsyncExecutor ¶ added in v1.2.8

type AsyncExecutor = executor.AsyncExecutor

type Compiler ¶ added in v1.2.8

type Compiler = planning.Compiler

func NewCompiler() Compiler

type Edge ¶ added in v1.2.8

type Edge = definition.Edge

type ExecuteResult ¶ added in v1.2.8

type ExecuteResult = executor.ExecuteResult

type ExecuteTask ¶ added in v1.2.8

type ExecuteTask = executor.ExecuteTask

type ExecutionPlan ¶ added in v1.2.8

type ExecutionPlan = planning.ExecutionPlan

Planning layer aliases.

type Executor ¶ added in v1.2.8

type Executor = executor.Executor

Executor layer aliases.

type ExecutorDispatcher ¶ added in v1.2.8

type ExecutorDispatcher = executor.Dispatcher

type ExecutorRegistry ¶ added in v1.2.8

type ExecutorRegistry = executor.Registry

func NewExecutorRegistry() *ExecutorRegistry

type ExecutorSpec ¶ added in v1.2.8

type ExecutorSpec = definition.ExecutorSpec

type InputBinding ¶ added in v1.2.8

type InputBinding = definition.InputBinding

type InputMode ¶ added in v1.2.8

type InputMode = definition.InputMode

type InputSource ¶ added in v1.2.8

type InputSource = definition.InputSource

type InputSpec ¶ added in v1.2.8

type InputSpec = definition.InputSpec

type Node ¶ added in v1.2.8

type Node = definition.Node

type NodeRun ¶ added in v1.2.8

type NodeRun = wfruntime.NodeRun

type PlanNode ¶ added in v1.2.8

type PlanNode = planning.PlanNode

type PublishConfig ¶ added in v1.2.8

type PublishConfig = definition.PublishConfig

type RunContext ¶ added in v1.2.8

type RunContext = wfruntime.RunContext

type RunEvent ¶ added in v1.2.8

type RunEvent = wfruntime.RunEvent

type RunSnapshot ¶ added in v1.2.8

type RunSnapshot = wfruntime.RunSnapshot

type RuntimeStore ¶ added in v1.2.8

type RuntimeStore = wfruntime.Store

func NewGormStore(db *gorm.DB) (RuntimeStore, error)

func NewMemoryStore() RuntimeStore

type Trigger ¶ added in v1.2.8

type Trigger = definition.Trigger

type WorkerDescriptor ¶ added in v1.2.8

type WorkerDescriptor = workerproto.WorkerDescriptor

Worker protocol aliases.

type WorkerStatus ¶ added in v1.2.8

type WorkerStatus = workerproto.Status

type Workflow ¶ added in v1.2.8

type Workflow = definition.Workflow

Definition layer aliases exposed as a stable shared package.

type WorkflowDefinition ¶ added in v1.2.8

type WorkflowDefinition = definition.WorkflowDefinition

type WorkflowRun ¶ added in v1.2.8

type WorkflowRun = wfruntime.WorkflowRun

Runtime layer aliases.

type WorkflowVersion ¶ added in v1.2.8

type WorkflowVersion = definition.WorkflowVersion