ofnet

package module
v0.0.0-...-d2b5aef Latest Latest
Warning

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

Go to latest
Published: Oct 12, 2017 License: Apache-2.0 Imports: 30 Imported by: 0

README

Ofnet

Ofnet is a networking library that manages a network of openflow switches using a distributed controller architecture

Ofnet is a golang library that can be used by Container network drivers or container executors to manage a cluster wide network. Ofnet implements openflow 1.3 based controller and works with OpenVswitch. Ofnet manages only the openflow forwarding aspect of OVS. It does not create OVS interfaces/ports required by containers. It is assumed that container network driver creates OVS interface, moves it to container namespace and passes endpoint information to Ofnet library using its API.

Ofnet Controller supports multiple Software Defined Networking paradigms. They are

  1. vrouter - In this mode entire network operates like a giant router. IP packates are forwarded based on their IP dest address using a Vxlan overlay. Ofnet controller keeps track of all IP addresses in the network and programs OVS to lookup IP destination address and forward it using the overlay. It Proxies all ARP requests so that there is no need for broadcast in the network.
  2. vxlan bridge - In this mode each OVS acts as a VXLAN switch and together they emulate multiple bridge domains. This mode requires OVS 2.3.1 or higher.
  3. vlan bridge - In this mode OVS acts as a VLAN bridge
  4. vlan router - In this mode OVS acts as an IP Router. Control plane protocol like BGP is used to exchange routing information with physical switches

High level Architecture

Architecture

As shown above Ofnet Controller consists of Ofnet Agents that run on each host along with OVS and multiple Ofnet Masters. Ofnet agents can connect to any number of Ofnet Masters. Ofnet Masters largely act as state distributors. Ofnet Masters and Agents form an eventually consistent database that can survive multiple node failures, network partitioning and temporary hiccups. Controller state is guaranteed to eventually reach a consistent state.

Ofnet controller supports the concept of multiple networks. Depending on the forwarding paradign, this can be mapped to Tenats(VRF in networking lingo, VPC in cloud lingo), Subnets or bridge domains.

Multiple datapath plugins

Datapath Plugins

Ofnet Controller supports multiple data path plugins. Currently vrouter and vxlan plugins are implemented. Vlan plugin is in development. These plugins use Ofctrl library to program Flows in OVS. Please see Ofctrl subdirectory on more details.

Usage

Documentation

Overview

** Copyright 2016 Cisco Systems Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

** Copyright 2014 Cisco Systems Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

** Copyright 2014 Cisco Systems Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

** Copyright 2016 Cisco Systems Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

** Copyright 2014 Cisco Systems Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

** Copyright 2014 Cisco Systems Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

** Copyright 2014 Cisco Systems Inc. All rights reserved. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

** Copyright 2014 Cisco Systems Inc. All rights reserved. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

** Copyright 2014 Cisco Systems Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source
const (
	OFNET_INTERNAL     = 1 //Internal contiv cluster ep type
	OFNET_INTERNAL_BGP = 2 //Internal contiv bgp intf ep
	OFNET_EXTERNAL_BGP = 3 //External contiv bgp neighbor ep
	OFNET_EXTERNAL     = 4 //External eps (non contiv eps)
)
View Source
const (
	// ArpFlood - ARP packets will be flooded in this mode
	ArpFlood ArpModeT = "flood"
	// ArpProxy - ARP packets will be redirected to controller
	ArpProxy ArpModeT = "proxy"

	// PortType - individual port
	PortType = "individual"
	// BondType - bonded port
	BondType = "bond"

	// LacpUpdate - for port update info
	LacpUpdate = "lacp-upd"
)
View Source
const (
	DNS_FLOW_MATCH_PRIORITY             = 100 // Priority for dns match flows
	FLOW_MATCH_PRIORITY                 = 100 // Priority for all match flows
	FLOW_FLOOD_PRIORITY                 = 10  // Priority for flood entries
	FLOW_MISS_PRIORITY                  = 1   // priority for table miss flow
	FLOW_POLICY_PRIORITY_OFFSET         = 10  // Priority offset for policy rules
	LOCAL_ENDPOINT_FLOW_TAGGED_PRIORITY = 103 // Priority for local tagged endpoints (currently used in l3 mode)
	LOCAL_ENDPOINT_FLOW_PRIORITY        = 102 //Priority for local untagged endpoints (currently used in l3 mode)
	EXTERNAL_FLOW_PRIORITY              = 101 // Priority for external flows (eg bgp routes)
	HOST_SNAT_DENY_PRIORITY             = 101 // Priority for host snat deny
)
View Source
const (
	VLAN_TBL_ID           = 1
	HOST_DNAT_TBL_ID      = 2
	SRV_PROXY_DNAT_TBL_ID = 3
	DST_GRP_TBL_ID        = 4
	POLICY_TBL_ID         = 5
	SRV_PROXY_SNAT_TBL_ID = 6
	IP_TBL_ID             = 7
	HOST_SNAT_TBL_ID      = 8
	MAC_DEST_TBL_ID       = 9
)
View Source
const (
	GARPRepeats = 15
	GARPDELAY   = 3
)
View Source
const DnsMaxRespMsgSize = 1024
View Source
const METADATA_RX_VTEP = 0x1
View Source
const OFNET_AGENT_VLAN_PORT = 9010
View Source
const OFNET_AGENT_VXLAN_PORT = 9002
View Source
const OFNET_MASTER_PORT = 9001

Default port numbers

View Source
const TCP_FLAG_ACK = 0x10
View Source
const TCP_FLAG_SYN = 0x2
View Source
const VXLAN_GARP_SUPPORTED = false

Variables

This section is empty.

Functions

func BuildGarpPkt

func BuildGarpPkt(ip net.IP, mac net.HardwareAddr, vlanID uint16) *openflow13.PacketOut

BuildGarpPkt builds a Gratuitous ARP packet

func DstGroupMetadata

func DstGroupMetadata(groupId int) (uint64, uint64)

DstGroupMetadata returns metadata for dst group

func ParseCIDR

func ParseCIDR(cidrStr string) (string, uint, error)

ParseCIDR parses a CIDR string into a gateway IP and length.

func ParseIPAddrMaskString

func ParseIPAddrMaskString(ipAddr string) (*net.IP, *net.IP, error)

ParseIPAddrMaskString Parse IP addr string

func SrcGroupMetadata

func SrcGroupMetadata(groupId int) (uint64, uint64)

SrcGroupMetadata returns metadata for src group

func Vrfmetadata

func Vrfmetadata(vrfid uint16) (uint64, uint64)

Types

type ArpModeT

type ArpModeT string

type EndpointInfo

type EndpointInfo struct {
	PortNo            uint32           // OVS port number
	EndpointGroup     int              // Endpoint group ID
	MacAddr           net.HardwareAddr // mac address
	Vlan              uint16           // OVS internal vlan for the network
	IpAddr            net.IP           // IPv4 address of the endpoint
	Ipv6Addr          net.IP           // IPv6 address of the endpoint
	Vrf               string           // VRF name
	EndpointGroupVlan uint16           // Endpoint group vlan when its different from network vlan
	Dscp              int              // DSCP value for the endpoint
	HostPvtIP         net.IP           // IPv4 address for NAT access to host
}

local End point information

type GARPInfo

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

GARPInfo for each EP

type HostBridge

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

hostAgent state

func NewHostBridge

func NewHostBridge(bridgeName, dpName string, ovsPort uint16) (*HostBridge, error)

NewHostBridge Create a new Host agent and initialize it

func (*HostBridge) AddHostPort

func (self *HostBridge) AddHostPort(endpoint EndpointInfo) error

AddHostPort Add a host port for access to host network.

func (*HostBridge) DelHostPort

func (self *HostBridge) DelHostPort(portNo uint32) error

DelHostPort Remove host port

func (*HostBridge) Delete

func (self *HostBridge) Delete() error

Delete cleans up an ofnet agent

func (*HostBridge) IsSwitchConnected

func (self *HostBridge) IsSwitchConnected() bool

IsSwitchConnected returns true if switch is connected

func (*HostBridge) MultipartReply

func (self *HostBridge) MultipartReply(sw *ofctrl.OFSwitch, reply *openflow13.MultipartReply)

MultipartReply Receives a multi-part reply from the switch.

func (*HostBridge) PacketRcvd

func (self *HostBridge) PacketRcvd(sw *ofctrl.OFSwitch, pkt *ofctrl.PacketIn)

Receive a packet from the switch.

func (*HostBridge) SwitchConnected

func (self *HostBridge) SwitchConnected(sw *ofctrl.OFSwitch)

Handle switch connected event

func (*HostBridge) SwitchDisconnected

func (self *HostBridge) SwitchDisconnected(sw *ofctrl.OFSwitch)

Handle switch disconnect event

func (*HostBridge) WaitForSwitchConnection

func (self *HostBridge) WaitForSwitchConnection()

WaitForSwitchConnection wait till switch connects

type HostPortInfo

type HostPortInfo struct {
	PortNo  uint32           // OVS port number
	MacAddr net.HardwareAddr // mac address
	IpAddr  string           // IP address in the a.b.c.d/N format
	Kind    string           // NAT or Regular
}

HostPortInfo holds information about a host access port

type LinkInfo

type LinkInfo struct {
	Name       string
	Port       *PortInfo
	LinkStatus linkStatus
	OfPort     uint32
}

LinkInfo maintains individual link information

type LinkUpdateInfo

type LinkUpdateInfo struct {
	LinkName   string
	LacpStatus bool
}

LACP update

type NameServer

type NameServer interface {
	NsLookup([]byte, *string) ([]byte, error)
}

type OfnetAgent

type OfnetAgent struct {
	MyPort uint16 // Port where the agent's RPC server is listening
	MyAddr string // RPC server addr. same as localIp. different in testing environments

	GARPStats map[int]uint32 // per EPG garp stats.
	// contains filtered or unexported fields
}

OfnetAgent state

func NewOfnetAgent

func NewOfnetAgent(bridgeName string, dpName string, localIp net.IP, rpcPort uint16,
	ovsPort uint16, uplinkInfo []string) (*OfnetAgent, error)

Create a new Ofnet agent and initialize it

func (*OfnetAgent) AddBgp

func (self *OfnetAgent) AddBgp(routerIP string, As string, neighborAs string, peer string) error

AddBgpNeighbors add bgp neighbor

func (*OfnetAgent) AddHostPort

func (self *OfnetAgent) AddHostPort(hp HostPortInfo) error

AddHostPort

func (*OfnetAgent) AddLocalEndpoint

func (self *OfnetAgent) AddLocalEndpoint(endpoint EndpointInfo) error

Add a local endpoint. This takes ofp port number, mac address, vlan , VrfId and IP address of the port.

func (*OfnetAgent) AddLocalProtoRoute

func (self *OfnetAgent) AddLocalProtoRoute(path []*OfnetProtoRouteInfo)

func (*OfnetAgent) AddMaster

func (self *OfnetAgent) AddMaster(masterInfo *OfnetNode, ret *bool) error

Add a master ofnet agent tries to connect to the master and download routes

func (*OfnetAgent) AddNameServer

func (self *OfnetAgent) AddNameServer(ns NameServer)

func (*OfnetAgent) AddNetwork

func (self *OfnetAgent) AddNetwork(vlanId uint16, vni uint32, Gw string, Vrf string) error

Add a Network. This is mainly used for mapping vlan id to Vxlan VNI and add gateway for network

func (*OfnetAgent) AddSvcSpec

func (self *OfnetAgent) AddSvcSpec(svcName string, spec *ServiceSpec) error

AddSvcSpec adds a service spec to proxy

func (self *OfnetAgent) AddUplink(uplinkPort *PortInfo) error

AddUplink adds an uplink to the switch

func (*OfnetAgent) AddVtepPort

func (self *OfnetAgent) AddVtepPort(portNo uint32, remoteIp net.IP) error

Add virtual tunnel end point. This is mainly used for mapping remote vtep IP to ofp port number.

func (*OfnetAgent) DelSvcSpec

func (self *OfnetAgent) DelSvcSpec(svcName string, spec *ServiceSpec) error

DelSvcSpec removes a service spec from proxy

func (*OfnetAgent) Delete

func (self *OfnetAgent) Delete() error

Delete cleans up an ofnet agent

func (*OfnetAgent) DeleteBgp

func (self *OfnetAgent) DeleteBgp() error

func (*OfnetAgent) DeleteLocalProtoRoute

func (self *OfnetAgent) DeleteLocalProtoRoute(path []*OfnetProtoRouteInfo)

func (*OfnetAgent) DummyRpc

func (self *OfnetAgent) DummyRpc(arg *string, ret *bool) error

func (*OfnetAgent) EndpointAdd

func (self *OfnetAgent) EndpointAdd(epreg *OfnetEndpoint, ret *bool) error

Add remote endpoint RPC call from master

func (*OfnetAgent) EndpointDel

func (self *OfnetAgent) EndpointDel(epreg *OfnetEndpoint, ret *bool) error

Delete remote endpoint RPC call from master

func (*OfnetAgent) FlushEndpoints

func (self *OfnetAgent) FlushEndpoints(endpointType int)

func (*OfnetAgent) GetEndpointIdByIpVrf

func (self *OfnetAgent) GetEndpointIdByIpVrf(ipAddr net.IP, vrf string) string

GetEndpointIdByIpVrf constructs Endpoint ID from IP and VRF

func (*OfnetAgent) GetEndpointStats

func (self *OfnetAgent) GetEndpointStats() (map[string]*OfnetEndpointStats, error)

GetEndpointStats fetches all endpoint stats

func (*OfnetAgent) GetRouterInfo

func (self *OfnetAgent) GetRouterInfo() *OfnetProtoRouterInfo

func (*OfnetAgent) GlobalConfigUpdate

func (self *OfnetAgent) GlobalConfigUpdate(cfg OfnetGlobalConfig) error

Update global config

func (*OfnetAgent) InjectGARPs

func (self *OfnetAgent) InjectGARPs(epgID int, resp *bool) error

InjectGARPs inject garps for all eps on the epg.

func (*OfnetAgent) InspectBgp

func (self *OfnetAgent) InspectBgp() (interface{}, error)

InspectBgp returns ofnet bgp state

func (*OfnetAgent) InspectState

func (self *OfnetAgent) InspectState() (interface{}, error)

InspectState returns ofnet agent state

func (*OfnetAgent) IsSwitchConnected

func (self *OfnetAgent) IsSwitchConnected() bool

IsSwitchConnected returns true if switch is connected

func (*OfnetAgent) MultipartReply

func (self *OfnetAgent) MultipartReply(sw *ofctrl.OFSwitch, reply *openflow13.MultipartReply)

MultipartReply Receives a multi-part reply from the switch.

func (*OfnetAgent) PacketRcvd

func (self *OfnetAgent) PacketRcvd(sw *ofctrl.OFSwitch, pkt *ofctrl.PacketIn)

Receive a packet from the switch.

func (*OfnetAgent) RemoveHostPort

func (self *OfnetAgent) RemoveHostPort(portNo uint32) error

RemoveHostPort

func (*OfnetAgent) RemoveLocalEndpoint

func (self *OfnetAgent) RemoveLocalEndpoint(portNo uint32) error

Remove local endpoint

func (*OfnetAgent) RemoveLocalEndpointByID

func (self *OfnetAgent) RemoveLocalEndpointByID(epID string) error

Remove local endpoint by ID

  • This function is an alternate of deleting endpoint, but not necessarily an optimized one. Use this function only when port number information is not available for the endpoint. Use the RemoveLocalEndpoint for an optimized way.

func (*OfnetAgent) RemoveMaster

func (self *OfnetAgent) RemoveMaster(masterInfo *OfnetNode) error

Remove the master from master DB

func (*OfnetAgent) RemoveNetwork

func (self *OfnetAgent) RemoveNetwork(vlanId uint16, vni uint32, Gw string, Vrf string) error

Remove a vlan from datapath

func (self *OfnetAgent) RemoveUplink(uplinkName string) error

RemoveUplink remove an uplink to the switch

func (*OfnetAgent) RemoveVtepPort

func (self *OfnetAgent) RemoveVtepPort(portNo uint32, remoteIp net.IP) error

Remove a VTEP port

func (*OfnetAgent) SvcProviderUpdate

func (self *OfnetAgent) SvcProviderUpdate(svcName string, providers []string)

SvcProviderUpdate Service Proxy Back End update

func (*OfnetAgent) SwitchConnected

func (self *OfnetAgent) SwitchConnected(sw *ofctrl.OFSwitch)

Handle switch connected event

func (*OfnetAgent) SwitchDisconnected

func (self *OfnetAgent) SwitchDisconnected(sw *ofctrl.OFSwitch)

Handle switch disconnect event

func (*OfnetAgent) UpdateLocalEndpoint

func (self *OfnetAgent) UpdateLocalEndpoint(endpoint EndpointInfo) error

UpdateLocalEndpoint update state on a local endpoint

func (self *OfnetAgent) UpdateUplink(uplinkName string, portUpds PortUpdates) error

UpdateUplink Updates an uplink to the switch

func (*OfnetAgent) WaitForSwitchConnection

func (self *OfnetAgent) WaitForSwitchConnection()

WaitForSwitchConnection wait till switch connects

type OfnetBgp

type OfnetBgp struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewOfnetBgp

func NewOfnetBgp(agent *OfnetAgent) *OfnetBgp

Create a new vlrouter instance

func (*OfnetBgp) AddLocalProtoRoute

func (self *OfnetBgp) AddLocalProtoRoute(pathInfo []*OfnetProtoRouteInfo) error

AddLocalProtoRoute is used to add local endpoint to the protocol RIB

func (*OfnetBgp) AddProtoNeighbor

func (self *OfnetBgp) AddProtoNeighbor(neighborInfo *OfnetProtoNeighborInfo) error

AddProtoNeighbor adds bgp neighbor

func (*OfnetBgp) DeleteLocalProtoRoute

func (self *OfnetBgp) DeleteLocalProtoRoute(pathInfo []*OfnetProtoRouteInfo) error

DeleteLocalProtoRoute withdraws local endpoints from protocol RIB

func (*OfnetBgp) DeleteProtoNeighbor

func (self *OfnetBgp) DeleteProtoNeighbor() error

DeleteProtoNeighbor deletes bgp neighbor for the host

func (*OfnetBgp) GetRouterInfo

func (self *OfnetBgp) GetRouterInfo() *OfnetProtoRouterInfo

GetRouterInfo returns the configured RouterInfo

func (*OfnetBgp) InspectProto

func (self *OfnetBgp) InspectProto() (interface{}, error)

func (*OfnetBgp) ModifyProtoRib

func (self *OfnetBgp) ModifyProtoRib(path interface{})

func (*OfnetBgp) SetRouterInfo

func (self *OfnetBgp) SetRouterInfo(uplink *PortInfo) error

func (*OfnetBgp) StartProtoServer

func (self *OfnetBgp) StartProtoServer(routerInfo *OfnetProtoRouterInfo) error

Bgp serve routine does the following: 1) Creates inb01 router port 2) Add local Bgp endpoint 3) Kicks off routines to monitor route updates and peer state

func (*OfnetBgp) StopProtoServer

func (self *OfnetBgp) StopProtoServer() error

type OfnetBgpInspect

type OfnetBgpInspect struct {
	Peers []*bgpconf.Neighbor `json:"peers,omitempty"`
	Dsts  []string            `json:"dsts,omitempty"`
}

type OfnetDatapath

type OfnetDatapath interface {
	// New master was added.
	MasterAdded(master *OfnetNode) error

	// Switch connected notification
	SwitchConnected(sw *ofctrl.OFSwitch)

	// Switch disconnected notification
	SwitchDisconnected(sw *ofctrl.OFSwitch)

	// Process Incoming packet
	PacketRcvd(sw *ofctrl.OFSwitch, pkt *ofctrl.PacketIn)

	// Add a local endpoint to forwarding DB
	AddLocalEndpoint(endpoint OfnetEndpoint) error

	// Remove a local endpoint from forwarding DB
	RemoveLocalEndpoint(endpoint OfnetEndpoint) error

	// Update a local endpoint state
	UpdateLocalEndpoint(ep *OfnetEndpoint, epInfo EndpointInfo) error

	// Add a remote endpoint to forwarding DB
	AddEndpoint(endpoint *OfnetEndpoint) error

	// Remove a remote endpoint from forwarding DB
	RemoveEndpoint(endpoint *OfnetEndpoint) error

	// Add an remote VTEP
	AddVtepPort(portNo uint32, remoteIp net.IP) error

	// Remove remote VTEP
	RemoveVtepPort(portNo uint32, remoteIp net.IP) error

	// Add a vlan
	AddVlan(vlanId uint16, vni uint32, vrf string) error

	// Remove a vlan
	RemoveVlan(vlanId uint16, vni uint32, vrf string) error

	//Add uplink port
	AddUplink(uplinkPort *PortInfo) error

	//Update uplink port
	UpdateUplink(uplinkName string, update PortUpdates) error

	//Delete uplink port
	RemoveUplink(uplinkName string) error

	// AddHostPort
	AddHostPort(hp HostPortInfo) error

	// RemoveHostPort
	RemoveHostPort(portNo uint32) error

	//Inject GARPs
	InjectGARPs(epgID int)

	// Add a service spec to proxy
	AddSvcSpec(svcName string, spec *ServiceSpec) error

	// Remove a service spec from proxy
	DelSvcSpec(svcName string, spec *ServiceSpec) error

	// Service Proxy Back End update
	SvcProviderUpdate(svcName string, providers []string)

	// Handle multipart replies from OVS
	MultipartReply(sw *ofctrl.OFSwitch, reply *openflow13.MultipartReply)

	// Get endpoint stats
	GetEndpointStats() (map[string]*OfnetEndpointStats, error)

	// Return the datapath state
	InspectState() (interface{}, error)

	// Set global config
	GlobalConfigUpdate(cfg OfnetGlobalConfig) error

	// flush the endpoints
	FlushEndpoints(endpointType int)
}

Interface implemented by each datapath

type OfnetDatapathStats

type OfnetDatapathStats struct {
	PacketsIn  uint64
	BytesIn    uint64
	PacketsOut uint64
	BytesOut   uint64
}

OfnetDatapathStats is generic stats struct

type OfnetEndpoint

type OfnetEndpoint struct {
	EndpointID        string    // Unique identifier for the endpoint
	EndpointType      int       // Type of the endpoint , "external" or "externalRoute"
	EndpointGroup     int       // Endpoint group identifier for policies.
	IpAddr            net.IP    // IP address of the end point
	IpMask            net.IP    // IP mask for the end point
	Ipv6Addr          net.IP    // IPv6 address of the end point
	Ipv6Mask          net.IP    // IPv6 mask for the end point
	Vrf               string    // IP address namespace
	MacAddrStr        string    // Mac address of the end point(in string format)
	Vlan              uint16    // Vlan Id for the endpoint
	Vni               uint32    // Vxlan VNI
	EndpointGroupVlan uint16    // EnpointGroup Vlan, needed in non-Standalone mode of netplugin
	OriginatorIp      net.IP    // Originating switch
	OriginatorMac     string    // Mac address of the endpoint host
	PortNo            uint32    `json:"-"` // Port number on originating switch
	Dscp              int       `json:"-"` // DSCP value for the endpoint
	Timestamp         time.Time // Timestamp of the last event
	HostPvtIP         net.IP    `json:"-"` // Private IP
}

OfnetEndpoint has info about an endpoint

type OfnetEndpointStats

type OfnetEndpointStats struct {
	EndpointIP string                   // Endpoint IP address
	VrfName    string                   // vrf name
	PortStats  OfnetDatapathStats       // Aggregate port stats
	SvcStats   map[string]OfnetSvcStats // Service level stats
}

OfnetEndpointStats has stats for local endpoints

type OfnetGlobalConfig

type OfnetGlobalConfig struct {
	ArpMode ArpModeT // arp mode: proxy or flood
}

OfnetGlobalConfig has global level configs for ofnet

type OfnetMaster

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

Ofnet master state

func NewOfnetMaster

func NewOfnetMaster(myAddr string, portNo uint16) *OfnetMaster

Create new Ofnet master

func (*OfnetMaster) AddNode

func (self *OfnetMaster) AddNode(hostInfo OfnetNode) error

AddNode adds a node by calling MasterAdd rpc call on the node

func (*OfnetMaster) AddRule

func (self *OfnetMaster) AddRule(rule *OfnetPolicyRule) error

AddRule adds a new rule to the policyDB

func (*OfnetMaster) ClearNode

func (self *OfnetMaster) ClearNode(host OfnetNode) error

ClearNode clears up the resources on the node for GC

func (*OfnetMaster) DelRule

func (self *OfnetMaster) DelRule(rule *OfnetPolicyRule) error

DelRule removes a rule from policy DB

func (*OfnetMaster) Delete

func (self *OfnetMaster) Delete() error

Delete closes rpc listener

func (*OfnetMaster) EndpointAdd

func (self *OfnetMaster) EndpointAdd(ep *OfnetEndpoint, ret *bool) error

Add an Endpoint

func (*OfnetMaster) EndpointDel

func (self *OfnetMaster) EndpointDel(ep *OfnetEndpoint, ret *bool) error

Delete an Endpoint

func (*OfnetMaster) InjectGARPs

func (self *OfnetMaster) InjectGARPs(epgID int)

InjectGARPs triggers GARPS in the datapath on the specified epg

func (*OfnetMaster) InspectState

func (self *OfnetMaster) InspectState() ([]byte, error)

InspectState returns current state as json

func (*OfnetMaster) MakeDummyRpcCall

func (self *OfnetMaster) MakeDummyRpcCall() error

Make a dummy RPC call to all agents. for testing purposes..

func (*OfnetMaster) RegisterNode

func (self *OfnetMaster) RegisterNode(hostInfo *OfnetNode, ret *bool) error

RegisterNode registers an agent

func (*OfnetMaster) UnRegisterNode

func (self *OfnetMaster) UnRegisterNode(hostInfo *OfnetNode, ret *bool) error

UnRegisterNode unregisters an agent

type OfnetNode

type OfnetNode struct {
	HostAddr string
	HostPort uint16
}

Information about each node

type OfnetPolicyRule

type OfnetPolicyRule struct {
	RuleId           string // Unique identifier for the rule
	Priority         int    // Priority for the rule (1..100. 100 is highest)
	SrcEndpointGroup int    // Source endpoint group
	DstEndpointGroup int    // Destination endpoint group
	SrcIpAddr        string // source IP addrss and mask
	DstIpAddr        string // Destination IP address and mask
	IpProtocol       uint8  // IP protocol number
	SrcPort          uint16 // Source port
	DstPort          uint16 // destination port
	TcpFlags         string // TCP flags to match: syn || syn,ack || ack || syn,!ack || !syn,ack;
	Action           string // rule action: 'accept' or 'deny'
}

OfnetPolicyRule has security rule to be installed

type OfnetProto

type OfnetProto interface {

	//Create a protocol server
	StartProtoServer(routerInfo *OfnetProtoRouterInfo) error

	StopProtoServer() error

	//Add a Protocol Neighbor
	AddProtoNeighbor(neighborInfo *OfnetProtoNeighborInfo) error

	//Delete a Protocol Neighbor
	DeleteProtoNeighbor() error

	//Get Protocol router info
	GetRouterInfo() *OfnetProtoRouterInfo

	//Set Protocol router info
	SetRouterInfo(uplinkPort *PortInfo) error

	//Add Local Route
	AddLocalProtoRoute(path []*OfnetProtoRouteInfo) error

	//Delete Local Route
	DeleteLocalProtoRoute(path []*OfnetProtoRouteInfo) error

	//Modify protocol Rib (Could be used for testing)
	ModifyProtoRib(path interface{})

	//Inspect bgp
	InspectProto() (interface{}, error)
}

Interface implemented by each control protocol.

type OfnetProtoNeighborInfo

type OfnetProtoNeighborInfo struct {
	ProtocolType string // type of protocol
	NeighborIP   string // ip address of the neighbor
	As           string // As of neighbor if applicable
}

OfnetProtoNeighborInfo has bgp neighbor info

type OfnetProtoRouteInfo

type OfnetProtoRouteInfo struct {
	ProtocolType string // type of protocol
	// contains filtered or unexported fields
}

OfnetProtoRouteInfo contains a route

type OfnetProtoRouterInfo

type OfnetProtoRouterInfo struct {
	ProtocolType string    // type of protocol
	RouterIP     string    // ip address of the router
	UplinkPort   *PortInfo // uplink L2 intf
	As           string    // As for Bgp protocol
}

OfnetProtoRouterInfo has local router info

type OfnetSvcProviderStats

type OfnetSvcProviderStats struct {
	ProviderIP         string // Provider IP address
	ServiceIP          string // service ip address
	ServiceVrf         string // Provider VRF name
	OfnetDatapathStats        // stats
}

OfnetSvcProviderStats has stats for a provider of a service

type OfnetSvcStats

type OfnetSvcStats struct {
	ServiceIP  string                           // service ip address
	ServiceVRF string                           // service vrf name
	Protocol   string                           // service protocol tcp | udp
	SvcPort    string                           // Service Port
	ProvPort   string                           // Provider port
	SvcStats   OfnetDatapathStats               // aggregate service stats
	ProvStats  map[string]OfnetSvcProviderStats // per provider stats
}

OfnetSvcStats per service stats from one client

type OfnetVrfInfo

type OfnetVrfInfo struct {
	VrfName     string // vrf name
	VrfId       uint16 // local vrf id
	NumNetworks uint16 // ref count of networks in the vrf
}

OfnetVrfInfo has info about a VRF

type PolicyAgent

type PolicyAgent struct {
	Rules map[string]*PolicyRule // rules database
	// contains filtered or unexported fields
}

PolicyAgent is an instance of a policy agent

func NewPolicyAgent

func NewPolicyAgent(agent *OfnetAgent, rpcServ *rpc.Server) *PolicyAgent

NewPolicyMgr Creates a new policy manager

func (*PolicyAgent) AddEndpoint

func (self *PolicyAgent) AddEndpoint(endpoint *OfnetEndpoint) error

AddEndpoint adds an endpoint to dst group lookup

func (*PolicyAgent) AddIpv6Endpoint

func (self *PolicyAgent) AddIpv6Endpoint(endpoint *OfnetEndpoint) error

AddIpv6Endpoint adds an endpoint to dst group lookup

func (*PolicyAgent) AddRule

func (self *PolicyAgent) AddRule(rule *OfnetPolicyRule, ret *bool) error

AddRule adds a security rule to policy table

func (*PolicyAgent) DelEndpoint

func (self *PolicyAgent) DelEndpoint(endpoint *OfnetEndpoint) error

DelEndpoint deletes an endpoint from dst group lookup

func (*PolicyAgent) DelIpv6Endpoint

func (self *PolicyAgent) DelIpv6Endpoint(endpoint *OfnetEndpoint) error

DelIpv6Endpoint deletes an endpoint from dst group lookup

func (*PolicyAgent) DelRule

func (self *PolicyAgent) DelRule(rule *OfnetPolicyRule, ret *bool) error

DelRule deletes a security rule from policy table

func (*PolicyAgent) InitTables

func (self *PolicyAgent) InitTables(nextTblId uint8) error

InitTables initializes policy table on the switch

func (*PolicyAgent) SwitchConnected

func (self *PolicyAgent) SwitchConnected(sw *ofctrl.OFSwitch)

Handle switch connected notification

func (*PolicyAgent) SwitchDisconnected

func (self *PolicyAgent) SwitchDisconnected(sw *ofctrl.OFSwitch)

Handle switch disconnected notification

type PolicyRule

type PolicyRule struct {
	Rule *OfnetPolicyRule // rule definition
	// contains filtered or unexported fields
}

PolicyRule has info about single rule

type PortInfo

type PortInfo struct {
	Name        string
	Type        string
	LinkStatus  linkStatus
	MbrLinks    []*LinkInfo
	ActiveLinks []*LinkInfo
}

PortInfo maintains port information

type PortSpec

type PortSpec struct {
	Protocol string
	SvcPort  uint16 // advertised port
	ProvPort uint16 // actual port of provider
}

PortSpec defines protocol/port info required to host the service

type PortUpdate

type PortUpdate struct {
	UpdateType string
	UpdateInfo interface{}
}

PortUpdate maintains information about port update

type PortUpdates

type PortUpdates struct {
	PortName string
	Updates  []PortUpdate
}

PortUpdates maintains multiplae port update info

type Providers

type Providers struct {
	Providers map[string]bool // Provider IP as key
}

Providers holds the current providers of a given service

type ServiceProxy

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

ServiceProxy is an instance of a service proxy

func NewServiceProxy

func NewServiceProxy(agent *OfnetAgent) *ServiceProxy

NewServiceProxy Creates a new service proxy

func (*ServiceProxy) AddSvcSpec

func (proxy *ServiceProxy) AddSvcSpec(svcName string, spec *ServiceSpec) error

AddSvcSpec adds or updates a service spec.

func (*ServiceProxy) DelEndpoint

func (proxy *ServiceProxy) DelEndpoint(endpoint *OfnetEndpoint)

DelEndpoint handles an endpoint delete

func (*ServiceProxy) DelSvcSpec

func (proxy *ServiceProxy) DelSvcSpec(svcName string, spec *ServiceSpec) error

DelSvcSpec deletes a service spec.

func (*ServiceProxy) FlowStats

func (proxy *ServiceProxy) FlowStats(reply *openflow13.MultipartReply)

FlowStats handles a stats response from the switch

func (*ServiceProxy) GetEndpointStats

func (proxy *ServiceProxy) GetEndpointStats() (map[string]*OfnetEndpointStats, error)

GetEndpointStats fetches ep stats

func (*ServiceProxy) GetSvcProxyMAC

func (proxy *ServiceProxy) GetSvcProxyMAC(svcIP net.IP) string

GetSvcProxyMAC looks up the service IP and returns a mac if the IP exists. if the svc IP is not found, returns empty string

func (*ServiceProxy) HandlePkt

func (proxy *ServiceProxy) HandlePkt(pkt *ofctrl.PacketIn)

HandlePkt processes a received pkt from a matching table entry

func (*ServiceProxy) InitDNATTable

func (proxy *ServiceProxy) InitDNATTable(nextIDdNAT uint8) error

InitDNATTable initializes the dNAT table

func (*ServiceProxy) InitSNATTable

func (proxy *ServiceProxy) InitSNATTable(nextIDsNAT uint8) error

InitSNATTable initializes the sNAT table

func (*ServiceProxy) InspectState

func (proxy *ServiceProxy) InspectState() interface{}

InspectState returns current state of svc proxy

func (*ServiceProxy) ProviderUpdate

func (proxy *ServiceProxy) ProviderUpdate(svcName string, providers []string)

ProviderUpdate updates the list of providers of the service

func (*ServiceProxy) SwitchConnected

func (proxy *ServiceProxy) SwitchConnected(sw *ofctrl.OFSwitch)

Handle switch connected notification

func (*ServiceProxy) SwitchDisconnected

func (proxy *ServiceProxy) SwitchDisconnected(sw *ofctrl.OFSwitch)

Handle switch disconnected notification

type ServiceSpec

type ServiceSpec struct {
	IpAddress string
	Ports     []PortSpec
}

ServiceSpec defines a service to be proxied

type Vlan

type Vlan struct {
	Vni uint32 // Vxlan VNI
	// contains filtered or unexported fields
}

Vlan info

type VlanBridge

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

VlanBridge has Vlan state.

func NewVlanBridge

func NewVlanBridge(agent *OfnetAgent, rpcServ *rpc.Server) *VlanBridge

NewVlanBridge Create a new vlan instance

func (*VlanBridge) AddEndpoint

func (vl *VlanBridge) AddEndpoint(endpoint *OfnetEndpoint) error

AddEndpoint Add an endpoint to the datapath

func (*VlanBridge) AddHostPort

func (vl *VlanBridge) AddHostPort(hp HostPortInfo) error

AddHostPort is not implemented

func (*VlanBridge) AddLocalEndpoint

func (vl *VlanBridge) AddLocalEndpoint(endpoint OfnetEndpoint) error

AddLocalEndpoint Add a local endpoint and install associated local route

func (*VlanBridge) AddSvcSpec

func (vl *VlanBridge) AddSvcSpec(svcName string, spec *ServiceSpec) error

AddSvcSpec adds a service spec to proxy

func (vl *VlanBridge) AddUplink(uplinkPort *PortInfo) error

AddUplink adds an uplink to the switch

func (*VlanBridge) AddVlan

func (vl *VlanBridge) AddVlan(vlanID uint16, vni uint32, vrf string) error

AddVlan Add a vlan.

func (*VlanBridge) AddVtepPort

func (vl *VlanBridge) AddVtepPort(portNo uint32, remoteIP net.IP) error

AddVtepPort Add virtual tunnel end point.

func (*VlanBridge) DelSvcSpec

func (vl *VlanBridge) DelSvcSpec(svcName string, spec *ServiceSpec) error

DelSvcSpec removes a service spec from proxy

func (*VlanBridge) FlushEndpoints

func (vl *VlanBridge) FlushEndpoints(endpointType int)

FlushEndpoints flushes endpoints from ovs

func (*VlanBridge) GetEndpointStats

func (vl *VlanBridge) GetEndpointStats() (map[string]*OfnetEndpointStats, error)

GetEndpointStats fetches ep stats

func (vl *VlanBridge) GetLink(linkID string) *LinkInfo

GetLink API gets the interface with linkID from interface DB

func (vl *VlanBridge) GetUplink(uplinkID string) *PortInfo

GetUplink API gets the uplink port with uplinkID from uplink DB

func (*VlanBridge) GlobalConfigUpdate

func (vl *VlanBridge) GlobalConfigUpdate(cfg OfnetGlobalConfig) error

Update global config

func (*VlanBridge) InjectGARPs

func (vl *VlanBridge) InjectGARPs(epgID int)

InjectGARPs for all endpoints on the epg

func (*VlanBridge) InspectState

func (vl *VlanBridge) InspectState() (interface{}, error)

InspectState returns current state

func (*VlanBridge) MasterAdded

func (vl *VlanBridge) MasterAdded(master *OfnetNode) error

MasterAdded Handle new master added event

func (*VlanBridge) MultipartReply

func (vl *VlanBridge) MultipartReply(sw *ofctrl.OFSwitch, reply *openflow13.MultipartReply)

MultipartReply handles stats reply

func (*VlanBridge) PacketRcvd

func (vl *VlanBridge) PacketRcvd(sw *ofctrl.OFSwitch, pkt *ofctrl.PacketIn)

PacketRcvd Handle incoming packet

func (*VlanBridge) RemoveEndpoint

func (vl *VlanBridge) RemoveEndpoint(endpoint *OfnetEndpoint) error

RemoveEndpoint removes an endpoint from the datapath

func (*VlanBridge) RemoveHostPort

func (vl *VlanBridge) RemoveHostPort(hp uint32) error

RemoveHostPort is not implemented

func (*VlanBridge) RemoveLocalEndpoint

func (vl *VlanBridge) RemoveLocalEndpoint(endpoint OfnetEndpoint) error

RemoveLocalEndpoint Remove local endpoint

func (vl *VlanBridge) RemoveUplink(uplinkName string) error

RemoveUplink remove an uplink to the switch

func (*VlanBridge) RemoveVlan

func (vl *VlanBridge) RemoveVlan(vlanID uint16, vni uint32, vrf string) error

RemoveVlan Remove a vlan

func (*VlanBridge) RemoveVtepPort

func (vl *VlanBridge) RemoveVtepPort(portNo uint32, remoteIP net.IP) error

RemoveVtepPort Remove a VTEP port

func (*VlanBridge) SvcProviderUpdate

func (vl *VlanBridge) SvcProviderUpdate(svcName string, providers []string)

SvcProviderUpdate Service Proxy Back End update

func (*VlanBridge) SwitchConnected

func (vl *VlanBridge) SwitchConnected(sw *ofctrl.OFSwitch)

SwitchConnected Handle switch connected notification

func (*VlanBridge) SwitchDisconnected

func (vl *VlanBridge) SwitchDisconnected(sw *ofctrl.OFSwitch)

SwitchDisconnected Handle switch disconnected notification

func (*VlanBridge) UpdateLocalEndpoint

func (vl *VlanBridge) UpdateLocalEndpoint(endpoint *OfnetEndpoint, epInfo EndpointInfo) error

UpdateLocalEndpoint update local endpoint state

func (vl *VlanBridge) UpdateUplink(uplinkName string, updates PortUpdates) error

UpdateUplink updates uplink info

type Vlrouter

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

Vlrouter state. One Vlrouter instance exists on each host

func NewVlrouter

func NewVlrouter(agent *OfnetAgent, rpcServ *rpc.Server) *Vlrouter

NewVlrouter creates a new vlrouter instance

func (*Vlrouter) AddEndpoint

func (vl *Vlrouter) AddEndpoint(endpoint *OfnetEndpoint) error
AddEndpoint does the following :

1)Adds a remote endpoint and associated flows to OVS 2)The remotes routes can be 3 endpoint types :

  a) internal - json rpc based learning from peer netplugins/ofnetagents in the cluster
	b) external - remote endpoint learn via BGP
	c) external-bgp - endpoint of BGP peer

func (*Vlrouter) AddHostPort

func (self *Vlrouter) AddHostPort(hp HostPortInfo) error

AddHostPort is not implemented

func (*Vlrouter) AddLocalEndpoint

func (vl *Vlrouter) AddLocalEndpoint(endpoint OfnetEndpoint) error

func (*Vlrouter) AddLocalIpv6Flow

func (vl *Vlrouter) AddLocalIpv6Flow(endpoint OfnetEndpoint) error

Add IPv6 flows

func (*Vlrouter) AddRemoteIpv6Flow

func (vl *Vlrouter) AddRemoteIpv6Flow(endpoint *OfnetEndpoint) error

Add IPv6 flow for the remote endpoint

func (*Vlrouter) AddSvcSpec

func (vl *Vlrouter) AddSvcSpec(svcName string, spec *ServiceSpec) error

AddSvcSpec adds a service spec to proxy

func (vl *Vlrouter) AddUplink(uplinkPort *PortInfo) error

AddUplink adds an uplink to the switch

func (*Vlrouter) AddVlan

func (vl *Vlrouter) AddVlan(vlanId uint16, vni uint32, vrf string) error

Add a vlan. This is mainly used for mapping vlan id to Vxlan VNI

func (*Vlrouter) AddVtepPort

func (vl *Vlrouter) AddVtepPort(portNo uint32, remoteIp net.IP) error

func (*Vlrouter) DelSvcSpec

func (vl *Vlrouter) DelSvcSpec(svcName string, spec *ServiceSpec) error

DelSvcSpec removes a service spec from proxy

func (*Vlrouter) FlushEndpoints

func (vl *Vlrouter) FlushEndpoints(endpointType int)

Flushendpoints - flushes out endpoints from ovs

func (*Vlrouter) GetEndpointStats

func (vl *Vlrouter) GetEndpointStats() (map[string]*OfnetEndpointStats, error)

GetEndpointStats fetches ep stats

func (vl *Vlrouter) GetUplink(uplinkID string) *PortInfo

GetUplink API gets the uplink port with uplinkID from uplink DB

func (*Vlrouter) GlobalConfigUpdate

func (vl *Vlrouter) GlobalConfigUpdate(cfg OfnetGlobalConfig) error

GlobalConfigUpdate not implemented

func (*Vlrouter) InjectGARPs

func (vl *Vlrouter) InjectGARPs(epgID int)

InjectGARPs not implemented

func (*Vlrouter) InspectState

func (vl *Vlrouter) InspectState() (interface{}, error)

InspectState returns current state

func (*Vlrouter) MasterAdded

func (vl *Vlrouter) MasterAdded(master *OfnetNode) error

MasterAdded handles new master added event

func (*Vlrouter) MultipartReply

func (vl *Vlrouter) MultipartReply(sw *ofctrl.OFSwitch, reply *openflow13.MultipartReply)

MultipartReply handles stats reply

func (*Vlrouter) PacketRcvd

func (vl *Vlrouter) PacketRcvd(sw *ofctrl.OFSwitch, pkt *ofctrl.PacketIn)

Handle incoming packet

func (*Vlrouter) RemoveEndpoint

func (vl *Vlrouter) RemoveEndpoint(endpoint *OfnetEndpoint) error

RemoveEndpoint removes an endpoint from the datapath

func (*Vlrouter) RemoveHostPort

func (self *Vlrouter) RemoveHostPort(hp uint32) error

RemoveHostPort is not implemented

func (*Vlrouter) RemoveLocalEndpoint

func (vl *Vlrouter) RemoveLocalEndpoint(endpoint OfnetEndpoint) error
RemoveLocalEndpoint does the following

1) Removes the local endpoint and associated flows from OVS 2) Withdraws the route from BGP RIB

func (*Vlrouter) RemoveLocalIpv6Flow

func (vl *Vlrouter) RemoveLocalIpv6Flow(endpoint OfnetEndpoint) error

Remove the IPv6 flow

func (*Vlrouter) RemoveRemoteIpv6Flow

func (vl *Vlrouter) RemoveRemoteIpv6Flow(endpoint *OfnetEndpoint) error

Remove IPv6 flow for the remote endpoint

func (vl *Vlrouter) RemoveUplink(uplinkName string) error

func (*Vlrouter) RemoveVlan

func (vl *Vlrouter) RemoveVlan(vlanId uint16, vni uint32, vrf string) error

Remove a vlan

func (*Vlrouter) RemoveVtepPort

func (vl *Vlrouter) RemoveVtepPort(portNo uint32, remoteIp net.IP) error

Remove a VTEP port

func (*Vlrouter) SvcProviderUpdate

func (vl *Vlrouter) SvcProviderUpdate(svcName string, providers []string)

SvcProviderUpdate Service Proxy Back End update

func (*Vlrouter) SwitchConnected

func (vl *Vlrouter) SwitchConnected(sw *ofctrl.OFSwitch)

Handle switch connected notification

func (*Vlrouter) SwitchDisconnected

func (vl *Vlrouter) SwitchDisconnected(sw *ofctrl.OFSwitch)

Handle switch disconnected notification

func (*Vlrouter) UpdateLocalEndpoint

func (vl *Vlrouter) UpdateLocalEndpoint(endpoint *OfnetEndpoint, epInfo EndpointInfo) error

UpdateLocalEndpoint update local endpoint state

func (vl *Vlrouter) UpdateUplink(uplinkName string, updates PortUpdates) error

UpdateUplink updates uplink info

type Vrouter

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

Vrouter state. One Vrouter instance exists on each host

func NewVrouter

func NewVrouter(agent *OfnetAgent, rpcServ *rpc.Server) *Vrouter

Create a new vrouter instance

func (*Vrouter) AddEndpoint

func (self *Vrouter) AddEndpoint(endpoint *OfnetEndpoint) error

AddEndpoint Add an endpoint to the datapath

func (*Vrouter) AddHostPort

func (self *Vrouter) AddHostPort(hp HostPortInfo) error

AddHostPort sets up host access.

func (*Vrouter) AddLocalEndpoint

func (self *Vrouter) AddLocalEndpoint(endpoint OfnetEndpoint) error

Add a local endpoint and install associated local route

func (*Vrouter) AddLocalIpv6Flow

func (self *Vrouter) AddLocalIpv6Flow(endpoint OfnetEndpoint) error

Add a local IPv6 flow

func (*Vrouter) AddRemoteIpv6Flow

func (self *Vrouter) AddRemoteIpv6Flow(endpoint *OfnetEndpoint) error

Add IPv6 flow for remote endpoint

func (*Vrouter) AddSvcSpec

func (vr *Vrouter) AddSvcSpec(svcName string, spec *ServiceSpec) error

AddSvcSpec adds a service spec to proxy

func (vr *Vrouter) AddUplink(uplinkPort *PortInfo) error

AddUplink adds an uplink to the switch

func (*Vrouter) AddVlan

func (self *Vrouter) AddVlan(vlanId uint16, vni uint32, vrf string) error

Add a vlan. This is mainly used for mapping vlan id to Vxlan VNI

func (*Vrouter) AddVtepPort

func (self *Vrouter) AddVtepPort(portNo uint32, remoteIp net.IP) error

Add virtual tunnel end point. This is mainly used for mapping remote vtep IP to ofp port number.

func (*Vrouter) DelSvcSpec

func (vr *Vrouter) DelSvcSpec(svcName string, spec *ServiceSpec) error

DelSvcSpec removes a service spec from proxy

func (*Vrouter) FlushEndpoints

func (self *Vrouter) FlushEndpoints(endpointType int)

FlushEndpoints flushes endpoints from ovs

func (*Vrouter) GetEndpointStats

func (vr *Vrouter) GetEndpointStats() (map[string]*OfnetEndpointStats, error)

GetEndpointStats fetches ep stats

func (*Vrouter) GlobalConfigUpdate

func (self *Vrouter) GlobalConfigUpdate(cfg OfnetGlobalConfig) error

GlobalConfigUpdate not implemented

func (*Vrouter) InjectGARPs

func (self *Vrouter) InjectGARPs(epgID int)

InjectGARPs not implemented

func (*Vrouter) InspectState

func (vr *Vrouter) InspectState() (interface{}, error)

func (*Vrouter) MasterAdded

func (self *Vrouter) MasterAdded(master *OfnetNode) error

Handle new master added event

func (*Vrouter) MultipartReply

func (vr *Vrouter) MultipartReply(sw *ofctrl.OFSwitch, reply *openflow13.MultipartReply)

MultipartReply handles multipart replies

func (*Vrouter) PacketRcvd

func (self *Vrouter) PacketRcvd(sw *ofctrl.OFSwitch, pkt *ofctrl.PacketIn)

Handle incoming packet

func (*Vrouter) RemoveEndpoint

func (self *Vrouter) RemoveEndpoint(endpoint *OfnetEndpoint) error

RemoveEndpoint removes an endpoint from the datapath

func (*Vrouter) RemoveHostPort

func (self *Vrouter) RemoveHostPort(hp uint32) error

RemoveHostPort sets up host access.

func (*Vrouter) RemoveLocalEndpoint

func (self *Vrouter) RemoveLocalEndpoint(endpoint OfnetEndpoint) error

Remove local endpoint

func (*Vrouter) RemoveLocalIpv6Flow

func (self *Vrouter) RemoveLocalIpv6Flow(endpoint OfnetEndpoint) error

Remove local IPv6 flow

func (*Vrouter) RemoveRemoteIpv6Flow

func (self *Vrouter) RemoveRemoteIpv6Flow(endpoint *OfnetEndpoint) error

Remove IPv6 flow for remote endpoint

func (vr *Vrouter) RemoveUplink(uplinkName string) error

RemoveUplink remove an uplink to the switch

func (*Vrouter) RemoveVlan

func (self *Vrouter) RemoveVlan(vlanId uint16, vni uint32, vrf string) error

Remove a vlan

func (*Vrouter) RemoveVtepPort

func (self *Vrouter) RemoveVtepPort(portNo uint32, remoteIp net.IP) error

Remove a VTEP port

func (*Vrouter) SvcProviderUpdate

func (vr *Vrouter) SvcProviderUpdate(svcName string, providers []string)

SvcProviderUpdate Service Proxy Back End update

func (*Vrouter) SwitchConnected

func (self *Vrouter) SwitchConnected(sw *ofctrl.OFSwitch)

Handle switch connected notification

func (*Vrouter) SwitchDisconnected

func (self *Vrouter) SwitchDisconnected(sw *ofctrl.OFSwitch)

Handle switch disconnected notification

func (*Vrouter) UpdateLocalEndpoint

func (self *Vrouter) UpdateLocalEndpoint(endpoint *OfnetEndpoint, epInfo EndpointInfo) error

UpdateLocalEndpoint update local endpoint state

func (vr *Vrouter) UpdateUplink(uplinkName string, updates PortUpdates) error

UpdateUplink updates uplink info

type Vxlan

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

Vxlan state.

func NewVxlan

func NewVxlan(agent *OfnetAgent, rpcServ *rpc.Server) *Vxlan

Create a new vxlan instance

func (*Vxlan) AddEndpoint

func (self *Vxlan) AddEndpoint(endpoint *OfnetEndpoint) error

AddEndpoint Add an endpoint to the datapath

func (*Vxlan) AddHostPort

func (vx *Vxlan) AddHostPort(hp HostPortInfo) error

AddHostPort is not implemented

func (*Vxlan) AddLocalEndpoint

func (self *Vxlan) AddLocalEndpoint(endpoint OfnetEndpoint) error

Add a local endpoint and install associated local route

func (*Vxlan) AddSvcSpec

func (vx *Vxlan) AddSvcSpec(svcName string, spec *ServiceSpec) error

AddSvcSpec adds a service spec to proxy

func (vx *Vxlan) AddUplink(uplinkPort *PortInfo) error

AddUplink adds an uplink to the switch

func (*Vxlan) AddVlan

func (self *Vxlan) AddVlan(vlanId uint16, vni uint32, vrf string) error

Add a vlan.

func (*Vxlan) AddVtepPort

func (self *Vxlan) AddVtepPort(portNo uint32, remoteIp net.IP) error

Add virtual tunnel end point. This is mainly used for mapping remote vtep IP to ofp port number.

func (*Vxlan) DelSvcSpec

func (vx *Vxlan) DelSvcSpec(svcName string, spec *ServiceSpec) error

DelSvcSpec removes a service spec from proxy

func (*Vxlan) FlushEndpoints

func (self *Vxlan) FlushEndpoints(endpointType int)

FlushEndpoints flushes endpoints from ovs

func (*Vxlan) GetEndpointStats

func (vx *Vxlan) GetEndpointStats() (map[string]*OfnetEndpointStats, error)

GetEndpointStats fetches ep stats

func (*Vxlan) GlobalConfigUpdate

func (self *Vxlan) GlobalConfigUpdate(cfg OfnetGlobalConfig) error

Update global config

func (*Vxlan) InjectGARPs

func (self *Vxlan) InjectGARPs(epgID int)

InjectGARPs not implemented

func (*Vxlan) InspectState

func (vx *Vxlan) InspectState() (interface{}, error)

InspectState returns current state

func (*Vxlan) MasterAdded

func (self *Vxlan) MasterAdded(master *OfnetNode) error

Handle new master added event

func (*Vxlan) MultipartReply

func (vx *Vxlan) MultipartReply(sw *ofctrl.OFSwitch, reply *openflow13.MultipartReply)

MultipartReply handles stats reply

func (*Vxlan) PacketRcvd

func (self *Vxlan) PacketRcvd(sw *ofctrl.OFSwitch, pkt *ofctrl.PacketIn)

Handle incoming packet

func (*Vxlan) RemoveEndpoint

func (self *Vxlan) RemoveEndpoint(endpoint *OfnetEndpoint) error

RemoveEndpoint removes an endpoint from the datapath

func (*Vxlan) RemoveHostPort

func (vx *Vxlan) RemoveHostPort(hp uint32) error

RemoveHostPort is not implemented

func (*Vxlan) RemoveLocalEndpoint

func (self *Vxlan) RemoveLocalEndpoint(endpoint OfnetEndpoint) error

Remove local endpoint

func (vx *Vxlan) RemoveUplink(uplinkName string) error

RemoveUplink remove an uplink to the switch

func (*Vxlan) RemoveVlan

func (self *Vxlan) RemoveVlan(vlanId uint16, vni uint32, vrf string) error

Remove a vlan

func (*Vxlan) RemoveVtepPort

func (self *Vxlan) RemoveVtepPort(portNo uint32, remoteIp net.IP) error

Remove a VTEP port

func (*Vxlan) SvcProviderUpdate

func (vx *Vxlan) SvcProviderUpdate(svcName string, providers []string)

SvcProviderUpdate Service Proxy Back End update

func (*Vxlan) SwitchConnected

func (self *Vxlan) SwitchConnected(sw *ofctrl.OFSwitch)

Handle switch connected notification

func (*Vxlan) SwitchDisconnected

func (self *Vxlan) SwitchDisconnected(sw *ofctrl.OFSwitch)

Handle switch disconnected notification

func (*Vxlan) UpdateLocalEndpoint

func (self *Vxlan) UpdateLocalEndpoint(endpoint *OfnetEndpoint, epInfo EndpointInfo) error

UpdateLocalEndpoint update local endpoint state

func (vx *Vxlan) UpdateUplink(uplinkName string, updates PortUpdates) error

UpdateUplink updates uplink info

Directories

Path Synopsis
** Copyright 2014 Cisco Systems Inc.
** Copyright 2014 Cisco Systems Inc.
** Copyright 2014 Cisco Systems Inc.
** Copyright 2014 Cisco Systems Inc.

Jump to

Keyboard shortcuts

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