cnimgr

Documentation

Index

• type CNIManager
  • func New(defaultNetwork, networkDir string, pluginDirs ...string) (*CNIManager, error)
  • func (c *CNIManager) AddWatcher() chan bool
  • func (c *CNIManager) GC(ctx context.Context, validPodList PodNetworkLister) error
  • func (c *CNIManager) Plugin() ocicni.CNIPlugin
  • func (c *CNIManager) ReadyOrError() error
  • func (c *CNIManager) Shutdown()
• type PodNetworkLister

Types

type CNIManager

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

func New

func New(defaultNetwork, networkDir string, pluginDirs ...string) (*CNIManager, error)

func (*CNIManager) AddWatcher

func (c *CNIManager) AddWatcher() chan bool

Add watcher creates a new watcher for the CNI manager said watcher will send a `true` value if the CNI plugin was successfully ready or `false` if the server shutdown first.

func (*CNIManager) GC

func (c *CNIManager) GC(ctx context.Context, validPodList PodNetworkLister) error

GC calls the plugin's GC to clean up any resources concerned with stale pods (pod other than the ones provided by validPodList). The call to the plugin will be deferred until it is ready logging any errors then and returning nil error here.

func (*CNIManager) Plugin

func (c *CNIManager) Plugin() ocicni.CNIPlugin

Plugin returns the CNI plugin.

func (*CNIManager) ReadyOrError

func (c *CNIManager) ReadyOrError() error

ReadyOrError returns nil if the plugin is ready, or the last error that was received in checking.

func (*CNIManager) Shutdown

func (c *CNIManager) Shutdown()

Shutdown shuts down the CNI manager, and notifies the watcher that the CNI manager is not ready.

type PodNetworkLister

type PodNetworkLister func() ([]*ocicni.PodNetwork, error)