ovn

package
v0.3.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 20, 2018 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

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

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

Variables

This section is empty.

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 added in v0.2.0

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 added in v0.3.0

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

AddEndpoints adds endpoints and creates corresponding resources in OVN

func (*Controller) AddLogicalPortWithIP added in v0.3.0

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

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

func (*Controller) AddNamespace added in v0.3.0

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

AddNamespace creates corresponding addressset in ovn db

func (*Controller) AddNetworkPolicy added in v0.3.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL