Documentation ¶
Index ¶
- func StartScheduler(wg *sync.WaitGroup, manager *CollectManager) error
- type CollectManager
- type CollectorScheduler
- func (cScheduler CollectorScheduler) AddTopicsToCSPCollector(addTopicList []string)
- func (cScheduler CollectorScheduler) AddTopicsToCollector(addTopicList []string, maxHostCount int)
- func (cScheduler CollectorScheduler) BalanceTopicsToCollector(maxHostCount int)
- func (cScheduler CollectorScheduler) DeleteTopicsToCSPCollector(delTopicList []string)
- func (cScheduler CollectorScheduler) DeleteTopicsToCollector(delTopicList []string)
- func (cScheduler CollectorScheduler) DistributeTopicsToCollector()
- func (cScheduler CollectorScheduler) ProvisioningCollectorByCSP()
- func (cScheduler CollectorScheduler) ScaleInOutCollector()
- func (cScheduler CollectorScheduler) ScheduleCSPBasedCollector(addTopicList []string, delTopicList []string)
- func (cScheduler CollectorScheduler) SchedulePolicyBasedCollector(addTopicList []string, delTopicList []string)
- func (cScheduler CollectorScheduler) Scheduler() error
- func (cScheduler CollectorScheduler) WriteCollectorMapToInMemoryDB()
- type InMemoryTopic
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartScheduler ¶
func StartScheduler(wg *sync.WaitGroup, manager *CollectManager) error
Types ¶
type CollectManager ¶
type CollectManager struct { // Usage of CollectorAddrSlice => DeployType ==Dev, Compose CollectorAddrSlice []*collector.MetricCollector CollectorPolicy string K8sClientSet *kubernetes.Clientset WaitGroup *sync.WaitGroup }
func NewCollectorManager ¶
func NewCollectorManager() (*CollectManager, error)
func (*CollectManager) CreateCollector ¶
func (manager *CollectManager) CreateCollector() error
func (*CollectManager) DeleteCollector ¶
func (manager *CollectManager) DeleteCollector() error
func (*CollectManager) InitDFK8sEnv ¶
func (manager *CollectManager) InitDFK8sEnv() (err error)
type CollectorScheduler ¶
type CollectorScheduler struct {
// contains filtered or unexported fields
}
func NewCollectorScheduler ¶
func NewCollectorScheduler(wg *sync.WaitGroup, manager *CollectManager) (*CollectorScheduler, error)
func (CollectorScheduler) AddTopicsToCSPCollector ¶
func (cScheduler CollectorScheduler) AddTopicsToCSPCollector(addTopicList []string)
func (CollectorScheduler) AddTopicsToCollector ¶
func (cScheduler CollectorScheduler) AddTopicsToCollector(addTopicList []string, maxHostCount int)
func (CollectorScheduler) BalanceTopicsToCollector ¶
func (cScheduler CollectorScheduler) BalanceTopicsToCollector(maxHostCount int)
func (CollectorScheduler) DeleteTopicsToCSPCollector ¶
func (cScheduler CollectorScheduler) DeleteTopicsToCSPCollector(delTopicList []string)
func (CollectorScheduler) DeleteTopicsToCollector ¶
func (cScheduler CollectorScheduler) DeleteTopicsToCollector(delTopicList []string)
func (CollectorScheduler) DistributeTopicsToCollector ¶
func (cScheduler CollectorScheduler) DistributeTopicsToCollector()
func (CollectorScheduler) ProvisioningCollectorByCSP ¶
func (cScheduler CollectorScheduler) ProvisioningCollectorByCSP()
func (CollectorScheduler) ScaleInOutCollector ¶
func (cScheduler CollectorScheduler) ScaleInOutCollector()
func (CollectorScheduler) ScheduleCSPBasedCollector ¶
func (cScheduler CollectorScheduler) ScheduleCSPBasedCollector(addTopicList []string, delTopicList []string)
* ### CSP Policy Start ###
func (CollectorScheduler) SchedulePolicyBasedCollector ¶
func (cScheduler CollectorScheduler) SchedulePolicyBasedCollector(addTopicList []string, delTopicList []string)
* ### AgentCnt Policy Start ###
func (CollectorScheduler) Scheduler ¶
func (cScheduler CollectorScheduler) Scheduler() error
func (CollectorScheduler) WriteCollectorMapToInMemoryDB ¶
func (cScheduler CollectorScheduler) WriteCollectorMapToInMemoryDB()
type InMemoryTopic ¶
Click to show internal directories.
Click to hide internal directories.