controller

package
v0.18.2-DeJeune Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2025 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BurstReplicas = 10
)
View Source 
const (
	VMProtectionFinalizer = "virtink.io/vm-protection"
)

Variables

This section is empty.

Functions

func MutateVM 

func MutateVM(ctx context.Context, vm *virtv1alpha1.VirtualMachine, oldVM *virtv1alpha1.VirtualMachine) error

func MutateVMReplicaSet 

func MutateVMReplicaSet(ctx context.Context, vmrs *virtv1alpha1.VirtualMachineReplicaSet, oldVMR *virtv1alpha1.VirtualMachineReplicaSet) error

func OwnerRef 

func OwnerRef(rs *virtv1alpha1.VirtualMachineReplicaSet) metav1.OwnerReference

func ValidateCIDR 

func ValidateCIDR(cidr string, capacity int, fieldPath *field.Path) field.ErrorList

func ValidateCPU 

func ValidateCPU(ctx context.Context, cpu *virtv1alpha1.CPU, fieldPath *field.Path) field.ErrorList

func ValidateCloudInitVolumeSource 

func ValidateCloudInitVolumeSource(ctx context.Context, source *virtv1alpha1.CloudInitVolumeSource, fieldPath *field.Path) field.ErrorList

func ValidateContainerDiskVolumeSource 

func ValidateContainerDiskVolumeSource(ctx context.Context, source *virtv1alpha1.ContainerDiskVolumeSource, fieldPath *field.Path) field.ErrorList

func ValidateContainerRootfsVolumeSource 

func ValidateContainerRootfsVolumeSource(ctx context.Context, source *virtv1alpha1.ContainerRootfsVolumeSource, fieldPath *field.Path) field.ErrorList

func ValidateDataVolumeSource 

func ValidateDataVolumeSource(ctx context.Context, source *virtv1alpha1.DataVolumeVolumeSource, fieldPath *field.Path) field.ErrorList

func ValidateDisk 

func ValidateDisk(ctx context.Context, disk *virtv1alpha1.Disk, fieldPath *field.Path) field.ErrorList

func ValidateFileSystem 

func ValidateFileSystem(ctx context.Context, fs *virtv1alpha1.FileSystem, fieldPath *field.Path) field.ErrorList

func ValidateInstance 

func ValidateInstance(ctx context.Context, instance *virtv1alpha1.Instance, fieldPath *field.Path) field.ErrorList

func ValidateInterface 

func ValidateInterface(ctx context.Context, iface *virtv1alpha1.Interface, fieldPath *field.Path) field.ErrorList

func ValidateInterfaceBindingMethod 

func ValidateInterfaceBindingMethod(ctx context.Context, bindingMethod *virtv1alpha1.InterfaceBindingMethod, fieldPath *field.Path) field.ErrorList

func ValidateKernel 

func ValidateKernel(ctx context.Context, kernel *virtv1alpha1.Kernel, fieldPath *field.Path) field.ErrorList

func ValidateMAC 

func ValidateMAC(mac string, fieldPath *field.Path) field.ErrorList

func ValidateMemory 

func ValidateMemory(ctx context.Context, memory *virtv1alpha1.Memory, fieldPath *field.Path) field.ErrorList

func ValidateMultusNetworkSource 

func ValidateMultusNetworkSource(ctx context.Context, source *virtv1alpha1.MultusNetworkSource, fieldPath *field.Path) field.ErrorList

func ValidateNetwork 

func ValidateNetwork(ctx context.Context, network *virtv1alpha1.Network, fieldPath *field.Path) field.ErrorList

func ValidateNetworkSource 

func ValidateNetworkSource(ctx context.Context, source *virtv1alpha1.NetworkSource, fieldPath *field.Path) field.ErrorList

func ValidatePersistentVolumeClaimSource 

func ValidatePersistentVolumeClaimSource(ctx context.Context, source *virtv1alpha1.PersistentVolumeClaimVolumeSource, fieldPath *field.Path) field.ErrorList

func ValidatePodNetworkSource 

func ValidatePodNetworkSource(ctx context.Context, source *virtv1alpha1.PodNetworkSource, fieldPath *field.Path) field.ErrorList

func ValidateVM 

func ValidateVM(ctx context.Context, vm *virtv1alpha1.VirtualMachine, oldVM *virtv1alpha1.VirtualMachine) field.ErrorList

func ValidateVMM 

func ValidateVMM(ctx context.Context, c client.Client, vmm *virtv1alpha1.VirtualMachineMigration, oldVMM *virtv1alpha1.VirtualMachineMigration) field.ErrorList

func ValidateVMMSpec 

func ValidateVMMSpec(ctx context.Context, c client.Client, namespace string, spec *virtv1alpha1.VirtualMachineMigrationSpec, fieldPath *field.Path) field.ErrorList

func ValidateVMName 

func ValidateVMName(ctx context.Context, c client.Client, namespace string, vmName string, fieldPath *field.Path) field.ErrorList

func ValidateVMReplicaSet 

func ValidateVMReplicaSet(ctx context.Context, vmrs *virtv1alpha1.VirtualMachineReplicaSet, oldVmrs *virtv1alpha1.VirtualMachineReplicaSet) field.ErrorList

func ValidateVMReplicaSetSpec 

func ValidateVMReplicaSetSpec(ctx context.Context, spec *virtv1alpha1.VirtualMachineReplicaSetSpec, fieldPath *field.Path) field.ErrorList

func ValidateVMReplicaSetUpdate 

func ValidateVMReplicaSetUpdate(ctx context.Context, vmrs *virtv1alpha1.VirtualMachineReplicaSet, oldVmrs *virtv1alpha1.VirtualMachineReplicaSet) field.ErrorList

func ValidateVMSpec 

func ValidateVMSpec(ctx context.Context, spec *virtv1alpha1.VirtualMachineSpec, fieldPath *field.Path) field.ErrorList

func ValidateVMUpdate 

func ValidateVMUpdate(ctx context.Context, vm *virtv1alpha1.VirtualMachine, oldVM *virtv1alpha1.VirtualMachine) field.ErrorList

func ValidateVolume 

func ValidateVolume(ctx context.Context, volume *virtv1alpha1.Volume, fieldPath *field.Path) field.ErrorList

func ValidateVolumeSource 

func ValidateVolumeSource(ctx context.Context, source *virtv1alpha1.VolumeSource, fieldPath *field.Path) field.ErrorList

Types

type VMMReconciler 

type VMMReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

func (*VMMReconciler) Reconcile 

func (r *VMMReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*VMMReconciler) SetupWithManager 

func (r *VMMReconciler) SetupWithManager(mgr ctrl.Manager) error

type VMMValidator 

type VMMValidator struct {
	client.Client
	// contains filtered or unexported fields
}

func (*VMMValidator) Handle 

func (h *VMMValidator) Handle(ctx context.Context, req admission.Request) admission.Response

func (*VMMValidator) SetupWebhookWithManager 

func (h *VMMValidator) SetupWebhookWithManager(mgr ctrl.Manager) error

type VMMutator 

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

func (*VMMutator) Handle 

func (h *VMMutator) Handle(ctx context.Context, req admission.Request) admission.Response

func (*VMMutator) SetupWebhookWithManager 

func (h *VMMutator) SetupWebhookWithManager(mgr ctrl.Manager) error

type VMReconciler 

type VMReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder

	PrerunnerImageName string
}

func (*VMReconciler) Reconcile 

func (r *VMReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*VMReconciler) SetupWithManager 

func (r *VMReconciler) SetupWithManager(mgr ctrl.Manager) error

type VMReplicaSetMutator 

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

func (*VMReplicaSetMutator) Handle 

func (h *VMReplicaSetMutator) Handle(ctx context.Context, req admission.Request) admission.Response

func (*VMReplicaSetMutator) SetupWebhookWithManager 

func (h *VMReplicaSetMutator) SetupWebhookWithManager(mgr ctrl.Manager) error

type VMReplicaSetReconciler 

type VMReplicaSetReconciler struct {
	client.Client
	Scheme       *runtime.Scheme
	Recorder     record.EventRecorder
	Expectations *expectations.UIDTrackingControllerExpectations
}

VMReplicaSetReconciler reconciles a VirtualMachineReplicaSet object

func (*VMReplicaSetReconciler) DeleteVM 

func (r *VMReplicaSetReconciler) DeleteVM(ctx context.Context, vm *virtv1alpha1.VirtualMachine, obj client.Object) error

func (*VMReplicaSetReconciler) Reconcile 

func (r *VMReplicaSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile handles the reconciliation loop for VMReplicaSet resources It ensures the desired state matches the actual state in the cluster

func (*VMReplicaSetReconciler) SetupWithManager 

func (r *VMReplicaSetReconciler) SetupWithManager(mgr ctrl.Manager) error

type VMReplicaSetValidator 

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

func (*VMReplicaSetValidator) Handle 

func (h *VMReplicaSetValidator) Handle(ctx context.Context, req admission.Request) admission.Response

func (*VMReplicaSetValidator) SetupWebhookWithManager 

func (h *VMReplicaSetValidator) SetupWebhookWithManager(mgr ctrl.Manager) error

type VMValidator 

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

func (*VMValidator) Handle 

func (h *VMValidator) Handle(ctx context.Context, req admission.Request) admission.Response

func (*VMValidator) SetupWebhookWithManager 

func (h *VMValidator) SetupWebhookWithManager(mgr ctrl.Manager) error

Source Files

View all Source files

Directories

Path Synopsis

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.