mcis

Documentation

Index

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

Functions

func StartScheduler

func StartScheduler(collectManager *CollectManager) error

StartScheduler MCK8S 콜렉터 스케줄러 구동

Types

type CollectManager

type CollectManager struct {
	CollectorAddrMap map[string]*collector.MetricCollector
	CollectorPolicy  string
	K8sClientSet     *kubernetes.Clientset
	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 콜렉터 삭제

func (*CollectManager) InitDFK8sEnv

func (manager *CollectManager) InitDFK8sEnv() (err error)

type CollectorScheduler

type CollectorScheduler struct {
	// contains filtered or unexported fields
}

CollectorScheduler 콜렉터에게 토픽을 분배하는 역할을 담당하는 콜렉터 스케줄러

func NewCollectorScheduler

func NewCollectorScheduler(manager *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

type InMemoryTopic struct {
	TopicMap map[string][]string // 콜렉터 별 토픽 현황
}