probes

package

Go to main page

Versions in this module

v0

v0.6.0

Oct 6, 2016

Changes in this version

+ type AFPacketHandle struct

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

+ func (h *AFPacketHandle) Close()

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

+ type GoPacketProbe struct

+ func (p *GoPacketProbe) SetProbeNode(flow *flow.Flow) bool

+ type GoPacketProbesHandler struct

+ 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

v0.5.0

Sep 15, 2016

v0.4.0

Aug 4, 2016

Changes in this version

+ var CaptureTypes = map[string]map[string][]string

+ func IsCaptureAllowed(n *graph.Node) bool

type FlowProbe

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

+ func (fp FlowProbe) Start()

+ func (fp FlowProbe) Stop()

type FlowProbeBundle

+ FlowTableAllocator *flow.TableAllocator

+ type FlowProbeInterface interface

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

+ UnregisterProbe func(n *graph.Node) error

type OvsSFlowProbe

+ ProbeNodeUUID string

+ func (p *OvsSFlowProbe) SetProbeNode(flow *flow.Flow) bool

type PcapProbe

+ func (p *PcapProbe) SetProbeNode(flow *flow.Flow) bool

v0.3.0

Apr 26, 2016

Changes in this version

+ type FlowProbe interface

+ Flush func()

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

+ UnregisterProbe func(n *graph.Node) error

type FlowProbeBundle

+ Graph *graph.Graph

+ func (fpb *FlowProbeBundle) Flush()

+ func (fpb *FlowProbeBundle) UnregisterAllProbes()

+ type OnDemandProbeListener struct

+ CaptureHandler api.ApiHandler

+ Graph *graph.Graph

+ Probes *FlowProbeBundle

+ func NewOnDemandProbeListener(fb *FlowProbeBundle, g *graph.Graph, ch api.ApiHandler) (*OnDemandProbeListener, error)

+ func (o *OnDemandProbeListener) OnEdgeAdded(e *graph.Edge)

+ func (o *OnDemandProbeListener) OnNodeAdded(n *graph.Node)

+ func (o *OnDemandProbeListener) OnNodeDeleted(n *graph.Node)

+ func (o *OnDemandProbeListener) OnNodeUpdated(n *graph.Node)

+ func (o *OnDemandProbeListener) Start() error

+ func (o *OnDemandProbeListener) Stop()

type OvsSFlowProbe

+ ProbeGraphPath string

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

type OvsSFlowProbesHandler

+ AnalyzerClient *analyzer.Client

+ func (o *OvsSFlowProbesHandler) Flush()

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

+ func (o *OvsSFlowProbesHandler) RegisterProbeOnBridge(bridgeUUID string, path string) error

+ func (o *OvsSFlowProbesHandler) UnregisterProbe(n *graph.Node) error

+ func (o *OvsSFlowProbesHandler) UnregisterSFlowProbeFromBridge(bridgeUUID string) error

+ type PcapProbe struct

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

+ type PcapProbesHandler struct

+ func NewPcapProbesHandler(tb *probes.TopologyProbeBundle, g *graph.Graph, ...) *PcapProbesHandler

+ func (o *PcapProbesHandler) Flush()

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

+ func (p *PcapProbesHandler) Start()

+ func (p *PcapProbesHandler) Stop()

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

v0.2.0

Feb 23, 2016

Changes in this version

+ type FlowProbeBundle struct

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

+ type OvsSFlowProbe struct

+ HeaderSize uint32

+ ID string

+ Interface string

+ Polling uint32

+ Sampling uint32

+ Target string

+ type OvsSFlowProbesHandler struct

+ Graph *graph.Graph

+ func NewOvsSFlowProbesHandler(p *probes.OvsdbProbe, agent *sflow.SFlowAgent, expire int, cleanup int) *OvsSFlowProbesHandler

+ func NewOvsSFlowProbesHandlerFromConfig(tb *probes.TopologyProbeBundle, g *graph.Graph, ...) *OvsSFlowProbesHandler

+ func (o *OvsSFlowProbesHandler) GetProbePath(index int64) string

+ func (o *OvsSFlowProbesHandler) OnOvsBridgeAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) OnOvsBridgeDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) OnOvsBridgeUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) OnOvsInterfaceAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) OnOvsInterfaceDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) OnOvsInterfaceUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) OnOvsPortAdd(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) OnOvsPortDel(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) OnOvsPortUpdate(monitor *ovsdb.OvsMonitor, uuid string, row *libovsdb.RowUpdate)

+ func (o *OvsSFlowProbesHandler) Start()

+ func (o *OvsSFlowProbesHandler) Stop()

v0.1.0

Feb 10, 2016

Changes in this version

+ type IpfixProbe struct

+ Addr string

+ Port int

+ func NewIpfixProbe(addr string, port int) IpfixProbe

+ func (probe *IpfixProbe) Start() error

+ type Probe interface

+ GetTarget func() string

+ SetAnalyzerClient func(a *analyzer.Client)

+ SetMappingPipeline func(p *mappings.FlowMappingPipeline)

+ Start func() error

+ type SFlowProbe struct

+ Addr string

+ AnalyzerClient *analyzer.Client

+ FlowMappingPipeline *mappings.FlowMappingPipeline

+ Graph *graph.Graph

+ Port int

+ func NewSFlowProbe(a string, p int, g *graph.Graph, expire int, cleanup int) (*SFlowProbe, error)

+ func NewSFlowProbeFromConfig(g *graph.Graph) (*SFlowProbe, error)

+ func (probe *SFlowProbe) GetTarget() string

+ func (probe *SFlowProbe) SetAnalyzerClient(a *analyzer.Client)

+ func (probe *SFlowProbe) SetMappingPipeline(p *mappings.FlowMappingPipeline)

+ func (probe *SFlowProbe) Start() error

+ func (probe *SFlowProbe) Stop()

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