probes

Documentation

Index

• type AFPacketHandle
  • func NewAFPacketHandle(ifName string, snaplen int32) (*AFPacketHandle, error)
  • func (h *AFPacketHandle) Close()
  • func (h *AFPacketHandle) ReadPacketData() ([]byte, gopacket.CaptureInfo, error)
• type FlowProbe
  • func (fp *FlowProbe) AsyncFlowPipeline(flows []*flow.Flow)
  • func (fp *FlowProbe) RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table) error
  • func (fp FlowProbe) Start()
  • func (fp FlowProbe) Stop()
  • func (fp *FlowProbe) UnregisterProbe(n *graph.Node) error
• type FlowProbeBundle
  • func NewFlowProbeBundleFromConfig(tb *probe.ProbeBundle, g *graph.Graph, fta *flow.TableAllocator) *FlowProbeBundle
  • func (fpb *FlowProbeBundle) UnregisterAllProbes()
• type FlowProbeInterface
• type GoPacketProbe
• type GoPacketProbesHandler
  • func NewGoPacketProbesHandler(g *graph.Graph) *GoPacketProbesHandler
  • func (p *GoPacketProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table) error
  • func (p *GoPacketProbesHandler) Start()
  • func (p *GoPacketProbesHandler) Stop()
  • func (p *GoPacketProbesHandler) UnregisterProbe(n *graph.Node) error
• type OvsSFlowProbe
• type OvsSFlowProbesHandler
  • func NewOvsSFlowProbesHandler(tb *probe.ProbeBundle, g *graph.Graph) *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

Types

type AFPacketHandle

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

func NewAFPacketHandle

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

func (*AFPacketHandle) Close

func (h *AFPacketHandle) Close()

func (*AFPacketHandle) ReadPacketData

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

type FlowProbe

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

func (*FlowProbe) AsyncFlowPipeline

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

func (*FlowProbe) RegisterProbe

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

func (FlowProbe) Start

func (fp FlowProbe) Start()

func (FlowProbe) Stop

func (fp FlowProbe) Stop()

func (*FlowProbe) UnregisterProbe

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

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 FlowProbeInterface interface {
	probe.Probe
	RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table) error
	UnregisterProbe(n *graph.Node) error
}

type GoPacketProbe

type GoPacketProbe struct {
	NodeUUID string
	// contains filtered or unexported fields
}

type GoPacketProbesHandler

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

func NewGoPacketProbesHandler

func NewGoPacketProbesHandler(g *graph.Graph) *GoPacketProbesHandler

func (*GoPacketProbesHandler) RegisterProbe

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

func (*GoPacketProbesHandler) Start

func (p *GoPacketProbesHandler) Start()

func (*GoPacketProbesHandler) Stop

func (p *GoPacketProbesHandler) Stop()

func (*GoPacketProbesHandler) UnregisterProbe

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

type OvsSFlowProbe

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

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 (o *OvsSFlowProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture, ft *flow.Table) error

func (*OvsSFlowProbesHandler) RegisterProbeOnBridge

func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, uuid string, ft *flow.Table) error

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