cron

type Config struct {
	MaxConcurrentJobs  int  `mapstructure:"max_concurrent_jobs" json:"max_concurrent_jobs,omitempty" bson:"max_concurrent_jobs,omitempty"`
	TagsUnique         bool `mapstructure:"tags_unique" json:"tags_unique,omitempty" bson:"tags_unique,omitempty"`
	WaitForScheduleAll bool `mapstructure:"wait_for_schedule_all" json:"wait_for_schedule_all,omitempty" bson:"wait_for_schedule_all,omitempty"`
	WaitForSchedule    bool `mapstructure:"wait_for_schedule" json:"wait_for_schedule,omitempty" bson:"wait_for_schedule,omitempty"`
}

type Configurer interface {
	Has(name string) bool
	UnmarshalKey(name string, out interface{}) error
}

type LockerConfig struct {
	// Tries can be used to set the number of times lock acquire is attempted.
	Tries *int `mapstructure:"tries" json:"tries,omitempty" bson:"tries,omitempty"`

	// DriftFactor can be used to set the clock drift factor.
	DriftFactor *float64 `mapstructure:"drift_factor" json:"drift_factor,omitempty" bson:"drift_factor,omitempty"`

	// TimeoutFactor can be used to set the timeout factor.
	TimeoutFactor *float64 `mapstructure:"timeout_factor" json:"timeout_factor,omitempty" bson:"timeout_factor,omitempty"`

	// Expiry can be used to set the expiry of a mutex to the given value.
	Expiry *time.Duration `mapstructure:"expiry" json:"expiry,omitempty" bson:"expiry,omitempty"`

	// RetryDelay can be used to set the amount of time to wait between retries.
	RetryDelay *time.Duration `mapstructure:"retry_delay" json:"retry_delay,omitempty" bson:"retry_delay,omitempty"`
}

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

type Logger interface {
	NamedLogger(name string) *slog.Logger
}

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

type RedisMaker interface {
	MakeRedis(name string) (redis.UniversalClient, error)
}

type Scheduler interface {
	WithDistributedLocker(locker gocron.Locker)

	StartAsync()
	Stop()
	IsRunning() bool

	Jobs() []*gocron.Job
	GetAllTags() []string

	Remove(jobFun interface{})
	RemoveByReference(job *gocron.Job)
	RemoveByTag(tag string) error
	RemoveByTags(tags ...string) error
	RemoveByTagsAny(tags ...string) error

	FindJobsByTag(tags ...string) ([]*gocron.Job, error)
	TaskPresent(jobFun interface{}) bool

	Clear()

	RegisterEventListeners(eventListeners ...gocron.EventListener)

	UpdateJob(job *gocron.Job) error
	AddTask(expression string, jobFun interface{}, name string, tags ...string) (*gocron.Job, error)
}

type Task interface {
	Expression() string
	Execute(job gocron.Job) error
}

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

type Tasks interface {
	Tasks() []interface{}
}

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