sflow

package

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

Details

This section is empty.

View Source

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

This section is empty.

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

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

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

func (sfa *SFlowAgent) Flush()

func (sfa *SFlowAgent) GetTarget() string

func (sfa *SFlowAgent) Start()

func (sfa *SFlowAgent) Stop()

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

func NewSFlowAgentAllocator() *SFlowAgentAllocator

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

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

func (a *SFlowAgentAllocator) Release(uuid string)

func (a *SFlowAgentAllocator) ReleaseAll()