Function NewShuffleShardingPlanner

pkg/compactor/shuffle_sharding_planner.go:29–53

(
	ctx context.Context,
	bkt objstore.InstrumentedBucket,
	logger log.Logger,
	ranges []int64,
	noCompBlocksFunc func() map[ulid.ULID]*metadata.NoCompactMark,
	ringLifecyclerID string,
	blockVisitMarkerTimeout time.Duration,
	blockVisitMarkerFileUpdateInterval time.Duration,
	blockVisitMarkerReadFailed prometheus.Counter,
	blockVisitMarkerWriteFailed prometheus.Counter,
)

}

func NewShuffleShardingPlanner(
	ctx context.Context,
	bkt objstore.InstrumentedBucket,
	logger log.Logger,
	ranges []int64,
	noCompBlocksFunc func() map[ulid.ULID]*metadata.NoCompactMark,
	ringLifecyclerID string,
	blockVisitMarkerTimeout time.Duration,
	blockVisitMarkerFileUpdateInterval time.Duration,
	blockVisitMarkerReadFailed prometheus.Counter,
	blockVisitMarkerWriteFailed prometheus.Counter,
) *ShuffleShardingPlanner {
	return &ShuffleShardingPlanner{
		ctx:                                ctx,
		bkt:                                bkt,
		logger:                             logger,
		ranges:                             ranges,
		noCompBlocksFunc:                   noCompBlocksFunc,
		ringLifecyclerID:                   ringLifecyclerID,
		blockVisitMarkerTimeout:            blockVisitMarkerTimeout,
		blockVisitMarkerFileUpdateInterval: blockVisitMarkerFileUpdateInterval,
		blockVisitMarkerReadFailed:         blockVisitMarkerReadFailed,
		blockVisitMarkerWriteFailed:        blockVisitMarkerWriteFailed,
	}
}

func (p *ShuffleShardingPlanner) Plan(_ context.Context, metasByMinTime []*metadata.Meta, _ chan error, _ any) ([]*metadata.Meta, error) {
	// Ensure all blocks fits within the largest range. This is a double check