daemon

Documentation

Index

• Variables
• func BindDefaultDriver(pciAddr string) error
• func BindDpdkDriver(pciAddr, driver string) error
• func DiscoverSriovDevices() ([]sriovnetworkv1.InterfaceExt, error)
• func Unbind(pciAddr string) error
• type Daemon
  • func New(nodeName string, client snclientset.Interface, ...) *Daemon
  • func (dn *Daemon) Run() error
• type NodeStateStatusWriter
  • func NewNodeStateStatusWriter(c snclientset.Interface, n string) *NodeStateStatusWriter
  • func (nm *NodeStateStatusWriter) Run(stop <-chan struct{}, refresh <-chan struct{})

Variables

var DpdkDrivers = []string{"igb_uio", "vfio-pci", "uio_pci_generic"}

Functions

func BindDefaultDriver

func BindDefaultDriver(pciAddr string) error

BindDefaultDriver bind driver for one device Bind the device given by "pciAddr" to the default driver

func BindDpdkDriver

func BindDpdkDriver(pciAddr, driver string) error

BindDpdkDriver bind dpdk driver for one device Bind the device given by "pciAddr" to the driver "driver"

func DiscoverSriovDevices

func DiscoverSriovDevices() ([]sriovnetworkv1.InterfaceExt, error)

func Unbind

func Unbind(pciAddr string) error

Unbind unbind driver for one device

Types

type Daemon

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

func New

func New(
	nodeName string,
	client snclientset.Interface,
	kubeClient *kubernetes.Clientset,
	exitCh chan<- error,
	stopCh <-chan struct{},
	refreshCh chan<- struct{},
) *Daemon

func (*Daemon) Run

func (dn *Daemon) Run() error

type NodeStateStatusWriter

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

func NewNodeStateStatusWriter

func NewNodeStateStatusWriter(c snclientset.Interface, n string) *NodeStateStatusWriter

NewNodeStateStatusWriter Create a new NodeStateStatusWriter

func (*NodeStateStatusWriter) Run

func (nm *NodeStateStatusWriter) Run(stop <-chan struct{}, refresh <-chan struct{})

Run reads from the writer channel and sets the interface status. It will return if the stop channel is closed. Intended to be run via a goroutine.