controllermanager

Documentation

Index

• type ControllerManager
  • func NewControllerManager(ovnClient *util.OVNClientset, wf *factory.WatchFactory, ...) (*ControllerManager, error)
  • func (cm *ControllerManager) CleanupStaleNetworks(validNetworks ...util.NetInfo) error
  • func (cm *ControllerManager) GetDefaultNetworkController() networkmanager.ReconcilableNetworkController
  • func (cm *ControllerManager) NewNetworkController(nInfo util.NetInfo) (networkmanager.NetworkController, error)
  • func (cm *ControllerManager) Start(ctx context.Context) error
  • func (cm *ControllerManager) Stop()
• type NodeControllerManager
  • func NewNodeControllerManager(ovnClient *util.OVNClientset, wf factory.NodeWatchFactory, name string, ...) (*NodeControllerManager, error)
  • func (ncm *NodeControllerManager) CleanupStaleNetworks(validNetworks ...util.NetInfo) error
  • func (ncm *NodeControllerManager) GetDefaultNetworkController() networkmanager.ReconcilableNetworkController
  • func (ncm *NodeControllerManager) NewNetworkController(nInfo util.NetInfo) (networkmanager.NetworkController, error)
  • func (ncm *NodeControllerManager) Start(ctx context.Context) (err error)
  • func (ncm *NodeControllerManager) Stop()

Types

type ControllerManager

type ControllerManager struct {

	// has SCTP support
	SCTPSupport bool
	// contains filtered or unexported fields
}

ControllerManager structure is the object manages all controllers

func NewControllerManager

func NewControllerManager(ovnClient *util.OVNClientset, wf *factory.WatchFactory,
	libovsdbOvnNBClient libovsdbclient.Client, libovsdbOvnSBClient libovsdbclient.Client,
	recorder record.EventRecorder, wg *sync.WaitGroup) (*ControllerManager, error)

NewControllerManager creates a new ovnkube controller manager to manage all the controller for all networks

func (*ControllerManager) CleanupStaleNetworks

func (cm *ControllerManager) CleanupStaleNetworks(validNetworks ...util.NetInfo) error

func (*ControllerManager) GetDefaultNetworkController

func (cm *ControllerManager) GetDefaultNetworkController() networkmanager.ReconcilableNetworkController

func (*ControllerManager) NewNetworkController

func (cm *ControllerManager) NewNetworkController(nInfo util.NetInfo) (networkmanager.NetworkController, error)

func (*ControllerManager) Start

func (cm *ControllerManager) Start(ctx context.Context) error

Start the ovnkube controller

func (*ControllerManager) Stop

func (cm *ControllerManager) Stop()

Stop gracefully stops all managed controllers

type NodeControllerManager

type NodeControllerManager struct {
	Kube kube.Interface
	// contains filtered or unexported fields
}

NodeControllerManager structure is the object manages all controllers for all networks for ovnkube-node

func NewNodeControllerManager

func NewNodeControllerManager(ovnClient *util.OVNClientset, wf factory.NodeWatchFactory, name string,
	wg *sync.WaitGroup, eventRecorder record.EventRecorder, routeManager *routemanager.Controller) (*NodeControllerManager, error)

NewNodeControllerManager creates a new OVN controller manager to manage all the controller for all networks

func (*NodeControllerManager) CleanupStaleNetworks

func (ncm *NodeControllerManager) CleanupStaleNetworks(validNetworks ...util.NetInfo) error

CleanupStaleNetworks cleans up all stale entities giving list of all existing secondary network controllers

func (*NodeControllerManager) GetDefaultNetworkController

func (ncm *NodeControllerManager) GetDefaultNetworkController() networkmanager.ReconcilableNetworkController

func (*NodeControllerManager) NewNetworkController

func (ncm *NodeControllerManager) NewNetworkController(nInfo util.NetInfo) (networkmanager.NetworkController, error)

NewNetworkController create secondary node network controllers for the given NetInfo

func (*NodeControllerManager) Start

func (ncm *NodeControllerManager) Start(ctx context.Context) (err error)

Start the node network controller manager

func (*NodeControllerManager) Stop

func (ncm *NodeControllerManager) Stop()

Stop gracefully stops all managed controllers