originally from https://github.com/cortexproject/cortex/blob/868898a2921c662dcd4f90683e8b95c927a8edd8/pkg/ingester/index/index.go but modified to support sharding queries.

New makes a new Ingester.

NewLimiter makes a new limiter.

CheckpointRecord is the type for the Checkpoint record based on protos.

The current type of Entries that this distribution writes.

RingKey is the key under which we store the ingesters ring in the KVStore.

WALRecordEntriesV1 is the type for the WAL record for samples.

WALRecordEntriesV2 is the type for the WAL record for samples with an additional counter value for use in replaying without the ordering constraint.

WALRecordSeries is the type for the WAL record for series.

ErrReadOnly is returned when the ingester is shutting down and a push was attempted.

Chunk is a {de,}serializable intermediate type for chunkDesc which allows efficient loading/unloading to disk during WAL checkpoint recovery.

Config for an ingester.

Ingester builds chunks for incoming log streams.

Limiter implements primitives to get the maximum number of streams an ingester can handle for a specific tenant.

OnceSwitch is an optimized switch that can only ever be switched "on" in a concurrent environment.

Series is a {de,}serializable intermediate type for Series.

WALRecord is a struct combining the series and samples record.

ChunkStore is the interface we need to store chunks.

Interface is an interface for the Ingester.

QuerierQueryServer is the GRPC server stream we use to send batch of entries.

RingCount is the interface exposed by a ring implementation which allows to count members.

WAL interface allows us to have a no-op WAL when the WAL is disabled.

RecordType represents the type of the WAL/Checkpoint record.