smallben

type Config struct {
	// SchedulerConfig configures the scheduler
	SchedulerConfig SchedulerConfig
	// Logger is the logger to use.
	Logger logr.Logger
}

type CronJob interface {
	Run(input CronJobInput)
}

type CronJobInput struct {
	// JobID is the ID of the current job.
	JobID int64
	// GroupID is the GroupID of the current job.
	GroupID int64
	// SuperGroupID is the SuperGroupID of the current job.
	SuperGroupID int64
	// CronExpression is the interval of execution, as specified on job creation.
	CronExpression string
	// OtherInputs contains the other inputs of the job.
	OtherInputs map[string]interface{}
}

type DeleteOptions struct {
	PauseResumeOptions
	// Paused specifies whether to delete paused
	// jobs or not (or do not care about it).
	Paused *bool
}

type Job struct {
	// ID is a unique ID identifying the rawJob object.
	// It is chosen by the user.
	ID int64
	// GroupID is the ID of the group this rawJob is inserted in.
	GroupID int64
	// SuperGroupID specifies the ID of the super group
	// where this group is contained in.
	SuperGroupID int64

	// CronExpression specifies the scheduling of the job.
	CronExpression string

	// Job is the real unit of work to be executed
	Job CronJob
	// JobInput is the additional input to pass to the inner Job.
	JobInput map[string]interface{}
	// contains filtered or unexported fields
}

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

type ListJobsOptions struct {
	// Paused controls the `paused` field.
	// If paused = true list all jobs that have been paused.
	// If paused = false list all jobs that have not been paused.
	// If paused = nil list all jobs no matter if they have been paused or not.
	Paused *bool
	// GroupIDs filters the jobs in the given Group ID.
	// if nil, it is ignored.
	// It makes ListJobs returning all the jobs whose GroupID
	// is in GroupIDs
	GroupIDs []int64
	// SuperGroupIDs filters the jobs by the given Super Group ID.
	// if nil, it is ignored.
	// It makes ListJobs returning all the jobs whose SuperGroupID
	// is in SuperGroupIDs
	SuperGroupIDs []int64
	// JobIDs filters the jobs by the given job ID.
	// This option logically overrides other options
	// since it is the most specific.
	JobIDs []int64
}

type PauseResumeOptions struct {
	// JobIDs specifies which jobs will be
	// paused or resumed.
	JobIDs []int64
	// GroupIDs specifies the group ids
	// whose jobs will be paused or resumed.
	GroupIDs []int64
	// SuperGroupIDs specifies the super group ids
	// whose jobs will be paused or resumed.
	SuperGroupIDs []int64
}

type RawJob struct {
	// ID is a unique ID identifying the rawJob object.
	// It is chosen by the user.
	ID int64 `gorm:"primaryKey,column:id"`
	// GroupID is the ID of the group this rawJob is inserted in.
	GroupID int64 `gorm:"column:group_id"`
	// SuperGroupID specifies the ID of the super group
	// where this group is contained in.
	SuperGroupID int64 `gorm:"column:super_group_id"`
	// CronID is the ID of the cron rawJob as assigned by the scheduler
	// internally.
	CronID int64 `gorm:"column:cron_id"`
	// CronExpression specifies the scheduling of the job.
	CronExpression string `gorm:"column:cron_expression"`
	// Paused specifies whether this rawJob has been paused.
	Paused bool `gorm:"column:paused"`
	// CreatedAt specifies when this rawJob has been created.
	CreatedAt time.Time `gorm:"column:created_at"`
	// UpdatedAt specifies the last time this object has been updated,
	// i.e., paused/resumed/schedule updated.
	UpdatedAt time.Time `gorm:"column:updated_at"`
	// SerializedJob is the base64(gob-encoded byte array)
	// of the interface executing this rawJob
	SerializedJob string `gorm:"column:serialized_job"`
	// SerializedJobInput is the base64(gob-encoded byte array)
	// of the map containing the argument for the job.
	SerializedJobInput string `gorm:"column:serialized_job_input"`
}

type Repository interface {
	// AddJobs adds `jobs` to the backend. This operation
	// must be atomic.
	AddJobs(jobs []JobWithSchedule) error
	// GetJob returns the job whose ID is `jobID`, returning
	// an error in case the required job has not been found.
	// That error must be of the type returned by ErrorTypeIfMismatchCount().
	GetJob(jobID int64) (JobWithSchedule, error)
	// PauseJobs pause `jobs`, i.e., marks them as paused.
	// This operation must be atomic.
	//
	// It must return an error of type ErrorTypeIfMismatchCount() in case
	// the number of updated jobs is different than the number
	// of required jobs, i.e., `len(jobs)`.
	// It should update all the jobs it can, i.e., not stopping
	// at the first ID not found.
	PauseJobs(jobs []RawJob) error
	// ResumeJobs resumes `jobs`, i.e., marks them as non-paused.
	// This operation must be atomic.
	//
	// It must return an error of type ErrorTypeIfMismatchCount() in case
	// the number of updated jobs is different than the number
	// of required jobs, i.e., `len(jobs)`.
	// It should update all the jobs it can, i.e., not stopping
	// at the first ID not found.
	ResumeJobs(jobs []JobWithSchedule) error
	// GetAllJobsToExecute returns all jobs the scheduler
	// should execute on startup, i.e., all jobs whose `paused` field
	// is set to `false`.
	GetAllJobsToExecute() ([]JobWithSchedule, error)
	// GetJobsByIds returns an array of jobs whose id is in `jobsID`.
	//
	// It must return an error of type ErrorTypeIfMismatchCount() in case
	// the number of returned jobs is different than the number
	// of required jobs, i.e., `len(jobsID)`.
	GetJobsByIds(jobsID []int64) ([]JobWithSchedule, error)
	// DeleteJobsByIds deletes all the jobs whose id is in `jobsID`.
	//
	// It must return an error of type ErrorTypeIfMismatchCount() in case
	// the number of deleted jobs is different than the number
	// of required jobs, i.e., `len(jobsID)`.
	DeleteJobsByIds(jobsID []int64) error
	// SetCronId updates the `cron_id` field of `jobs`.
	//
	// It must return an error of type ErrorTypeIfMismatchCount() in case
	// the number of updated jobs is different than the number
	// of required jobs, i.e., `len(jobs)`.
	SetCronId(jobs []JobWithSchedule) error
	// SetCronIdAndChangeSchedule updates the `cron_id`, `cron_expression`
	// and `job_input` fields of RawJob.
	//
	// It must return an error of type ErrorType() in case
	// the number of updated jobs is different than the number
	// of required jobs, i.e., `len(jobs)`.
	SetCronIdAndChangeScheduleAndJobInput(jobs []JobWithSchedule) error
	// ListJobs list all the jobs present in the job storage backend,
	// according to `options`.
	//
	// If options is `nil`, no filtering is applied.
	ListJobs(options ToListOptions) ([]RawJob, error)
	// ErrorTypeIfMismatchCount specifies the error type
	// to return in case there is a mismatch count
	// between the number of jobs involved in a backend operation
	// and the number of supposed jobs that should have been involved
	// in such an operation.
	ErrorTypeIfMismatchCount() error
}

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

type RepositoryGormConfig struct {
	// Dialector is the dialector to use to connect to the database
	Dialector gorm.Dialector
	// Config is the configuration to use to connect to the database.
	Config gorm.Config
}

type SchedulerConfig struct {
	// DelayIfStillRunning delays a job starting
	// if that job has not finished yet.
	// Equivalent to attaching: https://pkg.go.dev/github.com/robfig/cron/v3#DelayIfStillRunning
	DelayIfStillRunning bool
	// SkipIfStillRunning skips a job starting
	// if that job has not finished yet.
	// Equivalent to attaching: https://pkg.go.dev/github.com/robfig/cron/v3#SkipIfStillRunning
	SkipIfStillRunning bool
	// WithSeconds enable seconds-grained scheduling.
	// Equivalent to: https://pkg.go.dev/github.com/robfig/cron/v3#WithSeconds
	WithSeconds bool
	// WithLocation sets the location for the scheduler.
	// Equivalent to: https://pkg.go.dev/github.com/robfig/cron/v3#WithLocation
	WithLocation *time.Location
	// contains filtered or unexported fields
}

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

type ToListOptions interface {
	// contains filtered or unexported methods
}

type UpdateOption struct {
	// JobID is the ID of the Job to update.
	JobID int64
	// CronExpression is the new schedule of the Job.
	// If nil, it is ignored, i.e., the schedule
	// is not changed.
	CronExpression *string
	// JobOtherInputs is the new OtherInputs of the Job.
	// If nil, it is ignored, i.e.,
	// the Job input is not changed.
	JobOtherInputs *map[string]interface{}
}