cron

type Base struct {
	RedisClient *redis.Client

	LockName string
	IsRun    bool
	// contains filtered or unexported fields
}

type Config struct {
	LockPreName string       `json:"lockPreName"`
	IsRunCron   bool         `json:"isRunCron"`
	CronList    []ConfigItem `json:"cronList"`
}

type ConfigItem struct {
	Name                      string `json:"name"`
	DeadLockExpireMillisecond int64  `json:"deadLockExpireMillisecond"`
	MaxConcurrencyCnt         int    `json:"maxConcurrencyCnt"`

	JobType                 string                  `json:"jobType"`
	CronJobParams           CronJobParams           `json:"cronJobParams"`
	DurationJobParams       DurationJobParams       `json:"durationJobParams"`
	DurationRandomJobParams DurationRandomJobParams `json:"durationRandomJobParams"`
}

type CronJobParams struct {
	Crontab     string `json:"crontab"`
	WithSeconds bool   `json:"withSeconds"`
}

type DurationJobParams struct {
	EveryMillisecond int64 `json:"everyMillisecond"`
}

type DurationRandomJobParams struct {
	MinMillisecond int64 `json:"minMillisecond"`
	MaxMillisecond int64 `json:"maxMillisecond"`
}

type Interface interface {
	GetIsRun(context.Context) bool
	AddBaseTaskList(task func(context.Context))
	AddProcessAddTaskList(task func(context.Context))

	// Init 初始化只会执行一次
	Init(base Interface)
	Process(context.Context)

	Before(name, lockName string, deadLockExpireTime time.Duration, maxConcurrencyCnt int)
	Run(context.Context)
	Defer(context.Context)
}