schedule

Documentation

Index

• type DeletionAction
  • func (a DeletionAction) Run(kubeClient client.Client, job gocron.Job) error
• type ThrottleAction
  • func (a *ThrottleAction) Run(kubeClient client.Client, job gocron.Job) error
• type ThrottleRevertAction
  • func (a ThrottleRevertAction) Run(kubeClient client.Client) error

Types

type DeletionAction

type DeletionAction struct {
	Log      logr.Logger
	Selector v1.Selector
	DryRun   bool
	Timeout  time.Duration

	ReferenceDeletionRule *v1.DeletionRule
	// contains filtered or unexported fields
}

func (DeletionAction) Run

func (a DeletionAction) Run(kubeClient client.Client, job gocron.Job) error

type ThrottleAction

type ThrottleAction struct {
	Log               logr.Logger
	Selector          karbonitev1.Selector
	DesiredReplicas   int
	DryRun            bool
	ReentrantSchedule string
	Timeout           time.Duration

	ReferenceThrottlingRule *karbonitev1.ThrottlingRule

	CronScheduler *gocron.Scheduler
	// contains filtered or unexported fields
}

func (*ThrottleAction) Run

func (a *ThrottleAction) Run(kubeClient client.Client, job gocron.Job) error

type ThrottleRevertAction

type ThrottleRevertAction struct {
	Log                logr.Logger
	Timeout            time.Duration
	SourceThrottleRule *karbonitev1.ThrottlingRule
	AffectedResources  []karbonitev1.AffectedResource
}

func (ThrottleRevertAction) Run

func (a ThrottleRevertAction) Run(kubeClient client.Client) error