sflow

package

v0.10.0 Latest Latest Go to latest Published: Mar 31, 2017 License: Apache-2.0 Imports: 11 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
	BPFFilter string
}

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

func (sfa *SFlowAgent) GetTarget() string

func (sfa *SFlowAgent) Start()

func (sfa *SFlowAgent) Stop()

type SFlowAgentAllocator struct {
	sync.RWMutex

	Addr string
	// contains filtered or unexported fields
}

func NewSFlowAgentAllocator() (*SFlowAgentAllocator, error)

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

func (a *SFlowAgentAllocator) Release(uuid string)

func (a *SFlowAgentAllocator) ReleaseAll()