coordinator

Documentation

Index

• type Coordinator
  • func NewCoordinator(shardManager shard.Manager, maxSeries int64, maxShard int32, ...) *Coordinator
  • func (c *Coordinator) Run(ctx context.Context) error
  • func (c *Coordinator) RunOnce() error
• type Service
  • func NewService(configFile string, configApply []func(cfg *config.Config) error, ...) *Service
  • func (s *Service) Init() error

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,
	period time.Duration,
	getExploreResult func(job string, hash uint64) *target.ScrapeStatus,
	getActive func() map[string][]*discovery.SDTargets,
	log logrus.FieldLogger) *Coordinator

NewCoordinator create a new coordinator service

func (*Coordinator) Run

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

Run do coordinate periodically until ctx done

func (*Coordinator) RunOnce

func (c *Coordinator) RunOnce() error

RunOnce get shards information from shard manager, do shard reBalance and change expect shard number

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(
	configFile string,
	configApply []func(cfg *config.Config) error,
	getScrapeStatus func(map[string][]*discovery.SDTargets) (map[uint64]*target.ScrapeStatus, error),
	getActiveTargets func() map[string][]*discovery.SDTargets,
	getDropTargets func() map[string][]*discovery.SDTargets,
	lg logrus.FieldLogger) *Service

NewService return a new web server

func (*Service) Init

func (s *Service) Init() error

Init init config