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