Pub/Sub Lite API


A regional service name,, is needed to create RPC client stubs.

CreateReservation Creates a new reservation.
CreateSubscription Creates a new subscription.
CreateTopic Creates a new topic.
DeleteReservation Deletes the specified reservation.
DeleteSubscription Deletes the specified subscription.
DeleteTopic Deletes the specified topic.
GetReservation Returns the reservation configuration.
GetSubscription Returns the subscription configuration.
GetTopic Returns the topic configuration.
GetTopicPartitions Returns the partition information for the requested topic.
ListReservationTopics Lists the topics attached to the specified reservation.
ListReservations Returns the list of reservations for the given project.
ListSubscriptions Returns the list of subscriptions for the given project.
ListTopicSubscriptions Lists the subscriptions attached to the specified topic.
ListTopics Returns the list of topics for the given project.
SeekSubscription Performs an out-of-band seek for a subscription to a specified target, which may be timestamps or named positions within the message backlog.
UpdateReservation Updates properties of the specified reservation.
UpdateSubscription Updates properties of the specified subscription.
UpdateTopic Updates properties of the specified topic.

CommitCursor Updates the committed cursor.
ListPartitionCursors Returns all committed cursor information for a subscription.
StreamingCommitCursor Establishes a stream with the server for managing committed cursors.

OpenKafkaStream Request made when opening a new kafka stream.

AssignPartitions Assign partitions for this client to handle for the specified subscription.

Publish Establishes a stream with the server for publishing messages.

Subscribe Establishes a stream with the server for receiving messages.

ComputeHeadCursor Compute the head cursor for the partition.
ComputeMessageStats Compute statistics about a range of messages in a given topic and partition.
ComputeTimeCursor Compute the corresponding cursor for a publish or event time in a topic partition.


CancelOperation Starts asynchronous cancellation on a long-running operation.
DeleteOperation Deletes a long-running operation.
GetOperation Gets the latest state of a long-running operation.
ListOperations Lists operations that match the specified filter in the request.
WaitOperation Waits until the specified long-running operation is done or reaches at most a specified timeout, returning the latest state.