ovsMgr

package
v0.0.0-...-ac9ef1f Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// OVSDB Server Location
	OVSDB_HANDLER_HOST_IP   = "10.1.10.229"
	OVSDB_HANDLER_HOST_PORT = 6640

	// OVSDB Table
	OVSDB_HANDLER_DB_TABLE = "OpenSwitch"

	// OVSDB macro defines
	OVSDB_HANDLER_OPERATIONS_SIZE = 1024
	OVSDB_FS_INITIAL_SIZE         = 100
)
View Source 
const (
	OVSDB_DEFAULT_VRF          = "vrf_default"
	OVSDB_BGP_ROUTER_TABLE     = "BGP_Router"
	OVSDB_BGP_NEIGHBOR_TABLE   = "BGP_Neighbor"
	OVSDB_VRF_TABLE            = "VRF"
	OVSDB_BGP_NEIGHBOR_ENTRIES = "bgp_neighbors"
	OVSDB_BGP_ROUTER_ENTRIES   = "bgp_routers"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BGPFlexSwitch 

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

type BGPOvsOperations 

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

type BGPOvsRouterInfo 

type BGPOvsRouterInfo struct {
	HoldTime      uint32 // default is 180 seconds
	KeepaliveTime uint32 // default is 60 seconds
	// contains filtered or unexported fields
}

type BGPOvsdbHandler 

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

func NewBGPOvsdbHandler 

func NewBGPOvsdbHandler(logger *logging.Writer, handler *rpc.BGPHandler) (*BGPOvsdbHandler, error)

func (*BGPOvsdbHandler) CreateBgpGlobalConfig 

func (ovsHdl *BGPOvsdbHandler) CreateBgpGlobalConfig(rtrInfo *BGPOvsRouterInfo) *bgpd.BGPGlobal
Creating bgp global flexswitch object using BGP_Router information that was

* parse/collected from ovsdb update

func (*BGPOvsdbHandler) DumpBgpNeighborInfo 

func (ovsHdl *BGPOvsdbHandler) DumpBgpNeighborInfo(addrs []net.IP, uuids []UUID,
	table ovsdb.TableUpdate)

func (*BGPOvsdbHandler) GetBGPNeighInfoFromBgpRouter 

func (ovsHdl *BGPOvsdbHandler) GetBGPNeighInfoFromBgpRouter() ([]net.IP, []UUID, error)

Get bgp neighbor uuids and addrs information from bgp router table

func (*BGPOvsdbHandler) GetBGPRouterAsn 

func (ovsHdl *BGPOvsdbHandler) GetBGPRouterAsn(table ovsdb.TableUpdate) (*BGPOvsRouterInfo, error)

Lets get asn number for the local bgp and also get the ovsdb BGP_Router uuid

func (*BGPOvsdbHandler) GetBGPRouterId 

func (ovsHdl *BGPOvsdbHandler) GetBGPRouterId(rtUuid UUID, table ovsdb.TableUpdate) string

Lets get router id for the asn

func (*BGPOvsdbHandler) HandleBGPNeighborUpd 

func (ovsHdl *BGPOvsdbHandler) HandleBGPNeighborUpd(table ovsdb.TableUpdate) error

BGP neighbor update in ovsdb... we will update our backend object

func (*BGPOvsdbHandler) HandleBGPRouteUpd 

func (ovsHdl *BGPOvsdbHandler) HandleBGPRouteUpd(table ovsdb.TableUpdate) error

func (*BGPOvsdbHandler) PopulateOvsdbCache 

func (ovsHdl *BGPOvsdbHandler) PopulateOvsdbCache(updates ovsdb.TableUpdates)
BGP OVS DB populate cache with the latest update information from the

* notification channel

func (*BGPOvsdbHandler) StartMonitoring 

func (ovsHdl *BGPOvsdbHandler) StartMonitoring() error

* BGP OVS DB server. * This API will handle reading operations from table... It can also do * transactions.... In short its read/write bgp ovsdb handler

func (*BGPOvsdbHandler) Transact 

func (ovsHdl *BGPOvsdbHandler) Transact(operations []ovsdb.Operation) error

BGP OVS DB transaction api handler

func (*BGPOvsdbHandler) UpdateInfo 

func (ovsHdl *BGPOvsdbHandler) UpdateInfo(updates ovsdb.TableUpdates)

BGP OVS DB handle update information

type BGPOvsdbNotifier 

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

func NewBGPOvsdbNotifier 

func NewBGPOvsdbNotifier(ch chan *ovsdb.TableUpdates) *BGPOvsdbNotifier

func (BGPOvsdbNotifier) Disconnected 

func (ovsHdl BGPOvsdbNotifier) Disconnected(client *ovsdb.OvsdbClient)

Stub interfaces for ovsdb library notifier

func (BGPOvsdbNotifier) Echo 

func (ovsHdl BGPOvsdbNotifier) Echo([]interface{})

Stub interfaces for ovsdb library notifier

func (BGPOvsdbNotifier) Locked 

func (ovsHdl BGPOvsdbNotifier) Locked([]interface{})

Stub interfaces for ovsdb library notifier

func (BGPOvsdbNotifier) Stolen 

func (ovsHdl BGPOvsdbNotifier) Stolen([]interface{})

Stub interfaces for ovsdb library notifier

func (BGPOvsdbNotifier) Update 

func (ovsHdl BGPOvsdbNotifier) Update(context interface{}, tableUpdates ovsdb.TableUpdates)

Stub interfaces for ovsdb library notifier

type OvsBfdMgr 

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

func NewOvsBfdMgr 

func NewOvsBfdMgr() *OvsBfdMgr

Constructor for bfd manager

func (*OvsBfdMgr) CreateBfdSession 

func (mgr *OvsBfdMgr) CreateBfdSession(ipAddr string, iface string, sessionParam string) (bool, error)

func (*OvsBfdMgr) DeleteBfdSession 

func (mgr *OvsBfdMgr) DeleteBfdSession(ipAddr string, iface string) (bool, error)

func (*OvsBfdMgr) Start 

func (mgr *OvsBfdMgr) Start()

type OvsIntfMgr 

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

func NewOvsIntfMgr 

func NewOvsIntfMgr() *OvsIntfMgr

Constructor for interface manager

func (*OvsIntfMgr) GetIPv4Information 

func (mgr *OvsIntfMgr) GetIPv4Information(ifIndex int32) (string, error)

func (*OvsIntfMgr) GetIPv4Intfs 

func (mgr *OvsIntfMgr) GetIPv4Intfs() []*config.IntfStateInfo

func (*OvsIntfMgr) GetIPv6Information 

func (mgr *OvsIntfMgr) GetIPv6Information(ifIndex int32) (string, error)

func (*OvsIntfMgr) GetIPv6Intfs 

func (mgr *OvsIntfMgr) GetIPv6Intfs() []*config.IntfStateInfo

func (*OvsIntfMgr) GetIPv6Neighbors 

func (mgr *OvsIntfMgr) GetIPv6Neighbors() []*config.IntfStateInfo

func (*OvsIntfMgr) GetIfIndex 

func (mgr *OvsIntfMgr) GetIfIndex(ifIndex, ifType int) int32

func (*OvsIntfMgr) GetLogicalIntfInfo 

func (m *OvsIntfMgr) GetLogicalIntfInfo() []config.IntfMapInfo

func (*OvsIntfMgr) GetPortInfo 

func (m *OvsIntfMgr) GetPortInfo() []config.IntfMapInfo

func (*OvsIntfMgr) GetVlanInfo 

func (m *OvsIntfMgr) GetVlanInfo() []config.IntfMapInfo

func (*OvsIntfMgr) PortStateChange 

func (mgr *OvsIntfMgr) PortStateChange()

func (*OvsIntfMgr) Start 

func (mgr *OvsIntfMgr) Start()

type OvsPolicyMgr 

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

func NewOvsPolicyMgr 

func NewOvsPolicyMgr() *OvsPolicyMgr

Constructor for policy manager

func (*OvsPolicyMgr) Start 

func (mgr *OvsPolicyMgr) Start()

type OvsRouteMgr 

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

func NewOvsRouteMgr 

func NewOvsRouteMgr() *OvsRouteMgr

Constructor for route manager

func (*OvsRouteMgr) ApplyPolicy 

func (mgr *OvsRouteMgr) ApplyPolicy(applyList []*config.ApplyPolicyInfo, undoList []*config.ApplyPolicyInfo)

func (*OvsRouteMgr) CreateRoute 

func (mgr *OvsRouteMgr) CreateRoute(cfg *config.RouteConfig)

func (*OvsRouteMgr) DeleteRoute 

func (mgr *OvsRouteMgr) DeleteRoute(cfg *config.RouteConfig)

func (*OvsRouteMgr) GetNextHopInfo 

func (mgr *OvsRouteMgr) GetNextHopInfo(ipAddr string, ifIndex int32) (*config.NextHopInfo, error)

func (*OvsRouteMgr) GetRoutes 

func (mgr *OvsRouteMgr) GetRoutes() ([]*config.RouteInfo, []*config.RouteInfo)

func (*OvsRouteMgr) Start 

func (mgr *OvsRouteMgr) Start()

func (*OvsRouteMgr) UpdateRoute 

func (mgr *OvsRouteMgr) UpdateRoute(cfg *config.RouteConfig, op string)

type UUID 

type UUID string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.