NewLengthDelimitedFrameReader returns an io.Reader that will decode length-prefixed frames off of a stream.

UserFromContext loads User from context.

WithUser saves User into context.

const attributes keys the queue service implement must provide.

not necessary attribute keys.

const attributes keys the queue service implement must provide.

const attributes keys the queue service implement must provide.

const attributes keys the queue service implement must provide.

const attributes keys the queue service implement must provide.

Shutdown indicates the consumer will exit soon.

const attributes keys the queue service implement must provide.

const attributes keys the queue service implement must provide.

const attributes keys the queue service implement must provide.

const attributes keys the queue service implement must provide.

const attributes keys the queue service implement must provide.

const attributes keys the queue service implement must provide.

AttributesCodec helps to encode or decode Attributes from or to bytes.

DataFrameCodec helps to encode or decode a DataFrame from or to bytes.

User authenticated information.

Watcher is the entity following the stream.