Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type SFlowAgent ¶
type SFlowAgent struct {
UUID string
Addr string
Port int
AnalyzerClient *analyzer.Client
FlowMappingPipeline *mappings.FlowMappingPipeline
FlowProbePathSetter flow.FlowProbePathSetter
// contains filtered or unexported fields
}
func NewSFlowAgent ¶
func NewSFlowAgent(u string, a string, p int, c *analyzer.Client, m *mappings.FlowMappingPipeline) *SFlowAgent
func NewSFlowAgentFromConfig ¶
func NewSFlowAgentFromConfig(u string, a *analyzer.Client, m *mappings.FlowMappingPipeline) (*SFlowAgent, error)
func (*SFlowAgent) Flush ¶
func (sfa *SFlowAgent) Flush()
func (*SFlowAgent) GetTarget ¶
func (sfa *SFlowAgent) GetTarget() string
func (*SFlowAgent) SetFlowProbePathSetter ¶
func (sfa *SFlowAgent) SetFlowProbePathSetter(p flow.FlowProbePathSetter)
func (*SFlowAgent) Start ¶
func (sfa *SFlowAgent) Start()
func (*SFlowAgent) Stop ¶
func (sfa *SFlowAgent) Stop()
type SFlowAgentAllocator ¶
type SFlowAgentAllocator struct {
sync.RWMutex
AnalyzerClient *analyzer.Client
FlowMappingPipeline *mappings.FlowMappingPipeline
FlowProbePathSetter flow.FlowProbePathSetter
Addr string
MinPort int
MaxPort int
// contains filtered or unexported fields
}
func NewSFlowAgentAllocator ¶
func NewSFlowAgentAllocator(a *analyzer.Client, m *mappings.FlowMappingPipeline) *SFlowAgentAllocator
func (*SFlowAgentAllocator) Agents ¶
func (a *SFlowAgentAllocator) Agents() []*SFlowAgent
func (*SFlowAgentAllocator) Alloc ¶
func (a *SFlowAgentAllocator) Alloc(uuid string, p flow.FlowProbePathSetter) (*SFlowAgent, error)
func (*SFlowAgentAllocator) Release ¶
func (a *SFlowAgentAllocator) Release(uuid string)
func (*SFlowAgentAllocator) ReleaseAll ¶
func (a *SFlowAgentAllocator) ReleaseAll()
Source Files
¶
- agent.go
Click to show internal directories.
Click to hide internal directories.