ovs

Documentation

Index

• Constants
• Variables
• func CleanLostInterface()
• func ClearPodBandwidth(podName, podNamespace string) error
• func PodNameToPortName(pod, namespace string) string
• func SetPodBandwidth(podName, podNamespace, ingress, egress string) error
• type Client
  • func NewClient(ovnNbHost string, ovnNbPort int, ovnSbHost string, ovnSbPort int, ...) *Client
  • func (c Client) AddStaticRouter(policy, cidr, nextHop, router string) error
  • func (c Client) CleanLogicalSwitchAcl(ls string) error
  • func (c Client) CreateAddressSet(asName string) error
  • func (c Client) CreateEgressACL(pgName, asEgressName, asExceptName string, npp []netv1.NetworkPolicyPort) error
  • func (c Client) CreateIngressACL(pgName, asIngressName, asExceptName string, npp []netv1.NetworkPolicyPort) error
  • func (c Client) CreateLoadBalancer(lb, protocol string) error
  • func (c Client) CreateLoadBalancerRule(lb, vip, ips string) error
  • func (c Client) CreateLogicalRouter(lr string) error
  • func (c Client) CreateLogicalSwitch(ls, subnet, gateway, excludeIps string) error
  • func (c Client) CreatePort(ls, port, ip, mac string) (*nic, error)
  • func (c Client) CreatePortGroup(pgName string) error
  • func (c Client) DeleteACL(pgName, direction string) error
  • func (c Client) DeleteAddressSet(asName string) error
  • func (c Client) DeleteLoadBalancerVip(vip, lb string) error
  • func (c Client) DeleteLogicalSwitch(ls string) error
  • func (c Client) DeletePort(port string) error
  • func (c Client) DeletePortGroup(pgName string) error
  • func (c Client) DeleteStaticRouter(cidr, router string) error
  • func (c Client) FindLoadbalancer(lb string) (string, error)
  • func (c Client) GetLoadBalancerVips(lb string) (map[string]string, error)
  • func (c Client) GetPortAddr(port string) ([]string, error)
  • func (c Client) ListLogicalRouter() ([]string, error)
  • func (c Client) ListLogicalSwitch() ([]string, error)
  • func (c Client) SetAddressesToAddressSet(addresses []string, as string) error
  • func (c Client) SetPortsToPortGroup(portGroup string, portNames []string) error
  • func (c Client) SetPrivateLogicalSwitch(ls string, allow []string) error

Constants

const (
	OvnNbCtl    = "ovn-nbctl"
	MayExist    = "--may-exist"
	IfExists    = "--if-exists"
	WaitSb      = "--wait=sb"
	Policy      = "--policy"
	PolicyDstIP = "dst-ip"
	PolicySrcIP = "src-ip"
)

Variables

var (
	ErrNoAddr   = errors.New("no address")
	ErrNotFound = errors.New("not found")
)

Functions

func CleanLostInterface

func CleanLostInterface()

CleanLostInterface will clean up related ovs port, interface and qos When reboot node, the ovs internal interface will be deleted.

func ClearPodBandwidth

func ClearPodBandwidth(podName, podNamespace string) error

ClearPodBandwidth remove qos related to this pod. Only used when remove pod.

func PodNameToPortName

func PodNameToPortName(pod, namespace string) string

PodNameToPortName return the ovn port name for a given pod

func SetPodBandwidth

func SetPodBandwidth(podName, podNamespace, ingress, egress string) error

SetPodBandwidth set ingress/egress qos for given pod

Types

type Client

type Client struct {
	OvnNbAddress           string
	OvnSbAddress           string
	ClusterRouter          string
	ClusterTcpLoadBalancer string
	ClusterUdpLoadBalancer string
	NodeSwitch             string
	NodeSwitchCIDR         string
}

Client is the ovn client

func NewClient

func NewClient(ovnNbHost string, ovnNbPort int, ovnSbHost string, ovnSbPort int, clusterRouter, clusterTcpLoadBalancer, clusterUdpLoadBalancer, nodeSwitch, nodeSwitchCIDR string) *Client

NewClient init an ovn client

func (Client) AddStaticRouter

func (c Client) AddStaticRouter(policy, cidr, nextHop, router string) error

AddStaticRouter add a static route rule in ovn

func (Client) CleanLogicalSwitchAcl

func (c Client) CleanLogicalSwitchAcl(ls string) error

CleanLogicalSwitchAcl clean acl of a switch

func (Client) CreateAddressSet

func (c Client) CreateAddressSet(asName string) error

func (Client) CreateEgressACL

func (c Client) CreateEgressACL(pgName, asEgressName, asExceptName string, npp []netv1.NetworkPolicyPort) error

func (Client) CreateIngressACL

func (c Client) CreateIngressACL(pgName, asIngressName, asExceptName string, npp []netv1.NetworkPolicyPort) error

func (Client) CreateLoadBalancer

func (c Client) CreateLoadBalancer(lb, protocol string) error

CreateLoadBalancer create loadbalancer in ovn

func (Client) CreateLoadBalancerRule

func (c Client) CreateLoadBalancerRule(lb, vip, ips string) error

CreateLoadBalancerRule create loadbalancer rul in ovn

func (Client) CreateLogicalRouter

func (c Client) CreateLogicalRouter(lr string) error

CreateLogicalRouter create logical router in ovn

func (Client) CreateLogicalSwitch

func (c Client) CreateLogicalSwitch(ls, subnet, gateway, excludeIps string) error

CreateLogicalSwitch create logical switch in ovn, connect it to router and apply tcp/udp lb rules

func (Client) CreatePort

func (c Client) CreatePort(ls, port, ip, mac string) (*nic, error)

CreatePort create logical switch port in ovn

func (Client) CreatePortGroup

func (c Client) CreatePortGroup(pgName string) error

func (Client) DeleteACL

func (c Client) DeleteACL(pgName, direction string) error

func (Client) DeleteAddressSet

func (c Client) DeleteAddressSet(asName string) error

func (Client) DeleteLoadBalancerVip

func (c Client) DeleteLoadBalancerVip(vip, lb string) error

DeleteLoadBalancerVip delete a vip rule from loadbalancer

func (Client) DeleteLogicalSwitch

func (c Client) DeleteLogicalSwitch(ls string) error

DeleteLogicalSwitch delete logical switch and related router port

func (Client) DeletePort

func (c Client) DeletePort(port string) error

DeletePort delete logical switch port in ovn

func (Client) DeletePortGroup

func (c Client) DeletePortGroup(pgName string) error

func (Client) DeleteStaticRouter

func (c Client) DeleteStaticRouter(cidr, router string) error

DeleteStaticRouter delete a static route rule in ovn

func (Client) FindLoadbalancer

func (c Client) FindLoadbalancer(lb string) (string, error)

FindLoadbalancer find ovn loadbalancer uuid by name

func (Client) GetLoadBalancerVips

func (c Client) GetLoadBalancerVips(lb string) (map[string]string, error)

GetLoadBalancerVips return vips of a loadbalancer

func (Client) GetPortAddr

func (c Client) GetPortAddr(port string) ([]string, error)

GetPortAddr return port [mac, ip]

func (Client) ListLogicalRouter

func (c Client) ListLogicalRouter() ([]string, error)

ListLogicalRouter list logical router names

func (Client) ListLogicalSwitch

func (c Client) ListLogicalSwitch() ([]string, error)

ListLogicalSwitch list logical switch names

func (Client) SetAddressesToAddressSet

func (c Client) SetAddressesToAddressSet(addresses []string, as string) error

func (Client) SetPortsToPortGroup

func (c Client) SetPortsToPortGroup(portGroup string, portNames []string) error

func (Client) SetPrivateLogicalSwitch

func (c Client) SetPrivateLogicalSwitch(ls string, allow []string) error

SetPrivateLogicalSwitch will drop all ingress traffic except allow subnets