storegateway

type Block struct {
	BlockCloser
	// contains filtered or unexported fields
}

type BlockCloser interface {
	phlaredb.Querier
	Close() error
}

type BlockMetaFilter interface {
	Filter(ctx context.Context, metas map[ulid.ULID]*block.Meta, synced tsdb_block.GaugeVec) error
}

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

type BucketStoreConfig struct {
	SyncDir               string        `yaml:"sync_dir"`
	SyncInterval          time.Duration `yaml:"sync_interval" category:"advanced"`
	TenantSyncConcurrency int           `yaml:"tenant_sync_concurrency" category:"advanced"`
	IgnoreBlocksWithin    time.Duration `yaml:"ignore_blocks_within" category:"advanced"`
}

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

type Config struct {
	storegateway.Config `yaml:",inline"`
	BucketStoreConfig   BucketStoreConfig `yaml:"bucket_store,omitempty"`
}

type Limits interface {
	storegateway.ShardingLimits
}

type Metrics struct {
	Synced *prometheus.GaugeVec
	// contains filtered or unexported fields
}

type ShardingStrategy interface {
	// FilterUsers whose blocks should be loaded by the store-gateway. Returns the list of user IDs
	// that should be synced by the store-gateway.
	FilterUsers(ctx context.Context, userIDs []string) ([]string, error)

	// FilterBlocks filters metas in-place keeping only blocks that should be loaded by the store-gateway.
	// The provided loaded map contains blocks which have been previously returned by this function and
	// are now loaded or loading in the store-gateway.
	FilterBlocks(ctx context.Context, userID string, metas map[ulid.ULID]*block.Meta, loaded map[ulid.ULID]struct{}, synced tsdb_block.GaugeVec) error
}

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

type StoreGateway struct {
	services.Service
	// contains filtered or unexported fields
}