scheduler

type Options struct {
	Interval time.Duration
	Logger   *zap.Logger
	AutoRun  bool
}

type Scheduler interface {
	Start() error
	Stop()
	Running() bool
	GetTask(string) (TaskDefinition, bool)
	ScheduleTask(string, TaskOptions) error
	StopTask(string) error
	TotalTasks() int
}

type TaskDefinition struct {
	Name string
	Func TaskFunc
	// contains filtered or unexported fields
}

type TaskFunc func(context.Context)

type TaskOptions struct {
	// Interval is the time between each task run.
	// Timeout OR Interval must be set.
	Interval time.Duration
	// Timeout is the maximum time the task is allowed to run
	// before it is forcefully stopped.
	// Timeout OR Interval must be set.
	Timeout time.Duration
	// Overwrite indicates whether to overwrite the task if it already exists.
	// If set to false, an error will be returned if the task already exists.
	// If set to true, the task will be overwritten with the new task and any existing timers will be reset.
	Overwrite bool
	// TaskFunc is the function to run when the task is scheduled.
	TaskFunc TaskFunc
}