pool_manager

Documentation

Index

• Constants
• func GetMacPoolSize(rangeStart, rangeEnd net.HardwareAddr) (int64, error)
• type AllocationStatus
• type PoolManager
  • func NewPoolManager(kubeClient kubernetes.Interface, rangeStart, rangeEnd net.HardwareAddr, ...) (*PoolManager, error)
  • func (p *PoolManager) AddMacToWaitingConfig(allocations map[string]string) error
  • func (p *PoolManager) AllocatePodMac(pod *corev1.Pod) error
  • func (p *PoolManager) AllocateVirtualMachineMac(virtualMachine *kubevirt.VirtualMachine) error
  • func (p *PoolManager) InitMaps() error
  • func (p *PoolManager) IsKubevirtEnabled() bool
  • func (p *PoolManager) IsPodInstanceOptedIn(namespaceName string) (bool, error)
  • func (p *PoolManager) IsVmInstanceOptedIn(namespaceName string) (bool, error)
  • func (p *PoolManager) MarkVMAsReady(vm *kubevirt.VirtualMachine, parentLogger logr.Logger) error
  • func (p *PoolManager) ReleasePodMac(podName string) error
  • func (p *PoolManager) ReleaseVirtualMachineMac(vm *kubevirt.VirtualMachine, 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"
)

Functions

func GetMacPoolSize

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

Types

type AllocationStatus

type AllocationStatus string

const (
	AllocationStatusAllocated     AllocationStatus = "Allocated"
	AllocationStatusWaitingForPod AllocationStatus = "WaitingForPod"
)

type PoolManager

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

func NewPoolManager

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

func (*PoolManager) AddMacToWaitingConfig

func (p *PoolManager) AddMacToWaitingConfig(allocations map[string]string) error

Add all the allocated mac addresses to the waiting config map with the current time.

func (*PoolManager) AllocatePodMac

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

func (*PoolManager) AllocateVirtualMachineMac

func (p *PoolManager) AllocateVirtualMachineMac(virtualMachine *kubevirt.VirtualMachine) error

func (*PoolManager) InitMaps

func (p *PoolManager) InitMaps() error

func (*PoolManager) IsKubevirtEnabled

func (p *PoolManager) IsKubevirtEnabled() bool

func (*PoolManager) IsPodInstanceOptedIn

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

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

func (*PoolManager) IsVmInstanceOptedIn

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

Checks if the namespace of a vm instance is opted in for kubemacpool

func (*PoolManager) MarkVMAsReady

func (p *PoolManager) MarkVMAsReady(vm *kubevirt.VirtualMachine, 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) ReleasePodMac

func (p *PoolManager) ReleasePodMac(podName string) error

func (*PoolManager) ReleaseVirtualMachineMac

func (p *PoolManager) ReleaseVirtualMachineMac(vm *kubevirt.VirtualMachine, parentLogger logr.Logger) error

func (*PoolManager) Start

func (p *PoolManager) Start() error

func (*PoolManager) UpdateMacAddressesForVirtualMachine

func (p *PoolManager) UpdateMacAddressesForVirtualMachine(previousVirtualMachine, virtualMachine *kubevirt.VirtualMachine) error