network

Documentation

Index

• Constants
• type ConfigState
  • func NewConfigState(configStateCache configStateCacheReaderWriter, ns NSExecutor) ConfigState
  • func (c ConfigState) Run(nics []podNIC, discoverFunc func(*podNIC) error, ...) error
• type ConfigStateCache
  • func NewConfigStateCache(vmiUID string, cacheCreator cacheCreator) ConfigStateCache
  • func NewConfigStateCacheWithPodIfaceStateData(vmiUID string, cacheCreator cacheCreator, ...) ConfigStateCache
  • func (c *ConfigStateCache) Read(podInterfaceName string) (cache.PodIfaceState, error)
  • func (c *ConfigStateCache) Write(podInterfaceName string, state cache.PodIfaceState) error
• type NSExecutor
• type NetConf
  • func NewNetConf() *NetConf
  • func NewNetConfWithCustomFactory(nsFactory nsFactory, cacheCreator cacheCreator) *NetConf
  • func (c *NetConf) Setup(vmi *v1.VirtualMachineInstance, networks []v1.Network, launcherPid int, ...) error
  • func (c *NetConf) Teardown(vmi *v1.VirtualMachineInstance) error
• type NetStat
  • func NewNetStat() *NetStat
  • func NewNetStateWithCustomFactory(cacheCreator cacheCreator) *NetStat
  • func (c *NetStat) CachePodInterfaceVolatileData(vmi *v1.VirtualMachineInstance, ifaceName string, ...)
  • func (c *NetStat) PodInterfaceVolatileDataIsCached(vmi *v1.VirtualMachineInstance, ifaceName string) bool
  • func (c *NetStat) Teardown(vmi *v1.VirtualMachineInstance)
  • func (c *NetStat) UpdateStatus(vmi *v1.VirtualMachineInstance, domain *api.Domain) error
• type VMNetworkConfigurator
  • func NewVMNetworkConfigurator(vmi *v1.VirtualMachineInstance, cacheCreator cacheCreator) *VMNetworkConfigurator
  • func (n *VMNetworkConfigurator) SetupPodNetworkPhase1(launcherPID int, networks []v1.Network, configState ConfigState) error
  • func (n *VMNetworkConfigurator) SetupPodNetworkPhase2(domain *api.Domain, networks []v1.Network) error

Constants

const (
	DefaultInterfaceQueueCount = 1
	UnknownInterfaceQueueCount = 0
)

Types

type ConfigState

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

func NewConfigState

func NewConfigState(configStateCache configStateCacheReaderWriter, ns NSExecutor) ConfigState

func (ConfigState) Run

func (c ConfigState) Run(nics []podNIC, discoverFunc func(*podNIC) error, configFunc func(*podNIC) error) error

Run passes through the state machine flow, executing the following steps: - Discover the current pod network configuration status and persist some of it for future use. - Configure the pod network.

The discovery step can be executed repeatedly with no limitation. The configuration step is allowed to run only once. Any attempt to run it again will cause a critical error.

type ConfigStateCache

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

func NewConfigStateCache

func NewConfigStateCache(vmiUID string, cacheCreator cacheCreator) ConfigStateCache

func NewConfigStateCacheWithPodIfaceStateData

func NewConfigStateCacheWithPodIfaceStateData(vmiUID string, cacheCreator cacheCreator, volatilePodIfaceState map[string]cache.PodIfaceState) ConfigStateCache

func (*ConfigStateCache) Read

func (c *ConfigStateCache) Read(podInterfaceName string) (cache.PodIfaceState, error)

func (*ConfigStateCache) Write

func (c *ConfigStateCache) Write(podInterfaceName string, state cache.PodIfaceState) error

type NSExecutor

type NSExecutor interface {
	Do(func() error) error
}

type NetConf

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

func NewNetConf

func NewNetConf() *NetConf

func NewNetConfWithCustomFactory

func NewNetConfWithCustomFactory(nsFactory nsFactory, cacheCreator cacheCreator) *NetConf

func (*NetConf) Setup

func (c *NetConf) Setup(vmi *v1.VirtualMachineInstance, networks []v1.Network, launcherPid int, preSetup func() error) error

Setup applies (privilege) network related changes for an existing virt-launcher pod.

func (*NetConf) Teardown

func (c *NetConf) Teardown(vmi *v1.VirtualMachineInstance) error

type NetStat

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

func NewNetStat

func NewNetStat() *NetStat

func NewNetStateWithCustomFactory

func NewNetStateWithCustomFactory(cacheCreator cacheCreator) *NetStat

func (*NetStat) CachePodInterfaceVolatileData

func (c *NetStat) CachePodInterfaceVolatileData(vmi *v1.VirtualMachineInstance, ifaceName string, data *cache.PodIfaceCacheData)

func (*NetStat) PodInterfaceVolatileDataIsCached

func (c *NetStat) PodInterfaceVolatileDataIsCached(vmi *v1.VirtualMachineInstance, ifaceName string) bool

func (*NetStat) Teardown

func (c *NetStat) Teardown(vmi *v1.VirtualMachineInstance)

func (*NetStat) UpdateStatus

func (c *NetStat) UpdateStatus(vmi *v1.VirtualMachineInstance, domain *api.Domain) error

UpdateStatus calculates the vmi.Status.Interfaces based on the following data sets:

• Pod interface cache: interfaces data (IP/s) collected from the cache (which was populated during the network setup).
• domain.Spec: interfaces configuration as seen by the (libvirt) domain.
• domain.Status.Interfaces: interfaces reported by the guest agent (empty if Qemu agent not running).
• Multus status: Interfaces reported by multus on the pod annotation. The virt-controller updates the VMI interfaces status my setting the infoSource field.

Podnet nic has to be the first one in vmi.Status.Interfaces list to match vmi crd wide columns definition

type VMNetworkConfigurator

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

func NewVMNetworkConfigurator

func NewVMNetworkConfigurator(vmi *v1.VirtualMachineInstance, cacheCreator cacheCreator) *VMNetworkConfigurator

func (*VMNetworkConfigurator) SetupPodNetworkPhase1

func (n *VMNetworkConfigurator) SetupPodNetworkPhase1(launcherPID int, networks []v1.Network, configState ConfigState) error

func (*VMNetworkConfigurator) SetupPodNetworkPhase2

func (n *VMNetworkConfigurator) SetupPodNetworkPhase2(domain *api.Domain, networks []v1.Network) error