Documentation
¶
Index ¶
- type AFPacketHandle
- type FlowProbe
- type FlowProbeBundle
- type FlowProbeInterface
- type GoPacketProbe
- type GoPacketProbesHandler
- type OvsSFlowProbe
- type OvsSFlowProbesHandler
- func (o *OvsSFlowProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table) error
- func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, tid 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.9.0
type AFPacketHandle struct {
// contains filtered or unexported fields
}
func NewAFPacketHandle ¶ added in v0.9.0
func NewAFPacketHandle(ifName string, snaplen int32) (*AFPacketHandle, error)
func (*AFPacketHandle) Close ¶ added in v0.9.0
func (h *AFPacketHandle) Close()
func (*AFPacketHandle) ReadPacketData ¶ added in v0.9.0
func (h *AFPacketHandle) ReadPacketData() ([]byte, gopacket.CaptureInfo, error)
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 *probe.ProbeBundle, g *graph.Graph, fta *flow.TableAllocator) *FlowProbeBundle
func (*FlowProbeBundle) UnregisterAllProbes ¶
func (fpb *FlowProbeBundle) UnregisterAllProbes()
type FlowProbeInterface ¶
type GoPacketProbe ¶ added in v0.9.0
type GoPacketProbe struct {
NodeTID string
// contains filtered or unexported fields
}
type GoPacketProbesHandler ¶ added in v0.9.0
type GoPacketProbesHandler struct {
// contains filtered or unexported fields
}
func NewGoPacketProbesHandler ¶ added in v0.9.0
func NewGoPacketProbesHandler(g *graph.Graph) *GoPacketProbesHandler
func (*GoPacketProbesHandler) RegisterProbe ¶ added in v0.9.0
func (*GoPacketProbesHandler) Start ¶ added in v0.9.0
func (p *GoPacketProbesHandler) Start()
func (*GoPacketProbesHandler) Stop ¶ added in v0.9.0
func (p *GoPacketProbesHandler) Stop()
func (*GoPacketProbesHandler) UnregisterProbe ¶ added in v0.9.0
func (p *GoPacketProbesHandler) UnregisterProbe(n *graph.Node) error
type OvsSFlowProbe ¶
type OvsSFlowProbesHandler ¶
type OvsSFlowProbesHandler struct {
FlowProbe
Graph *graph.Graph
// contains filtered or unexported fields
}
func NewOvsSFlowProbesHandler ¶
func NewOvsSFlowProbesHandler(tb *probe.ProbeBundle, 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
Source Files
¶
- afpacket.go
- gopacket.go
- ovssflow.go
- probes.go
Click to show internal directories.
Click to hide internal directories.