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.

Consumer contains information pertaining to a subscriber that is a member of a consumer group.

ConsumerGroupMetadata contains information for a consumer group.

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.

FetchConsumerGroupAssignmentsRequest is sent to a consumer group coordinator to retrieve the consumer's partition assignments.

FetchConsumerGroupAssignmentsResponse is sent by the group coordinator to notify the consumer of its partition assignments.

FetchCursorRequest is sent to retrieve a consumer's cursor position for a particular stream partition.

FetchCursorResponse contains the requested consumer cursor position.

FetchMetadataRequest is sent to retrieve the latest cluster metadata.

FetchMetadataResponse contains the cluster metadata requested.

FetchPartitionMetadataRequest is sent to retrieve latest partition metadata.

FetchPartitionMetadataResponse contains the partition metadata requested.

JoinConsumerGroupOp represents a consumer group join operation.

JoinConsumerGroupRequest is sent to add a consumer to a consumer group.

JoinConsumerGroupResponse is sent by the server after adding a consumer to a consumer group.

LeaveConsumerGroupOp represents a consumer group leave operation.

LeaveConsumerGroupRequest is sent to remove a consumer from a consumer group.

LeaveConsumerGroupResponse is sent by the server after removing a consumer from a consumer group.

Message represents a message from a stream.

PartitionAssignment contains a set of stream partitions that are assigned to a consumer.

PartitionEventTimestamps contains timestamps related to a stream partition.

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.

PublishAsyncError is returned on the PublishAsync stream if a publish failed.

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.

ReportConsumerGroupCoordinatorRequest is sent by a consumer group member to report the group coordinator as failed.

ReportConsumerGroupCoordinatorResponse is sent by the server in response to a request to report a consumer group coordinator.

ResumeStreamOp represents a stream resume operation.

SetCursorRequest is sent to set a consumer's cursor position for a particular stream partition.

SetCursorResponse is sent by the server after setting a consumer cursor.

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.

Error represents an error that is piggybacked to AckInbox due to any error that is encountered upon publishing, e.g.

AckPolicy controls the behavior of message acknowledgements.

ActivityStreamOp represents an activity stream operation.

StartPosition determines the start-position type on a subscription.

StopPosition determines the stop-position type on a subscription.