Classes
AdminProto
AdminServiceGrpc
The service that a client application uses to manage topics and subscriptions, such creating, listing, and deleting topics and subscriptions.
AdminServiceGrpc.AdminServiceBlockingStub
A stub to allow clients to do synchronous rpc calls to service AdminService.
The service that a client application uses to manage topics and subscriptions, such creating, listing, and deleting topics and subscriptions.
AdminServiceGrpc.AdminServiceFutureStub
A stub to allow clients to do ListenableFuture-style rpc calls to service AdminService.
The service that a client application uses to manage topics and subscriptions, such creating, listing, and deleting topics and subscriptions.
AdminServiceGrpc.AdminServiceImplBase
Base class for the server implementation of the service AdminService.
The service that a client application uses to manage topics and subscriptions, such creating, listing, and deleting topics and subscriptions.
AdminServiceGrpc.AdminServiceStub
A stub to allow clients to do asynchronous rpc calls to service AdminService.
The service that a client application uses to manage topics and subscriptions, such creating, listing, and deleting topics and subscriptions.
AttributeValues
The values associated with a key of an attribute.
Protobuf type google.cloud.pubsublite.v1.AttributeValues
AttributeValues.Builder
The values associated with a key of an attribute.
Protobuf type google.cloud.pubsublite.v1.AttributeValues
CommitCursorRequest
Request for CommitCursor.
Protobuf type google.cloud.pubsublite.v1.CommitCursorRequest
CommitCursorRequest.Builder
Request for CommitCursor.
Protobuf type google.cloud.pubsublite.v1.CommitCursorRequest
CommitCursorResponse
Response for CommitCursor.
Protobuf type google.cloud.pubsublite.v1.CommitCursorResponse
CommitCursorResponse.Builder
Response for CommitCursor.
Protobuf type google.cloud.pubsublite.v1.CommitCursorResponse
CommonProto
ComputeHeadCursorRequest
Compute the current head cursor for a partition.
Protobuf type google.cloud.pubsublite.v1.ComputeHeadCursorRequest
ComputeHeadCursorRequest.Builder
Compute the current head cursor for a partition.
Protobuf type google.cloud.pubsublite.v1.ComputeHeadCursorRequest
ComputeHeadCursorResponse
Response containing the head cursor for the requested topic and partition.
Protobuf type google.cloud.pubsublite.v1.ComputeHeadCursorResponse
ComputeHeadCursorResponse.Builder
Response containing the head cursor for the requested topic and partition.
Protobuf type google.cloud.pubsublite.v1.ComputeHeadCursorResponse
ComputeMessageStatsRequest
Compute statistics about a range of messages in a given topic and partition.
Protobuf type google.cloud.pubsublite.v1.ComputeMessageStatsRequest
ComputeMessageStatsRequest.Builder
Compute statistics about a range of messages in a given topic and partition.
Protobuf type google.cloud.pubsublite.v1.ComputeMessageStatsRequest
ComputeMessageStatsResponse
Response containing stats for messages in the requested topic and partition.
Protobuf type google.cloud.pubsublite.v1.ComputeMessageStatsResponse
ComputeMessageStatsResponse.Builder
Response containing stats for messages in the requested topic and partition.
Protobuf type google.cloud.pubsublite.v1.ComputeMessageStatsResponse
ComputeTimeCursorRequest
Compute the corresponding cursor for a publish or event time in a topic partition.
Protobuf type google.cloud.pubsublite.v1.ComputeTimeCursorRequest
ComputeTimeCursorRequest.Builder
Compute the corresponding cursor for a publish or event time in a topic partition.
Protobuf type google.cloud.pubsublite.v1.ComputeTimeCursorRequest
ComputeTimeCursorResponse
Response containing the cursor corresponding to a publish or event time in a topic partition.
Protobuf type google.cloud.pubsublite.v1.ComputeTimeCursorResponse
ComputeTimeCursorResponse.Builder
Response containing the cursor corresponding to a publish or event time in a topic partition.
Protobuf type google.cloud.pubsublite.v1.ComputeTimeCursorResponse
CreateReservationRequest
Request for CreateReservation.
Protobuf type google.cloud.pubsublite.v1.CreateReservationRequest
CreateReservationRequest.Builder
Request for CreateReservation.
Protobuf type google.cloud.pubsublite.v1.CreateReservationRequest
CreateSubscriptionRequest
Request for CreateSubscription.
Protobuf type google.cloud.pubsublite.v1.CreateSubscriptionRequest
CreateSubscriptionRequest.Builder
Request for CreateSubscription.
Protobuf type google.cloud.pubsublite.v1.CreateSubscriptionRequest
CreateTopicRequest
Request for CreateTopic.
Protobuf type google.cloud.pubsublite.v1.CreateTopicRequest
CreateTopicRequest.Builder
Request for CreateTopic.
Protobuf type google.cloud.pubsublite.v1.CreateTopicRequest
Cursor
A cursor that describes the position of a message within a topic partition.
Protobuf type google.cloud.pubsublite.v1.Cursor
Cursor.Builder
A cursor that describes the position of a message within a topic partition.
Protobuf type google.cloud.pubsublite.v1.Cursor
CursorProto
CursorServiceGrpc
The service that a subscriber client application uses to manage committed cursors while receiving messsages. A cursor represents a subscriber's progress within a topic partition for a given subscription.
CursorServiceGrpc.CursorServiceBlockingStub
A stub to allow clients to do synchronous rpc calls to service CursorService.
The service that a subscriber client application uses to manage committed cursors while receiving messsages. A cursor represents a subscriber's progress within a topic partition for a given subscription.
CursorServiceGrpc.CursorServiceFutureStub
A stub to allow clients to do ListenableFuture-style rpc calls to service CursorService.
The service that a subscriber client application uses to manage committed cursors while receiving messsages. A cursor represents a subscriber's progress within a topic partition for a given subscription.
CursorServiceGrpc.CursorServiceImplBase
Base class for the server implementation of the service CursorService.
The service that a subscriber client application uses to manage committed cursors while receiving messsages. A cursor represents a subscriber's progress within a topic partition for a given subscription.
CursorServiceGrpc.CursorServiceStub
A stub to allow clients to do asynchronous rpc calls to service CursorService.
The service that a subscriber client application uses to manage committed cursors while receiving messsages. A cursor represents a subscriber's progress within a topic partition for a given subscription.
DeleteReservationRequest
Request for DeleteReservation.
Protobuf type google.cloud.pubsublite.v1.DeleteReservationRequest
DeleteReservationRequest.Builder
Request for DeleteReservation.
Protobuf type google.cloud.pubsublite.v1.DeleteReservationRequest
DeleteSubscriptionRequest
Request for DeleteSubscription.
Protobuf type google.cloud.pubsublite.v1.DeleteSubscriptionRequest
DeleteSubscriptionRequest.Builder
Request for DeleteSubscription.
Protobuf type google.cloud.pubsublite.v1.DeleteSubscriptionRequest
DeleteTopicRequest
Request for DeleteTopic.
Protobuf type google.cloud.pubsublite.v1.DeleteTopicRequest
DeleteTopicRequest.Builder
Request for DeleteTopic.
Protobuf type google.cloud.pubsublite.v1.DeleteTopicRequest
ExportConfig
Configuration for a Pub/Sub Lite subscription that writes messages to a destination. User subscriber clients must not connect to this subscription.
Protobuf type google.cloud.pubsublite.v1.ExportConfig
ExportConfig.Builder
Configuration for a Pub/Sub Lite subscription that writes messages to a destination. User subscriber clients must not connect to this subscription.
Protobuf type google.cloud.pubsublite.v1.ExportConfig
ExportConfig.PubSubConfig
Configuration for exporting to a Pub/Sub topic.
Protobuf type google.cloud.pubsublite.v1.ExportConfig.PubSubConfig
ExportConfig.PubSubConfig.Builder
Configuration for exporting to a Pub/Sub topic.
Protobuf type google.cloud.pubsublite.v1.ExportConfig.PubSubConfig
FlowControlRequest
Request to grant tokens to the server, requesting delivery of messages when they become available.
Protobuf type google.cloud.pubsublite.v1.FlowControlRequest
FlowControlRequest.Builder
Request to grant tokens to the server, requesting delivery of messages when they become available.
Protobuf type google.cloud.pubsublite.v1.FlowControlRequest
GetReservationRequest
Request for GetReservation.
Protobuf type google.cloud.pubsublite.v1.GetReservationRequest
GetReservationRequest.Builder
Request for GetReservation.
Protobuf type google.cloud.pubsublite.v1.GetReservationRequest
GetSubscriptionRequest
Request for GetSubscription.
Protobuf type google.cloud.pubsublite.v1.GetSubscriptionRequest
GetSubscriptionRequest.Builder
Request for GetSubscription.
Protobuf type google.cloud.pubsublite.v1.GetSubscriptionRequest
GetTopicPartitionsRequest
Request for GetTopicPartitions.
Protobuf type google.cloud.pubsublite.v1.GetTopicPartitionsRequest
GetTopicPartitionsRequest.Builder
Request for GetTopicPartitions.
Protobuf type google.cloud.pubsublite.v1.GetTopicPartitionsRequest
GetTopicRequest
Request for GetTopic.
Protobuf type google.cloud.pubsublite.v1.GetTopicRequest
GetTopicRequest.Builder
Request for GetTopic.
Protobuf type google.cloud.pubsublite.v1.GetTopicRequest
InitialCommitCursorRequest
The first streaming request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.
Protobuf type google.cloud.pubsublite.v1.InitialCommitCursorRequest
InitialCommitCursorRequest.Builder
The first streaming request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.
Protobuf type google.cloud.pubsublite.v1.InitialCommitCursorRequest
InitialCommitCursorResponse
Response to an InitialCommitCursorRequest.
Protobuf type google.cloud.pubsublite.v1.InitialCommitCursorResponse
InitialCommitCursorResponse.Builder
Response to an InitialCommitCursorRequest.
Protobuf type google.cloud.pubsublite.v1.InitialCommitCursorResponse
InitialPartitionAssignmentRequest
The first request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.
Protobuf type google.cloud.pubsublite.v1.InitialPartitionAssignmentRequest
InitialPartitionAssignmentRequest.Builder
The first request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.
Protobuf type google.cloud.pubsublite.v1.InitialPartitionAssignmentRequest
InitialPublishRequest
The first request that must be sent on a newly-opened stream.
Protobuf type google.cloud.pubsublite.v1.InitialPublishRequest
InitialPublishRequest.Builder
The first request that must be sent on a newly-opened stream.
Protobuf type google.cloud.pubsublite.v1.InitialPublishRequest
InitialPublishResponse
Response to an InitialPublishRequest.
Protobuf type google.cloud.pubsublite.v1.InitialPublishResponse
InitialPublishResponse.Builder
Response to an InitialPublishRequest.
Protobuf type google.cloud.pubsublite.v1.InitialPublishResponse
InitialSubscribeRequest
The first request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.
Protobuf type google.cloud.pubsublite.v1.InitialSubscribeRequest
InitialSubscribeRequest.Builder
The first request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.
Protobuf type google.cloud.pubsublite.v1.InitialSubscribeRequest
InitialSubscribeResponse
Response to an InitialSubscribeRequest.
Protobuf type google.cloud.pubsublite.v1.InitialSubscribeResponse
InitialSubscribeResponse.Builder
Response to an InitialSubscribeRequest.
Protobuf type google.cloud.pubsublite.v1.InitialSubscribeResponse
ListPartitionCursorsRequest
Request for ListPartitionCursors.
Protobuf type google.cloud.pubsublite.v1.ListPartitionCursorsRequest
ListPartitionCursorsRequest.Builder
Request for ListPartitionCursors.
Protobuf type google.cloud.pubsublite.v1.ListPartitionCursorsRequest
ListPartitionCursorsResponse
Response for ListPartitionCursors
Protobuf type google.cloud.pubsublite.v1.ListPartitionCursorsResponse
ListPartitionCursorsResponse.Builder
Response for ListPartitionCursors
Protobuf type google.cloud.pubsublite.v1.ListPartitionCursorsResponse
ListReservationTopicsRequest
Request for ListReservationTopics.
Protobuf type google.cloud.pubsublite.v1.ListReservationTopicsRequest
ListReservationTopicsRequest.Builder
Request for ListReservationTopics.
Protobuf type google.cloud.pubsublite.v1.ListReservationTopicsRequest
ListReservationTopicsResponse
Response for ListReservationTopics.
Protobuf type google.cloud.pubsublite.v1.ListReservationTopicsResponse
ListReservationTopicsResponse.Builder
Response for ListReservationTopics.
Protobuf type google.cloud.pubsublite.v1.ListReservationTopicsResponse
ListReservationsRequest
Request for ListReservations.
Protobuf type google.cloud.pubsublite.v1.ListReservationsRequest
ListReservationsRequest.Builder
Request for ListReservations.
Protobuf type google.cloud.pubsublite.v1.ListReservationsRequest
ListReservationsResponse
Response for ListReservations.
Protobuf type google.cloud.pubsublite.v1.ListReservationsResponse
ListReservationsResponse.Builder
Response for ListReservations.
Protobuf type google.cloud.pubsublite.v1.ListReservationsResponse
ListSubscriptionsRequest
Request for ListSubscriptions.
Protobuf type google.cloud.pubsublite.v1.ListSubscriptionsRequest
ListSubscriptionsRequest.Builder
Request for ListSubscriptions.
Protobuf type google.cloud.pubsublite.v1.ListSubscriptionsRequest
ListSubscriptionsResponse
Response for ListSubscriptions.
Protobuf type google.cloud.pubsublite.v1.ListSubscriptionsResponse
ListSubscriptionsResponse.Builder
Response for ListSubscriptions.
Protobuf type google.cloud.pubsublite.v1.ListSubscriptionsResponse
ListTopicSubscriptionsRequest
Request for ListTopicSubscriptions.
Protobuf type google.cloud.pubsublite.v1.ListTopicSubscriptionsRequest
ListTopicSubscriptionsRequest.Builder
Request for ListTopicSubscriptions.
Protobuf type google.cloud.pubsublite.v1.ListTopicSubscriptionsRequest
ListTopicSubscriptionsResponse
Response for ListTopicSubscriptions.
Protobuf type google.cloud.pubsublite.v1.ListTopicSubscriptionsResponse
ListTopicSubscriptionsResponse.Builder
Response for ListTopicSubscriptions.
Protobuf type google.cloud.pubsublite.v1.ListTopicSubscriptionsResponse
ListTopicsRequest
Request for ListTopics.
Protobuf type google.cloud.pubsublite.v1.ListTopicsRequest
ListTopicsRequest.Builder
Request for ListTopics.
Protobuf type google.cloud.pubsublite.v1.ListTopicsRequest
ListTopicsResponse
Response for ListTopics.
Protobuf type google.cloud.pubsublite.v1.ListTopicsResponse
ListTopicsResponse.Builder
Response for ListTopics.
Protobuf type google.cloud.pubsublite.v1.ListTopicsResponse
LocationName
LocationName.Builder
Builder for projects/{project}/locations/{location}.
MessagePublishRequest
Request to publish messages to the topic.
Protobuf type google.cloud.pubsublite.v1.MessagePublishRequest
MessagePublishRequest.Builder
Request to publish messages to the topic.
Protobuf type google.cloud.pubsublite.v1.MessagePublishRequest
MessagePublishResponse
Response to a MessagePublishRequest.
Protobuf type google.cloud.pubsublite.v1.MessagePublishResponse
MessagePublishResponse.Builder
Response to a MessagePublishRequest.
Protobuf type google.cloud.pubsublite.v1.MessagePublishResponse
MessagePublishResponse.CursorRange
Cursors for a subrange of published messages.
Protobuf type google.cloud.pubsublite.v1.MessagePublishResponse.CursorRange
MessagePublishResponse.CursorRange.Builder
Cursors for a subrange of published messages.
Protobuf type google.cloud.pubsublite.v1.MessagePublishResponse.CursorRange
MessageResponse
Response containing a list of messages. Upon delivering a MessageResponse to the client, the server:
- Updates the stream's delivery cursor to one greater than the cursor of the last message in the list.
- Subtracts the total number of bytes and messages from the tokens available to the server.
Protobuf type google.cloud.pubsublite.v1.MessageResponse
MessageResponse.Builder
Response containing a list of messages. Upon delivering a MessageResponse to the client, the server:
- Updates the stream's delivery cursor to one greater than the cursor of the last message in the list.
- Subtracts the total number of bytes and messages from the tokens available to the server.
Protobuf type google.cloud.pubsublite.v1.MessageResponse
OperationMetadata
Metadata for long running operations.
Protobuf type google.cloud.pubsublite.v1.OperationMetadata
OperationMetadata.Builder
Metadata for long running operations.
Protobuf type google.cloud.pubsublite.v1.OperationMetadata
PartitionAssignment
PartitionAssignments should not race with acknowledgements. There should be exactly one unacknowledged PartitionAssignment at a time. If not, the client must break the stream.
Protobuf type google.cloud.pubsublite.v1.PartitionAssignment
PartitionAssignment.Builder
PartitionAssignments should not race with acknowledgements. There should be exactly one unacknowledged PartitionAssignment at a time. If not, the client must break the stream.
Protobuf type google.cloud.pubsublite.v1.PartitionAssignment
PartitionAssignmentAck
Acknowledge receipt and handling of the previous assignment. If not sent within a short period after receiving the assignment, partitions may remain unassigned for a period of time until the client is known to be inactive, after which time the server will break the stream.
Protobuf type google.cloud.pubsublite.v1.PartitionAssignmentAck
PartitionAssignmentAck.Builder
Acknowledge receipt and handling of the previous assignment. If not sent within a short period after receiving the assignment, partitions may remain unassigned for a period of time until the client is known to be inactive, after which time the server will break the stream.
Protobuf type google.cloud.pubsublite.v1.PartitionAssignmentAck
PartitionAssignmentRequest
A request on the PartitionAssignment stream.
Protobuf type google.cloud.pubsublite.v1.PartitionAssignmentRequest
PartitionAssignmentRequest.Builder
A request on the PartitionAssignment stream.
Protobuf type google.cloud.pubsublite.v1.PartitionAssignmentRequest
PartitionAssignmentServiceGrpc
The service that a subscriber client application uses to determine which partitions it should connect to.
PartitionAssignmentServiceGrpc.PartitionAssignmentServiceBlockingStub
A stub to allow clients to do synchronous rpc calls to service PartitionAssignmentService.
The service that a subscriber client application uses to determine which partitions it should connect to.
PartitionAssignmentServiceGrpc.PartitionAssignmentServiceFutureStub
A stub to allow clients to do ListenableFuture-style rpc calls to service PartitionAssignmentService.
The service that a subscriber client application uses to determine which partitions it should connect to.
PartitionAssignmentServiceGrpc.PartitionAssignmentServiceImplBase
Base class for the server implementation of the service PartitionAssignmentService.
The service that a subscriber client application uses to determine which partitions it should connect to.
PartitionAssignmentServiceGrpc.PartitionAssignmentServiceStub
A stub to allow clients to do asynchronous rpc calls to service PartitionAssignmentService.
The service that a subscriber client application uses to determine which partitions it should connect to.
PartitionCursor
A pair of a Cursor and the partition it is for.
Protobuf type google.cloud.pubsublite.v1.PartitionCursor
PartitionCursor.Builder
A pair of a Cursor and the partition it is for.
Protobuf type google.cloud.pubsublite.v1.PartitionCursor
PubSubMessage
A message that is published by publishers and delivered to subscribers.
Protobuf type google.cloud.pubsublite.v1.PubSubMessage
PubSubMessage.Builder
A message that is published by publishers and delivered to subscribers.
Protobuf type google.cloud.pubsublite.v1.PubSubMessage
PublishRequest
Request sent from the client to the server on a stream.
Protobuf type google.cloud.pubsublite.v1.PublishRequest
PublishRequest.Builder
Request sent from the client to the server on a stream.
Protobuf type google.cloud.pubsublite.v1.PublishRequest
PublishResponse
Response to a PublishRequest.
Protobuf type google.cloud.pubsublite.v1.PublishResponse
PublishResponse.Builder
Response to a PublishRequest.
Protobuf type google.cloud.pubsublite.v1.PublishResponse
PublisherProto
PublisherServiceGrpc
The service that a publisher client application uses to publish messages to
topics. Published messages are retained by the service for the duration of
the retention period configured for the respective topic, and are delivered
to subscriber clients upon request (via the SubscriberService).
PublisherServiceGrpc.PublisherServiceBlockingStub
A stub to allow clients to do synchronous rpc calls to service PublisherService.
The service that a publisher client application uses to publish messages to
topics. Published messages are retained by the service for the duration of
the retention period configured for the respective topic, and are delivered
to subscriber clients upon request (via the SubscriberService).
PublisherServiceGrpc.PublisherServiceFutureStub
A stub to allow clients to do ListenableFuture-style rpc calls to service PublisherService.
The service that a publisher client application uses to publish messages to
topics. Published messages are retained by the service for the duration of
the retention period configured for the respective topic, and are delivered
to subscriber clients upon request (via the SubscriberService).
PublisherServiceGrpc.PublisherServiceImplBase
Base class for the server implementation of the service PublisherService.
The service that a publisher client application uses to publish messages to
topics. Published messages are retained by the service for the duration of
the retention period configured for the respective topic, and are delivered
to subscriber clients upon request (via the SubscriberService).
PublisherServiceGrpc.PublisherServiceStub
A stub to allow clients to do asynchronous rpc calls to service PublisherService.
The service that a publisher client application uses to publish messages to
topics. Published messages are retained by the service for the duration of
the retention period configured for the respective topic, and are delivered
to subscriber clients upon request (via the SubscriberService).
Reservation
Metadata about a reservation resource.
Protobuf type google.cloud.pubsublite.v1.Reservation
Reservation.Builder
Metadata about a reservation resource.
Protobuf type google.cloud.pubsublite.v1.Reservation
ReservationName
ReservationName.Builder
Builder for projects/{project}/locations/{location}/reservations/{reservation}.
SeekRequest
Request to update the stream's delivery cursor based on the given target. Resets the server available tokens to 0. SeekRequests past head result in stream breakage.
SeekRequests may not be sent while another SeekRequest is outstanding (i.e., has not received a SeekResponse) on the same stream.
Protobuf type google.cloud.pubsublite.v1.SeekRequest
SeekRequest.Builder
Request to update the stream's delivery cursor based on the given target. Resets the server available tokens to 0. SeekRequests past head result in stream breakage.
SeekRequests may not be sent while another SeekRequest is outstanding (i.e., has not received a SeekResponse) on the same stream.
Protobuf type google.cloud.pubsublite.v1.SeekRequest
SeekResponse
Response to a SeekRequest.
Protobuf type google.cloud.pubsublite.v1.SeekResponse
SeekResponse.Builder
Response to a SeekRequest.
Protobuf type google.cloud.pubsublite.v1.SeekResponse
SeekSubscriptionRequest
Request for SeekSubscription.
Protobuf type google.cloud.pubsublite.v1.SeekSubscriptionRequest
SeekSubscriptionRequest.Builder
Request for SeekSubscription.
Protobuf type google.cloud.pubsublite.v1.SeekSubscriptionRequest
SeekSubscriptionResponse
Response for SeekSubscription long running operation.
Protobuf type google.cloud.pubsublite.v1.SeekSubscriptionResponse
SeekSubscriptionResponse.Builder
Response for SeekSubscription long running operation.
Protobuf type google.cloud.pubsublite.v1.SeekSubscriptionResponse
SequencedCommitCursorRequest
Streaming request to update the committed cursor. Subsequent SequencedCommitCursorRequests override outstanding ones.
Protobuf type google.cloud.pubsublite.v1.SequencedCommitCursorRequest
SequencedCommitCursorRequest.Builder
Streaming request to update the committed cursor. Subsequent SequencedCommitCursorRequests override outstanding ones.
Protobuf type google.cloud.pubsublite.v1.SequencedCommitCursorRequest
SequencedCommitCursorResponse
Response to a SequencedCommitCursorRequest.
Protobuf type google.cloud.pubsublite.v1.SequencedCommitCursorResponse
SequencedCommitCursorResponse.Builder
Response to a SequencedCommitCursorRequest.
Protobuf type google.cloud.pubsublite.v1.SequencedCommitCursorResponse
SequencedMessage
A message that has been stored and sequenced by the Pub/Sub Lite system.
Protobuf type google.cloud.pubsublite.v1.SequencedMessage
SequencedMessage.Builder
A message that has been stored and sequenced by the Pub/Sub Lite system.
Protobuf type google.cloud.pubsublite.v1.SequencedMessage
StreamingCommitCursorRequest
A request sent from the client to the server on a stream.
Protobuf type google.cloud.pubsublite.v1.StreamingCommitCursorRequest
StreamingCommitCursorRequest.Builder
A request sent from the client to the server on a stream.
Protobuf type google.cloud.pubsublite.v1.StreamingCommitCursorRequest
StreamingCommitCursorResponse
Response to a StreamingCommitCursorRequest.
Protobuf type google.cloud.pubsublite.v1.StreamingCommitCursorResponse
StreamingCommitCursorResponse.Builder
Response to a StreamingCommitCursorRequest.
Protobuf type google.cloud.pubsublite.v1.StreamingCommitCursorResponse
SubscribeRequest
A request sent from the client to the server on a stream.
Protobuf type google.cloud.pubsublite.v1.SubscribeRequest
SubscribeRequest.Builder
A request sent from the client to the server on a stream.
Protobuf type google.cloud.pubsublite.v1.SubscribeRequest
SubscribeResponse
Response to SubscribeRequest.
Protobuf type google.cloud.pubsublite.v1.SubscribeResponse
SubscribeResponse.Builder
Response to SubscribeRequest.
Protobuf type google.cloud.pubsublite.v1.SubscribeResponse
SubscriberProto
SubscriberServiceGrpc
The service that a subscriber client application uses to receive messages from subscriptions.
SubscriberServiceGrpc.SubscriberServiceBlockingStub
A stub to allow clients to do synchronous rpc calls to service SubscriberService.
The service that a subscriber client application uses to receive messages from subscriptions.
SubscriberServiceGrpc.SubscriberServiceFutureStub
A stub to allow clients to do ListenableFuture-style rpc calls to service SubscriberService.
The service that a subscriber client application uses to receive messages from subscriptions.
SubscriberServiceGrpc.SubscriberServiceImplBase
Base class for the server implementation of the service SubscriberService.
The service that a subscriber client application uses to receive messages from subscriptions.
SubscriberServiceGrpc.SubscriberServiceStub
A stub to allow clients to do asynchronous rpc calls to service SubscriberService.
The service that a subscriber client application uses to receive messages from subscriptions.
Subscription
Metadata about a subscription resource.
Protobuf type google.cloud.pubsublite.v1.Subscription
Subscription.Builder
Metadata about a subscription resource.
Protobuf type google.cloud.pubsublite.v1.Subscription
Subscription.DeliveryConfig
The settings for a subscription's message delivery.
Protobuf type google.cloud.pubsublite.v1.Subscription.DeliveryConfig
Subscription.DeliveryConfig.Builder
The settings for a subscription's message delivery.
Protobuf type google.cloud.pubsublite.v1.Subscription.DeliveryConfig
SubscriptionName
SubscriptionName.Builder
Builder for projects/{project}/locations/{location}/subscriptions/{subscription}.
TimeTarget
A target publish or event time. Can be used for seeking to or retrieving the corresponding cursor.
Protobuf type google.cloud.pubsublite.v1.TimeTarget
TimeTarget.Builder
A target publish or event time. Can be used for seeking to or retrieving the corresponding cursor.
Protobuf type google.cloud.pubsublite.v1.TimeTarget
Topic
Metadata about a topic resource.
Protobuf type google.cloud.pubsublite.v1.Topic
Topic.Builder
Metadata about a topic resource.
Protobuf type google.cloud.pubsublite.v1.Topic
Topic.PartitionConfig
The settings for a topic's partitions.
Protobuf type google.cloud.pubsublite.v1.Topic.PartitionConfig
Topic.PartitionConfig.Builder
The settings for a topic's partitions.
Protobuf type google.cloud.pubsublite.v1.Topic.PartitionConfig
Topic.PartitionConfig.Capacity
The throughput capacity configuration for each partition.
Protobuf type google.cloud.pubsublite.v1.Topic.PartitionConfig.Capacity
Topic.PartitionConfig.Capacity.Builder
The throughput capacity configuration for each partition.
Protobuf type google.cloud.pubsublite.v1.Topic.PartitionConfig.Capacity
Topic.ReservationConfig
The settings for this topic's Reservation usage.
Protobuf type google.cloud.pubsublite.v1.Topic.ReservationConfig
Topic.ReservationConfig.Builder
The settings for this topic's Reservation usage.
Protobuf type google.cloud.pubsublite.v1.Topic.ReservationConfig
Topic.RetentionConfig
The settings for a topic's message retention.
Protobuf type google.cloud.pubsublite.v1.Topic.RetentionConfig
Topic.RetentionConfig.Builder
The settings for a topic's message retention.
Protobuf type google.cloud.pubsublite.v1.Topic.RetentionConfig
TopicName
TopicName.Builder
Builder for projects/{project}/locations/{location}/topics/{topic}.
TopicPartitions
Response for GetTopicPartitions.
Protobuf type google.cloud.pubsublite.v1.TopicPartitions
TopicPartitions.Builder
Response for GetTopicPartitions.
Protobuf type google.cloud.pubsublite.v1.TopicPartitions
TopicStatsProto
TopicStatsServiceGrpc
This service allows users to get stats about messages in their topic.
TopicStatsServiceGrpc.TopicStatsServiceBlockingStub
A stub to allow clients to do synchronous rpc calls to service TopicStatsService.
This service allows users to get stats about messages in their topic.
TopicStatsServiceGrpc.TopicStatsServiceFutureStub
A stub to allow clients to do ListenableFuture-style rpc calls to service TopicStatsService.
This service allows users to get stats about messages in their topic.
TopicStatsServiceGrpc.TopicStatsServiceImplBase
Base class for the server implementation of the service TopicStatsService.
This service allows users to get stats about messages in their topic.
TopicStatsServiceGrpc.TopicStatsServiceStub
A stub to allow clients to do asynchronous rpc calls to service TopicStatsService.
This service allows users to get stats about messages in their topic.
UpdateReservationRequest
Request for UpdateReservation.
Protobuf type google.cloud.pubsublite.v1.UpdateReservationRequest
UpdateReservationRequest.Builder
Request for UpdateReservation.
Protobuf type google.cloud.pubsublite.v1.UpdateReservationRequest
UpdateSubscriptionRequest
Request for UpdateSubscription.
Protobuf type google.cloud.pubsublite.v1.UpdateSubscriptionRequest
UpdateSubscriptionRequest.Builder
Request for UpdateSubscription.
Protobuf type google.cloud.pubsublite.v1.UpdateSubscriptionRequest
UpdateTopicRequest
Request for UpdateTopic.
Protobuf type google.cloud.pubsublite.v1.UpdateTopicRequest
UpdateTopicRequest.Builder
Request for UpdateTopic.
Protobuf type google.cloud.pubsublite.v1.UpdateTopicRequest
Interfaces
AdminServiceGrpc.AsyncService
The service that a client application uses to manage topics and subscriptions, such creating, listing, and deleting topics and subscriptions.
AttributeValuesOrBuilder
CommitCursorRequestOrBuilder
CommitCursorResponseOrBuilder
ComputeHeadCursorRequestOrBuilder
ComputeHeadCursorResponseOrBuilder
ComputeMessageStatsRequestOrBuilder
ComputeMessageStatsResponseOrBuilder
ComputeTimeCursorRequestOrBuilder
ComputeTimeCursorResponseOrBuilder
CreateReservationRequestOrBuilder
CreateSubscriptionRequestOrBuilder
CreateTopicRequestOrBuilder
CursorOrBuilder
CursorServiceGrpc.AsyncService
The service that a subscriber client application uses to manage committed cursors while receiving messsages. A cursor represents a subscriber's progress within a topic partition for a given subscription.
DeleteReservationRequestOrBuilder
DeleteSubscriptionRequestOrBuilder
DeleteTopicRequestOrBuilder
ExportConfig.PubSubConfigOrBuilder
ExportConfigOrBuilder
FlowControlRequestOrBuilder
GetReservationRequestOrBuilder
GetSubscriptionRequestOrBuilder
GetTopicPartitionsRequestOrBuilder
GetTopicRequestOrBuilder
InitialCommitCursorRequestOrBuilder
InitialCommitCursorResponseOrBuilder
InitialPartitionAssignmentRequestOrBuilder
InitialPublishRequestOrBuilder
InitialPublishResponseOrBuilder
InitialSubscribeRequestOrBuilder
InitialSubscribeResponseOrBuilder
ListPartitionCursorsRequestOrBuilder
ListPartitionCursorsResponseOrBuilder
ListReservationTopicsRequestOrBuilder
ListReservationTopicsResponseOrBuilder
ListReservationsRequestOrBuilder
ListReservationsResponseOrBuilder
ListSubscriptionsRequestOrBuilder
ListSubscriptionsResponseOrBuilder
ListTopicSubscriptionsRequestOrBuilder
ListTopicSubscriptionsResponseOrBuilder
ListTopicsRequestOrBuilder
ListTopicsResponseOrBuilder
MessagePublishRequestOrBuilder
MessagePublishResponse.CursorRangeOrBuilder
MessagePublishResponseOrBuilder
MessageResponseOrBuilder
OperationMetadataOrBuilder
PartitionAssignmentAckOrBuilder
PartitionAssignmentOrBuilder
PartitionAssignmentRequestOrBuilder
PartitionAssignmentServiceGrpc.AsyncService
The service that a subscriber client application uses to determine which partitions it should connect to.
PartitionCursorOrBuilder
PubSubMessageOrBuilder
PublishRequestOrBuilder
PublishResponseOrBuilder
PublisherServiceGrpc.AsyncService
The service that a publisher client application uses to publish messages to
topics. Published messages are retained by the service for the duration of
the retention period configured for the respective topic, and are delivered
to subscriber clients upon request (via the SubscriberService).
ReservationOrBuilder
SeekRequestOrBuilder
SeekResponseOrBuilder
SeekSubscriptionRequestOrBuilder
SeekSubscriptionResponseOrBuilder
SequencedCommitCursorRequestOrBuilder
SequencedCommitCursorResponseOrBuilder
SequencedMessageOrBuilder
StreamingCommitCursorRequestOrBuilder
StreamingCommitCursorResponseOrBuilder
SubscribeRequestOrBuilder
SubscribeResponseOrBuilder
SubscriberServiceGrpc.AsyncService
The service that a subscriber client application uses to receive messages from subscriptions.
Subscription.DeliveryConfigOrBuilder
SubscriptionOrBuilder
TimeTargetOrBuilder
Topic.PartitionConfig.CapacityOrBuilder
Topic.PartitionConfigOrBuilder
Topic.ReservationConfigOrBuilder
Topic.RetentionConfigOrBuilder
TopicOrBuilder
TopicPartitionsOrBuilder
TopicStatsServiceGrpc.AsyncService
This service allows users to get stats about messages in their topic.
UpdateReservationRequestOrBuilder
UpdateSubscriptionRequestOrBuilder
UpdateTopicRequestOrBuilder
Enums
ExportConfig.DestinationCase
ExportConfig.State
The desired export state.
Protobuf enum google.cloud.pubsublite.v1.ExportConfig.State
PartitionAssignmentRequest.RequestCase
PublishRequest.RequestTypeCase
PublishResponse.ResponseTypeCase
SeekRequest.NamedTarget
A special target in the partition that takes no other parameters.
Protobuf enum google.cloud.pubsublite.v1.SeekRequest.NamedTarget
SeekRequest.TargetCase
SeekSubscriptionRequest.NamedTarget
A named position with respect to the message backlog.
Protobuf enum google.cloud.pubsublite.v1.SeekSubscriptionRequest.NamedTarget
SeekSubscriptionRequest.TargetCase
StreamingCommitCursorRequest.RequestCase
StreamingCommitCursorResponse.RequestCase
SubscribeRequest.RequestCase
SubscribeResponse.ResponseCase
Subscription.DeliveryConfig.DeliveryRequirement
When this subscription should send messages to subscribers relative to messages persistence in storage. For details, see Creating Lite subscriptions.
Protobuf enum
google.cloud.pubsublite.v1.Subscription.DeliveryConfig.DeliveryRequirement