sflow

Documentation

Index

• Variables
• type SFlowAgent
  • 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
  • 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()

Variables

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

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

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

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

func NewSFlowAgentAllocator

func NewSFlowAgentAllocator() *SFlowAgentAllocator

func (*SFlowAgentAllocator) Agents

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

func (*SFlowAgentAllocator) Alloc

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

func (*SFlowAgentAllocator) Release

func (a *SFlowAgentAllocator) Release(uuid string)

func (*SFlowAgentAllocator) ReleaseAll

func (a *SFlowAgentAllocator) ReleaseAll()