Documentation
¶
Index ¶
- type FlowProbe
- type FlowProbeBundle
- type FlowProbeInterface
- 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) RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table) error
- func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, uuid string, ft *flow.Table) 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 FlowProbe struct {
// contains filtered or unexported fields
}
func (*FlowProbe) RegisterProbe ¶
type FlowProbeBundle ¶
type FlowProbeBundle struct {
probe.ProbeBundle
Graph *graph.Graph
FlowTableAllocator *flow.TableAllocator
}
func NewFlowProbeBundleFromConfig ¶
func NewFlowProbeBundleFromConfig(tb *probes.TopologyProbeBundle, g *graph.Graph, fta *flow.TableAllocator) *FlowProbeBundle
func (*FlowProbeBundle) UnregisterAllProbes ¶
func (fpb *FlowProbeBundle) UnregisterAllProbes()
type FlowProbeInterface ¶
type OnDemandProbeListener ¶
type OnDemandProbeListener struct {
sync.RWMutex
graph.DefaultGraphListener
Graph *graph.Graph
Probes *FlowProbeBundle
CaptureHandler *api.CaptureApiHandler
// contains filtered or unexported fields
}
func NewOnDemandProbeListener ¶
func NewOnDemandProbeListener(fb *FlowProbeBundle, g *graph.Graph, ch *api.CaptureApiHandler) (*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
ProbeNodeUUID string
}
func (*OvsSFlowProbe) SetProbeNode ¶
func (p *OvsSFlowProbe) SetProbeNode(flow *flow.Flow) bool
type OvsSFlowProbesHandler ¶
type OvsSFlowProbesHandler struct {
FlowProbe
Graph *graph.Graph
AnalyzerClient *analyzer.Client
// contains filtered or unexported fields
}
func NewOvsSFlowProbesHandler ¶
func NewOvsSFlowProbesHandler(tb *probes.TopologyProbeBundle, g *graph.Graph) *OvsSFlowProbesHandler
func (*OvsSFlowProbesHandler) RegisterProbe ¶
func (*OvsSFlowProbesHandler) RegisterProbeOnBridge ¶
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(g *graph.Graph) *PcapProbesHandler
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
¶
- ondemand.go
- ovssflow.go
- pcap.go
- probes.go
Click to show internal directories.
Click to hide internal directories.