GetPrimaryTokenIndex returns the broker index of the start token in a given range.

Gets a token based on a murmur3 hash.

NewTopology creates a Topology struct using brokers in ordinal order.

Creates a new TrackedConnection using the provided tcp conn.

OrdinalsPlacementOrder gets a slice of ordinals in the placement order.

Gets the start and end of a range based on the token, range index and cluster size.

{uint32_length}{bytes}{uint32_length}{bytes}...

Peer processed the GET request, but didn't found the information that was looking for.

BrokerInfo contains information about a broker.

ConsumerGroup contains info about a single group of consumers.

Represents a point-in-time set of ranges.

Represents a unique reference to a generation.

Represents a topic offset for a given token.

Represents an identifier of an offset to be persisted.

Represents an identifier and a value of an offset.

Represents slices of the token range between two tokens.

TopicDataId contains information to locate a certain piece of data.

TopologyInfo represents a snapshot of the current placement of the brokers.

TrackedConnection represents a net connection over http that contains information about whether it's open/closed.

Represents a writer backed by an in-memory buffer.

Represents a local view of the consumer group offsets.

Represents an error while producing that we are certain it caused side effect in the data store.

Replicator contains logic to send data to replicas.

SegmentChunk represents a group of compressed records.

BrokerIndex represents the position of a broker in the current broker list.

GenStatus determines the state (proposed, accepted, ...) of the status.

Represents an index in the token range.

Represents a partition token.