Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
AgentAlreadyAllocated error = errors.New("agent already allocated for this uuid")
)
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 ¶ added in v0.3.0
func (sfa *SFlowAgent) Flush()
func (*SFlowAgent) GetTarget ¶
func (sfa *SFlowAgent) GetTarget() string
func (*SFlowAgent) SetFlowProbePathSetter ¶ added in v0.3.0
func (sfa *SFlowAgent) SetFlowProbePathSetter(p flow.FlowProbePathSetter)
func (*SFlowAgent) Start ¶
func (sfa *SFlowAgent) Start()
func (*SFlowAgent) Stop ¶
func (sfa *SFlowAgent) Stop()
type SFlowAgentAllocator ¶ added in v0.3.0
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 ¶ added in v0.3.0
func NewSFlowAgentAllocator(a *analyzer.Client, m *mappings.FlowMappingPipeline) *SFlowAgentAllocator
func (*SFlowAgentAllocator) Agents ¶ added in v0.3.0
func (a *SFlowAgentAllocator) Agents() []*SFlowAgent
func (*SFlowAgentAllocator) Alloc ¶ added in v0.3.0
func (a *SFlowAgentAllocator) Alloc(uuid string, p flow.FlowProbePathSetter) (*SFlowAgent, error)
func (*SFlowAgentAllocator) Release ¶ added in v0.3.0
func (a *SFlowAgentAllocator) Release(uuid string)
func (*SFlowAgentAllocator) ReleaseAll ¶ added in v0.3.0
func (a *SFlowAgentAllocator) ReleaseAll()
Click to show internal directories.
Click to hide internal directories.