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 NewMacKey(macAddress string) macKey
• 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 NewMacKey

func NewMacKey(macAddress string) macKey

NewMacKey creates a macKey struct containing a mac string that can be used for different mac string format comparison. It uses net.ParseMAC function to parse the given macAddress and then stores its String() value. The given macAddress MUST have already been validated.

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