ovsdbDriver

Documentation

Index

• type OvsDriver
  • func NewOvsDriver(bridgeName string) *OvsDriver
  • func (self *OvsDriver) AddController(ipAddr string, portNo uint16) error
  • func (self *OvsDriver) CreateBridge(bridgeName string) error
  • func (self *OvsDriver) CreatePort(intfName, intfType string, vlanTag uint) error
  • func (self *OvsDriver) CreateVtep(intfName string, vtepRemoteIP string) error
  • func (self *OvsDriver) DeleteBridge(bridgeName string) error
  • func (self *OvsDriver) DeletePort(intfName string) error
  • func (self *OvsDriver) DeleteVtep(intfName string) error
  • func (self *OvsDriver) Disconnected(ovsClient *libovsdb.OvsdbClient)
  • func (self *OvsDriver) Echo([]interface{})
  • func (self *OvsDriver) GetOfpPortNo(intfName string) (uint32, error)
  • func (self *OvsDriver) IsBridgePresent(bridgeName string) bool
  • func (self *OvsDriver) IsControllerPresent(target string) bool
  • func (self *OvsDriver) IsPortNamePresent(intfName string) bool
  • func (self *OvsDriver) IsVtepPresent(remoteIp string) (bool, string)
  • func (self *OvsDriver) Locked([]interface{})
  • func (self *OvsDriver) PrintCache()
  • func (self *OvsDriver) RemoveController(target string) error
  • func (self *OvsDriver) Stolen([]interface{})
  • func (self *OvsDriver) Update(context interface{}, tableUpdates libovsdb.TableUpdates)

Types

type OvsDriver

type OvsDriver struct {

	// Name of the OVS bridge
	OvsBridgeName string
	// contains filtered or unexported fields
}

OVS driver state

func NewOvsDriver

func NewOvsDriver(bridgeName string) *OvsDriver

Create a new OVS driver

func (*OvsDriver) AddController

func (self *OvsDriver) AddController(ipAddr string, portNo uint16) error

Add controller configuration to OVS

func (*OvsDriver) CreateBridge

func (self *OvsDriver) CreateBridge(bridgeName string) error

**************** OVS driver API ********************

func (*OvsDriver) CreatePort

func (self *OvsDriver) CreatePort(intfName, intfType string, vlanTag uint) error

Create an internal port in OVS

func (*OvsDriver) CreateVtep

func (self *OvsDriver) CreateVtep(intfName string, vtepRemoteIP string) error

Create a VTEP port on the OVS

func (*OvsDriver) DeleteBridge

func (self *OvsDriver) DeleteBridge(bridgeName string) error

Delete a bridge from ovs

func (*OvsDriver) DeletePort

func (self *OvsDriver) DeletePort(intfName string) error

Delete a port from OVS

func (*OvsDriver) DeleteVtep

func (self *OvsDriver) DeleteVtep(intfName string) error

Delete a VTEP port

func (*OvsDriver) Disconnected

func (self *OvsDriver) Disconnected(ovsClient *libovsdb.OvsdbClient)

func (*OvsDriver) Echo

func (self *OvsDriver) Echo([]interface{})

func (*OvsDriver) GetOfpPortNo

func (self *OvsDriver) GetOfpPortNo(intfName string) (uint32, error)

Return OFP port number for an interface

func (*OvsDriver) IsBridgePresent

func (self *OvsDriver) IsBridgePresent(bridgeName string) bool

Check if the bridge entry already exists

func (*OvsDriver) IsControllerPresent

func (self *OvsDriver) IsControllerPresent(target string) bool

Check if Controller already exists

func (*OvsDriver) IsPortNamePresent

func (self *OvsDriver) IsPortNamePresent(intfName string) bool

Check the local cache and see if the portname is taken already HACK alert: This is used to pick next port number instead of managing

port number space actively across agent restarts

func (*OvsDriver) IsVtepPresent

func (self *OvsDriver) IsVtepPresent(remoteIp string) (bool, string)

Check if VTEP already exists

func (*OvsDriver) Locked

func (self *OvsDriver) Locked([]interface{})

func (*OvsDriver) PrintCache

func (self *OvsDriver) PrintCache()

Dump the contents of the cache into stdout

func (*OvsDriver) RemoveController

func (self *OvsDriver) RemoveController(target string) error

func (*OvsDriver) Stolen

func (self *OvsDriver) Stolen([]interface{})

func (*OvsDriver) Update

func (self *OvsDriver) Update(context interface{}, tableUpdates libovsdb.TableUpdates)

************************ Notification handler for OVS DB changes ****************