ovsdb

package
v0.21.0 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const ConnectionPollInterval time.Duration = 4 * time.Second

ConnectionPollInterval poll OVS database every 4 seconds

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultOvsMonitorHandler added in v0.21.0 

type DefaultOvsMonitorHandler struct {
}

DefaultOvsMonitorHandler default implementation of an handler

func (*DefaultOvsMonitorHandler) OnConnected added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnConnected(monitor *OvsMonitor)

OnConnected default implementation

func (*DefaultOvsMonitorHandler) OnDisconnected added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnDisconnected(monitor *OvsMonitor)

OnDisconnected default implementation

func (*DefaultOvsMonitorHandler) OnOvsBridgeAdd added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsBridgeAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsBridgeAdd default implementation

func (*DefaultOvsMonitorHandler) OnOvsBridgeDel added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsBridgeDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsBridgeDel default implementation

func (*DefaultOvsMonitorHandler) OnOvsBridgeUpdate added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsBridgeUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsBridgeUpdate default implementation

func (*DefaultOvsMonitorHandler) OnOvsInterfaceAdd added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsInterfaceAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsInterfaceAdd default implementation

func (*DefaultOvsMonitorHandler) OnOvsInterfaceDel added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsInterfaceDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsInterfaceDel default implementation

func (*DefaultOvsMonitorHandler) OnOvsInterfaceUpdate added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsInterfaceUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsInterfaceUpdate default implementation

func (*DefaultOvsMonitorHandler) OnOvsPortAdd added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsPortAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsPortAdd default implementation

func (*DefaultOvsMonitorHandler) OnOvsPortDel added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsPortDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsPortDel default implementation

func (*DefaultOvsMonitorHandler) OnOvsPortUpdate added in v0.21.0 

func (d *DefaultOvsMonitorHandler) OnOvsPortUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

OnOvsPortUpdate default implementation

type Notifier 

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

Notifier describes a notification based on the monitor

func (Notifier) Disconnected 

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

Disconnected OVS notifier event

func (Notifier) Echo 

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

Echo OVS notifier event

func (Notifier) Locked 

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

Locked OVS notifier event

func (Notifier) Stolen 

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

Stolen OVS notifier event

func (Notifier) Update 

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

Update OVS notifier tables event

type OvsClient 

type OvsClient struct {
	common.RWMutex
	// contains filtered or unexported fields
}

OvsClient describes an OVS database client connection

func (*OvsClient) Exec 

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

Exec execute a transaction on the OVS database

type OvsMonitor 

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

OvsMonitor describes an OVS client Monitor

func NewOvsMonitor 

func NewOvsMonitor(protocol string, target string) *OvsMonitor

NewOvsMonitor creates a new monitoring probe agent on target

func (*OvsMonitor) AddMonitorHandler 

func (o *OvsMonitor) AddMonitorHandler(handler OvsMonitorHandler)

AddMonitorHandler subscribe a new monitor events handler

func (*OvsMonitor) ExcludeColumn added in v0.4.0 

func (o *OvsMonitor) ExcludeColumn(table, column string)

ExcludeColumn excludes the given table/column to be monitored. All columns can be excluded using "*" as column name.

func (*OvsMonitor) IncludeColumn added in v0.16.0 

func (o *OvsMonitor) IncludeColumn(table, column string)

IncludeColumn includes the given column in the set of the monitored column. Columns are excluded and then included in that order. By default all the column are included.

func (*OvsMonitor) StartMonitoring 

func (o *OvsMonitor) StartMonitoring()

StartMonitoring start the OVS database monitoring

func (*OvsMonitor) StopMonitoring 

func (o *OvsMonitor) StopMonitoring()

StopMonitoring stop the OVS database monitoring

type OvsMonitorHandler 

type OvsMonitorHandler interface {
	OnConnected(monitor *OvsMonitor)
	OnDisconnected(monitor *OvsMonitor)
	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)
}

OvsMonitorHandler describes an OVS Monitor interface mechanism

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.