croncontroller

package

Go to main page

Versions in this module

v0

v0.3.0

Feb 13, 2025

v0.2.1

Dec 8, 2022

Changes in this version

type CronWorker

+ func (w *CronWorker) Init() error

v0.2.0

Jun 5, 2022

v0.1.0

Apr 29, 2022

Changes in this version

+ func ClockTickUntil(work func(), timestep time.Duration, stopCh <-chan struct{})

+ func JoinJobConfigKeyName(key string, ts time.Time) string

type Context

+ HasSynced []cache.InformerSynced

type CronWorker

+ func (w *CronWorker) Work()

+ type EnqueueHandler interface

+ EnqueueJobConfig func(jobConfig *execution.JobConfig, scheduleTime time.Time) error

+ type ExecutionControl struct

+ func NewExecutionControl(name string, client executionv1alpha1.ExecutionV1alpha1Interface, ...) *ExecutionControl

+ func (c *ExecutionControl) CreateJob(ctx context.Context, rjc *execution.JobConfig, rj *execution.Job) error

+ type ExecutionControlInterface interface

+ CreateJob func(ctx context.Context, rjc *execution.JobConfig, rj *execution.Job) error

type InformerWorker

+ func (w *InformerWorker) Init()

+ type Recorder interface

+ CreateJobFailed func(ctx context.Context, jobConfig *execution.JobConfig, job *execution.Job, ...)

+ CreatedJob func(ctx context.Context, jobConfig *execution.JobConfig, job *execution.Job)

+ SkippedJobSchedule func(ctx context.Context, jobConfig *execution.JobConfig, scheduleTime time.Time, ...)

+ type UpdateHandler interface

+ OnUpdate func(*execution.JobConfig)

+ func NewUpdateHandler(ctrlContext *Context) UpdateHandler

v0.0.1

Mar 27, 2022

Changes in this version

+ const CronWorkerInterval

+ var Clock clock.Clock = clock.RealClock

+ func CronTimerUntil(work func(), timestep time.Duration, stopCh <-chan struct{})

+ func IsScheduleEqual(orig, updated *execution.ScheduleSpec) (bool, error)

+ func JobConfigKeyFunc(config *execution.JobConfig, scheduleTime time.Time) (string, error)

+ func ParseUnix(unixString string) (time.Time, error)

+ func SplitJobConfigKeyName(key string) (name string, ts time.Time, err error)

+ type Context struct

+ func NewContext(context controllercontext.ContextInterface) *Context

+ type Controller struct

+ func NewController(ctrlContext controllercontext.ContextInterface, ...) (*Controller, error)

+ func (c *Controller) GetHealth() controllermanager.HealthStatus

+ func (c *Controller) Run(ctx context.Context) error

+ func (c *Controller) Shutdown(ctx context.Context)

+ type CronWorker struct

+ func NewCronWorker(ctrlContext *Context) *CronWorker

+ func (w *CronWorker) Start(stopCh <-chan struct{})

+ func (w *CronWorker) WorkerName() string

+ type Factory struct

+ func NewFactory() *Factory

+ func (f *Factory) Name() string

+ func (f *Factory) New(ctrlContext controllercontext.ContextInterface, ...) (controllermanager.Controller, error)

+ type InformerWorker struct

+ func NewInformerWorker(ctrlContext *Context) *InformerWorker

+ func (w *InformerWorker) WorkerName() string

+ type Reconciler struct

+ func NewReconciler(ctrlContext *Context, concurrency *configv1.Concurrency) *Reconciler

+ func (w *Reconciler) Concurrency() int

+ func (w *Reconciler) MaxRequeues() int

+ func (w *Reconciler) Name() string

+ func (w *Reconciler) SyncOne(ctx context.Context, namespace, name string, _ int) error

+ type Schedule struct

+ func NewSchedule(ctrlContext controllercontext.ContextInterface) *Schedule

+ func (w *Schedule) BumpNextScheduleTime(jobConfig *execution.JobConfig, fromTime time.Time, expr *cronexpr.Expression)

+ func (w *Schedule) FlushNextScheduleTime(jobConfig *execution.JobConfig)

+ func (w *Schedule) GetNextScheduleTime(jobConfig *execution.JobConfig, fromTime time.Time, expr *cronexpr.Expression) time.Time

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL