New makes a new Ingester.

NewLimiter makes a new limiter.

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

WALRecordSamples is the type for the WAL record for samples.

WALRecordSeries is the type for the WAL record for series.

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

Errors returned on Query.

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

Config for an ingester.

Decbuf extends encoding.Decbuf with support for multi byte decoding.

Encbuf extends encoding.Encbuf with support for multi byte encoding.

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.

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.