Documentation
¶
Index ¶
- Variables
- type AFPacketHandle
- type DPDKProbesHandler
- type EBPFProbesHandler
- type FlowProbe
- type FlowProbeBundle
- type FlowProbeEventHandler
- type FlowProbeTableAllocator
- type GoPacketProbe
- type GoPacketProbesHandler
- type OvsSFlowProbe
- type OvsSFlowProbesHandler
- func (o *OvsSFlowProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, e FlowProbeEventHandler) error
- func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, tid string, capture *api.Capture) error
- func (o *OvsSFlowProbesHandler) Start()
- func (o *OvsSFlowProbesHandler) Stop()
- func (o *OvsSFlowProbesHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
- func (o *OvsSFlowProbesHandler) UnregisterSFlowProbeFromBridge(bridgeUUID string) error
- type PcapSocketProbe
- type PcapSocketProbeHandler
- type SFlowProbesHandler
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type AFPacketHandle ¶ added in v0.6.0
type AFPacketHandle struct {
// contains filtered or unexported fields
}
AFPacketHandle describes a AF network kernel packets
func NewAFPacketHandle ¶ added in v0.6.0
func NewAFPacketHandle(ifName string, snaplen int32) (*AFPacketHandle, error)
NewAFPacketHandle creates a new network AF packet probe
func (*AFPacketHandle) Close ¶ added in v0.6.0
func (h *AFPacketHandle) Close()
Close the AF packet handle
func (*AFPacketHandle) ReadPacketData ¶ added in v0.6.0
func (h *AFPacketHandle) ReadPacketData() ([]byte, gopacket.CaptureInfo, error)
ReadPacketData reads one packet
type DPDKProbesHandler ¶ added in v0.14.0
type DPDKProbesHandler struct {
}
DPDKProbesHandler describes a flow probe handle in the graph
func NewDPDKProbesHandler ¶ added in v0.14.0
func NewDPDKProbesHandler(g *graph.Graph, fpta *FlowProbeTableAllocator) (*DPDKProbesHandler, error)
NewDPDKProbesHandler creates a new gopacket probe in the graph
func (*DPDKProbesHandler) RegisterProbe ¶ added in v0.14.0
func (p *DPDKProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, e FlowProbeEventHandler) error
RegisterProbe registers a gopacket probe
func (*DPDKProbesHandler) UnregisterProbe ¶ added in v0.14.0
func (p *DPDKProbesHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
UnregisterProbe unregisters gopacket probe
type EBPFProbesHandler ¶ added in v0.15.0
type EBPFProbesHandler struct {
}
EBPFProbesHandler describes a flow probe handle in the graph
func NewEBPFProbesHandler ¶ added in v0.15.0
func NewEBPFProbesHandler(g *graph.Graph, fpta *FlowProbeTableAllocator) (*EBPFProbesHandler, error)
NewEBPFProbesHandler creates a new gopacket probe in the graph
func (*EBPFProbesHandler) RegisterProbe ¶ added in v0.15.0
func (p *EBPFProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, e FlowProbeEventHandler) error
RegisterProbe registers a gopacket probe
func (*EBPFProbesHandler) UnregisterProbe ¶ added in v0.15.0
func (p *EBPFProbesHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
UnregisterProbe unregisters gopacket probe
type FlowProbe ¶ added in v0.3.0
type FlowProbe interface {
probe.Probe // inheritance of the probe.Probe interface Start/Stop functions
RegisterProbe(n *graph.Node, capture *api.Capture, e FlowProbeEventHandler) error
UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
}
FlowProbe defines flow probe mechanism
type FlowProbeBundle ¶ added in v0.2.0
type FlowProbeBundle struct {
probe.ProbeBundle
}
FlowProbeBundle describes a flow probes bundle
func NewFlowProbeBundle ¶ added in v0.12.0
func NewFlowProbeBundle(tb *probe.ProbeBundle, g *graph.Graph, fta *flow.TableAllocator, fcpool *analyzer.FlowClientPool) *FlowProbeBundle
type FlowProbeEventHandler ¶ added in v0.13.0
type FlowProbeEventHandler interface {
OnStarted()
OnStopped()
}
FlowProbeEventHandler used by probes to notify capture state
type FlowProbeTableAllocator ¶ added in v0.14.0
type FlowProbeTableAllocator struct {
*flow.TableAllocator
// contains filtered or unexported fields
}
FlowProbeTableAllocator allocates table and set the table update callback
type GoPacketProbe ¶ added in v0.6.0
type GoPacketProbe struct {
NodeTID string
// contains filtered or unexported fields
}
GoPacketProbe describes a new probe that store packets from gopacket pcap library in a flowtable
type GoPacketProbesHandler ¶ added in v0.6.0
type GoPacketProbesHandler struct {
// contains filtered or unexported fields
}
GoPacketProbesHandler describes a flow probe handle in the graph
func NewGoPacketProbesHandler ¶ added in v0.6.0
func NewGoPacketProbesHandler(g *graph.Graph, fpta *FlowProbeTableAllocator) (*GoPacketProbesHandler, error)
NewGoPacketProbesHandler creates a new gopacket probe in the graph
func (*GoPacketProbesHandler) RegisterProbe ¶ added in v0.6.0
func (p *GoPacketProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, e FlowProbeEventHandler) error
RegisterProbe registers a gopacket probe
func (*GoPacketProbesHandler) Start ¶ added in v0.6.0
func (p *GoPacketProbesHandler) Start()
Start probe
func (*GoPacketProbesHandler) Stop ¶ added in v0.6.0
func (p *GoPacketProbesHandler) Stop()
Stop probe
func (*GoPacketProbesHandler) UnregisterProbe ¶ added in v0.6.0
func (p *GoPacketProbesHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
UnregisterProbe unregisters gopacket probe
type OvsSFlowProbe ¶ added in v0.2.0
type OvsSFlowProbe struct {
ID string
Interface string
Target string
HeaderSize uint32
Sampling uint32
Polling uint32
NodeTID string
// contains filtered or unexported fields
}
OvsSFlowProbe describes a SFlow probe from OVS switch
type OvsSFlowProbesHandler ¶ added in v0.2.0
OvsSFlowProbesHandler describes a flow probe in running in the graph
func NewOvsSFlowProbesHandler ¶ added in v0.2.0
func NewOvsSFlowProbesHandler(g *graph.Graph, fpta *FlowProbeTableAllocator, tb *probe.ProbeBundle) (*OvsSFlowProbesHandler, error)
NewOvsSFlowProbesHandler creates a new OVS SFlow porbes
func (*OvsSFlowProbesHandler) RegisterProbe ¶ added in v0.3.0
func (o *OvsSFlowProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, e FlowProbeEventHandler) error
RegisterProbe registers a probe on a graph node
func (*OvsSFlowProbesHandler) RegisterProbeOnBridge ¶ added in v0.3.0
func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, tid string, capture *api.Capture) error
RegisterProbeOnBridge registers a new probe on the OVS bridge
func (*OvsSFlowProbesHandler) Start ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) Start()
Start the probe
func (*OvsSFlowProbesHandler) Stop ¶ added in v0.2.0
func (o *OvsSFlowProbesHandler) Stop()
Stop the probe
func (*OvsSFlowProbesHandler) UnregisterProbe ¶ added in v0.3.0
func (o *OvsSFlowProbesHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
UnregisterProbe at the graph node
func (*OvsSFlowProbesHandler) UnregisterSFlowProbeFromBridge ¶ added in v0.3.0
func (o *OvsSFlowProbesHandler) UnregisterSFlowProbeFromBridge(bridgeUUID string) error
UnregisterSFlowProbeFromBridge unregisters a flow probe from the bridge selected by UUID
type PcapSocketProbe ¶ added in v0.10.0
type PcapSocketProbe struct {
// contains filtered or unexported fields
}
PcapSocketProbe describes a TCP packet listener that inject packets in a flowtable
type PcapSocketProbeHandler ¶ added in v0.10.0
type PcapSocketProbeHandler struct {
// contains filtered or unexported fields
}
PcapSocketProbeHandler describes a Pcap socket probe in the graph
func NewPcapSocketProbeHandler ¶ added in v0.10.0
func NewPcapSocketProbeHandler(g *graph.Graph, fpta *FlowProbeTableAllocator) (*PcapSocketProbeHandler, error)
NewPcapSocketProbeHandler creates a new pcap socket probe
func (*PcapSocketProbeHandler) RegisterProbe ¶ added in v0.10.0
func (p *PcapSocketProbeHandler) RegisterProbe(n *graph.Node, capture *api.Capture, e FlowProbeEventHandler) error
RegisterProbe registers a new probe in the graph
func (*PcapSocketProbeHandler) Start ¶ added in v0.10.0
func (p *PcapSocketProbeHandler) Start()
Start the probe
func (*PcapSocketProbeHandler) Stop ¶ added in v0.10.0
func (p *PcapSocketProbeHandler) Stop()
Stop the probe
func (*PcapSocketProbeHandler) UnregisterProbe ¶ added in v0.10.0
func (p *PcapSocketProbeHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
UnregisterProbe a probe
type SFlowProbesHandler ¶ added in v0.12.0
SFlowProbesHandler describes a SFlow probe in the graph
func NewSFlowProbesHandler ¶ added in v0.12.0
func NewSFlowProbesHandler(g *graph.Graph, fpta *FlowProbeTableAllocator) (*SFlowProbesHandler, error)
NewSFlowProbesHandler creates a new SFlow probe in the graph
func (*SFlowProbesHandler) RegisterProbe ¶ added in v0.12.0
func (d *SFlowProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, e FlowProbeEventHandler) error
RegisterProbe registers a probe in the graph
func (*SFlowProbesHandler) Start ¶ added in v0.12.0
func (d *SFlowProbesHandler) Start()
Start a probe
func (*SFlowProbesHandler) UnregisterProbe ¶ added in v0.12.0
func (d *SFlowProbesHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
UnregisterProbe unregisters a probe from the graph
Source Files
¶
- afpacket.go
- gopacket.go
- no_dpdk.go
- no_ebpf.go
- ovssflow.go
- pcapsocket.go
- probes.go
- sflow.go