sflow

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Jan 27, 2017 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	AgentAlreadyAllocated error = errors.New("agent already allocated for this uuid")
)

Functions

This section is empty.

Types

type SFlowAgent

type SFlowAgent struct {
	UUID      string
	Addr      string
	Port      int
	FlowTable *flow.Table
	Conn      *net.UDPConn
}

func NewSFlowAgent

func NewSFlowAgent(u string, a string, p int, ft *flow.Table) *SFlowAgent

func NewSFlowAgentFromConfig

func NewSFlowAgentFromConfig(u string, ft *flow.Table) (*SFlowAgent, error)

func (*SFlowAgent) Flush added in v0.3.0

func (sfa *SFlowAgent) Flush()

func (*SFlowAgent) GetTarget

func (sfa *SFlowAgent) GetTarget() string

func (*SFlowAgent) Start

func (sfa *SFlowAgent) Start()

func (*SFlowAgent) Stop

func (sfa *SFlowAgent) Stop()

type SFlowAgentAllocator added in v0.3.0

type SFlowAgentAllocator struct {
	sync.RWMutex
	Addr    string
	MinPort int
	MaxPort int
	// contains filtered or unexported fields
}

func NewSFlowAgentAllocator added in v0.3.0

func NewSFlowAgentAllocator() *SFlowAgentAllocator

func (*SFlowAgentAllocator) Agents added in v0.3.0

func (a *SFlowAgentAllocator) Agents() []*SFlowAgent

func (*SFlowAgentAllocator) Alloc added in v0.3.0

func (a *SFlowAgentAllocator) Alloc(uuid string, ft *flow.Table) (*SFlowAgent, error)

func (*SFlowAgentAllocator) Release added in v0.3.0

func (a *SFlowAgentAllocator) Release(uuid string)

func (*SFlowAgentAllocator) ReleaseAll added in v0.3.0

func (a *SFlowAgentAllocator) ReleaseAll()

Jump to

Keyboard shortcuts

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