scheduler

type Job struct {
	ID   cron.EntryID
	Name string
	Plan string

	Paused bool
	// contains filtered or unexported fields
}

type JobCreator interface {
	// Add a cron job
	Add(name string, plan string, handler interface{}) error
	// AddAndRunOnServerReady add a cron job, and trigger it immediately when server is ready
	AddAndRunOnServerReady(name string, plan string, handler interface{}) error

	// MustAdd add a cron job
	MustAdd(name string, plan string, handler interface{})
	// MustAddAndRunOnServerReady add a cron job, and trigger it immediately when server is ready
	MustAddAndRunOnServerReady(name string, plan string, handler interface{})
}

type JobHandler interface {
	Handle(resolver infra.Resolver) error
}

type LockManager interface {
	TryLock(ctx context.Context) error
	Release(ctx context.Context) error
}

type LockManagerBuilder func(name string) LockManager

type Option func(resolver infra.Resolver, cr Scheduler)

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

type Scheduler interface {
	JobCreator
	// Remove remove a cron job
	Remove(name string) error
	// Pause set job status to paused
	Pause(name string) error
	// Continue set job status to continue
	Continue(name string) error
	// Info get job info
	Info(name string) (Job, error)

	// Start cron manager
	Start()
	// Stop cron job manager
	Stop()

	LockManagerBuilder(builder LockManagerBuilder)
}