probes

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2016 License: Apache-2.0 Imports: 25 Imported by: 20

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FlowProbe added in v0.3.0

type FlowProbe interface {
	RegisterProbe(n *graph.Node, capture *api.Capture) error
	UnregisterProbe(n *graph.Node) error
	Flush()
}

type FlowProbeBundle added in v0.2.0

type FlowProbeBundle struct {
	probe.ProbeBundle
	Graph *graph.Graph
}

func NewFlowProbeBundleFromConfig added in v0.2.0

func NewFlowProbeBundleFromConfig(tb *probes.TopologyProbeBundle, g *graph.Graph) *FlowProbeBundle

func (*FlowProbeBundle) Flush added in v0.3.0

func (fpb *FlowProbeBundle) Flush()

func (*FlowProbeBundle) UnregisterAllProbes added in v0.3.0

func (fpb *FlowProbeBundle) UnregisterAllProbes()

type IpfixProbe

type IpfixProbe struct {
	Addr string
	Port int
}

func NewIpfixProbe

func NewIpfixProbe(addr string, port int) IpfixProbe

func (*IpfixProbe) Start

func (probe *IpfixProbe) Start() error

type OnDemandProbeListener added in v0.3.0

type OnDemandProbeListener struct {
	graph.DefaultGraphListener
	Graph          *graph.Graph
	Probes         *FlowProbeBundle
	CaptureHandler api.ApiHandler
	// contains filtered or unexported fields
}

func NewOnDemandProbeListener added in v0.3.0

func NewOnDemandProbeListener(fb *FlowProbeBundle, g *graph.Graph, ch api.ApiHandler) (*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
	ProbeGraphPath string
}

func (*OvsSFlowProbe) SetProbePath added in v0.3.0

func (p *OvsSFlowProbe) SetProbePath(flow *flow.Flow) bool

type OvsSFlowProbesHandler added in v0.2.0

type OvsSFlowProbesHandler struct {
	Graph          *graph.Graph
	AnalyzerClient *analyzer.Client
	// contains filtered or unexported fields
}

func (*OvsSFlowProbesHandler) Flush added in v0.3.0

func (o *OvsSFlowProbesHandler) Flush()

func (*OvsSFlowProbesHandler) RegisterProbe added in v0.3.0

func (o *OvsSFlowProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture) error

func (*OvsSFlowProbesHandler) RegisterProbeOnBridge added in v0.3.0

func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, path string) 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

type PcapProbe added in v0.3.0

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

func (*PcapProbe) SetProbePath added in v0.3.0

func (p *PcapProbe) SetProbePath(flow *flow.Flow) bool

type PcapProbesHandler added in v0.3.0

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

func NewPcapProbesHandler added in v0.3.0

func (*PcapProbesHandler) Flush added in v0.3.0

func (o *PcapProbesHandler) Flush()

func (*PcapProbesHandler) RegisterProbe added in v0.3.0

func (p *PcapProbesHandler) RegisterProbe(n *graph.Node, capture *api.Capture) error

func (*PcapProbesHandler) Start added in v0.3.0

func (p *PcapProbesHandler) Start()

func (*PcapProbesHandler) Stop added in v0.3.0

func (p *PcapProbesHandler) Stop()

func (*PcapProbesHandler) UnregisterProbe added in v0.3.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL