core

package

Go to main page

Versions in this module

v1

v1.2.18

Sep 7, 2026

v1.2.16

Sep 4, 2026

v1.2.15

Sep 4, 2026

v1.2.13

Sep 4, 2026

v1.2.12

Sep 1, 2026

v1.2.11

Aug 28, 2026

v1.2.10-alpha

Aug 28, 2026

v1.2.9

Aug 27, 2026

v1.2.8

Aug 24, 2026

Changes in this version

+ type AsyncExecutor = executor.AsyncExecutor

+ type Compiler = planning.Compiler

+ func NewCompiler() Compiler

+ type Edge = definition.Edge

+ type ExecuteResult = executor.ExecuteResult

+ type ExecuteTask = executor.ExecuteTask

+ type ExecutionPlan = planning.ExecutionPlan

+ type Executor = executor.Executor

+ type ExecutorDispatcher = executor.Dispatcher

+ type ExecutorRegistry = executor.Registry

+ func NewExecutorRegistry() *ExecutorRegistry

+ type ExecutorSpec = definition.ExecutorSpec

+ type InputBinding = definition.InputBinding

+ type InputMode = definition.InputMode

+ type InputSource = definition.InputSource

+ type InputSpec = definition.InputSpec

+ type Node = definition.Node

+ type NodeRun = wfruntime.NodeRun

+ type PlanNode = planning.PlanNode

+ type PublishConfig = definition.PublishConfig

+ type RunContext = wfruntime.RunContext

+ type RunEvent = wfruntime.RunEvent

+ type RunSnapshot = wfruntime.RunSnapshot

+ type RuntimeStore = wfruntime.Store

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

+ func NewMemoryStore() RuntimeStore

+ type Trigger = definition.Trigger

+ type WorkerDescriptor = workerproto.WorkerDescriptor

+ type WorkerStatus = workerproto.Status

+ type Workflow = definition.Workflow

+ type WorkflowDefinition = definition.WorkflowDefinition

+ type WorkflowRun = wfruntime.WorkflowRun

+ type WorkflowVersion = definition.WorkflowVersion

v1.0.1-beta

Aug 21, 2026

v0

v0.0.7

Feb 27, 2025

Changes in this version

+ var BETWEEN = Operator

+ var EQ = Operator

+ var EXISTS = Operator

+ var GT = Operator

+ var GTE = Operator

+ var IN = Operator

+ var IN_LIKE = Operator

+ var LIKE = Operator

+ var LT = Operator

+ var LTE = Operator

+ var NE = Operator

+ var NON_EXISTS = Operator

+ var NOT_IN = Operator

+ type Condition struct

+ Children []Condition

+ JointNext Joiner

+ Key string

+ Label string

+ Operator OperatorStr

+ Script string

+ Value interface{}

+ func NewCondition(key string, operator OperatorStr, value interface{}) *Condition

+ func (c *Condition) MarshalJSON() ([]byte, error)

+ type DictValueType string

+ const Number

+ const NumberTuple

+ const Single

+ const String

+ const StringList

+ type FormatFunction string

+ const BOOL

+ const DATE

+ const DATETIME

+ const DECIMAL

+ const INT

+ const NUMBER

+ const STRING

+ const TIME

+ type Joiner string

+ const AND

+ const NOT

+ const OR

+ type Operator struct

+ Desc string

+ Disabled bool

+ Order int

+ Value string

+ ValueType DictValueType

+ type OperatorStr = string

+ type SortEnum string

+ const ASC

+ const DESC

+ type SortRO struct

+ Column string

+ Desc bool

+ Format FormatFunction

+ func NewSortRO(column string, desc bool, format FormatFunction) *SortRO

+ func (s *SortRO) String() string

v0.0.7-202502270012

Feb 27, 2025

v0.0.6-alpha

Jan 16, 2025

v0.0.6-202501161422

Jan 16, 2025

v0.0.5

Jan 10, 2025

Changes in this version

+ type Line struct

+ From string

+ To string

type Pipeline

+ func (p *Pipeline) RunWithCallback(ctx context.Context, initialInput any, callback StageCallback) (any, error)

+ type StageCallback func(stage *Stage, status StageStatus, self *Pipeline, err error) bool

type StageStatus

+ const ALLStageCompleted

+ type StoryBoard struct

+ Lines []*Line

+ Stages []*Stage

+ func (u *StoryBoard) Build() (p *Pipeline, e error)

v0.0.5-alpha

Jan 9, 2025

v0.0.3

Dec 24, 2024

v0.0.2

Dec 24, 2024

Changes in this version

+ type DefaultUnit struct

+ Description string

+ Name string

+ type ExecutionState interface

+ Load func() (PipelineState, error)

+ Save func(state PipelineState) error

+ type IJob interface

+ Execute func(ctx context.Context, input any, current *Unit) (T, error)

+ GetPolicy func() IJobPolicy

+ ID func() string

+ Status func() JobStatus

+ type IJobPolicy interface

+ MaxRetries func() int

+ RetryCount func() int

+ RetryDelay func() time.Duration

+ type IStage interface

+ DependsOn func() []string

+ Name func() string

+ Status func() StageStatus

+ type Job struct

+ Dependencies []*IJob[any]

+ Executor func(ctx context.Context, i any, current *Unit) (any, error)

+ Input any

+ Name string

+ Output any

+ Policy IJobPolicy

+ Results any

+ func NewJob(name string) *Job

+ func (j *Job) Execute(ctx context.Context, input any, current *Unit) (any, error)

+ func (j *Job) GetPolicy() IJobPolicy

+ func (j *Job) ID() string

+ func (j *Job) Status() JobStatus

+ type JobPolicy struct

+ func NewPolicy(maxRetries int, retryDelay time.Duration) *JobPolicy

+ func (j *JobPolicy) MaxRetries() int

+ func (j *JobPolicy) ReachMaxRetries() bool

+ func (j *JobPolicy) Retry()

+ func (j *JobPolicy) RetryCount() int

+ func (j *JobPolicy) RetryDelay() time.Duration

+ type JobStatus string

+ const TaskCompleted

+ const TaskFailed

+ const TaskPending

+ const TaskRunning

+ type JobUnit struct

+ Job IJob[any]

+ UnitId string

+ func NewJobUnit(job IJob[any]) *JobUnit

+ func (u *JobUnit) ID() string

+ func (u *JobUnit) Run(ctx context.Context, input any, current *Unit) (any, error)

+ type Pipeline struct

+ EndTime time.Time

+ ID string

+ Results map[string]any

+ StartTime time.Time

+ StateStore ExecutionState

+ Status string

+ func NewPipeline(StateStore ExecutionState, stages ...*Stage) *Pipeline

+ func (p *Pipeline) ApplyState(state PipelineState)

+ func (p *Pipeline) LoadState() error

+ func (p *Pipeline) Pause()

+ func (p *Pipeline) Resume()

+ func (p *Pipeline) Run(ctx context.Context, initialInput any) (any, error)

+ func (p *Pipeline) SaveState()

+ func (p *Pipeline) Stop()

+ type PipelineState struct

+ CurrentStageIndex int

+ CurrentUnitIndex int

+ LastOutput any

+ Status string

+ type Stage struct

+ DependsOn string

+ Name string

+ Status StageStatus

+ func NewStage(name string, units []Unit) *Stage

+ func (s *Stage) Run(ctx context.Context, input any) (any, error)

+ type StageStatus string

+ const StageCompleted

+ const StageFailed

+ const StageNeedTerminate

+ const StagePending

+ const StageRunning

+ type Unit interface

+ ID func() string

+ Run func(ctx context.Context, input any, current *Unit) (any, error)

+ type UnitOutput struct

+ ID string

+ Output any

+ type UnitRegistry interface

+ GetOutput func() any

+ Name func() string

+ Order func() int

+ SetInput func(any) error

+ TemplateName func() string

+ type UnitTemplate interface

+ Description func() string

+ Instantiate func() Unit

+ Name func() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL