cron

type CronTask struct {
	// contains filtered or unexported fields
}

type Pipe struct {
	// contains filtered or unexported fields
}

type RetryTaskParam struct {
	NewContext         func() context.Context
	GetDatas           func() []interface{}
	BeforeAction       func(data interface{}) error
	DoAction           func(ctx context.Context, times int, data interface{}) error
	AfterActionSuccess func(data interface{}) error
	AfterActionFail    func(data interface{}) error
	GetTaskDataId      func(data interface{}) string
	RecordFailByPanic  func(data interface{}, error string)
}

type Task struct {
	// contains filtered or unexported fields
}

type TaskContext struct {
	// contains filtered or unexported fields
}