process

Documentation

Index

• func AddConditions(p *Process, condition ...bool)
• func WrapFunc(f func()) func(ctx context.Context) error
• type Process
  • func NewProcess() *Process
  • func (p *Process) AddConditions(condition ...bool)
  • func (p *Process) AddTasks(task ...*Task)
  • func (p *Process) Clear()
  • func (p *Process) ContinueExec() error
  • func (p *Process) Exec() error
  • func (p *Process) ExecOffset(offset int) error
  • func (p *Process) GetTaskNum() int
  • func (p *Process) ResetConditions(condition ...bool)
  • func (p *Process) SetContext(ctx context.Context)
• type Task
  • func NewTask(shouldRun bool, f any, args ...any) *Task
  • func (t *Task) AddNegativeFunc(f any, args ...any) *Task

Functions

func AddConditions

func AddConditions(p *Process, condition ...bool)

func WrapFunc

func WrapFunc(f func()) func(ctx context.Context) error

WrapFunc wrap common func

Types

type Process

type Process struct {
	Tasks []*Task

	// Only all RunCondition is true, process will exec tasks.
	RunConditions []bool
	// contains filtered or unexported fields
}

func NewProcess

func NewProcess() *Process

func (*Process) AddConditions

func (p *Process) AddConditions(condition ...bool)

func (*Process) AddTasks

func (p *Process) AddTasks(task ...*Task)

func (*Process) Clear

func (p *Process) Clear()

func (*Process) ContinueExec

func (p *Process) ContinueExec() error

func (*Process) Exec

func (p *Process) Exec() error

func (*Process) ExecOffset

func (p *Process) ExecOffset(offset int) error

func (*Process) GetTaskNum

func (p *Process) GetTaskNum() int

func (*Process) ResetConditions

func (p *Process) ResetConditions(condition ...bool)

func (*Process) SetContext

func (p *Process) SetContext(ctx context.Context)

type Task

type Task struct {
	ShouldRun    bool  // determine if task will run
	Func         any   // must be func. run funcs
	Args         []any // func args
	NegativeFunc any   // must be func. if !ShouldRun, will run this
	NegativeArgs []any // negative args
}

func NewTask

func NewTask(shouldRun bool, f any, args ...any) *Task

func (*Task) AddNegativeFunc

func (t *Task) AddNegativeFunc(f any, args ...any) *Task