engine

Jul 24, 2023

Changes in this version

type Engine

+ func (e *Engine) RegisterNewFuncAgr(name string, fun func(ctx context.Context, arg Arg) error)

Sep 25, 2021

Changes in this version

+ const ContextKey

+ const FmtErrContext

+ var ErrArgNotApplied = errors.Errorf("Argument is not applied")

+ var ErrArgOverwrite = errors.Errorf("Argument already applied")

+ func IsNotResolved(x interface{}) bool

+ type Arg int32

+ type ArgApplier interface

+ Apply func(a Arg) (Doer, bool, error)

+ type Doer interface

+ Do func(context.Context) error

+ String func() string

+ Validate func() error

+ func ArgApply(d Doer, arg Arg) (Doer, bool, error)

+ func Force(d Doer) (Doer, bool, error)

+ type Engine struct

+ Log *log2.Log

+ func GetGlobal(ctx context.Context) *Engine

+ func NewEngine(log *log2.Log) *Engine

+ func (e *Engine) TestDo(t testing.TB, ctx context.Context, name string)

+ func (self *Engine) Exec(ctx context.Context, d Doer) error

+ func (self *Engine) ExecList(ctx context.Context, tag string, list []string) []error

+ func (self *Engine) ExecPart(ctx context.Context, d Doer) error

+ func (self *Engine) List() []string

+ func (self *Engine) ParseText(tag, text string) (Doer, error)

+ func (self *Engine) Register(action string, d Doer)

+ func (self *Engine) RegisterNewFunc(name string, fun func(context.Context) error)

+ func (self *Engine) RegisterNewSeq(name string, ds ...Doer)

+ func (self *Engine) RegisterParse(name, scenario string) error

+ func (self *Engine) Resolve(action string) Doer

+ func (self *Engine) ResolveOrLazy(action string) (Doer, error)

+ func (self *Engine) SetProfile(re *regexp.Regexp, min time.Duration, fun ProfileFunc)

+ func (self *Engine) ValidateExec(ctx context.Context, d Doer) error

+ type ErrNotResolved struct

+ func NewErrNotResolved(action string) ErrNotResolved

+ func (e ErrNotResolved) Error() string

+ type Fail struct

+ E error

+ func (self Fail) Do(ctx context.Context) error

+ func (self Fail) String() string

+ func (self Fail) Validate() error

+ type Forcer interface

+ Force func() (Doer, bool, error)

+ type Func struct

+ F func(context.Context) error

+ Name string

+ V ValidateFunc

+ func (self Func) Do(ctx context.Context) error

+ func (self Func) String() string

+ func (self Func) Validate() error

+ type Func0 struct

+ F func() error

+ Name string

+ V ValidateFunc

+ func (self Func0) Do(ctx context.Context) error

+ func (self Func0) String() string

+ func (self Func0) Validate() error

+ type FuncArg struct

+ F func(context.Context, Arg) error

+ Name string

+ V ValidateFunc

+ func (fa FuncArg) Apply(a Arg) (Doer, bool, error)

+ func (fa FuncArg) Do(ctx context.Context) error

+ func (fa FuncArg) String() string

+ func (fa FuncArg) Validate() error

+ type IgnoreArg struct

+ func (self IgnoreArg) Apply(Arg) (Doer, bool, error)

+ type Lazy struct

+ Name string

+ func (l *Lazy) Do(ctx context.Context) error

+ func (l *Lazy) Force() (d Doer, forced bool, err error)

+ func (l *Lazy) String() string

+ func (l *Lazy) Validate() error

+ type MaybeBool uint8

+ type Nothing struct

+ Name string

+ func (self Nothing) Do(ctx context.Context) error

+ func (self Nothing) String() string

+ func (self Nothing) Validate() error

+ type ProfileFunc func(Doer, time.Duration)

+ type RepeatN struct

+ D Doer

+ N uint

+ func (self RepeatN) Do(ctx context.Context) error

+ func (self RepeatN) String() string

+ func (self RepeatN) Validate() error

+ type RestartError struct

+ Check func(error) bool

+ Reset Doer

+ func (self *RestartError) Apply(arg Arg) (Doer, bool, error)

+ func (self *RestartError) Do(ctx context.Context) error

+ func (self *RestartError) String() string

+ func (self *RestartError) Validate() error

+ type Run struct

+ func NewRunner() *Run

+ func (r *Run) Loop(ctx context.Context, parent *alive.Alive)

+ func (r *Run) Schedule(ctx context.Context, priority tele_api.Priority, fun types.TaskFunc) chan error

+ func (r *Run) ScheduleSync(ctx context.Context, priority tele_api.Priority, fun types.TaskFunc) error

+ type Seq struct

+ func NewSeq(name string) *Seq

+ func (seq *Seq) Append(d Doer) *Seq

+ func (seq *Seq) Apply(arg Arg) (Doer, bool, error)

+ func (seq *Seq) Do(ctx context.Context) error

+ func (seq *Seq) Force() (Doer, bool, error)

+ func (seq *Seq) String() string

+ func (seq *Seq) Validate() error

+ type Sleep struct

+ func (self Sleep) Do(ctx context.Context) error

+ func (self Sleep) String() string

+ func (self Sleep) Validate() error

+ type ValidateFunc func() error