Documentation ¶
Index ¶
- type AFPacketHandle
- type FlowProbe
- type FlowProbeBundle
- type FlowProbeInterface
- type GoPacketProbe
- type GoPacketProbesHandler
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AFPacketHandle ¶ added in v0.6.0
type AFPacketHandle struct {
// contains filtered or unexported fields
}
func NewAFPacketHandle ¶ added in v0.6.0
func NewAFPacketHandle(ifName string, snaplen int32) (*AFPacketHandle, error)
func (*AFPacketHandle) Close ¶ added in v0.6.0
func (h *AFPacketHandle) Close()
func (*AFPacketHandle) ReadPacketData ¶ added in v0.6.0
func (h *AFPacketHandle) ReadPacketData() ([]byte, gopacket.CaptureInfo, error)
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 GoPacketProbe ¶ added in v0.6.0
type GoPacketProbe struct {
// contains filtered or unexported fields
}
func (*GoPacketProbe) SetProbeNode ¶ added in v0.6.0
func (p *GoPacketProbe) SetProbeNode(flow *flow.Flow) bool
type GoPacketProbesHandler ¶ added in v0.6.0
type GoPacketProbesHandler struct {
// contains filtered or unexported fields
}
func NewGoPacketProbesHandler ¶ added in v0.6.0
func NewGoPacketProbesHandler(g *graph.Graph) *GoPacketProbesHandler
func (*GoPacketProbesHandler) RegisterProbe ¶ added in v0.6.0
func (*GoPacketProbesHandler) Start ¶ added in v0.6.0
func (p *GoPacketProbesHandler) Start()
func (*GoPacketProbesHandler) Stop ¶ added in v0.6.0
func (p *GoPacketProbesHandler) Stop()
func (*GoPacketProbesHandler) UnregisterProbe ¶ added in v0.6.0
func (p *GoPacketProbesHandler) UnregisterProbe(n *graph.Node) error
type OnDemandProbeListener ¶ added in v0.3.0
type OnDemandProbeListener struct { sync.RWMutex graph.DefaultGraphListener Graph *graph.Graph Probes *FlowProbeBundle CaptureHandler *api.CaptureApiHandler // contains filtered or unexported fields }
func NewOnDemandProbeListener ¶ added in v0.3.0
func NewOnDemandProbeListener(fb *FlowProbeBundle, g *graph.Graph, ch *api.CaptureApiHandler) (*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
Click to show internal directories.
Click to hide internal directories.