manager

package
v0.4.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 14, 2021 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KafkaConnectionRetryCnt      = 5
	KafkaConnectionRetryInterval = 5
)

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 NewAPIServer 

func NewAPIServer() (*APIServer, error)

NewAPIServer API 서버 초기화

func (*APIServer) SetRoutingRule 

func (apiServer *APIServer) SetRoutingRule(e *echo.Echo)

func (*APIServer) StartAPIServer 

func (apiServer *APIServer) StartAPIServer(wg *sync.WaitGroup) error

StartAPIServer 모니터링 API 서버 실행

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 PullManager added in v0.3.5 

type PullManager struct {
	AgentListManager agent.AgentListManager
	AgentList        map[string]agent.AgentInfo
	WaitGroup        *sync.WaitGroup
}

func NewPullManager added in v0.3.5 

func NewPullManager() (*PullManager, error)

func (*PullManager) StartPullCaller added in v0.3.5 

func (pm *PullManager) StartPullCaller() error

func (*PullManager) StopPullCaller added in v0.3.5 

func (pm *PullManager) StopPullCaller() error

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.