wf

package module

Go to main page

Versions in this module

v0

v0.6.0

Nov 1, 2025

v0.5.0

Aug 7, 2025

Changes in this version

+ func WithDependency(dependent RunnableInterface, dependencies ...RunnableInterface) func(DependencyAdder)

+ func WithRunnables(nodes ...RunnableInterface) func(RunnableAdder)

+ type DependencyAdder interface

+ DependencyAdd func(dependent RunnableInterface, dependency ...RunnableInterface)

+ type RunnableAdder interface

+ RunnableAdd func(node ...RunnableInterface)

v0.4.0

Aug 7, 2025

Changes in this version

+ func WithHandler(...) func(StepInterface)

+ type StepOption = func(StepInterface)

v0.3.0

Aug 7, 2025

Changes in this version

+ func WithID(id string) func(Identifiable)

+ func WithName(name string) func(Nameable)

+ type Identifiable interface

+ SetID func(id string)

+ type Nameable interface

+ SetName func(name string)

v0.2.0

Aug 7, 2025

v0.1.0

Aug 4, 2025

Changes in this version

+ const StateStatusComplete

+ const StateStatusFailed

+ const StateStatusPaused

+ const StateStatusRunning

+ type Dag struct

+ func (d *Dag) DependencyAdd(dependent RunnableInterface, dependency ...RunnableInterface)

+ func (d *Dag) DependencyList(ctx context.Context, node RunnableInterface, data map[string]any) []RunnableInterface

+ func (d *Dag) GetID() string

+ func (d *Dag) GetName() string

+ func (d *Dag) GetState() StateInterface

+ func (d *Dag) IsCompleted() bool

+ func (d *Dag) IsFailed() bool

+ func (d *Dag) IsPaused() bool

+ func (d *Dag) IsRunning() bool

+ func (d *Dag) IsWaiting() bool

+ func (d *Dag) Pause() error

+ func (d *Dag) Resume(ctx context.Context, data map[string]any) (context.Context, map[string]any, error)

+ func (d *Dag) Run(ctx context.Context, data map[string]any) (context.Context, map[string]any, error)

+ func (d *Dag) RunnableAdd(node ...RunnableInterface)

+ func (d *Dag) RunnableList() []RunnableInterface

+ func (d *Dag) RunnableRemove(node RunnableInterface) bool

+ func (d *Dag) SetID(id string)

+ func (d *Dag) SetName(name string)

+ func (d *Dag) SetState(state StateInterface)

+ func (d *Dag) Visualize() string

+ type DagInterface interface

+ DependencyAdd func(dependent RunnableInterface, dependency ...RunnableInterface)

+ DependencyList func(ctx context.Context, node RunnableInterface, data map[string]any) []RunnableInterface

+ GetState func() StateInterface

+ Pause func() error

+ Resume func(ctx context.Context, data map[string]any) (context.Context, map[string]any, error)

+ RunnableAdd func(node ...RunnableInterface)

+ RunnableList func() []RunnableInterface

+ RunnableRemove func(node RunnableInterface) bool

+ SetState func(state StateInterface)

+ func NewDag() DagInterface

+ type DotEdgeSpec struct

+ Color string

+ FromNodeName string

+ Style string

+ ToNodeName string

+ Tooltip string

+ type DotNodeSpec struct

+ DisplayName string

+ FillColor string

+ Name string

+ Shape string

+ Style string

+ Tooltip string

+ type PipelineInterface interface

+ GetState func() StateInterface

+ Pause func() error

+ Resume func(ctx context.Context, data map[string]any) (context.Context, map[string]any, error)

+ RunnableAdd func(node ...RunnableInterface)

+ RunnableList func() []RunnableInterface

+ RunnableRemove func(node RunnableInterface) bool

+ SetState func(state StateInterface)

+ func NewPipeline() PipelineInterface

+ type RunnableInterface interface

+ GetID func() string

+ GetName func() string

+ IsCompleted func() bool

+ IsFailed func() bool

+ IsPaused func() bool

+ IsRunning func() bool

+ IsWaiting func() bool

+ Run func(ctx context.Context, data map[string]any) (context.Context, map[string]any, error)

+ SetID func(id string)

+ SetName func(name string)

+ Visualize func() string

+ type State struct

+ CompletedSteps []string

+ CurrentStepID string

+ Data map[string]any

+ LastUpdated time.Time

+ Status StateStatus

+ func (s *State) AddCompletedStep(id string)

+ func (s *State) FromJSON(data []byte) error

+ func (s *State) GetCompletedSteps() []string

+ func (s *State) GetCurrentStepID() string

+ func (s *State) GetData() map[string]any

+ func (s *State) GetLastUpdated() time.Time

+ func (s *State) GetStatus() StateStatus

+ func (s *State) GetWorkflowData() map[string]any

+ func (s *State) SetCurrentStepID(id string)

+ func (s *State) SetData(data map[string]any)

+ func (s *State) SetLastUpdated(t time.Time)

+ func (s *State) SetStatus(status StateStatus)

+ func (s *State) SetWorkflowData(data map[string]any)

+ func (s *State) ToJSON() ([]byte, error)

+ type StateInterface interface

+ AddCompletedStep func(id string)

+ FromJSON func(data []byte) error

+ GetCompletedSteps func() []string

+ GetCurrentStepID func() string

+ GetData func() map[string]any

+ GetLastUpdated func() time.Time

+ GetStatus func() StateStatus

+ GetWorkflowData func() map[string]any

+ SetCurrentStepID func(id string)

+ SetData func(data map[string]any)

+ SetLastUpdated func(t time.Time)

+ SetStatus func(status StateStatus)

+ SetWorkflowData func(data map[string]any)

+ ToJSON func() ([]byte, error)

+ func NewState() StateInterface

+ type StateStatus string

+ type StepHandler func(ctx context.Context, data map[string]any) (context.Context, map[string]any, error)

+ type StepInterface interface

+ GetHandler func() StepHandler

+ GetState func() StateInterface

+ Pause func() error

+ Resume func(ctx context.Context, data map[string]any) (context.Context, map[string]any, error)

+ SetHandler func(handler StepHandler)

+ SetState func(state StateInterface)

+ func NewStep() StepInterface

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