evacuation

Documentation

Index

• Constants
• func GenerateNewMigration(vmiName string, key string) *virtv1.VirtualMachineInstanceMigration
• type EvacuationController
  • func NewEvacuationController(vmiInformer cache.SharedIndexInformer, ...) (*EvacuationController, error)
  • func (c *EvacuationController) Execute() bool
  • func (c *EvacuationController) Run(threadiness int, stopCh <-chan struct{})

Constants

const (
	// FailedCreateVirtualMachineInstanceMigrationReason is added in an event if creating a VirtualMachineInstanceMigration failed.
	FailedCreateVirtualMachineInstanceMigrationReason = "FailedCreate"
	// SuccessfulCreateVirtualMachineInstanceMigrationReason is added in an event if creating a VirtualMachineInstanceMigration succeeded.
	SuccessfulCreateVirtualMachineInstanceMigrationReason = "SuccessfulCreate"
)

Functions

func GenerateNewMigration

func GenerateNewMigration(vmiName string, key string) *virtv1.VirtualMachineInstanceMigration

Types

type EvacuationController

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

func NewEvacuationController

func NewEvacuationController(
	vmiInformer cache.SharedIndexInformer,
	migrationInformer cache.SharedIndexInformer,
	nodeInformer cache.SharedIndexInformer,
	vmiPodInformer cache.SharedIndexInformer,
	recorder record.EventRecorder,
	clientset kubecli.KubevirtClient,
	clusterConfig *virtconfig.ClusterConfig,
) (*EvacuationController, error)

func (*EvacuationController) Execute

func (c *EvacuationController) Execute() bool

func (*EvacuationController) Run

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

Run runs the passed in NodeController.