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.

NewFPMapper returns an fpMapper ready to use.

NewLimiter makes a new limiter.

PartitionRingKey is the key under which we store the partitions ring used by the "ingest storage".

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

ShardLbName is the internal label to be used by Loki when dividing a stream into smaller pieces.

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.

FpMapper is used to map fingerprints in order to work around fingerprint collisions.

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.

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.

Store is the store interface we need on the ingester.

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