Documentation
¶
Index ¶
- Variables
- func IsCaptureAllowed(n *graph.Node) bool
- 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 ¶
View Source
var CaptureTypes = map[string]map[string][]string{
"ovsbridge": {"allowed": {"ovssflow"}, "default": {"ovssflow"}},
"device": {"allowed": {"pcap"}, "default": {"pcap"}},
"internal": {"allowed": {"pcap"}, "default": {"pcap"}},
"veth": {"allowed": {"pcap"}, "default": {"pcap"}},
"tun": {"allowed": {"pcap"}, "default": {"pcap"}},
"bridge": {"allowed": {"pcap"}, "default": {"pcap"}},
}
Functions ¶
Types ¶
type FlowProbe ¶ added in v0.3.0
type FlowProbe struct {
// contains filtered or unexported fields
}
func (*FlowProbe) AsyncFlowPipeline ¶ added in v0.4.0
func (*FlowProbe) RegisterProbe ¶ added in v0.3.0
type FlowProbeBundle ¶ added in v0.2.0
type FlowProbeBundle struct {
probe.ProbeBundle
Graph *graph.Graph
FlowTableAllocator *flow.TableAllocator
}
func NewFlowProbeBundleFromConfig ¶ added in v0.2.0
func NewFlowProbeBundleFromConfig(tb *probes.TopologyProbeBundle, g *graph.Graph, fta *flow.TableAllocator) *FlowProbeBundle
func (*FlowProbeBundle) UnregisterAllProbes ¶ added in v0.3.0
func (fpb *FlowProbeBundle) UnregisterAllProbes()
type FlowProbeInterface ¶ added in v0.4.0
type OnDemandProbeListener ¶ added in v0.3.0
type OnDemandProbeListener struct {
sync.RWMutex
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
ProbeNodeUUID string
}
func (*OvsSFlowProbe) SetProbeNode ¶ added in v0.4.0
func (p *OvsSFlowProbe) SetProbeNode(flow *flow.Flow) bool
type OvsSFlowProbesHandler ¶ added in v0.2.0
type OvsSFlowProbesHandler struct {
FlowProbe
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) *OvsSFlowProbesHandler
func (*OvsSFlowProbesHandler) RegisterProbe ¶ added in v0.3.0
func (*OvsSFlowProbesHandler) RegisterProbeOnBridge ¶ added in v0.3.0
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(g *graph.Graph) *PcapProbesHandler
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
Source Files
¶
- ondemand.go
- ovssflow.go
- pcap.go
- probes.go
Click to show internal directories.
Click to hide internal directories.