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(logger log.Logger, expr string) (Expr, Task, error)

JobCreator is the creator for creating {cron.Expr, cron.Task} tuple.

type JobCreators ¶

type JobCreators map[JobExpressionName]JobCreator

JobCreators holds JobCreator with its expression name.

type JobExpressionName ¶ added in v0.3.1

type JobExpressionName = string

JobExpressionName holds the name of the cron.Expr.

type Lock ¶

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

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

func (lk *Lock) Unlock(ctx context.Context) error

type Locker ¶

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

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

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

func (l *Locker) Lock(ctx context.Context, key string) (cron.Lock, 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 StartCorrecterOptions ¶ added in v0.3.1

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

type Task ¶

type Task = cron.Task

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