pool_manager

Documentation

Index

• Constants
• func CreateTransactionTimestamp() time.Time
• func GetMacPoolSize(rangeStart, rangeEnd net.HardwareAddr) (int64, error)
• func GetTransactionTimestampAnnotationFromVm(virtualMachine *kubevirt.VirtualMachine) (time.Time, error)
• func IsVirtualMachineDeletionInProgress(vm *kubevirt.VirtualMachine) bool
• func SetTransactionTimestampAnnotationToVm(virtualMachine *kubevirt.VirtualMachine, transactionTimestamp time.Time)
• func VmNamespaced(machine *kubevirt.VirtualMachine) string
• func VmNamespacedFromRequest(request *reconcile.Request) string
• type OptMode
• type PoolManager
  • func NewPoolManager(kubeClient, cachedKubeClient client.Client, ...) (*PoolManager, error)
  • func (p *PoolManager) AllocatePodMac(pod *corev1.Pod, isNotDryRun bool) error
  • func (p *PoolManager) AllocateVirtualMachineMac(virtualMachine *kubevirt.VirtualMachine, transactionTimestamp *time.Time, ...) error
  • func (p *PoolManager) InitMaps() error
  • func (p *PoolManager) IsKubevirtEnabled() bool
  • func (p *PoolManager) IsNamespaceManaged(namespaceName, webhookName string) (bool, error)
  • func (p *PoolManager) IsPodManaged(namespaceName string) (bool, error)
  • func (p *PoolManager) IsVirtualMachineManaged(namespaceName string) (bool, error)
  • func (p *PoolManager) MarkVMAsReady(vm *kubevirt.VirtualMachine, latestPersistedTransactionTimeStamp *time.Time, ...) error
  • func (p *PoolManager) ReleaseAllPodMacs(podFullName string) error
  • func (p *PoolManager) ReleaseAllVirtualMachineMacs(vmFullName string, parentLogger logr.Logger) error
  • func (p *PoolManager) Start() error
  • func (p *PoolManager) UpdateMacAddressesForVirtualMachine(previousVirtualMachine, virtualMachine *kubevirt.VirtualMachine, ...) error

Constants

const (
	RangeStartEnv              = "RANGE_START"
	RangeEndEnv                = "RANGE_END"
	RuntimeObjectFinalizerName = "k8s.v1.cni.cncf.io/kubeMacPool"
	NetworksAnnotation         = "k8s.v1.cni.cncf.io/networks"

	TransactionTimestampAnnotation = "kubemacpool.io/transaction-timestamp"
)

Functions

func CreateTransactionTimestamp

func CreateTransactionTimestamp() time.Time

func GetMacPoolSize

func GetMacPoolSize(rangeStart, rangeEnd net.HardwareAddr) (int64, error)

func GetTransactionTimestampAnnotationFromVm

func GetTransactionTimestampAnnotationFromVm(virtualMachine *kubevirt.VirtualMachine) (time.Time, error)

func IsVirtualMachineDeletionInProgress

func IsVirtualMachineDeletionInProgress(vm *kubevirt.VirtualMachine) bool

func SetTransactionTimestampAnnotationToVm

func SetTransactionTimestampAnnotationToVm(virtualMachine *kubevirt.VirtualMachine, transactionTimestamp time.Time)

func VmNamespaced

func VmNamespaced(machine *kubevirt.VirtualMachine) string

func VmNamespacedFromRequest

func VmNamespacedFromRequest(request *reconcile.Request) string

Types

type OptMode

type OptMode string

const (
	OptInMode  OptMode = "Opt-in"
	OptOutMode OptMode = "Opt-out"
)

type PoolManager

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

func NewPoolManager

func NewPoolManager(kubeClient, cachedKubeClient client.Client, rangeStart, rangeEnd net.HardwareAddr, managerNamespace string, kubevirtExist bool, waitTime int) (*PoolManager, error)

func (*PoolManager) AllocatePodMac

func (p *PoolManager) AllocatePodMac(pod *corev1.Pod, isNotDryRun bool) error

func (*PoolManager) AllocateVirtualMachineMac

func (p *PoolManager) AllocateVirtualMachineMac(virtualMachine *kubevirt.VirtualMachine, transactionTimestamp *time.Time, isNotDryRun bool, parentLogger logr.Logger) error

func (*PoolManager) InitMaps

func (p *PoolManager) InitMaps() error

func (*PoolManager) IsKubevirtEnabled

func (p *PoolManager) IsKubevirtEnabled() bool

func (*PoolManager) IsNamespaceManaged

func (p *PoolManager) IsNamespaceManaged(namespaceName, webhookName string) (bool, error)

IsNamespaceManaged checks if the namespace of the instance is managed by kubemacpool in terms of opt-mode

func (*PoolManager) IsPodManaged

func (p *PoolManager) IsPodManaged(namespaceName string) (bool, error)

IsPodManaged checks if the namespace of a pod instance is opted in for kubemacpool

func (*PoolManager) IsVirtualMachineManaged

func (p *PoolManager) IsVirtualMachineManaged(namespaceName string) (bool, error)

IsVirtualMachineManaged checks if the namespace of a VirtualMachine instance is managed by kubemacpool

func (*PoolManager) MarkVMAsReady

func (p *PoolManager) MarkVMAsReady(vm *kubevirt.VirtualMachine, latestPersistedTransactionTimeStamp *time.Time, parentLogger logr.Logger) error

Remove all the mac addresses from the waiting configmap this mean the vm was saved in the etcd and pass validations

func (*PoolManager) ReleaseAllPodMacs

func (p *PoolManager) ReleaseAllPodMacs(podFullName string) error

func (*PoolManager) ReleaseAllVirtualMachineMacs

func (p *PoolManager) ReleaseAllVirtualMachineMacs(vmFullName string, parentLogger logr.Logger) error

func (*PoolManager) Start

func (p *PoolManager) Start() error

func (*PoolManager) UpdateMacAddressesForVirtualMachine

func (p *PoolManager) UpdateMacAddressesForVirtualMachine(previousVirtualMachine, virtualMachine *kubevirt.VirtualMachine, transactionTimestamp *time.Time, isNotDryRun bool, parentLogger logr.Logger) error