coordinator

Documentation

Index

• type Coordinator
  • func NewCoordinator(shardManager shard.Manager, maxSeries int64, maxShard int32, ...) *Coordinator
  • func (c *Coordinator) LastGlobalScrapeStatus() map[uint64]*target.ScrapeStatus
  • func (c *Coordinator) Run(ctx context.Context) error
• type Service
  • func NewService(cfgManager *prom.ConfigManager, ...) *Service

Types

type Coordinator

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

Coordinator periodically re balance all replicates

func NewCoordinator

func NewCoordinator(
	shardManager shard.Manager,
	maxSeries int64,
	maxShard int32,
	maxIdleTime time.Duration,
	period time.Duration,
	getConfigMd5 func() string,
	getExploreResult func(hash uint64) *target.ScrapeStatus,
	getActive func() map[uint64]*discovery.SDTargets,
	log logrus.FieldLogger) *Coordinator

NewCoordinator create a new coordinator service

func (*Coordinator) LastGlobalScrapeStatus

func (c *Coordinator) LastGlobalScrapeStatus() map[uint64]*target.ScrapeStatus

LastGlobalScrapeStatus return the last scraping status of last coordinate

func (*Coordinator) Run

func (c *Coordinator) Run(ctx context.Context) error

Run do coordinate periodically until ctx done

type Service

type Service struct {
	// gin.Engine is the gin engine for handle http request
	*gin.Engine
	// contains filtered or unexported fields
}

Service is the api server of coordinator

func NewService

func NewService(
	cfgManager *prom.ConfigManager,
	getScrapeStatus func() map[uint64]*target.ScrapeStatus,
	getActiveTargets func() map[string][]*discovery.SDTargets,
	getDropTargets func() map[string][]*discovery.SDTargets,
	lg logrus.FieldLogger) *Service

NewService return a new web server