scheduler

type Config struct {
	Timeout    string      `yaml:"timeout"`
	JobConfigs []JobConfig `yaml:"jobs"`
}

type CronJob struct {
	Expr string
}

type Job struct {
	Spec     *JobSpec
	Metadata JobMetadata
	Status   Status

	PreExecTime int64
	ExecTime    int64

	Error  error
	Result []byte
	Runs   uint64
}

type JobConfig struct {
	Disabled *bool          `yaml:"disabled"`
	Name     string         `yaml:"name"`
	Timeout  *time.Duration `yaml:"timeout"`

	// MaxRetries is the maximum number of retries before aborting the
	// current job execution.
	// Default: 0.
	MaxRetries *int `yaml:"max_retries"`

	// RetryInterval is the fixed time interval between retry attempts.
	// Default: 1 second.
	RetryInterval *time.Duration `yaml:"retry_interval"`

	// Replace indicates whether the job should replace an existing job
	// with the same key.
	// Default: false.
	Replace *bool `yaml:"replace"`

	Location *string `yaml:"location"`
	// contains filtered or unexported fields
}

type JobExecutor interface {
	Name() string
	Exec(ctx context.Context, name string, metadata *JobMetadata) result.Result[[]byte]
}

type JobFunc func(ctx context.Context, name string, metadata *JobMetadata) result.Result[[]byte]

type JobManager interface {
	CreateJob(spec JobSpec) result.Error
	PatchJob(name string, config *JobConfig) result.Error
	PauseJob(name string) result.Error
	ResumeJob(name string) result.Error
	DeleteJob(name string) result.Error
	ReloadJob(name string) result.Error
	ListJobs() []*Job
	GetJob(name string) result.Result[*Job]
}

type JobMetadata struct {
	Name          string
	Timeout       time.Duration
	MaxRetries    int
	RetryInterval time.Duration
	Replace       bool
	Location      string

	NextExecTime int64
	ExecTime     int64
}

type JobRegister interface {
	RegisterSchedulerJob(reg JobRegistry)
}

type JobRegistry interface {
	Once(name string, delay time.Duration, fn JobFunc) result.Error
	Every(name string, dur time.Duration, fn JobFunc) result.Error
	Cron(name, expr string, fn JobFunc) result.Error
}

type JobSpec struct {
	Name     string
	Config   *JobConfig
	Executor string
	Once     *OnceJob
	Ticker   *TickerJob
	Cron     *CronJob
}

type JobsConfigLoader struct {
	Scheduler *Config `yaml:"scheduler"`
}

type OnceJob struct {
	Delay time.Duration
}

type Params struct {
	M         lifecycle.Lifecycle
	Log       log.Logger
	Configs   []*Config
	Routers   []JobRegister
	Metric    metrics.Metric
	Executors []JobExecutor
}

type ResponseParams struct {
	Service supervisor.Service
	Manager JobManager
}

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

type Status string

type TickerJob struct {
	Dur time.Duration
}