probes

package
v0.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 12, 2017 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

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
}

AFPacketHandle describes a AF network kernel packets

func NewAFPacketHandle added in v0.9.0 

func NewAFPacketHandle(ifName string, snaplen int32) (*AFPacketHandle, error)

NewAFPacketHandle creates a new network AF packet probe

func (*AFPacketHandle) Close added in v0.9.0 

func (h *AFPacketHandle) Close()

Close the AF packet handle

func (*AFPacketHandle) ReadPacketData added in v0.9.0 

func (h *AFPacketHandle) ReadPacketData() ([]byte, gopacket.CaptureInfo, error)

ReadPacketData reads one packet

type FlowProbe added in v0.3.0 

type FlowProbe struct {
	// contains filtered or unexported fields
}

FlowProbe link the pool of client and probes

func (*FlowProbe) AsyncFlowPipeline added in v0.5.0 

func (fp *FlowProbe) AsyncFlowPipeline(flows []*flow.Flow)

AsyncFlowPipeline run the flow pipeline

func (*FlowProbe) RegisterProbe added in v0.3.0 

func (fp *FlowProbe) RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table, e FlowProbeEventHandler) error

RegisterProbe a probe

func (*FlowProbe) Start added in v0.5.0 

func (fp *FlowProbe) Start()

Start the probe

func (*FlowProbe) Stop added in v0.5.0 

func (fp *FlowProbe) Stop()

Stop the probe

func (*FlowProbe) UnregisterProbe added in v0.3.0 

func (fp *FlowProbe) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error

UnregisterProbe a probe

type FlowProbeBundle added in v0.3.0 

type FlowProbeBundle struct {
	probe.ProbeBundle
	Graph              *graph.Graph
	FlowTableAllocator *flow.TableAllocator
}

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()
}

type FlowProbeInterface added in v0.5.0 

type FlowProbeInterface interface {
	probe.Probe
	RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table, e FlowProbeEventHandler) error
	UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error
}

FlowProbeInterface defines flow probe mechanism

type GoPacketProbe added in v0.9.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.9.0 

type GoPacketProbesHandler struct {
	// contains filtered or unexported fields
}

GoPacketProbesHandler describes a flow probe handle in the graph

func NewGoPacketProbesHandler added in v0.9.0 

func NewGoPacketProbesHandler(g *graph.Graph) (*GoPacketProbesHandler, error)

NewGoPacketProbesHandler creates a new gopacket probe in the graph

func (*GoPacketProbesHandler) RegisterProbe added in v0.9.0 

func (p *GoPacketProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table, e FlowProbeEventHandler) error

RegisterProbe registers a gopacket probe

func (*GoPacketProbesHandler) Start added in v0.9.0 

func (p *GoPacketProbesHandler) Start()

Start probe

func (*GoPacketProbesHandler) Stop added in v0.9.0 

func (p *GoPacketProbesHandler) Stop()

Stop probe

func (*GoPacketProbesHandler) UnregisterProbe added in v0.9.0 

func (p *GoPacketProbesHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error

UnregisterProbe unregisters gopacket probe

type OvsSFlowProbe added in v0.3.0 

type OvsSFlowProbe struct {
	ID         string
	Interface  string
	Target     string
	HeaderSize uint32
	Sampling   uint32
	Polling    uint32
	NodeTID    string
}

OvsSFlowProbe describes a SFlow probe from OVS switch

type OvsSFlowProbesHandler added in v0.3.0 

type OvsSFlowProbesHandler struct {
	FlowProbe
	Graph *graph.Graph
	// contains filtered or unexported fields
}

OvsSFlowProbesHandler describes a flow probe in running in the graph

func NewOvsSFlowProbesHandler added in v0.3.0 

func NewOvsSFlowProbesHandler(tb *probe.ProbeBundle, g *graph.Graph) (*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, ft *flow.Table, 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, ft *flow.Table, capture *api.Capture) error

RegisterProbeOnBridge registers a new probe on the OVS bridge

func (*OvsSFlowProbesHandler) Start added in v0.3.0 

func (o *OvsSFlowProbesHandler) Start()

Start the probe

func (*OvsSFlowProbesHandler) Stop added in v0.3.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.12.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.12.0 

type PcapSocketProbeHandler struct {
	// contains filtered or unexported fields
}

PcapSocketProbeHandler describes a Pcap socket probe in the graph

func NewPcapSocketProbeHandler added in v0.12.0 

func NewPcapSocketProbeHandler(g *graph.Graph) (*PcapSocketProbeHandler, error)

NewPcapSocketProbeHandler creates a new pcap socket probe

func (*PcapSocketProbeHandler) RegisterProbe added in v0.12.0 

func (p *PcapSocketProbeHandler) RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table, e FlowProbeEventHandler) error

RegisterProbe registers a new probe in the graph

func (*PcapSocketProbeHandler) Start added in v0.12.0 

func (p *PcapSocketProbeHandler) Start()

Start the probe

func (*PcapSocketProbeHandler) Stop added in v0.12.0 

func (p *PcapSocketProbeHandler) Stop()

Stop the probe

func (*PcapSocketProbeHandler) UnregisterProbe added in v0.12.0 

func (p *PcapSocketProbeHandler) UnregisterProbe(n *graph.Node, e FlowProbeEventHandler) error

UnregisterProbe a probe

type SFlowProbesHandler added in v0.12.0 

type SFlowProbesHandler struct {
	FlowProbe
	Graph *graph.Graph
	// contains filtered or unexported fields
}

SFlowProbesHandler describes a SFlow probe in the graph

func NewSFlowProbesHandler added in v0.12.0 

func NewSFlowProbesHandler(g *graph.Graph) (*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, ft *flow.Table, 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) Stop added in v0.12.0 

func (d *SFlowProbesHandler) Stop()

Stop 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
  • ovssflow.go
  • pcapsocket.go
  • probes.go
  • sflow.go

Directories

Path Synopsis
Package afpacket provides Go bindings for MMap'd AF_PACKET socket reading.
 Package afpacket provides Go bindings for MMap'd AF_PACKET socket reading.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.