ovsdb

Documentation

Index

• Constants
• type Notifier
  • func (n Notifier) Disconnected(c *libovsdb.OvsdbClient)
  • func (n Notifier) Echo([]interface{})
  • func (n Notifier) Locked([]interface{})
  • func (n Notifier) Stolen([]interface{})
  • func (n Notifier) Update(context interface{}, tableUpdates libovsdb.TableUpdates)
• type OvsClient
  • func (o *OvsClient) Exec(operations ...libovsdb.Operation) ([]libovsdb.OperationResult, error)
• type OvsMonitor
  • func NewOvsMonitor(protcol string, target string) *OvsMonitor
  • func (o *OvsMonitor) AddMonitorHandler(handler OvsMonitorHandler)
  • func (o *OvsMonitor) ExcludeColumn(column string)
  • func (o *OvsMonitor) StartMonitoring()
  • func (o *OvsMonitor) StopMonitoring()
• type OvsMonitorHandler

Constants

const ConnectionPollInterval time.Duration = 4 * time.Second

Types

type Notifier

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

func (Notifier) Disconnected

func (n Notifier) Disconnected(c *libovsdb.OvsdbClient)

func (Notifier) Echo

func (n Notifier) Echo([]interface{})

func (Notifier) Locked

func (n Notifier) Locked([]interface{})

func (Notifier) Stolen

func (n Notifier) Stolen([]interface{})

func (Notifier) Update

func (n Notifier) Update(context interface{}, tableUpdates libovsdb.TableUpdates)

type OvsClient

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

func (*OvsClient) Exec

func (o *OvsClient) Exec(operations ...libovsdb.Operation) ([]libovsdb.OperationResult, error)

type OvsMonitor

type OvsMonitor struct {
	sync.RWMutex
	Protocol        string
	Target          string
	OvsClient       *OvsClient
	MonitorHandlers []OvsMonitorHandler
	// contains filtered or unexported fields
}

func NewOvsMonitor

func NewOvsMonitor(protcol string, target string) *OvsMonitor

func (*OvsMonitor) AddMonitorHandler

func (o *OvsMonitor) AddMonitorHandler(handler OvsMonitorHandler)

func (*OvsMonitor) ExcludeColumn

func (o *OvsMonitor) ExcludeColumn(column string)

func (*OvsMonitor) StartMonitoring

func (o *OvsMonitor) StartMonitoring()

func (*OvsMonitor) StopMonitoring

func (o *OvsMonitor) StopMonitoring()

type OvsMonitorHandler

type OvsMonitorHandler interface {
	OnOvsBridgeAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
	OnOvsBridgeDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
	OnOvsBridgeUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
	OnOvsInterfaceAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
	OnOvsInterfaceDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
	OnOvsInterfaceUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
	OnOvsPortAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
	OnOvsPortDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
	OnOvsPortUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
}