pod_interface

Documentation

Index

• func WriteProcSys(path, value string) error
• type LoopbackPodInterfaceDriver
  • func NewLoopbackPodInterfaceDriver(vpp *vpplink.VppLink, log *logrus.Entry) *LoopbackPodInterfaceDriver
  • func (i *LoopbackPodInterfaceDriver) CreateInterface(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack) (err error)
  • func (i *LoopbackPodInterfaceDriver) DeleteInterface(podSpec *storage.LocalPodSpec)
• type MemifPodInterfaceDriver
  • func NewMemifPodInterfaceDriver(vpp *vpplink.VppLink, log *logrus.Entry) *MemifPodInterfaceDriver
  • func (i *MemifPodInterfaceDriver) CreateInterface(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack, ...) (err error)
  • func (i *MemifPodInterfaceDriver) DeleteInterface(podSpec *storage.LocalPodSpec)
• type PodInterfaceDriverData
  • func (i *PodInterfaceDriverData) DoPodIfNatConfiguration(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack, swIfIndex uint32) (err error)
  • func (i *PodInterfaceDriverData) DoPodInterfaceConfiguration(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack, ...) (err error)
  • func (i *PodInterfaceDriverData) SpreadRxQueuesOnWorkers(swIfIndex uint32, numRxQueues int)
  • func (i *PodInterfaceDriverData) SpreadTxQueuesOnWorkers(swIfIndex uint32, numTxQueues int) (err error)
  • func (i *PodInterfaceDriverData) UndoPodIfNatConfiguration(swIfIndex uint32)
  • func (i *PodInterfaceDriverData) UndoPodInterfaceConfiguration(swIfIndex uint32)
• type TunTapPodInterfaceDriver
  • func NewTunTapPodInterfaceDriver(vpp *vpplink.VppLink, log *logrus.Entry) *TunTapPodInterfaceDriver
  • func (i *TunTapPodInterfaceDriver) CreateInterface(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack, ...) error
  • func (i *TunTapPodInterfaceDriver) DeleteInterface(podSpec *storage.LocalPodSpec)
  • func (i *TunTapPodInterfaceDriver) FelixConfigChanged(newFelixConfig *felixConfig.Config, ipipEncapRefCountDelta int, ...)
  • func (i *TunTapPodInterfaceDriver) SetFelixConfig(felixConfig *felixConfig.Config)
• type VclPodInterfaceDriver
  • func NewVclPodInterfaceDriver(vpp *vpplink.VppLink, log *logrus.Entry) *VclPodInterfaceDriver
  • func (i *VclPodInterfaceDriver) CreateInterface(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack) (err error)
  • func (i *VclPodInterfaceDriver) DeleteInterface(podSpec *storage.LocalPodSpec)
  • func (i *VclPodInterfaceDriver) Init() (err error)

Functions

func WriteProcSys

func WriteProcSys(path, value string) error

WriteProcSys takes the sysctl path and a string value to set i.e. "0" or "1" and sets the sysctl. This method was copied from cni-plugin/internal/pkg/utils/network_linux.go

Types

type LoopbackPodInterfaceDriver

type LoopbackPodInterfaceDriver struct {
	PodInterfaceDriverData
}

func NewLoopbackPodInterfaceDriver

func NewLoopbackPodInterfaceDriver(vpp *vpplink.VppLink, log *logrus.Entry) *LoopbackPodInterfaceDriver

func (*LoopbackPodInterfaceDriver) CreateInterface

func (i *LoopbackPodInterfaceDriver) CreateInterface(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack) (err error)

func (*LoopbackPodInterfaceDriver) DeleteInterface

func (i *LoopbackPodInterfaceDriver) DeleteInterface(podSpec *storage.LocalPodSpec)

type MemifPodInterfaceDriver

type MemifPodInterfaceDriver struct {
	PodInterfaceDriverData
}

func NewMemifPodInterfaceDriver

func NewMemifPodInterfaceDriver(vpp *vpplink.VppLink, log *logrus.Entry) *MemifPodInterfaceDriver

func (*MemifPodInterfaceDriver) CreateInterface

func (i *MemifPodInterfaceDriver) CreateInterface(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack, doHostSideConf bool) (err error)

func (*MemifPodInterfaceDriver) DeleteInterface

func (i *MemifPodInterfaceDriver) DeleteInterface(podSpec *storage.LocalPodSpec)

type PodInterfaceDriverData

type PodInterfaceDriverData struct {
	Name         string
	NDataThreads int
	// contains filtered or unexported fields
}

func (*PodInterfaceDriverData) DoPodIfNatConfiguration

func (i *PodInterfaceDriverData) DoPodIfNatConfiguration(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack, swIfIndex uint32) (err error)

func (*PodInterfaceDriverData) DoPodInterfaceConfiguration

func (i *PodInterfaceDriverData) DoPodInterfaceConfiguration(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack, ifSpec config.InterfaceSpec, swIfIndex uint32) (err error)

func (*PodInterfaceDriverData) SpreadRxQueuesOnWorkers

func (i *PodInterfaceDriverData) SpreadRxQueuesOnWorkers(swIfIndex uint32, numRxQueues int)

func (*PodInterfaceDriverData) SpreadTxQueuesOnWorkers

func (i *PodInterfaceDriverData) SpreadTxQueuesOnWorkers(swIfIndex uint32, numTxQueues int) (err error)

func (*PodInterfaceDriverData) UndoPodIfNatConfiguration

func (i *PodInterfaceDriverData) UndoPodIfNatConfiguration(swIfIndex uint32)

func (*PodInterfaceDriverData) UndoPodInterfaceConfiguration

func (i *PodInterfaceDriverData) UndoPodInterfaceConfiguration(swIfIndex uint32)

type TunTapPodInterfaceDriver

type TunTapPodInterfaceDriver struct {
	PodInterfaceDriverData
	// contains filtered or unexported fields
}

func NewTunTapPodInterfaceDriver

func NewTunTapPodInterfaceDriver(vpp *vpplink.VppLink, log *logrus.Entry) *TunTapPodInterfaceDriver

func (*TunTapPodInterfaceDriver) CreateInterface

func (i *TunTapPodInterfaceDriver) CreateInterface(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack, doHostSideConf bool) error

func (*TunTapPodInterfaceDriver) DeleteInterface

func (i *TunTapPodInterfaceDriver) DeleteInterface(podSpec *storage.LocalPodSpec)

func (*TunTapPodInterfaceDriver) FelixConfigChanged

func (i *TunTapPodInterfaceDriver) FelixConfigChanged(newFelixConfig *felixConfig.Config, ipipEncapRefCountDelta int, vxlanEncapRefCountDelta int, podSpecs map[string]storage.LocalPodSpec)

*

• This is called when the felix config or ippool encap refcount change,
• and update the linux mtu accordingly. *

func (*TunTapPodInterfaceDriver) SetFelixConfig

func (i *TunTapPodInterfaceDriver) SetFelixConfig(felixConfig *felixConfig.Config)

type VclPodInterfaceDriver

type VclPodInterfaceDriver struct {
	PodInterfaceDriverData
}

func NewVclPodInterfaceDriver

func NewVclPodInterfaceDriver(vpp *vpplink.VppLink, log *logrus.Entry) *VclPodInterfaceDriver

func (*VclPodInterfaceDriver) CreateInterface

func (i *VclPodInterfaceDriver) CreateInterface(podSpec *storage.LocalPodSpec, stack *vpplink.CleanupStack) (err error)

func (*VclPodInterfaceDriver) DeleteInterface

func (i *VclPodInterfaceDriver) DeleteInterface(podSpec *storage.LocalPodSpec)

func (*VclPodInterfaceDriver) Init

func (i *VclPodInterfaceDriver) Init() (err error)