Documentation
¶
Index ¶
- type Notifier
- type OvsClient
- type OvsMonitor
- type OvsMonitorHandler
- type OvsOpsExecutor
- type OvsSFlowProbesHandler
- func (o *OvsSFlowProbesHandler) OnOvsBridgeAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsBridgeDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsBridgeUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsInterfaceAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsInterfaceDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsInterfaceUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsPortAdd(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsPortDel(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsPortUpdate(monitor *OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- type SFlowProbe
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) Update ¶
func (n Notifier) Update(context interface{}, tableUpdates libovsdb.TableUpdates)
type OvsClient ¶
type OvsClient struct {
// contains filtered or unexported fields
}
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)
Source Files
¶
- ovsdb.go
- sflow.go
Click to show internal directories.
Click to hide internal directories.