strategies

Documentation

Index

• Constants
• func FindGapsInFingerprintBounds(ownershipRange v1.FingerprintBounds, metas []v1.FingerprintBounds) (gaps []v1.FingerprintBounds, err error)
• func SplitFingerprintKeyspaceByFactor(factor int) []v1.FingerprintBounds
• type ChunkSizeStrategy
  • func NewChunkSizeStrategy(limits ChunkSizeStrategyLimits, metrics *ChunkSizeStrategyMetrics, ...) (*ChunkSizeStrategy, error)
  • func (s *ChunkSizeStrategy) Name() string
  • func (s *ChunkSizeStrategy) Plan(ctx context.Context, table config.DayTable, tenant string, tsdbs TSDBSet, ...) ([]*protos.Task, error)
• type ChunkSizeStrategyLimits
• type ChunkSizeStrategyMetrics
  • func NewChunkSizeStrategyMetrics(r prometheus.Registerer) *ChunkSizeStrategyMetrics
• type Factory
  • func NewFactory(limits Limits, metrics *Metrics, logger log.Logger) *Factory
  • func (f *Factory) GetStrategy(tenantID string) (PlanningStrategy, error)
• type Limits
• type Metrics
  • func NewMetrics(reg prometheus.Registerer) *Metrics
• type PlanningStrategy
• type SplitKeyspaceStrategy
  • func NewSplitKeyspaceStrategy(limits SplitKeyspaceStrategyLimits, logger log.Logger) (*SplitKeyspaceStrategy, error)
  • func (s *SplitKeyspaceStrategy) Name() string
  • func (s *SplitKeyspaceStrategy) Plan(ctx context.Context, table config.DayTable, tenant string, tsdbs TSDBSet, ...) ([]*protos.Task, error)
• type SplitKeyspaceStrategyLimits
• type TSDBSet

Constants

const (
	SplitKeyspaceStrategyName          = "split_keyspace_by_factor"
	SplitBySeriesChunkSizeStrategyName = "split_by_series_chunks_size"
)

Functions

func FindGapsInFingerprintBounds

func FindGapsInFingerprintBounds(ownershipRange v1.FingerprintBounds, metas []v1.FingerprintBounds) (gaps []v1.FingerprintBounds, err error)

func SplitFingerprintKeyspaceByFactor

func SplitFingerprintKeyspaceByFactor(factor int) []v1.FingerprintBounds

SplitFingerprintKeyspaceByFactor splits the keyspace covered by model.Fingerprint into contiguous non-overlapping ranges.

Types

type ChunkSizeStrategy

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

func NewChunkSizeStrategy

func NewChunkSizeStrategy(
	limits ChunkSizeStrategyLimits,
	metrics *ChunkSizeStrategyMetrics,
	logger log.Logger,
) (*ChunkSizeStrategy, error)

func (*ChunkSizeStrategy) Name

func (s *ChunkSizeStrategy) Name() string

func (*ChunkSizeStrategy) Plan

func (s *ChunkSizeStrategy) Plan(
	ctx context.Context,
	table config.DayTable,
	tenant string,
	tsdbs TSDBSet,
	metas []bloomshipper.Meta,
) ([]*protos.Task, error)

type ChunkSizeStrategyLimits

type ChunkSizeStrategyLimits interface {
	BloomTaskTargetSeriesChunksSizeBytes(tenantID string) uint64
}

type ChunkSizeStrategyMetrics

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

func NewChunkSizeStrategyMetrics

func NewChunkSizeStrategyMetrics(r prometheus.Registerer) *ChunkSizeStrategyMetrics

type Factory

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

func NewFactory

func NewFactory(
	limits Limits,
	metrics *Metrics,
	logger log.Logger,
) *Factory

func (*Factory) GetStrategy

func (f *Factory) GetStrategy(tenantID string) (PlanningStrategy, error)

type Limits

type Limits interface {
	BloomPlanningStrategy(tenantID string) string
	SplitKeyspaceStrategyLimits
	ChunkSizeStrategyLimits
}

type Metrics

type Metrics struct {
	*ChunkSizeStrategyMetrics
}

func NewMetrics

func NewMetrics(reg prometheus.Registerer) *Metrics

type PlanningStrategy

type PlanningStrategy interface {
	Name() string
	// Plan returns a set of tasks for a given tenant-table tuple and TSDBs.
	Plan(ctx context.Context, table config.DayTable, tenant string, tsdbs TSDBSet, metas []bloomshipper.Meta) ([]*protos.Task, error)
}

type SplitKeyspaceStrategy

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

func NewSplitKeyspaceStrategy

func NewSplitKeyspaceStrategy(
	limits SplitKeyspaceStrategyLimits,
	logger log.Logger,
) (*SplitKeyspaceStrategy, error)

func (*SplitKeyspaceStrategy) Name

func (s *SplitKeyspaceStrategy) Name() string

func (*SplitKeyspaceStrategy) Plan

func (s *SplitKeyspaceStrategy) Plan(
	ctx context.Context,
	table config.DayTable,
	tenant string,
	tsdbs TSDBSet,
	metas []bloomshipper.Meta,
) ([]*protos.Task, error)

type SplitKeyspaceStrategyLimits

type SplitKeyspaceStrategyLimits interface {
	BloomSplitSeriesKeyspaceBy(tenantID string) int
}

type TSDBSet

type TSDBSet = map[tsdb.SingleTenantTSDBIdentifier]common.ClosableForSeries