schedulecontroller

Documentation

Index

• Constants
• func SetupWithManager(mgr ctrl.Manager) error
• type ScheduleHandler
  • func NewScheduleHandler(config job.Config, schedule *k8upv1.Schedule, logger logr.Logger) *ScheduleHandler
  • func (s *ScheduleHandler) Handle(ctx context.Context) error
• type ScheduleReconciler
  • func (r *ScheduleReconciler) Deprovision(ctx context.Context, obj *k8upv1.Schedule) (controllerruntime.Result, error)
  • func (r *ScheduleReconciler) NewObject() *k8upv1.Schedule
  • func (r *ScheduleReconciler) NewObjectList() *k8upv1.ScheduleList
  • func (r *ScheduleReconciler) Provision(ctx context.Context, schedule *k8upv1.Schedule) (controllerruntime.Result, error)

Constants

const (
	ScheduleHourlyRandom   = "@hourly-random"
	ScheduleDailyRandom    = "@daily-random"
	ScheduleYearlyRandom   = "@yearly-random"
	ScheduleAnnuallyRandom = "@annually-random"
	ScheduleMonthlyRandom  = "@monthly-random"
	ScheduleWeeklyRandom   = "@weekly-random"
)

Functions

func SetupWithManager

func SetupWithManager(mgr ctrl.Manager) error

SetupWithManager configures the reconciler.

Types

type ScheduleHandler

type ScheduleHandler struct {
	Log logr.Logger
	job.Config
	// contains filtered or unexported fields
}

ScheduleHandler handles the reconciles for the schedules. Schedules are a special type of k8up objects as they will only trigger jobs indirectly.

func NewScheduleHandler

func NewScheduleHandler(config job.Config, schedule *k8upv1.Schedule, logger logr.Logger) *ScheduleHandler

NewScheduleHandler will return a new ScheduleHandler.

func (*ScheduleHandler) Handle

func (s *ScheduleHandler) Handle(ctx context.Context) error

Handle handles the schedule management. It's responsible for adding and removing the jobs from the internal cron library.

type ScheduleReconciler

type ScheduleReconciler struct {
	Kube client.Client
}

ScheduleReconciler reconciles a Schedule object

func (*ScheduleReconciler) Deprovision

func (r *ScheduleReconciler) Deprovision(ctx context.Context, obj *k8upv1.Schedule) (controllerruntime.Result, error)

func (*ScheduleReconciler) NewObject

func (r *ScheduleReconciler) NewObject() *k8upv1.Schedule

func (*ScheduleReconciler) NewObjectList

func (r *ScheduleReconciler) NewObjectList() *k8upv1.ScheduleList

func (*ScheduleReconciler) Provision

func (r *ScheduleReconciler) Provision(ctx context.Context, schedule *k8upv1.Schedule) (controllerruntime.Result, error)