Versions in this module Expand all Collapse all v0 v0.6.1 Jun 12, 2023 Changes in this version + func GetShuffleShardingSubring(ring *ring.Ring, userID string, limits storegateway.ShardingLimits) ring.ReadRing + type Block struct + type BlockCloser interface + Close func() error + type BlockMetaFilter interface + Filter func(ctx context.Context, metas map[ulid.ULID]*block.Meta, ...) error + func NewShardingMetadataFilterAdapter(userID string, strategy ShardingStrategy) BlockMetaFilter + type BucketStore struct + func NewBucketStore(bucket phlareobj.Bucket, tenantID string, syncDir string, ...) (*BucketStore, error) + func (b *BucketStore) InitialSync(ctx context.Context) error + func (b *BucketStore) Stats() storegateway.BucketStoreStats + func (s *BucketStore) RemoveBlocksAndClose() error + func (s *BucketStore) SyncBlocks(ctx context.Context) error + func (store *BucketStore) MergeProfilesLabels(ctx context.Context, ...) error + func (store *BucketStore) MergeProfilesPprof(ctx context.Context, ...) error + func (store *BucketStore) MergeProfilesStacktraces(ctx context.Context, ...) error + type BucketStoreConfig struct + IgnoreBlocksWithin time.Duration + SyncDir string + SyncInterval time.Duration + TenantSyncConcurrency int + func (cfg *BucketStoreConfig) RegisterFlags(f *flag.FlagSet, logger log.Logger) + func (cfg *BucketStoreConfig) Validate(logger log.Logger) error + type BucketStores struct + func NewBucketStores(cfg BucketStoreConfig, shardingStrategy ShardingStrategy, ...) (*BucketStores, error) + func (bs *BucketStores) InitialSync(ctx context.Context) error + func (bs *BucketStores) SyncBlocks(ctx context.Context) error + type Config struct + BucketStoreConfig BucketStoreConfig + func (c *Config) Validate(limits validation.Limits) error + func (cfg *Config) RegisterFlags(f *flag.FlagSet, logger log.Logger) + type Limits interface + type Metrics struct + Synced *prometheus.GaugeVec + func NewMetrics(reg prometheus.Registerer) *Metrics + type ShardingStrategy interface + FilterBlocks func(ctx context.Context, userID string, metas map[ulid.ULID]*block.Meta, ...) error + FilterUsers func(ctx context.Context, userIDs []string) ([]string, error) + type ShuffleShardingStrategy struct + func NewShuffleShardingStrategy(r *ring.Ring, instanceID, instanceAddr string, ...) *ShuffleShardingStrategy + func (s *ShuffleShardingStrategy) FilterBlocks(_ context.Context, userID string, metas map[ulid.ULID]*block.Meta, ...) error + func (s *ShuffleShardingStrategy) FilterUsers(_ context.Context, userIDs []string) ([]string, error) + type StoreGateway struct + func NewStoreGateway(gatewayCfg Config, storageBucket phlareobj.Bucket, limits Limits, ...) (*StoreGateway, error) + func (c *StoreGateway) RingHandler(w http.ResponseWriter, req *http.Request) + func (s *StoreGateway) BlocksHandler(w http.ResponseWriter, req *http.Request) + func (s *StoreGateway) MergeProfilesLabels(ctx context.Context, ...) error + func (s *StoreGateway) MergeProfilesPprof(ctx context.Context, ...) error + func (s *StoreGateway) MergeProfilesStacktraces(ctx context.Context, ...) error + func (s *StoreGateway) TenantsHandler(w http.ResponseWriter, req *http.Request)