ovn

Documentation

Index

• Constants
• func CreateManagementPort(nodeName, localSubnet, clusterSubnet, clusterServicesSubnet string) error
• type Controller
  • func NewOvnController(kubeClient kubernetes.Interface, wf *factory.WatchFactory, nodePortEnable bool) *Controller
  • func (ovn *Controller) AddEndpoints(ep *kapi.Endpoints) error
  • func (oc *Controller) AddLogicalPortWithIP(pod *kapi.Pod)
  • func (oc *Controller) AddNamespace(ns *kapi.Namespace)
  • func (oc *Controller) AddNetworkPolicy(policy *knet.NetworkPolicy)
  • func (oc *Controller) Run() error
  • func (oc *Controller) WatchEndpoints() error
  • func (oc *Controller) WatchNamespaces() error
  • func (oc *Controller) WatchNetworkPolicy() error
  • func (oc *Controller) WatchPods() error
  • func (oc *Controller) WatchServices() error

Constants

const (
	// TCP is the constant string for the string "TCP"
	TCP = "TCP"

	// UDP is the constant string for the string "UDP"
	UDP = "UDP"
)

Functions

func CreateManagementPort

func CreateManagementPort(nodeName, localSubnet, clusterSubnet,
	clusterServicesSubnet string) error

CreateManagementPort creates a logical switch for the node and connect it to the distributed router. This switch will start with one logical port (A OVS internal interface). 1. This logical port is via which a node can access all other nodes and the containers running inside them using the private IP addresses. 2. When this port is created on the master node, the K8s daemons become reachable from the containers without any NAT. 3. The nodes can health-check the pod IP addresses.

Types

type Controller

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

Controller structure is the object which holds the controls for starting and reacting upon the watched resources (e.g. pods, endpoints)

func NewOvnController

func NewOvnController(kubeClient kubernetes.Interface, wf *factory.WatchFactory, nodePortEnable bool) *Controller

NewOvnController creates a new OVN controller for creating logical network infrastructure and policy

func (*Controller) AddEndpoints

func (ovn *Controller) AddEndpoints(ep *kapi.Endpoints) error

AddEndpoints adds endpoints and creates corresponding resources in OVN

func (*Controller) AddLogicalPortWithIP

func (oc *Controller) AddLogicalPortWithIP(pod *kapi.Pod)

AddLogicalPortWithIP add logical port with static ip address and mac adddress for the pod

func (*Controller) AddNamespace

func (oc *Controller) AddNamespace(ns *kapi.Namespace)

AddNamespace creates corresponding addressset in ovn db

func (*Controller) AddNetworkPolicy

func (oc *Controller) AddNetworkPolicy(policy *knet.NetworkPolicy)

AddNetworkPolicy adds network policy and create corresponding acl rules

func (*Controller) Run

func (oc *Controller) Run() error

Run starts the actual watching. Also initializes any local structures needed.

func (*Controller) WatchEndpoints

func (oc *Controller) WatchEndpoints() error

WatchEndpoints starts the watching of Endpoint resource and calls back the appropriate handler logic

func (*Controller) WatchNamespaces

func (oc *Controller) WatchNamespaces() error

WatchNamespaces starts the watching of namespace resource and calls back the appropriate handler logic

func (*Controller) WatchNetworkPolicy

func (oc *Controller) WatchNetworkPolicy() error

WatchNetworkPolicy starts the watching of network policy resource and calls back the appropriate handler logic

func (*Controller) WatchPods

func (oc *Controller) WatchPods() error

WatchPods starts the watching of Pod resource and calls back the appropriate handler logic

func (*Controller) WatchServices

func (oc *Controller) WatchServices() error

WatchServices starts the watching of Service resource and calls back the appropriate handler logic