Versions in this module Expand all Collapse all v0 v0.1.3 Sep 15, 2023 v0.1.2 Sep 15, 2023 Changes in this version + const PersistPriorityAfterAction + const PersistPriorityImmediately + var EndLoop = errors.New("end loop") + func LoopDo(ctx ExecuteContext, do func() error, ops ...LoopDoOptionOp) error + type Action interface + Name func() string + Run func(ctx ExecuteContext, params interface{}) error + type AfterAction interface + RunAfter func(ctx ExecuteContext, params interface{}) error + type BeforeAction interface + RunBefore func(ctx ExecuteContext, params interface{}) error + type DefExecuteContext struct + func NewDefExecuteContext(ctx context.Context, op ShareDataOperator, ...) *DefExecuteContext + func (e *DefExecuteContext) Context() context.Context + func (e *DefExecuteContext) GetVar(varName string) (string, bool) + func (e *DefExecuteContext) IterateVars(iterateFunc utils.KeyValueIterateFunc) + func (e *DefExecuteContext) ShareData() ShareDataOperator + func (e *DefExecuteContext) Trace(msg string, opt ...TraceOp) + func (e *DefExecuteContext) Tracef(msg string, a ...interface{}) + func (e *DefExecuteContext) WithValue(key, value interface{}) + type ExecuteContext interface + Context func() context.Context + GetVar func(varName string) (string, bool) + IterateVars func(iterateFunc utils.KeyValueIterateFunc) + ShareData func() ShareDataOperator + Trace func(msg string, opt ...TraceOp) + Tracef func(msg string, a ...interface{}) + WithValue func(key, value interface{}) + type LoopDoOption struct + type LoopDoOptionOp func(loop *LoopDoOption) + func LoopInterval(duration time.Duration) LoopDoOptionOp + type MockAction struct + func (_m *MockAction) Name() string + func (_m *MockAction) ParameterNew() interface{} + func (_m *MockAction) RetryBefore(ctx ExecuteContext, params interface{}) error + func (_m *MockAction) Run(ctx ExecuteContext, params interface{}) error + func (_m *MockAction) RunAfter(ctx ExecuteContext, params interface{}) error + func (_m *MockAction) RunBefore(ctx ExecuteContext, params interface{}) error + type MockExecuteContext struct + func (_m *MockExecuteContext) Context() context.Context + func (_m *MockExecuteContext) GetVar(varName string) (string, bool) + func (_m *MockExecuteContext) IterateVars(iterateFunc utils.KeyValueIterateFunc) + func (_m *MockExecuteContext) ShareData() ShareDataOperator + func (_m *MockExecuteContext) Trace(msg string, opt ...TraceOp) + func (_m *MockExecuteContext) Tracef(msg string, a ...interface{}) + func (_m *MockExecuteContext) WithValue(key interface{}, value interface{}) + type ParameterAction interface + ParameterNew func() interface{} + type PersistPriority string + type RetryBeforeAction interface + RetryBefore func(ctx ExecuteContext, params interface{}) error + type RunFunc func(ctx ExecuteContext, params interface{}) error + type ShareDataOperator interface + Get func(key string) (string, bool) + Set func(key string, val string) + type TraceOp func(opt *TraceOption) + var TraceOpPersistAfterAction TraceOp = func(opt *TraceOption) { ... } + type TraceOption struct + Priority PersistPriority + func NewTraceOption(ops ...TraceOp) *TraceOption