ConsistencyMiddleware takes the consistency level from the X-Read-Consistency header and sets it in the context.

ContextWithReadConsistencyEncodedOffsets returns a new context with the given partition offsets.

ContextWithReadConsistencyLevel returns a new context with the given consistency level.

EncodeOffsets serialise the input offsets into a string which is safe to be used as HTTP header value.

ReadConsistencyEncodedOffsetsFromContext returns the partition offsets to enforce strong read consistency.

ReadConsistencyLevelFromContext returns the consistency level from the context if set via ContextWithReadConsistencyLevel.

ContentTypeRemoteReadStreamedChunks is taken from the prometheus protobuf definitions documentation.

ReadConsistencyEventual is the default consistency level for all queries.

ReadConsistencyStrong means that a query sent by the same client will always observe the writes that have completed before issuing the query.

EncodedOffsets holds the encoded partition offsets.