flow

Apr 12, 2023

Changes in this version

type Controller

+ func (c *Controller) Stats() (counts stats.Counts)

type Task

+ func (t *Task) Stats() stats.Counts

Apr 20, 2022

Changes in this version

type Config

+ FindHiddenTasks bool

type Controller

+ func (c *Controller) Value() cue.Value

Apr 2, 2021

Changes in this version

+ var ErrAbort = errors.New("abort dependant tasks without failure")

+ type Config struct

+ IgnoreConcrete bool

+ InferTasks bool

+ Root cue.Path

+ UpdateFunc func(c *Controller, t *Task) error

+ type Controller struct

+ func New(cfg *Config, inst *cue.Instance, f TaskFunc) *Controller

+ func (c *Controller) Run(ctx context.Context) error

+ func (c *Controller) Tasks() []*Task

+ type Runner interface

+ Run func(t *Task, err error) error

+ type RunnerFunc func(t *Task) error

+ func (f RunnerFunc) Run(t *Task, err error) error

+ type State int

+ const Ready

+ const Running

+ const Terminated

+ const Waiting

+ func (s State) String() string

+ type Task struct

+ func (t *Task) Context() context.Context

+ func (t *Task) Dependencies() []*Task

+ func (t *Task) Err() error

+ func (t *Task) Fill(x interface{}) error

+ func (t *Task) Index() int

+ func (t *Task) Path() cue.Path

+ func (t *Task) PathDependencies(p cue.Path) []*Task

+ func (t *Task) State() State

+ func (t *Task) Value() cue.Value

+ type TaskFunc func(v cue.Value) (Runner, error)