shard

Documentation

Index

• type Group
  • func NewGroup(id string, lg logrus.FieldLogger) *Group
  • func (s *Group) AddReplicas(r *Replicas)
  • func (s *Group) Replicas() []*Replicas
  • func (s *Group) RuntimeInfo() (*RuntimeInfo, error)
  • func (s *Group) TargetStatus() (map[uint64]*target.ScrapeStatus, error)
  • func (s *Group) TargetsScraping() (map[uint64]bool, error)
  • func (s *Group) UpdateTarget(request *UpdateTargetsRequest) error
• type Manager
• type Replicas
  • func NewReplicas(id string, url string, log logrus.FieldLogger) *Replicas
• type RuntimeInfo
• type UpdateTargetsRequest

Types

type Group

type Group struct {
	// ID is the unique ID of this group
	ID string
	// contains filtered or unexported fields
}

Group is a shard group contains one or more replicates it knows how to communicate with shard sidecar and manager local scraping cache

func NewGroup

func NewGroup(id string, lg logrus.FieldLogger) *Group

NewGroup return a new shard with no replicate

func (*Group) AddReplicas

func (s *Group) AddReplicas(r *Replicas)

AddReplicas add a Replicas to this shard

func (*Group) Replicas

func (s *Group) Replicas() []*Replicas

Replicas return all replicates of this shard

func (*Group) RuntimeInfo

func (s *Group) RuntimeInfo() (*RuntimeInfo, error)

RuntimeInfo return the runtime status of this Group

func (*Group) TargetStatus

func (s *Group) TargetStatus() (map[uint64]*target.ScrapeStatus, error)

TargetStatus return the target runtime status that Group scraping

func (*Group) TargetsScraping

func (s *Group) TargetsScraping() (map[uint64]bool, error)

TargetsScraping return the targets hash that this Group scraping the key of the map is target hash the result is union set of all replicates

func (*Group) UpdateTarget

func (s *Group) UpdateTarget(request *UpdateTargetsRequest) error

UpdateTarget update the scraping targets of this Group every Replicas will compare the new targets to it's targets scraping cache and decide if communicate with sidecar or not, request will be send to sidecar only if new activeTargets not eq to the scraping

type Manager

type Manager interface {
	// Shards return current Shards in the cluster
	Shards() ([]*Group, error)
	// ChangeScale create or delete Shards according to "expReplicate"
	ChangeScale(expReplicate int32) error
}

Manager known how to create or delete Shards

type Replicas

type Replicas struct {
	// ID is the unique ID for differentiate different replicate of shard
	ID string
	// APIGet is a function to do stand api request to target
	// exposed this field for user to writ unit testing easily
	APIGet func(url string, ret interface{}) error
	// APIPost is a function to do stand api request to target
	// exposed this field for user to writ unit testing easily
	APIPost func(url string, req interface{}, ret interface{}) (err error)
	// contains filtered or unexported fields
}

Replicas is a replicas of one shard all replicas of one shard scrape same targets and expected to have same load

func NewReplicas

func NewReplicas(id string, url string, log logrus.FieldLogger) *Replicas

NewReplicas create a Replicas with empty scraping cache

type RuntimeInfo

type RuntimeInfo struct {
	// HeadSeries return current head_series of prometheus
	HeadSeries int64 `json:"headSeries"`
}

RuntimeInfo contains all running status of this shard

type UpdateTargetsRequest

type UpdateTargetsRequest struct {
	// targets contains all targets this shard should scrape
	Targets map[string][]*target.Target
}

UpdateTargetsRequest contains all information about the targets updating request