push

Documentation

Index

• func StartScheduler(wg *sync.WaitGroup, manager *CollectManager) error
• type CollectManager
  • func NewCollectorManager() (*CollectManager, error)
  • func (manager *CollectManager) CreateCollector() error
  • func (manager *CollectManager) DeleteCollector() error
  • func (manager *CollectManager) InitDFK8sEnv() (err error)
• type CollectorScheduler
  • func NewCollectorScheduler(wg *sync.WaitGroup, manager *CollectManager) (*CollectorScheduler, error)
  • 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

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

type InMemoryTopic struct {
	TopicMap             map[int][]string
	CollectorPerAgentCnt []int
}