cron

type Expr ¶

type Expr = cron.Expr

Expr holds the definition of cron expression.

func AwaitedExpr(raw string) Expr

func ImmediateExpr(raw string) Expr

type JobCreator ¶

type JobCreator func(ctx context.Context, name, expr string) (Expr, Task, error)

JobCreator is the creator for creating {cron.Expr, cron.Task} tuple, the life of given context.Context ends by this creation, do not use the long-term processing with this context.Context.

type JobCreators ¶

type JobCreators map[string]JobCreator

JobCreators holds JobCreator with its name.

type Lock ¶

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

Lock implement the cronjob go-co-op/gocron Lock interface.

func (l *Lock) Unlock(ctx context.Context) (err error)

type Locker ¶

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

Locker implement the cronjob go-co-op/gocron Locker interface.

func NewLocker(client *model.Client, options ...Option) *Locker

func (l *Locker) Lock(ctx context.Context, key string) (lock cron.Lock, err error)

type Option ¶

type Option func(*Locker)

Option is a function that configures a locker.

func WithExpiryInterval(expiry time.Duration) Option

func WithRenewConfig(renewInterval, maxExecuteDuration time.Duration) Option

type StartSyncerOptions ¶

type StartSyncerOptions struct {
	ModelClient model.ClientSet
	Interval    time.Duration
}

type Syncer ¶

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

func NewSyncer(mc model.ClientSet) *Syncer

func (in *Syncer) Sync(ctx context.Context) error

type Task ¶

type Task = cron.Task

Task defines the interface to hold the job executing main logic.