storegateway

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

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

type BucketIndexConfig struct {
	UpdateOnErrorInterval time.Duration `yaml:"update_on_error_interval" category:"advanced"`
	IdleTimeout           time.Duration `yaml:"idle_timeout" category:"advanced"`
	MaxStalePeriod        time.Duration `yaml:"max_stale_period" category:"advanced"`
}

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

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"`
	MetaSyncConcurrency      int           `yaml:"meta_sync_concurrency" category:"advanced"`
	IgnoreDeletionMarksDelay time.Duration `yaml:"ignore_deletion_mark_delay" category:"advanced"`
}

type BucketStoreStats struct {
	// BlocksLoaded is the number of blocks currently loaded in the bucket store.
	BlocksLoaded int
}

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

type Config struct {
	ShardingRing      RingConfig        `yaml:"sharding_ring" doc:"description=The hash ring configuration."`
	BucketStoreConfig BucketStoreConfig `yaml:"bucket_store,omitempty"`
}

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

type Limits interface {
	ShardingLimits
	phlareobj.TenantConfigProvider
}

type MetadataFilterWithBucketIndex interface {
	// FilterWithBucketIndex is like Thanos MetadataFilter.Filter() but it provides in input the bucket index too.
	FilterWithBucketIndex(ctx context.Context, metas map[ulid.ULID]*block.Meta, idx *bucketindex.Index, synced block.GaugeVec) error
}

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

type RingConfig struct {
	Ring                 util.CommonRingConfig `yaml:",inline"`
	ReplicationFactor    int                   `yaml:"replication_factor" category:"advanced"`
	TokensFilePath       string                `yaml:"tokens_file_path"`
	ZoneAwarenessEnabled bool                  `yaml:"zone_awareness_enabled"`

	// Wait ring stability.
	WaitStabilityMinDuration time.Duration `yaml:"wait_stability_min_duration" category:"advanced"`
	WaitStabilityMaxDuration time.Duration `yaml:"wait_stability_max_duration" category:"advanced"`

	// Instance details
	InstanceZone string `yaml:"instance_availability_zone"`

	UnregisterOnShutdown bool `yaml:"unregister_on_shutdown"`

	// Injected internally
	RingCheckPeriod time.Duration `yaml:"-"`
}

type ShardingLimits interface {
	StoreGatewayTenantShardSize(tenantID string) int
}

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 block.GaugeVec) error
}

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

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