multicluster

Documentation

Index

• type MCRouteController
  • func NewMCRouteController(mcClient mcclientset.Interface, gwInformer mcinformers.GatewayInformer, ...) *MCRouteController
  • func (c *MCRouteController) Run(stopCh <-chan struct{})
• type StretchedNetworkPolicyController
  • func NewMCAgentStretchedNetworkPolicyController(client openflow.Client, interfaceStore interfacestore.InterfaceStore, ...) *StretchedNetworkPolicyController
  • func (s *StretchedNetworkPolicyController) Run(stopCh <-chan struct{})

Types

type MCRouteController

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

MCRouteController watches Gateway and ClusterInfoImport events. It is responsible for setting up necessary Openflow entries for multi-cluster traffic on a Gateway or a regular Node.

func NewMCRouteController

func NewMCRouteController(
	mcClient mcclientset.Interface,
	gwInformer mcinformers.GatewayInformer,
	ciImportInformer mcinformers.ClusterInfoImportInformer,
	client openflow.Client,
	ovsBridgeClient ovsconfig.OVSBridgeClient,
	interfaceStore interfacestore.InterfaceStore,
	nodeConfig *config.NodeConfig,
	namespace string,
	enableStretchedNetworkPolicy bool,
) *MCRouteController

func (*MCRouteController) Run

func (c *MCRouteController) Run(stopCh <-chan struct{})

Run will create defaultWorkers workers (go routines) which will process the Gateway events from the workqueue.

type StretchedNetworkPolicyController

type StretchedNetworkPolicyController struct {
	LabelIdentityListerSynced cache.InformerSynced
	// contains filtered or unexported fields
}

StretchedNetworkPolicyController is used to update classifier flows of Pods. It will make sure the latest LabelIdentity of the Pod, if available, will be loaded into tun_id in the classifier flow of the Pod. If the LabelIdentity of the Pod is not available when updating, the UnknownLabelIdentity will be loaded. When the actual LabelIdentity is created, the classifier flow will be updated accordingly.

func NewMCAgentStretchedNetworkPolicyController

func NewMCAgentStretchedNetworkPolicyController(
	client openflow.Client,
	interfaceStore interfacestore.InterfaceStore,
	podInformer cache.SharedIndexInformer,
	namespaceInformer coreinformers.NamespaceInformer,
	labelIdentityInformer mcinformers.LabelIdentityInformer,
	podUpdateSubscriber channel.Subscriber,
) *StretchedNetworkPolicyController

func (*StretchedNetworkPolicyController) Run

func (s *StretchedNetworkPolicyController) Run(stopCh <-chan struct{})