Documentation ¶
Index ¶
- func TopicMangerInit()
- type APIServer
- type CollectManager
- func (manager *CollectManager) CreateCollectorGroup() error
- func (manager *CollectManager) FlushMonitoringData()
- func (manager *CollectManager) SetConfigurationToMemoryDB()
- func (manager *CollectManager) StartCollectorGroup(wg *sync.WaitGroup) error
- func (manager *CollectManager) StartScheduler(wg *sync.WaitGroup) error
- func (manager *CollectManager) StopCollectorGroup() error
- type CollectorScheduler
- func (cScheduler CollectorScheduler) NeedCollectorScaleInOut()
- func (cScheduler CollectorScheduler) NeedRebalancedTopics(currentTopicsState []string, currentMaxHostCount int) bool
- func (cScheduler CollectorScheduler) ReturnDiffTopics(beforeTopics []string, currentTopics []string) ([]string, []string)
- func (cScheduler CollectorScheduler) ScheduleBasedCollectorCSPType(currentTopicsState []string, beforeTopicsState []string, topicListChanged bool)
- func (cScheduler CollectorScheduler) ScheduleBasedTheNumberOfCollector(currentTopicsState []string, beforeTopicsState []string, ...)
- func (cScheduler CollectorScheduler) Scheduler() error
- func (cScheduler CollectorScheduler) SendTopicsToCollectors()
- type TopicManager
- func (t *TopicManager) AddNewTopics(newTopicList []string, maxHostCount int) error
- func (t *TopicManager) AddNewTopicsOnCSPCollector(newTopicList []string) error
- func (t *TopicManager) DeleteAllTopicsInfo() error
- func (t *TopicManager) DeleteTopics(deletedTopicList []string) error
- func (t *TopicManager) SetTopicToCollectorBasedCSPTypeOfAgent(topicList []string)
- func (t *TopicManager) SetTopicToCollectorBasedTheNumberOfAgent(topicList []string, maxHostCount int)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func TopicMangerInit ¶ added in v0.2.8
func TopicMangerInit()
Types ¶
type APIServer ¶
type APIServer struct {
// contains filtered or unexported fields
}
func (*APIServer) SetRoutingRule ¶
func (apiServer *APIServer) SetRoutingRule(e *echo.Echo)
type CollectManager ¶
type CollectManager struct { CollectorGroupManageMap map[int][]*collector.MetricCollector WaitGroup *sync.WaitGroup // contains filtered or unexported fields }
func NewCollectorManager ¶
func NewCollectorManager() (*CollectManager, error)
func (*CollectManager) CreateCollectorGroup ¶ added in v0.2.8
func (manager *CollectManager) CreateCollectorGroup() error
func (*CollectManager) FlushMonitoringData ¶
func (manager *CollectManager) FlushMonitoringData()
func (*CollectManager) SetConfigurationToMemoryDB ¶ added in v0.2.8
func (manager *CollectManager) SetConfigurationToMemoryDB()
func (*CollectManager) StartCollectorGroup ¶ added in v0.2.8
func (manager *CollectManager) StartCollectorGroup(wg *sync.WaitGroup) error
func (*CollectManager) StartScheduler ¶ added in v0.2.8
func (manager *CollectManager) StartScheduler(wg *sync.WaitGroup) error
func (*CollectManager) StopCollectorGroup ¶ added in v0.2.8
func (manager *CollectManager) StopCollectorGroup() error
type CollectorScheduler ¶
type CollectorScheduler struct {
// contains filtered or unexported fields
}
func NewCollectorScheduler ¶
func NewCollectorScheduler(manager *CollectManager) (*CollectorScheduler, error)
func (CollectorScheduler) NeedCollectorScaleInOut ¶ added in v0.2.8
func (cScheduler CollectorScheduler) NeedCollectorScaleInOut()
func (CollectorScheduler) NeedRebalancedTopics ¶ added in v0.2.8
func (cScheduler CollectorScheduler) NeedRebalancedTopics(currentTopicsState []string, currentMaxHostCount int) bool
func (CollectorScheduler) ReturnDiffTopics ¶ added in v0.2.8
func (cScheduler CollectorScheduler) ReturnDiffTopics(beforeTopics []string, currentTopics []string) ([]string, []string)
################# Common methods ################
func (CollectorScheduler) ScheduleBasedCollectorCSPType ¶ added in v0.2.8
func (cScheduler CollectorScheduler) ScheduleBasedCollectorCSPType(currentTopicsState []string, beforeTopicsState []string, topicListChanged bool)
################# ScheduleBasedCollectorCSPType Start ################
func (CollectorScheduler) ScheduleBasedTheNumberOfCollector ¶ added in v0.2.8
func (cScheduler CollectorScheduler) ScheduleBasedTheNumberOfCollector(currentTopicsState []string, beforeTopicsState []string, beforeMaxHostCount int, currentMaxHostCount int, topicListChanged bool, maxHostCountChanged bool)
################# ScheduleBasedTheNumberOfCollector Start ################
func (CollectorScheduler) Scheduler ¶ added in v0.2.8
func (cScheduler CollectorScheduler) Scheduler() error
func (CollectorScheduler) SendTopicsToCollectors ¶ added in v0.2.8
func (cScheduler CollectorScheduler) SendTopicsToCollectors()
type TopicManager ¶ added in v0.2.8
type TopicManager struct { IdealCollectorGroupMap map[int][]string IdealCollectorPerAgentCntSlice []int }
func TopicMangerInstance ¶ added in v0.2.8
func TopicMangerInstance() *TopicManager
func (*TopicManager) AddNewTopics ¶ added in v0.2.8
func (t *TopicManager) AddNewTopics(newTopicList []string, maxHostCount int) error
func (*TopicManager) AddNewTopicsOnCSPCollector ¶ added in v0.2.8
func (t *TopicManager) AddNewTopicsOnCSPCollector(newTopicList []string) error
func (*TopicManager) DeleteAllTopicsInfo ¶ added in v0.2.8
func (t *TopicManager) DeleteAllTopicsInfo() error
func (*TopicManager) DeleteTopics ¶ added in v0.2.8
func (t *TopicManager) DeleteTopics(deletedTopicList []string) error
func (*TopicManager) SetTopicToCollectorBasedCSPTypeOfAgent ¶ added in v0.2.8
func (t *TopicManager) SetTopicToCollectorBasedCSPTypeOfAgent(topicList []string)
func (*TopicManager) SetTopicToCollectorBasedTheNumberOfAgent ¶ added in v0.2.8
func (t *TopicManager) SetTopicToCollectorBasedTheNumberOfAgent(topicList []string, maxHostCount int)
Click to show internal directories.
Click to hide internal directories.