task

type BackupTask struct {
	Name               string
	Fun                func(ctx context.Context) error
	BackupTask         Task
	EnableRetry        bool
	RetryBackOffPolicy RetryBackOffPolicy
	Timeout            time.Duration
}

type ExponentialRetryBackoffPolicy struct {
	Retry    int
	Duration time.Duration
}

type FixedRetryBackoffPolicy struct {
	Retry    int
	Duration time.Duration
}

type NormalTask struct {
	Name    string
	Timeout time.Duration
	Fun     func(ctx context.Context) error
}

type RetryBackOffPolicy interface {
	MaxRetry() int
	Next(retryCount int) time.Duration
}

type RetryableTask struct {
	// 任务名
	Name string
	// 执行函数
	Fun                func(ctx context.Context) error
	RetryBackoffPolicy RetryBackOffPolicy
	// 执行超时时间
	Timeout time.Duration
}

type Task interface {
	Func() func(ctx context.Context) error
	// contains filtered or unexported methods
}

type TerminatedTask struct {
	// 任务名
	Name string
	// 执行函数
	Fun     func(ctx context.Context) error
	Timeout time.Duration
}