sharding

Documentation

Index

• type Strategy
  • func (s Strategy) ComputeShards(currentShardCount int, timeSeries float64) int
  • func (s Strategy) Merge(newStrategy *Strategy) Strategy

Types

type Strategy

type Strategy struct {
	// Configures the number of series needed to add a new shard. Computation is number of series / ScaleUpSeriesCount
	ScaleUpSeriesCount float64
	// Percentage of needed series based on ScaleUpSeriesCount to scale down agents
	ScaleDownPercentage float64
}

func (Strategy) ComputeShards

func (s Strategy) ComputeShards(currentShardCount int, timeSeries float64) int

We want to start with 1 prometheus-agent for each 1M time series with a scale down 20% threshold.

func (Strategy) Merge

func (s Strategy) Merge(newStrategy *Strategy) Strategy