clustermanager

Documentation

Index

• type ClusterManager
  • func NewClusterManager(ovnClient *util.OVNClusterManagerClientset, wf *factory.WatchFactory, ...) (*ClusterManager, error)
  • func (cm *ClusterManager) CleanupStaleNetworks(validNetworks ...util.NetInfo) error
  • func (cm *ClusterManager) GetDefaultNetworkController() networkmanager.ReconcilableNetworkController
  • func (cm *ClusterManager) NewNetworkController(netInfo util.NetInfo) (networkmanager.NetworkController, error)
  • func (cm *ClusterManager) Reconcile(name string, old, new util.NetInfo) error
  • func (cm *ClusterManager) Start(ctx context.Context) error
  • func (cm *ClusterManager) Stop()
• type NetworkStatusReporter

Types

type ClusterManager

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

ClusterManager structure is the object which manages the cluster nodes. It creates a default network controller for the default network and a secondary network cluster controller manager to manage the multi networks.

func NewClusterManager

func NewClusterManager(ovnClient *util.OVNClusterManagerClientset, wf *factory.WatchFactory,
	identity string, wg *sync.WaitGroup, recorder record.EventRecorder) (*ClusterManager, error)

NewClusterManager creates a new cluster manager to manage the cluster nodes.

func (*ClusterManager) CleanupStaleNetworks

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

func (*ClusterManager) GetDefaultNetworkController

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

func (*ClusterManager) NewNetworkController

func (cm *ClusterManager) NewNetworkController(netInfo util.NetInfo) (networkmanager.NetworkController, error)

func (*ClusterManager) Reconcile

func (cm *ClusterManager) Reconcile(name string, old, new util.NetInfo) error

func (*ClusterManager) Start

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

Start the cluster manager.

func (*ClusterManager) Stop

func (cm *ClusterManager) Stop()

Stop the cluster manager.

type NetworkStatusReporter

type NetworkStatusReporter func(networkName string, fieldManager string, condition *metav1.Condition, events ...*util.EventDetails) error