probes

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2016 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.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 (fp *FlowProbe) AsyncFlowPipeline(flows []*flow.Flow)

func (*FlowProbe) RegisterProbe added in v0.3.0 

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

func (FlowProbe) Start added in v0.4.0 

func (fp FlowProbe) Start()

func (FlowProbe) Stop added in v0.4.0 

func (fp FlowProbe) Stop()

func (*FlowProbe) UnregisterProbe added in v0.3.0 

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

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

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

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

func (*OvsSFlowProbesHandler) RegisterProbeOnBridge added in v0.3.0 

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

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

Source Files

View all Source files

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.