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

ActivityStreamEvent represents an entry into the activity stream.

Broker contains information for a Liftbridge broker.

CreateStreamOp represents a stream creation operation.

CreateStreamRequest is sent to create a new stream.

CreateStreamResponse is sent by server after creating a stream.

DeleteStreamOp represents a stream deletion operation.

DeleteStreamRequest is sent to delete a stream.

DeleteStreamResponse is sent by server after deleting 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.

PauseStreamOp represents a stream pause operation.

PauseStreamRequest is sent to pause the specified stream partitions.

PauseStreamResponse is sent by server after pausing a stream.

PublishRequest is sent to publish a new message to a stream.

PublishResponse is sent by the server after publishing a message to a stream.

PublishToSubjectRequest is sent to publish a Liftbridge message to a NATS subject.

PublishToSubjectResponse is sent by the server after publishing a message to a NATS subject.

ResumeStreamOp represents a stream resume operation.

ReadonlyStreamOp represents a stream readonly operation.

SetStreamReadonlyRequest is send to set a stream as read-only.

SetStreamReadonlyResponse is sent by server after setting a stream's readonly flag.

StreamMetadata contains information for a stream.

SubscribeRequest is sent to subscribe to a stream partition.

UnimplementedAPIServer can be embedded to have forward compatible implementations.

APIClient is the client API for API service.

APIServer is the server API for API service.

AckPolicy controls the behavior of message acknowledgements.

ActivityStreamOp represents an activity stream operation.

StartPosition determines the start-position type on a subscription.