scheduler

type ITimer interface {
	Init(...Option) error
	// Start the scheduler manager and initialize it according to the preset configuration
	Start() error
	// IsRunning will return the status of scheduler
	IsRunning() bool
	// Tick main loop
	Tick()
	// AddTimer will add a scheduled task that is executed periodically and stops immediately if an error occurs during execution
	AddTimer(TimerFunc, time.Duration, ...TaskOption) (TimerHandler, error)
	// AddTimerOnce will add a scheduled task that triggers execution at a specified time.
	AddTimerOnce(TimerFunc, time.Duration, ...TaskOption) (TimerHandler, error)
	//AddTimerWithCount will add a scheduled task and execute it periodically at the specified interval.
	//When a specified number of times is reached or an error occurs, the task is stopped
	AddTimerWithCount(TimerFunc, time.Duration, int, ...TaskOption) (TimerHandler, error)
	// Corn will set a scheduled task to be automatically executed at a specified time
	// which follows https://en.wikipedia.org/wiki/Cron
	Corn(TimerFunc, string, ...TaskOption) (TimerHandler, error)
	// CancelTimer will stop a scheduled task
	CancelTimer(TimerHandler) error
	// Count will return the number of tasks on the timer
	Count() int
	// Shutdown will stop all tasks, and remove them from scheduler
	Shutdown() error
}

type Option func(options *Options)

type Options struct {
	Location          *time.Location `yaml:"location"`            // 定时器时区,
	MaxConcurrentJobs int            `yaml:"max_concurrent_jobs"` // 最大定时任务数量
}

type TaskOption func(options *TaskOptions)

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

type TimerFunc func() error // 定时器函数

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

type TimerHandler uint64 // 定时器句柄