bloomcompactor

type BloomGenerator interface {
	Generate(ctx context.Context) (skippedBlocks []v1.BlockMetadata, toClose []io.Closer, results v1.Iterator[*v1.Block], err error)
}

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

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

type ChunkLoader interface {
	Load(ctx context.Context, userID string, series *v1.Series) *ChunkItersByFingerprint
}

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

type Config struct {
	// Ring configures the ring store used to save and retrieve the different Bloom-Compactor instances.
	// In case it isn't explicitly set, it follows the same behavior of the other rings (ex: using the common configuration
	// section and the ingester configuration by default).
	Ring ring.RingConfig `` /* 205-byte string literal not displayed */
	// Enabled configures whether bloom-compactors should be used to compact index values into bloomfilters
	Enabled            bool          `yaml:"enabled"`
	CompactionInterval time.Duration `yaml:"compaction_interval"`
	MinTableOffset     int           `yaml:"min_table_offset"`
	MaxTableOffset     int           `yaml:"max_table_offset"`
	WorkerParallelism  int           `yaml:"worker_parallelism"`
	RetryMinBackoff    time.Duration `yaml:"compaction_retries_min_backoff"`
	RetryMaxBackoff    time.Duration `yaml:"compaction_retries_max_backoff"`
	CompactionRetries  int           `yaml:"compaction_retries"`

	MaxCompactionParallelism int `yaml:"max_compaction_parallelism"`

	RetentionConfig RetentionConfig `yaml:"retention"`
}

type FetchFunc[A, B any] func(ctx context.Context, inputs []A) ([]B, error)

type Fetcher[A, B any] interface {
	Fetch(ctx context.Context, inputs []A) ([]B, error)
}

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

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

type Limits interface {
	RetentionLimits
	BloomCompactorShardSize(tenantID string) int
	BloomCompactorEnabled(tenantID string) bool
	BloomNGramLength(tenantID string) int
	BloomNGramSkip(tenantID string) int
	BloomFalsePositiveRate(tenantID string) float64
	BloomCompactorMaxBlockSize(tenantID string) int
	BloomCompactorMaxBloomSize(tenantID string) int
	BloomBlockEncoding(tenantID string) string
}

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

type RetentionConfig struct {
	Enabled         bool `yaml:"enabled"`
	MaxLookbackDays int  `yaml:"max_lookback_days"`
}

type RetentionLimits interface {
	RetentionPeriod(userID string) time.Duration
	StreamRetention(userID string) []validation.StreamRetention
	AllByUserID() map[string]*validation.Limits
	DefaultLimits() *validation.Limits
}

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

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

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

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

type TSDBStore interface {
	UsersForPeriod(ctx context.Context, table config.DayTable) ([]string, error)
	ResolveTSDBs(ctx context.Context, table config.DayTable, tenant string) ([]tsdb.SingleTenantTSDBIdentifier, error)
	LoadTSDB(
		ctx context.Context,
		table config.DayTable,
		tenant string,
		id tsdb.Identifier,
		bounds v1.FingerprintBounds,
	) (v1.Iterator[*v1.Series], error)
}

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