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.

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.

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.

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.