multicluster

Documentation

Index

• type MCDefaultRouteController
  • func NewMCDefaultRouteController(mcClient mcclientset.Interface, gwInformer mcinformersv1alpha1.GatewayInformer, ...) *MCDefaultRouteController
  • func (c *MCDefaultRouteController) Run(stopCh <-chan struct{})
• type MCPodRouteController
  • func NewMCPodRouteController(k8sClient kubernetes.Interface, gwInformer v1alpha1.GatewayInformer, ...) *MCPodRouteController
  • func (c *MCPodRouteController) Run(stopCh <-chan struct{})
• type StretchedNetworkPolicyController
  • func NewMCAgentStretchedNetworkPolicyController(client openflow.Client, interfaceStore interfacestore.InterfaceStore, ...) *StretchedNetworkPolicyController
  • func (s *StretchedNetworkPolicyController) Run(stopCh <-chan struct{})

Types

type MCDefaultRouteController

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

MCDefaultRouteController 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 NewMCDefaultRouteController

func NewMCDefaultRouteController(
	mcClient mcclientset.Interface,
	gwInformer mcinformersv1alpha1.GatewayInformer,
	ciImportInformer mcinformersv1alpha1.ClusterInfoImportInformer,
	client openflow.Client,
	nodeConfig *config.NodeConfig,
	enableStretchedNetworkPolicy bool,
	enablePodToPodConnectivity bool,
) *MCDefaultRouteController

func (*MCDefaultRouteController) Run

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

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

type MCPodRouteController

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

MCPodRouteController generates L3 forwarding flows to forward cross-cluster traffic from MC Gateway to Pods on other Nodes inside a member cluster. It is required when networkPolicyOnly, noEncap or hybrid mode are configured, to forward the traffic through tunnels between Gateway and other Nodes, as otherwise the traffic will not go through tunnels in those modes.

func NewMCPodRouteController

func NewMCPodRouteController(
	k8sClient kubernetes.Interface,
	gwInformer v1alpha1.GatewayInformer,
	client openflow.Client,
	nodeConfig *config.NodeConfig,
) *MCPodRouteController

func (*MCPodRouteController) Run

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

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{})