disruptionbudget

Documentation

Index

• Constants
• type DisruptionBudgetController
  • func NewDisruptionBudgetController(vmiInformer cache.SharedIndexInformer, pdbInformer cache.SharedIndexInformer, ...) (*DisruptionBudgetController, error)
  • func (c *DisruptionBudgetController) Execute() bool
  • func (c *DisruptionBudgetController) Run(threadiness int, stopCh <-chan struct{})

Constants

const (
	// FailedCreatePodDisruptionBudgetReason is added in an event if creating a PodDisruptionBudget failed.
	FailedCreatePodDisruptionBudgetReason = "FailedCreate"
	// SuccessfulCreatePodDisruptionBudgetReason is added in an event if creating a PodDisruptionBudget succeeded.
	SuccessfulCreatePodDisruptionBudgetReason = "SuccessfulCreate"
	// FailedDeletePodDisruptionBudgetReason is added in an event if deleting a PodDisruptionBudget failed.
	FailedDeletePodDisruptionBudgetReason = "FailedDelete"
	// SuccessfulDeletePodDisruptionBudgetReason is added in an event if deleting a PodDisruptionBudget succeeded.
	SuccessfulDeletePodDisruptionBudgetReason = "SuccessfulDelete"
	// FailedUpdatePodDisruptionBudgetReason is added in an event if updating a PodDisruptionBudget failed.
	FailedUpdatePodDisruptionBudgetReason = "FailedUpdate"
	// SuccessfulUpdatePodDisruptionBudgetReason is added in an event if updating a PodDisruptionBudget succeeded.
	SuccessfulUpdatePodDisruptionBudgetReason = "SuccessfulUpdate"
)

Types

type DisruptionBudgetController

type DisruptionBudgetController struct {
	Queue workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

func NewDisruptionBudgetController

func NewDisruptionBudgetController(
	vmiInformer cache.SharedIndexInformer,
	pdbInformer cache.SharedIndexInformer,
	podInformer cache.SharedIndexInformer,
	migrationInformer cache.SharedIndexInformer,
	recorder record.EventRecorder,
	clientset kubecli.KubevirtClient,
	clusterConfig *virtconfig.ClusterConfig,
) (*DisruptionBudgetController, error)

func (*DisruptionBudgetController) Execute

func (c *DisruptionBudgetController) Execute() bool

func (*DisruptionBudgetController) Run

func (c *DisruptionBudgetController) Run(threadiness int, stopCh <-chan struct{})

Run runs the passed in NodeController.