coordinator

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

type ExtendTarget struct {
	// Target is Prometheus active target from /api/v1/targets
	v1.Target
	// Series is the avg series of last 5 scraping results
	Series int64 `json:"series"`
	// TotalSeries is the total series without metrics_relabel
	TotalSeries int64 `json:"totalSeries"`
	// Shards contains ID of shards that is scraping this target
	Shards []string `json:"shards"`
}

type JobSamplesInfo struct {
	// JobName is the name of this job
	JobName string `json:"jobName"`
	// SamplesRateTotal is the total samples rate of this job' targets
	SamplesRate uint64 `json:"samplesRateTotal"`
	// MetricsSamplesRate indicate the metrics samples rate
	MetricsSamplesRate map[string]uint64 `json:"metricsSamplesRate"`
}

type Option struct {
	// MaxHeadSeries is max series after metrics_relabels every shard can assign
	MaxHeadSeries int64
	// MaxProcessSeries is max series before metrics_relabels every shard can assign
	MaxProcessSeries int64
	// MaxShard is the max number we can scale up to
	MaxShard int32
	// MinShard is the min shard number that coordinator need
	// Coordinator will change scale to MinShard if current shard number < MinShard
	MinShard int32
	// MaxIdleTime indicate how long to wait when one shard has no target is scraping
	MaxIdleTime time.Duration
	// Period is the interval between every coordinating
	Period time.Duration
	// DisableAlleviate disable shard alleviation when shard is overload
	DisableAlleviate bool
}

type SamplesInfo struct {
	// SamplesRate is total sample rate in last scrape
	SamplesRate uint64 `json:"samplesRate"`
	// JobsSamplesRate show total sample rate in last scrape about a job
	JobsSamplesRate []*JobSamplesInfo `json:"jobsSamplesRate"`
}

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

type TargetDiscovery struct {
	// ActiveTargets contains all targets that should be scraped
	ActiveTargets []*ExtendTarget `json:"activeTargets"`
	// ActiveStatistics contains job's statistics number according to target health
	ActiveStatistics []TargetStatistics `json:"activeStatistics,omitempty"`
	// DroppedTargets contains all targets that been dropped from relabel
	DroppedTargets []*v1.DroppedTarget `json:"droppedTargets"`
}

type TargetStatistics struct {
	// JobName is the job name of this statistics
	JobName string
	// Total is all active targets number
	Total uint64
	// Health contains the number of every health status
	Health map[scrape.TargetHealth]uint64
}