sflow

Documentation

Index

• Variables
• type SFlowAgent
  • func NewSFlowAgent(u string, a *common.ServiceAddress, ft *flow.Table, bpfFilter string, ...) *SFlowAgent
  • func (sfa *SFlowAgent) GetTarget() string
  • func (sfa *SFlowAgent) Start()
  • func (sfa *SFlowAgent) Stop()
• type SFlowAgentAllocator
  • func NewSFlowAgentAllocator() (*SFlowAgentAllocator, error)
  • func (a *SFlowAgentAllocator) Alloc(uuid string, ft *flow.Table, bpfFilter string, headerSize uint32, ...) (agent *SFlowAgent, _ error)
  • func (a *SFlowAgentAllocator) Release(uuid string)
  • func (a *SFlowAgentAllocator) ReleaseAll()

Variables

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

Types

type SFlowAgent

type SFlowAgent struct {
	common.RWMutex
	UUID       string
	Addr       string
	Port       int
	FlowTable  *flow.Table
	Conn       *net.UDPConn
	BPFFilter  string
	HeaderSize uint32
}

SFlowAgent describes SFlow agent probe

func NewSFlowAgent

func NewSFlowAgent(u string, a *common.ServiceAddress, ft *flow.Table, bpfFilter string, headerSize uint32) *SFlowAgent

NewSFlowAgent creates a new sFlow agent which will populate the given flowtable

func (*SFlowAgent) GetTarget

func (sfa *SFlowAgent) GetTarget() string

GetTarget returns the current used connection

func (*SFlowAgent) Start

func (sfa *SFlowAgent) Start()

Start the SFlow probe agent

func (*SFlowAgent) Stop

func (sfa *SFlowAgent) Stop()

Stop the SFlow probe agent

type SFlowAgentAllocator

type SFlowAgentAllocator struct {
	common.RWMutex
	// contains filtered or unexported fields
}

SFlowAgentAllocator describes an SFlow agent allocator to manage multiple SFlow agent probe

func NewSFlowAgentAllocator

func NewSFlowAgentAllocator() (*SFlowAgentAllocator, error)

NewSFlowAgentAllocator creates a new sFlow agent allocator

func (*SFlowAgentAllocator) Alloc

func (a *SFlowAgentAllocator) Alloc(uuid string, ft *flow.Table, bpfFilter string, headerSize uint32, addr *common.ServiceAddress) (agent *SFlowAgent, _ error)

Alloc allocates a new sFlow agent

func (*SFlowAgentAllocator) Release

func (a *SFlowAgentAllocator) Release(uuid string)

Release a sFlow agent

func (*SFlowAgentAllocator) ReleaseAll

func (a *SFlowAgentAllocator) ReleaseAll()

ReleaseAll sFlow agents