gotaskflow

May 9, 2025

Changes in this version

+ type DotEdge struct

+ func (edge *DotEdge) Format(indent string) string

+ type DotGraph struct

+ func NewDotGraph(name string) *DotGraph

+ func (g *DotGraph) CreateEdge(from, to *DotNode, label string) *DotEdge

+ func (g *DotGraph) CreateNode(name string) *DotNode

+ func (g *DotGraph) String() string

+ func (g *DotGraph) SubGraph(name string) *DotGraph

+ type DotNode struct

+ func (node *DotNode) Format(indent string) string

Mar 27, 2025

Changes in this version

+ var ErrVisualizerNotSupport = errors.New("visualization not support")

Mar 27, 2025

Changes in this version

+ var ErrVisualizerNotCompile = errors.New("feature not support, try to remove !noviz build tag instead")

type Visualizer

+ Visualize func(tf *TaskFlow, writer io.Writer) error

Nov 22, 2024

Changes in this version

type TaskFlow

+ func (tf *TaskFlow) Dump(writer io.Writer) error

Nov 21, 2024

Changes in this version

type Subflow

+ func (sf *Subflow) NewCondition(name string, predict func() uint) *Task

+ func (sf *Subflow) NewSubflow(name string, f func(sf *Subflow)) *Task

+ func (sf *Subflow) NewTask(name string, f func()) *Task

type TaskFlow

+ func (tf *TaskFlow) NewCondition(name string, predict func() uint) *Task

+ func (tf *TaskFlow) NewSubflow(name string, f func(sf *Subflow)) *Task

+ func (tf *TaskFlow) NewTask(name string, f func()) *Task

Nov 7, 2024

Changes in this version

+ const HIGH

+ const LOW

+ const NORMAL

type Task

+ func (t *Task) Priority(p TaskPriority) *Task

+ type TaskPriority uint

Oct 21, 2024

Changes in this version

+ func Visualize(tf *TaskFlow, writer io.Writer) error

+ type Condition struct

type NodeType

+ const NodeCondition

type Task

+ func NewCondition(name string, f func() int) *Task

Oct 12, 2024

Changes in this version

+ var ErrGraphIsCyclic = errors.New("graph is cyclic, not support")

+ var FlowBuilder = flowBuilder

+ var Visualizer = visualizer

+ type Executor interface

+ Profile func(w io.Writer) error

+ Run func(tf *TaskFlow) Executor

+ Wait func()

+ func NewExecutor(concurrency uint) Executor

+ type ExecutorImpl struct

+ func (e *ExecutorImpl) Profile(w io.Writer) error

+ func (e *ExecutorImpl) Run(tf *TaskFlow) Executor

+ func (e *ExecutorImpl) Wait()

+ type Graph struct

+ func (g *Graph) JoinCounter() int

+ type Node struct

+ Typ NodeType

+ func (n *Node) JoinCounter() int

+ type NodeType string

+ const NodeStatic

+ const NodeSubflow

+ type Profiler struct

+ func NewTracer() *Profiler

+ func (t *Profiler) AddSpan(s *span)

+ func (t *Profiler) Start()

+ func (t *Profiler) Stop()

+ type Static struct

+ type Subflow struct

+ func (sf *Subflow) Push(tasks ...*Task)

+ type Task struct

+ func NewSubflow(name string, f func(sf *Subflow)) *Task

+ func NewTask(name string, f func(ctx *context.Context)) *Task

+ func (t *Task) Name() string

+ func (t *Task) Precede(task *Task)

+ func (t *Task) Succeed(task *Task)

+ type TaskFlow struct

+ func NewTaskFlow(name string) *TaskFlow

+ func (tf *TaskFlow) Name() string

+ func (tf *TaskFlow) Push(tasks ...*Task)

+ func (tf *TaskFlow) Reset()

+ type TaskInterface interface

+ Name func()

+ Precede func(task TaskInterface)

+ Succeed func(task TaskInterface)