ovsdb

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Feb 10, 2016 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Notifier

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

func (Notifier) Disconnected

func (n Notifier) Disconnected(*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
	Addr            string
	Port            int
	OvsClient       OvsOpsExecutor
	MonitorHandlers []OvsMonitorHandler
	// contains filtered or unexported fields
}

func NewOvsMonitor

func NewOvsMonitor(addr string, port int) *OvsMonitor

func NewOvsMonitorFromConfig

func NewOvsMonitorFromConfig() *OvsMonitor

func (*OvsMonitor) AddMonitorHandler

func (o *OvsMonitor) AddMonitorHandler(handler OvsMonitorHandler)

func (*OvsMonitor) StartMonitoring

func (o *OvsMonitor) StartMonitoring() error

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)
}

type OvsOpsExecutor

type OvsOpsExecutor interface {
	Exec(operations ...libovsdb.Operation) ([]libovsdb.OperationResult, error)
}

type OvsSFlowProbesHandler

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

func NewOvsSFlowProbesHandler

func NewOvsSFlowProbesHandler(probes []SFlowProbe) *OvsSFlowProbesHandler

func (*OvsSFlowProbesHandler) OnOvsBridgeAdd

func (o *OvsSFlowProbesHandler) OnOvsBridgeAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

func (*OvsSFlowProbesHandler) OnOvsBridgeDel

func (o *OvsSFlowProbesHandler) OnOvsBridgeDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

func (*OvsSFlowProbesHandler) OnOvsBridgeUpdate

func (o *OvsSFlowProbesHandler) OnOvsBridgeUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

func (*OvsSFlowProbesHandler) OnOvsInterfaceAdd

func (o *OvsSFlowProbesHandler) OnOvsInterfaceAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

func (*OvsSFlowProbesHandler) OnOvsInterfaceDel

func (o *OvsSFlowProbesHandler) OnOvsInterfaceDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

func (*OvsSFlowProbesHandler) OnOvsInterfaceUpdate

func (o *OvsSFlowProbesHandler) OnOvsInterfaceUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

func (*OvsSFlowProbesHandler) OnOvsPortAdd

func (o *OvsSFlowProbesHandler) OnOvsPortAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

func (*OvsSFlowProbesHandler) OnOvsPortDel

func (o *OvsSFlowProbesHandler) OnOvsPortDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

func (*OvsSFlowProbesHandler) OnOvsPortUpdate

func (o *OvsSFlowProbesHandler) OnOvsPortUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)

type SFlowProbe

type SFlowProbe struct {
	ID         string
	Interface  string
	Target     string
	HeaderSize uint32
	Sampling   uint32
	Polling    uint32
}

Source Files

  • ovsdb.go
  • sflow.go

Jump to

Keyboard shortcuts

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