Ack represents an acknowledgement that a message was committed to a stream partition.

Broker contains information for a Liftbridge broker.

CreateStreamRequest is sent to create a new stream.

CreateStreamResponse is sent by server after creating a stream.

FetchMetadataRequest is sent to retrieve the latest cluster metadata.

FetchMetadataResponse contains the cluster metadata requested.

Message represents a message from a stream.

PartitionMetadata contains information for a stream partition.

PublishRequest is sent to publish a new message.

PublishResponse is sent by the server after publishing a message.

StreamMetadata contains information for a stream.

SubscribeRequest is sent to subscribe to a stream partition.

AckPolicy controls the behavior of message acknowledgements.

StartPosition determines the start-position type on a subscription.