watch

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 8, 2024 License: Apache-2.0 Imports: 104 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	FailedUpdateVirtualMachineReason     = "FailedUpdate"
	SuccessfulUpdateVirtualMachineReason = "SuccessfulUpdate"
)
View Source 
const (
	FailedScaleOutReason        = "FailedScaleOut"
	FailedScaleInReason         = "FailedScaleIn"
	FailedUpdateReason          = "FailedUpdate"
	FailedRevisionPruningReason = "FailedRevisionPruning"

	SuccessfulPausedPoolReason = "SuccessfulPaused"
	SuccessfulResumePoolReason = "SuccessfulResume"
)
View Source 
const (
	// FailedCreateVirtualMachineReason is added in an event and in a replica set condition
	// when a virtual machine for a replica set is failed to be created.
	FailedCreateVirtualMachineReason = "FailedCreate"
	// SuccessfulCreateVirtualMachineReason is added in an event when a virtual machine for a replica set
	// is successfully created.
	SuccessfulCreateVirtualMachineReason = "SuccessfulCreate"
	// FailedDeleteVirtualMachineReason is added in an event and in a replica set condition
	// when a virtual machine for a replica set is failed to be deleted.
	FailedDeleteVirtualMachineReason = "FailedDelete"
	// SuccessfulDeleteVirtualMachineReason is added in an event when a virtual machine for a replica set
	// is successfully deleted.
	SuccessfulDeleteVirtualMachineReason = "SuccessfulDelete"
	// SuccessfulPausedReplicaSetReason is added in an event when the replica set discovered that it
	// should be paused. The event is triggered after it successfully managed to add the Paused Condition
	// to itself.
	SuccessfulPausedReplicaSetReason = "SuccessfulPaused"
	// SuccessfulResumedReplicaSetReason is added in an event when the replica set discovered that it
	// should be resumed. The event is triggered after it successfully managed to remove the Paused Condition
	// from itself.
	SuccessfulResumedReplicaSetReason = "SuccessfulResumed"
)

Reasons for replicaset events

View Source 
const (

	// UnauthorizedDataVolumeCreateReason is added in an event when the DataVolume
	// ServiceAccount doesn't have permission to create a DataVolume
	UnauthorizedDataVolumeCreateReason = "UnauthorizedDataVolumeCreate"
	// FailedDataVolumeCreateReason is added in an event when posting a dynamically
	// generated dataVolume to the cluster fails.
	FailedDataVolumeCreateReason = "FailedDataVolumeCreate"
	// SuccessfulDataVolumeCreateReason is added in an event when a dynamically generated
	// dataVolume is successfully created
	SuccessfulDataVolumeCreateReason = "SuccessfulDataVolumeCreate"
	// SourcePVCNotAvailabe is added in an event when the source PVC of a valid
	// clone Datavolume doesn't exist
	SourcePVCNotAvailabe = "SourcePVCNotAvailabe"
)

Repeating info / error messages

View Source 
const (
	HotPlugVolumeErrorReason           = "HotPlugVolumeError"
	HotPlugCPUErrorReason              = "HotPlugCPUError"
	MemoryDumpErrorReason              = "MemoryDumpError"
	FailedUpdateErrorReason            = "FailedUpdateError"
	FailedCreateReason                 = "FailedCreate"
	VMIFailedDeleteReason              = "FailedDelete"
	HotPlugNetworkInterfaceErrorReason = "HotPlugNetworkInterfaceError"
	AffinityChangeErrorReason          = "AffinityChangeError"
	HotPlugMemoryErrorReason           = "HotPlugMemoryError"
	VolumesUpdateErrorReason           = "VolumesUpdateError"
)
View Source 
const (
	// NodeUnresponsiveReason is in various places as reason to indicate that
	// an action was taken because virt-handler became unresponsive.
	NodeUnresponsiveReason = "NodeUnresponsive"
)

Variables

This section is empty.

Functions

func Execute 

func Execute()

func MatchPolicy added in v0.55.0 

func MatchPolicy(policyList *v1alpha1.MigrationPolicyList, vmi *k6tv1.VirtualMachineInstance, vmiNamespace *k8sv1.Namespace) *v1alpha1.MigrationPolicy

MatchPolicy returns the policy that is matched to the vmi, or nil of no policy is matched.

Since every policy can specify VMI and Namespace labels to match to, matching is done by returning the most detailed policy, meaning the policy that matches the VMI and specifies the most labels that matched either the VMI or its namespace labels.

If two policies are matched and have the same level of details (i.e. same number of matching labels) the matched policy is chosen by policies' names ordered by lexicographic order. The reason is to create a rather arbitrary yet deterministic way of matching policies.

func OwnerRef added in v0.1.0 

func OwnerRef(rs *virtv1.VirtualMachineInstanceReplicaSet) metav1.OwnerReference

Types

type CloneAuthFunc added in v0.20.0 

type CloneAuthFunc func(dv *cdiv1.DataVolume, requestNamespace, requestName string, proxy cdiv1.AuthorizationHelperProxy, saNamespace, saName string) (bool, string, error)

type MigrationController 

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

func NewMigrationController 

func NewMigrationController(templateService services.TemplateService,
	vmiInformer cache.SharedIndexInformer,
	podInformer cache.SharedIndexInformer,
	migrationInformer cache.SharedIndexInformer,
	nodeInformer cache.SharedIndexInformer,
	pvcInformer cache.SharedIndexInformer,
	pdbInformer cache.SharedIndexInformer,
	migrationPolicyInformer cache.SharedIndexInformer,
	resourceQuotaInformer cache.SharedIndexInformer,
	recorder record.EventRecorder,
	clientset kubecli.KubevirtClient,
	clusterConfig *virtconfig.ClusterConfig,
) (*MigrationController, error)

func (*MigrationController) Execute 

func (c *MigrationController) Execute() bool

func (*MigrationController) Run 

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

type NodeController added in v0.5.0 

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

NodeController is the main NodeController struct.

func NewNodeController added in v0.5.0 

func NewNodeController(clientset kubecli.KubevirtClient, nodeInformer cache.SharedIndexInformer, vmiInformer cache.SharedIndexInformer, recorder record.EventRecorder) (*NodeController, error)

NewNodeController creates a new instance of the NodeController struct.

func (*NodeController) Execute added in v0.5.0 

func (c *NodeController) Execute() bool

Execute runs commands from the controller queue, if there is an error it requeues the command. Returns false if the queue is empty.

func (*NodeController) Run added in v0.5.0 

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

Run runs the passed in NodeController.

type PoolController added in v0.49.0 

type PoolController struct {
	// contains filtered or unexported fields
}

PoolController is the main PoolController struct.

func NewPoolController added in v0.49.0 

func NewPoolController(clientset kubecli.KubevirtClient,
	vmiInformer cache.SharedIndexInformer,
	vmInformer cache.SharedIndexInformer,
	poolInformer cache.SharedIndexInformer,
	revisionInformer cache.SharedIndexInformer,
	recorder record.EventRecorder,
	burstReplicas uint) (*PoolController, error)

NewPoolController creates a new instance of the PoolController struct.

func (*PoolController) Execute added in v0.49.0 

func (c *PoolController) Execute() bool

Execute runs commands from the controller queue, if there is an error it requeues the command. Returns false if the queue is empty.

func (*PoolController) Run added in v0.49.0 

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

Run runs the passed in PoolController.

type VMController 

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

func NewVMController 

func NewVMController(vmiInformer cache.SharedIndexInformer,
	vmInformer cache.SharedIndexInformer,
	dataVolumeInformer cache.SharedIndexInformer,
	dataSourceInformer cache.SharedIndexInformer,
	namespaceStore cache.Store,
	pvcInformer cache.SharedIndexInformer,
	crInformer cache.SharedIndexInformer,
	podInformer cache.SharedIndexInformer,
	instancetypeMethods instancetype.Methods,
	recorder record.EventRecorder,
	clientset kubecli.KubevirtClient,
	clusterConfig *virtconfig.ClusterConfig) (*VMController, error)

func (*VMController) Execute 

func (c *VMController) Execute() bool

func (*VMController) Run 

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

func (*VMController) VMIAffinityPatch added in v1.1.0 

func (c *VMController) VMIAffinityPatch(vm *virtv1.VirtualMachine, vmi *virtv1.VirtualMachineInstance) error

func (*VMController) VMICPUsPatch added in v1.0.0 

func (c *VMController) VMICPUsPatch(vm *virtv1.VirtualMachine, vmi *virtv1.VirtualMachineInstance) error

func (*VMController) VMNodeSelectorPatch added in v1.1.0 

func (c *VMController) VMNodeSelectorPatch(vm *virtv1.VirtualMachine, vmi *virtv1.VirtualMachineInstance) error

type VMIController added in v0.6.1 

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

func NewVMIController added in v0.6.1 

func NewVMIController(templateService services.TemplateService,
	vmiInformer cache.SharedIndexInformer,
	vmInformer cache.SharedIndexInformer,
	podInformer cache.SharedIndexInformer,
	pvcInformer cache.SharedIndexInformer,
	storageClassInformer cache.SharedIndexInformer,
	recorder record.EventRecorder,
	clientset kubecli.KubevirtClient,
	dataVolumeInformer cache.SharedIndexInformer,
	storageProfileInformer cache.SharedIndexInformer,
	cdiInformer cache.SharedIndexInformer,
	cdiConfigInformer cache.SharedIndexInformer,
	clusterConfig *virtconfig.ClusterConfig,
	topologyHinter topology.Hinter,
) (*VMIController, error)

func (*VMIController) Execute added in v0.6.1 

func (c *VMIController) Execute() bool

func (*VMIController) Run added in v0.6.1 

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

type VMIReplicaSet added in v0.6.1 

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

func NewVMIReplicaSet added in v0.6.1 

func NewVMIReplicaSet(vmiInformer cache.SharedIndexInformer, vmiRSInformer cache.SharedIndexInformer, recorder record.EventRecorder, clientset kubecli.KubevirtClient, burstReplicas uint) (*VMIReplicaSet, error)

func (*VMIReplicaSet) Execute added in v0.6.1 

func (c *VMIReplicaSet) Execute() bool

func (*VMIReplicaSet) Run added in v0.6.1 

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

type VirtControllerApp 

type VirtControllerApp struct {
	service.ServiceListen

	LeaderElection leaderelectionconfig.Configuration
	// contains filtered or unexported fields
}

func (*VirtControllerApp) AddFlags added in v0.1.0 

func (vca *VirtControllerApp) AddFlags()

func (*VirtControllerApp) Run 

func (vca *VirtControllerApp) Run()

type VirtualMachineRevisionData added in v1.0.0 

type VirtualMachineRevisionData struct {
	Spec virtv1.VirtualMachineSpec `json:"spec"`
}

Follows the template used in createVMRevision for the Data.Raw value

Source Files

View all Source files

Directories

Path Synopsis
drain
disruptionbudget
evacuation

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.