Versions in this module Expand all Collapse all v0 v0.5.0 Mar 23, 2021 Changes in this version + type Manager interface + NewTaskHandler func(timeout time.Duration, retryDelay time.Duration, t Task) TaskHandler + WaitForTasks func() + func NewManager(logger *logrus.Logger) Manager + type ManagerDetails struct + func (md *ManagerDetails) NewTaskHandler(timeout time.Duration, retryDelay time.Duration, task Task) TaskHandler + func (md *ManagerDetails) WaitForTasks() + type SnapshotTask struct + func NewSnapshotTask(logger *logrus.Logger, eth blockchain.Ethereum, acct accounts.Account, ...) *SnapshotTask + func (t *SnapshotTask) DoDone() + func (t *SnapshotTask) DoRetry(ctx context.Context) bool + func (t *SnapshotTask) DoWork(ctx context.Context) bool + func (t *SnapshotTask) ShouldRetry(ctx context.Context) bool + type Task interface + DoDone func() + DoRetry func(context.Context) bool + DoWork func(context.Context) bool + ShouldRetry func(context.Context) bool + type TaskDoFunc func(context.Context) bool + type TaskDoneFunc func() + type TaskHandler interface + Cancel func() + Complete func() bool + Start func() + Successful func() bool + type TaskHandlerDetails struct + ID int + func (td *TaskHandlerDetails) Cancel() + func (td *TaskHandlerDetails) Complete() bool + func (td *TaskHandlerDetails) Start() + func (td *TaskHandlerDetails) Successful() bool + type TaskShouldFunc func(context.Context) bool