Documentation
¶
Index ¶
- type FlowProbe
- type FlowProbeBundle
- type IpfixProbe
- type OnDemandProbeListener
- func (o *OnDemandProbeListener) OnEdgeAdded(e *graph.Edge)
- func (o *OnDemandProbeListener) OnNodeAdded(n *graph.Node)
- func (o *OnDemandProbeListener) OnNodeDeleted(n *graph.Node)
- func (o *OnDemandProbeListener) OnNodeUpdated(n *graph.Node)
- func (o *OnDemandProbeListener) Start() error
- func (o *OnDemandProbeListener) Stop()
- type OvsSFlowProbe
- type OvsSFlowProbesHandler
- func (o *OvsSFlowProbesHandler) Flush()
- func (o *OvsSFlowProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture) error
- func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, path string) error
- func (o *OvsSFlowProbesHandler) Start()
- func (o *OvsSFlowProbesHandler) Stop()
- func (o *OvsSFlowProbesHandler) UnregisterProbe(n *graph.Node) error
- func (o *OvsSFlowProbesHandler) UnregisterSFlowProbeFromBridge(bridgeUUID string) error
- type PcapProbe
- type PcapProbesHandler
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
Graph *graph.Graph
}
func NewFlowProbeBundleFromConfig ¶ added in v0.2.0
func NewFlowProbeBundleFromConfig(tb *probes.TopologyProbeBundle, g *graph.Graph) *FlowProbeBundle
func (*FlowProbeBundle) Flush ¶ added in v0.3.0
func (fpb *FlowProbeBundle) Flush()
func (*FlowProbeBundle) UnregisterAllProbes ¶ added in v0.3.0
func (fpb *FlowProbeBundle) UnregisterAllProbes()
type IpfixProbe ¶
func NewIpfixProbe ¶
func NewIpfixProbe(addr string, port int) IpfixProbe
func (*IpfixProbe) Start ¶
func (probe *IpfixProbe) Start() error
type OnDemandProbeListener ¶ added in v0.3.0
type OnDemandProbeListener struct {
graph.DefaultGraphListener
Graph *graph.Graph
Probes *FlowProbeBundle
CaptureHandler api.ApiHandler
// contains filtered or unexported fields
}
func NewOnDemandProbeListener ¶ added in v0.3.0
func NewOnDemandProbeListener(fb *FlowProbeBundle, g *graph.Graph, ch api.ApiHandler) (*OnDemandProbeListener, error)
func (*OnDemandProbeListener) OnEdgeAdded ¶ added in v0.3.0
func (o *OnDemandProbeListener) OnEdgeAdded(e *graph.Edge)
func (*OnDemandProbeListener) OnNodeAdded ¶ added in v0.3.0
func (o *OnDemandProbeListener) OnNodeAdded(n *graph.Node)
func (*OnDemandProbeListener) OnNodeDeleted ¶ added in v0.3.0
func (o *OnDemandProbeListener) OnNodeDeleted(n *graph.Node)
func (*OnDemandProbeListener) OnNodeUpdated ¶ added in v0.3.0
func (o *OnDemandProbeListener) OnNodeUpdated(n *graph.Node)
func (*OnDemandProbeListener) Start ¶ added in v0.3.0
func (o *OnDemandProbeListener) Start() error
func (*OnDemandProbeListener) Stop ¶ added in v0.3.0
func (o *OnDemandProbeListener) Stop()
type OvsSFlowProbe ¶ added in v0.2.0
type OvsSFlowProbe struct {
ID string
Interface string
Target string
HeaderSize uint32
Sampling uint32
Polling uint32
ProbeGraphPath string
}
func (*OvsSFlowProbe) SetProbePath ¶ added in v0.3.0
func (p *OvsSFlowProbe) SetProbePath(flow *flow.Flow) bool
type OvsSFlowProbesHandler ¶ added in v0.2.0
type OvsSFlowProbesHandler struct {
Graph *graph.Graph
AnalyzerClient *analyzer.Client
// contains filtered or unexported fields
}
func NewOvsSFlowProbesHandler ¶ added in v0.2.0
func NewOvsSFlowProbesHandler(tb *probes.TopologyProbeBundle, g *graph.Graph, m *mappings.FlowMappingPipeline, a *analyzer.Client) *OvsSFlowProbesHandler
func (*OvsSFlowProbesHandler) Flush ¶ added in v0.3.0
func (o *OvsSFlowProbesHandler) Flush()
func (*OvsSFlowProbesHandler) RegisterProbe ¶ added in v0.3.0
func (*OvsSFlowProbesHandler) RegisterProbeOnBridge ¶ added in v0.3.0
func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, path string) error
func (*OvsSFlowProbesHandler) Start ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) Start()
func (*OvsSFlowProbesHandler) Stop ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) Stop()
func (*OvsSFlowProbesHandler) UnregisterProbe ¶ added in v0.3.0
func (o *OvsSFlowProbesHandler) UnregisterProbe(n *graph.Node) error
func (*OvsSFlowProbesHandler) UnregisterSFlowProbeFromBridge ¶ added in v0.3.0
func (o *OvsSFlowProbesHandler) UnregisterSFlowProbeFromBridge(bridgeUUID string) error
type PcapProbe ¶ added in v0.3.0
type PcapProbe struct {
// contains filtered or unexported fields
}
type PcapProbesHandler ¶ added in v0.3.0
type PcapProbesHandler struct {
// contains filtered or unexported fields
}
func NewPcapProbesHandler ¶ added in v0.3.0
func NewPcapProbesHandler(tb *probes.TopologyProbeBundle, g *graph.Graph, p *mappings.FlowMappingPipeline, a *analyzer.Client) *PcapProbesHandler
func (*PcapProbesHandler) Flush ¶ added in v0.3.0
func (o *PcapProbesHandler) Flush()
func (*PcapProbesHandler) RegisterProbe ¶ added in v0.3.0
func (*PcapProbesHandler) Start ¶ added in v0.3.0
func (p *PcapProbesHandler) Start()
func (*PcapProbesHandler) Stop ¶ added in v0.3.0
func (p *PcapProbesHandler) Stop()
func (*PcapProbesHandler) UnregisterProbe ¶ added in v0.3.0
func (p *PcapProbesHandler) UnregisterProbe(n *graph.Node) error
Click to show internal directories.
Click to hide internal directories.