Versions in this module Expand all Collapse all v0 v0.0.3 Oct 18, 2023 Changes in this version + const DefaultCon + const DefaultTaskName + const DefaultTimeout + type Interface interface + Execute func() *ending.TaskResult + ExecuteRollback func() + GetDesc func() string + Init func(runtime connector.Runtime, moduleCache *cache.Cache, ...) + type LocalTask struct + Action action.Action + Delay time.Duration + Desc string + IgnoreError bool + ModuleCache *cache.Cache + Name string + PipelineCache *cache.Cache + Prepare prepare.Prepare + Retry int + Rollback rollback.Rollback + Runtime connector.Runtime + TaskResult *ending.TaskResult + Timeout time.Duration + func (l *LocalTask) Default() + func (l *LocalTask) Execute() *ending.TaskResult + func (l *LocalTask) ExecuteRollback() + func (l *LocalTask) ExecuteWithRetry(runtime connector.Runtime, host connector.Host) error + func (l *LocalTask) GetDesc() string + func (l *LocalTask) Init(runtime connector.Runtime, moduleCache *cache.Cache, ...) + func (l *LocalTask) Run(runtime connector.Runtime, host connector.Host, resCh chan error) + func (l *LocalTask) RunWithTimeout(runtime connector.Runtime, host connector.Host) + func (l *LocalTask) When(runtime connector.Runtime) (bool, error) + func (l *LocalTask) WhenWithRetry(runtime connector.Runtime, host connector.Host) (bool, error) + type RemoteTask struct + Action action.Action + Concurrency float64 + Delay time.Duration + Desc string + Hosts []connector.Host + IgnoreError bool + ModuleCache *cache.Cache + Name string + Parallel bool + PipelineCache *cache.Cache + Prepare prepare.Prepare + Retry int + Rollback rollback.Rollback + Runtime connector.Runtime + TaskResult *ending.TaskResult + Timeout time.Duration + func (t *RemoteTask) ConfigureSelfRuntime(runtime connector.Runtime, host connector.Host, index int) error + func (t *RemoteTask) Default() + func (t *RemoteTask) Execute() *ending.TaskResult + func (t *RemoteTask) ExecuteRollback() + func (t *RemoteTask) ExecuteWithRetry(runtime connector.Runtime) error + func (t *RemoteTask) GetDesc() string + func (t *RemoteTask) Init(runtime connector.Runtime, moduleCache *cache.Cache, ...) + func (t *RemoteTask) RollbackWithTimeout(ctx context.Context, runtime connector.Runtime, host connector.Host, index int, ...) + func (t *RemoteTask) Run(runtime connector.Runtime, host connector.Host, index int, resCh chan error) + func (t *RemoteTask) RunRollback(runtime connector.Runtime, host connector.Host, index int, ...) + func (t *RemoteTask) RunWithTimeout(ctx context.Context, runtime connector.Runtime, host connector.Host, index int, ...) + func (t *RemoteTask) When(runtime connector.Runtime) (bool, error) + func (t *RemoteTask) WhenWithRetry(runtime connector.Runtime) (bool, error)
Go to main page