Documentation ¶
Index ¶
- func StartScheduler(collectManager CollectManager) error
- type CollectManager
- type CollectorScheduler
- func (cScheduler CollectorScheduler) AddTopicsToCollector(addTopicList []string)
- func (cScheduler CollectorScheduler) DeleteTopicsToCollector(delTopicList []string)
- func (cScheduler CollectorScheduler) DoSchedule() error
- func (cScheduler CollectorScheduler) ProvisioningCollector()
- func (cScheduler CollectorScheduler) SchedulePolicyBasedCollector(addTopicList []string, delTopicList []string)
- func (cScheduler CollectorScheduler) TriggerCollector()
- func (cScheduler CollectorScheduler) WriteCollectorMapToInMemoryDB()
- type InMemoryTopic
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartScheduler ¶
func StartScheduler(collectManager CollectManager) error
StartScheduler MCK8S 콜렉터 스케줄러 구동
Types ¶
type CollectManager ¶
type CollectManager struct { CollectorAddrMap map[string]*collector.MetricCollector CollectorPolicy string WaitGroup *sync.WaitGroup }
func NewCollectorManager ¶
func NewCollectorManager(wg *sync.WaitGroup) (CollectManager, error)
func (*CollectManager) CreateCollector ¶
func (manager *CollectManager) CreateCollector(topic string) error
CreateCollector 콜렉터 생성
func (*CollectManager) DeleteCollector ¶
func (manager *CollectManager) DeleteCollector(topic string) error
DeleteCollector 콜렉터 삭제
type CollectorScheduler ¶
type CollectorScheduler struct {
// contains filtered or unexported fields
}
CollectorScheduler 콜렉터에게 토픽을 분배하는 역할을 담당하는 콜렉터 스케줄러
func NewCollectorScheduler ¶
func NewCollectorScheduler(cm CollectManager) (*CollectorScheduler, error)
NewCollectorScheduler 콜렉터 스케줄러 생성
func (CollectorScheduler) AddTopicsToCollector ¶
func (cScheduler CollectorScheduler) AddTopicsToCollector(addTopicList []string)
AddTopicsToCollector 신규 토픽에 대한 콜렉터 생성
func (CollectorScheduler) DeleteTopicsToCollector ¶
func (cScheduler CollectorScheduler) DeleteTopicsToCollector(delTopicList []string)
DeleteTopicsToCollector 삭제 토픽에 대한 콜렉터 삭제
func (CollectorScheduler) DoSchedule ¶
func (cScheduler CollectorScheduler) DoSchedule() error
DoSchedule 콜렉터 스케줄러 구동
func (CollectorScheduler) ProvisioningCollector ¶
func (cScheduler CollectorScheduler) ProvisioningCollector()
func (CollectorScheduler) SchedulePolicyBasedCollector ¶
func (cScheduler CollectorScheduler) SchedulePolicyBasedCollector(addTopicList []string, delTopicList []string)
SchedulePolicyBasedCollector 쿠버네티스 서비스(MCK8S) 에이전트와 콜렉터를 1:1로 스케줄링
func (CollectorScheduler) TriggerCollector ¶
func (cScheduler CollectorScheduler) TriggerCollector()
func (CollectorScheduler) WriteCollectorMapToInMemoryDB ¶
func (cScheduler CollectorScheduler) WriteCollectorMapToInMemoryDB()
type InMemoryTopic ¶
Click to show internal directories.
Click to hide internal directories.