probes

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Feb 10, 2016 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 Probe

type Probe interface {
	GetTarget() string
	SetAnalyzerClient(a *analyzer.Client)
	SetMappingPipeline(p *mappings.FlowMappingPipeline)
	Start() error
}

type SFlowProbe

type SFlowProbe struct {
	Addr string
	Port int

	Graph               *graph.Graph
	AnalyzerClient      *analyzer.Client
	FlowMappingPipeline *mappings.FlowMappingPipeline
	// contains filtered or unexported fields
}

func NewSFlowProbe

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

func NewSFlowProbeFromConfig

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

func (*SFlowProbe) GetTarget

func (probe *SFlowProbe) GetTarget() string

func (*SFlowProbe) SetAnalyzerClient

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

func (*SFlowProbe) SetMappingPipeline

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

func (*SFlowProbe) Start

func (probe *SFlowProbe) Start() error

func (*SFlowProbe) Stop

func (probe *SFlowProbe) Stop()

Source Files

  • agent.go
  • ipfix.go
  • sflow.go

Jump to

Keyboard shortcuts

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