Documentation
¶
Index ¶
- type FlowProbeBundle
- type IpfixProbe
- type OvsSFlowProbe
- type OvsSFlowProbesHandler
- func (o *OvsSFlowProbesHandler) GetProbePath(index int64) string
- func (o *OvsSFlowProbesHandler) OnOvsBridgeAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsBridgeDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsBridgeUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsInterfaceAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsInterfaceDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsInterfaceUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsPortAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsPortDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) OnOvsPortUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
- func (o *OvsSFlowProbesHandler) Start()
- func (o *OvsSFlowProbesHandler) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlowProbeBundle ¶ added in v0.2.0
type FlowProbeBundle struct {
probe.ProbeBundle
}
func NewFlowProbeBundleFromConfig ¶ added in v0.2.0
func NewFlowProbeBundleFromConfig(tb *probes.TopologyProbeBundle, g *graph.Graph) *FlowProbeBundle
type IpfixProbe ¶
func NewIpfixProbe ¶
func NewIpfixProbe(addr string, port int) IpfixProbe
func (*IpfixProbe) Start ¶
func (probe *IpfixProbe) Start() error
type OvsSFlowProbe ¶ added in v0.2.0
type OvsSFlowProbesHandler ¶ added in v0.2.0
func NewOvsSFlowProbesHandler ¶ added in v0.2.0
func NewOvsSFlowProbesHandler(p *probes.OvsdbProbe, agent *sflow.SFlowAgent, expire int, cleanup int) *OvsSFlowProbesHandler
func NewOvsSFlowProbesHandlerFromConfig ¶ added in v0.2.0
func NewOvsSFlowProbesHandlerFromConfig(tb *probes.TopologyProbeBundle, g *graph.Graph, p *mappings.FlowMappingPipeline, a *analyzer.Client) *OvsSFlowProbesHandler
func (*OvsSFlowProbesHandler) GetProbePath ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) GetProbePath(index int64) string
func (*OvsSFlowProbesHandler) OnOvsBridgeAdd ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsBridgeAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) OnOvsBridgeDel ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsBridgeDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) OnOvsBridgeUpdate ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsBridgeUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) OnOvsInterfaceAdd ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsInterfaceAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) OnOvsInterfaceDel ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsInterfaceDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) OnOvsInterfaceUpdate ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsInterfaceUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) OnOvsPortAdd ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsPortAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) OnOvsPortDel ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsPortDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) OnOvsPortUpdate ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) OnOvsPortUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)
func (*OvsSFlowProbesHandler) Start ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) Start()
func (*OvsSFlowProbesHandler) Stop ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) Stop()
Source Files
¶
- ipfix.go
- ovssflow.go
- probes.go
Click to show internal directories.
Click to hide internal directories.