Class |
Description |
com.google.cloud.pubsublite.proto.AdminProto |
|
com.google.cloud.pubsublite.proto.AdminServiceGrpc |
The service that a client application uses to manage topics and
subscriptions, such creating, listing, and deleting topics and subscriptions.
|
com.google.cloud.pubsublite.proto.AdminServiceGrpc.AdminServiceImplBase |
Base class for the server implementation of the service AdminService.
The service that a client application uses to manage topics and |
com.google.cloud.pubsublite.proto.AttributeValues |
The values associated with a key of an attribute.
|
com.google.cloud.pubsublite.proto.AttributeValues.Builder |
The values associated with a key of an attribute.
|
com.google.cloud.pubsublite.proto.CommitCursorRequest |
Request for CommitCursor.
|
com.google.cloud.pubsublite.proto.CommitCursorRequest.Builder |
Request for CommitCursor.
|
com.google.cloud.pubsublite.proto.CommitCursorResponse |
Response for CommitCursor.
|
com.google.cloud.pubsublite.proto.CommitCursorResponse.Builder |
Response for CommitCursor.
|
com.google.cloud.pubsublite.proto.CommonProto |
|
com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest |
Compute the current head cursor for a partition.
|
com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest.Builder |
Compute the current head cursor for a partition.
|
com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse |
Response containing the head cursor for the requested topic and partition.
|
com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse.Builder |
Response containing the head cursor for the requested topic and partition.
|
com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest |
Compute statistics about a range of messages in a given topic and partition.
|
com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest.Builder |
Compute statistics about a range of messages in a given topic and partition.
|
com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse |
Response containing stats for messages in the requested topic and partition.
|
com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse.Builder |
Response containing stats for messages in the requested topic and partition.
|
com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest |
Compute the corresponding cursor for a publish or event time in a topic
partition.
|
com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest.Builder |
Compute the corresponding cursor for a publish or event time in a topic
partition.
|
com.google.cloud.pubsublite.proto.ComputeTimeCursorResponse |
Response containing the cursor corresponding to a publish or event time in a
topic partition.
|
com.google.cloud.pubsublite.proto.ComputeTimeCursorResponse.Builder |
Response containing the cursor corresponding to a publish or event time in a
topic partition.
|
com.google.cloud.pubsublite.proto.CreateReservationRequest |
Request for CreateReservation.
|
com.google.cloud.pubsublite.proto.CreateReservationRequest.Builder |
Request for CreateReservation.
|
com.google.cloud.pubsublite.proto.CreateSubscriptionRequest |
Request for CreateSubscription.
|
com.google.cloud.pubsublite.proto.CreateSubscriptionRequest.Builder |
Request for CreateSubscription.
|
com.google.cloud.pubsublite.proto.CreateTopicRequest |
Request for CreateTopic.
|
com.google.cloud.pubsublite.proto.CreateTopicRequest.Builder |
Request for CreateTopic.
|
com.google.cloud.pubsublite.proto.Cursor |
A cursor that describes the position of a message within a topic partition.
|
com.google.cloud.pubsublite.proto.Cursor.Builder |
A cursor that describes the position of a message within a topic partition.
|
com.google.cloud.pubsublite.proto.CursorProto |
|
com.google.cloud.pubsublite.proto.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. |
com.google.cloud.pubsublite.proto.CursorServiceGrpc.CursorServiceImplBase |
Base class for the server implementation of the service CursorService.
The service that a subscriber client application uses to manage committed |
com.google.cloud.pubsublite.proto.DeleteReservationRequest |
Request for DeleteReservation.
|
com.google.cloud.pubsublite.proto.DeleteReservationRequest.Builder |
Request for DeleteReservation.
|
com.google.cloud.pubsublite.proto.DeleteSubscriptionRequest |
Request for DeleteSubscription.
|
com.google.cloud.pubsublite.proto.DeleteSubscriptionRequest.Builder |
Request for DeleteSubscription.
|
com.google.cloud.pubsublite.proto.DeleteTopicRequest |
Request for DeleteTopic.
|
com.google.cloud.pubsublite.proto.DeleteTopicRequest.Builder |
Request for DeleteTopic.
|
com.google.cloud.pubsublite.proto.ExportConfig |
Configuration for a Pub/Sub Lite subscription that writes messages to a
destination. User subscriber clients must not connect to this subscription.
|
com.google.cloud.pubsublite.proto.ExportConfig.Builder |
Configuration for a Pub/Sub Lite subscription that writes messages to a
destination. User subscriber clients must not connect to this subscription.
|
com.google.cloud.pubsublite.proto.ExportConfig.PubSubConfig |
Configuration for exporting to a Pub/Sub topic.
|
com.google.cloud.pubsublite.proto.ExportConfig.PubSubConfig.Builder |
Configuration for exporting to a Pub/Sub topic.
|
com.google.cloud.pubsublite.proto.FlowControlRequest |
Request to grant tokens to the server, requesting delivery of messages when
they become available.
|
com.google.cloud.pubsublite.proto.FlowControlRequest.Builder |
Request to grant tokens to the server, requesting delivery of messages when
they become available.
|
com.google.cloud.pubsublite.proto.GetReservationRequest |
Request for GetReservation.
|
com.google.cloud.pubsublite.proto.GetReservationRequest.Builder |
Request for GetReservation.
|
com.google.cloud.pubsublite.proto.GetSubscriptionRequest |
Request for GetSubscription.
|
com.google.cloud.pubsublite.proto.GetSubscriptionRequest.Builder |
Request for GetSubscription.
|
com.google.cloud.pubsublite.proto.GetTopicPartitionsRequest |
Request for GetTopicPartitions.
|
com.google.cloud.pubsublite.proto.GetTopicPartitionsRequest.Builder |
Request for GetTopicPartitions.
|
com.google.cloud.pubsublite.proto.GetTopicRequest |
Request for GetTopic.
|
com.google.cloud.pubsublite.proto.GetTopicRequest.Builder |
Request for GetTopic.
|
com.google.cloud.pubsublite.proto.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. |
com.google.cloud.pubsublite.proto.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. |
com.google.cloud.pubsublite.proto.InitialCommitCursorResponse |
Response to an InitialCommitCursorRequest.
|
com.google.cloud.pubsublite.proto.InitialCommitCursorResponse.Builder |
Response to an InitialCommitCursorRequest.
|
com.google.cloud.pubsublite.proto.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.
|
com.google.cloud.pubsublite.proto.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.
|
com.google.cloud.pubsublite.proto.InitialPublishRequest |
The first request that must be sent on a newly-opened stream.
|
com.google.cloud.pubsublite.proto.InitialPublishRequest.Builder |
The first request that must be sent on a newly-opened stream.
|
com.google.cloud.pubsublite.proto.InitialPublishResponse |
Response to an InitialPublishRequest.
|
com.google.cloud.pubsublite.proto.InitialPublishResponse.Builder |
Response to an InitialPublishRequest.
|
com.google.cloud.pubsublite.proto.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.
|
com.google.cloud.pubsublite.proto.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.
|
com.google.cloud.pubsublite.proto.InitialSubscribeResponse |
Response to an InitialSubscribeRequest.
|
com.google.cloud.pubsublite.proto.InitialSubscribeResponse.Builder |
Response to an InitialSubscribeRequest.
|
com.google.cloud.pubsublite.proto.ListPartitionCursorsRequest |
Request for ListPartitionCursors.
|
com.google.cloud.pubsublite.proto.ListPartitionCursorsRequest.Builder |
Request for ListPartitionCursors.
|
com.google.cloud.pubsublite.proto.ListPartitionCursorsResponse |
Response for ListPartitionCursors
|
com.google.cloud.pubsublite.proto.ListPartitionCursorsResponse.Builder |
Response for ListPartitionCursors
|
com.google.cloud.pubsublite.proto.ListReservationTopicsRequest |
Request for ListReservationTopics.
|
com.google.cloud.pubsublite.proto.ListReservationTopicsRequest.Builder |
Request for ListReservationTopics.
|
com.google.cloud.pubsublite.proto.ListReservationTopicsResponse |
Response for ListReservationTopics.
|
com.google.cloud.pubsublite.proto.ListReservationTopicsResponse.Builder |
Response for ListReservationTopics.
|
com.google.cloud.pubsublite.proto.ListReservationsRequest |
Request for ListReservations.
|
com.google.cloud.pubsublite.proto.ListReservationsRequest.Builder |
Request for ListReservations.
|
com.google.cloud.pubsublite.proto.ListReservationsResponse |
Response for ListReservations.
|
com.google.cloud.pubsublite.proto.ListReservationsResponse.Builder |
Response for ListReservations.
|
com.google.cloud.pubsublite.proto.ListSubscriptionsRequest |
Request for ListSubscriptions.
|
com.google.cloud.pubsublite.proto.ListSubscriptionsRequest.Builder |
Request for ListSubscriptions.
|
com.google.cloud.pubsublite.proto.ListSubscriptionsResponse |
Response for ListSubscriptions.
|
com.google.cloud.pubsublite.proto.ListSubscriptionsResponse.Builder |
Response for ListSubscriptions.
|
com.google.cloud.pubsublite.proto.ListTopicSubscriptionsRequest |
Request for ListTopicSubscriptions.
|
com.google.cloud.pubsublite.proto.ListTopicSubscriptionsRequest.Builder |
Request for ListTopicSubscriptions.
|
com.google.cloud.pubsublite.proto.ListTopicSubscriptionsResponse |
Response for ListTopicSubscriptions.
|
com.google.cloud.pubsublite.proto.ListTopicSubscriptionsResponse.Builder |
Response for ListTopicSubscriptions.
|
com.google.cloud.pubsublite.proto.ListTopicsRequest |
Request for ListTopics.
|
com.google.cloud.pubsublite.proto.ListTopicsRequest.Builder |
Request for ListTopics.
|
com.google.cloud.pubsublite.proto.ListTopicsResponse |
Response for ListTopics.
|
com.google.cloud.pubsublite.proto.ListTopicsResponse.Builder |
Response for ListTopics.
|
com.google.cloud.pubsublite.proto.LocationName |
|
com.google.cloud.pubsublite.proto.LocationName.Builder |
Builder for projects/{project}/locations/{location}. |
com.google.cloud.pubsublite.proto.MessagePublishRequest |
Request to publish messages to the topic.
|
com.google.cloud.pubsublite.proto.MessagePublishRequest.Builder |
Request to publish messages to the topic.
|
com.google.cloud.pubsublite.proto.MessagePublishResponse |
Response to a MessagePublishRequest.
|
com.google.cloud.pubsublite.proto.MessagePublishResponse.Builder |
Response to a MessagePublishRequest.
|
com.google.cloud.pubsublite.proto.MessagePublishResponse.CursorRange |
Cursors for a subrange of published messages.
|
com.google.cloud.pubsublite.proto.MessagePublishResponse.CursorRange.Builder |
Cursors for a subrange of published messages.
|
com.google.cloud.pubsublite.proto.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 |
com.google.cloud.pubsublite.proto.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 |
com.google.cloud.pubsublite.proto.OperationMetadata |
Metadata for long running operations.
|
com.google.cloud.pubsublite.proto.OperationMetadata.Builder |
Metadata for long running operations.
|
com.google.cloud.pubsublite.proto.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. |
com.google.cloud.pubsublite.proto.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. |
com.google.cloud.pubsublite.proto.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 |
com.google.cloud.pubsublite.proto.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 |
com.google.cloud.pubsublite.proto.PartitionAssignmentRequest |
A request on the PartitionAssignment stream.
|
com.google.cloud.pubsublite.proto.PartitionAssignmentRequest.Builder |
A request on the PartitionAssignment stream.
|
com.google.cloud.pubsublite.proto.PartitionAssignmentServiceGrpc |
The service that a subscriber client application uses to determine which
partitions it should connect to.
|
com.google.cloud.pubsublite.proto.PartitionAssignmentServiceGrpc.PartitionAssignmentServiceImplBase |
Base class for the server implementation of the service PartitionAssignmentService.
The service that a subscriber client application uses to determine which |
com.google.cloud.pubsublite.proto.PartitionCursor |
A pair of a Cursor and the partition it is for.
|
com.google.cloud.pubsublite.proto.PartitionCursor.Builder |
A pair of a Cursor and the partition it is for.
|
com.google.cloud.pubsublite.proto.PubSubMessage |
A message that is published by publishers and delivered to subscribers.
|
com.google.cloud.pubsublite.proto.PubSubMessage.Builder |
A message that is published by publishers and delivered to subscribers.
|
com.google.cloud.pubsublite.proto.PublishRequest |
Request sent from the client to the server on a stream.
|
com.google.cloud.pubsublite.proto.PublishRequest.Builder |
Request sent from the client to the server on a stream.
|
com.google.cloud.pubsublite.proto.PublishResponse |
Response to a PublishRequest.
|
com.google.cloud.pubsublite.proto.PublishResponse.Builder |
Response to a PublishRequest.
|
com.google.cloud.pubsublite.proto.PublisherProto |
|
com.google.cloud.pubsublite.proto.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 |
com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceImplBase |
Base class for the server implementation of the service PublisherService.
The service that a publisher client application uses to publish messages to |
com.google.cloud.pubsublite.proto.Reservation |
Metadata about a reservation resource.
|
com.google.cloud.pubsublite.proto.Reservation.Builder |
Metadata about a reservation resource.
|
com.google.cloud.pubsublite.proto.ReservationName |
|
com.google.cloud.pubsublite.proto.ReservationName.Builder |
Builder for projects/{project}/locations/{location}/reservations/{reservation}. |
com.google.cloud.pubsublite.proto.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. |
com.google.cloud.pubsublite.proto.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. |
com.google.cloud.pubsublite.proto.SeekResponse |
Response to a SeekRequest.
|
com.google.cloud.pubsublite.proto.SeekResponse.Builder |
Response to a SeekRequest.
|
com.google.cloud.pubsublite.proto.SeekSubscriptionRequest |
Request for SeekSubscription.
|
com.google.cloud.pubsublite.proto.SeekSubscriptionRequest.Builder |
Request for SeekSubscription.
|
com.google.cloud.pubsublite.proto.SeekSubscriptionResponse |
Response for SeekSubscription long running operation.
|
com.google.cloud.pubsublite.proto.SeekSubscriptionResponse.Builder |
Response for SeekSubscription long running operation.
|
com.google.cloud.pubsublite.proto.SequencedCommitCursorRequest |
Streaming request to update the committed cursor. Subsequent
SequencedCommitCursorRequests override outstanding ones.
|
com.google.cloud.pubsublite.proto.SequencedCommitCursorRequest.Builder |
Streaming request to update the committed cursor. Subsequent
SequencedCommitCursorRequests override outstanding ones.
|
com.google.cloud.pubsublite.proto.SequencedCommitCursorResponse |
Response to a SequencedCommitCursorRequest.
|
com.google.cloud.pubsublite.proto.SequencedCommitCursorResponse.Builder |
Response to a SequencedCommitCursorRequest.
|
com.google.cloud.pubsublite.proto.SequencedMessage |
A message that has been stored and sequenced by the Pub/Sub Lite system.
|
com.google.cloud.pubsublite.proto.SequencedMessage.Builder |
A message that has been stored and sequenced by the Pub/Sub Lite system.
|
com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest |
A request sent from the client to the server on a stream.
|
com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest.Builder |
A request sent from the client to the server on a stream.
|
com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse |
Response to a StreamingCommitCursorRequest.
|
com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse.Builder |
Response to a StreamingCommitCursorRequest.
|
com.google.cloud.pubsublite.proto.SubscribeRequest |
A request sent from the client to the server on a stream.
|
com.google.cloud.pubsublite.proto.SubscribeRequest.Builder |
A request sent from the client to the server on a stream.
|
com.google.cloud.pubsublite.proto.SubscribeResponse |
Response to SubscribeRequest.
|
com.google.cloud.pubsublite.proto.SubscribeResponse.Builder |
Response to SubscribeRequest.
|
com.google.cloud.pubsublite.proto.SubscriberProto |
|
com.google.cloud.pubsublite.proto.SubscriberServiceGrpc |
The service that a subscriber client application uses to receive messages
from subscriptions.
|
com.google.cloud.pubsublite.proto.SubscriberServiceGrpc.SubscriberServiceImplBase |
Base class for the server implementation of the service SubscriberService.
The service that a subscriber client application uses to receive messages |
com.google.cloud.pubsublite.proto.Subscription |
Metadata about a subscription resource.
|
com.google.cloud.pubsublite.proto.Subscription.Builder |
Metadata about a subscription resource.
|
com.google.cloud.pubsublite.proto.Subscription.DeliveryConfig |
The settings for a subscription's message delivery.
|
com.google.cloud.pubsublite.proto.Subscription.DeliveryConfig.Builder |
The settings for a subscription's message delivery.
|
com.google.cloud.pubsublite.proto.SubscriptionName |
|
com.google.cloud.pubsublite.proto.SubscriptionName.Builder |
Builder for projects/{project}/locations/{location}/subscriptions/{subscription}. |
com.google.cloud.pubsublite.proto.TimeTarget |
A target publish or event time. Can be used for seeking to or retrieving the
corresponding cursor.
|
com.google.cloud.pubsublite.proto.TimeTarget.Builder |
A target publish or event time. Can be used for seeking to or retrieving the
corresponding cursor.
|
com.google.cloud.pubsublite.proto.Topic |
Metadata about a topic resource.
|
com.google.cloud.pubsublite.proto.Topic.Builder |
Metadata about a topic resource.
|
com.google.cloud.pubsublite.proto.Topic.PartitionConfig |
The settings for a topic's partitions.
|
com.google.cloud.pubsublite.proto.Topic.PartitionConfig.Builder |
The settings for a topic's partitions.
|
com.google.cloud.pubsublite.proto.Topic.PartitionConfig.Capacity |
The throughput capacity configuration for each partition.
|
com.google.cloud.pubsublite.proto.Topic.PartitionConfig.Capacity.Builder |
The throughput capacity configuration for each partition.
|
com.google.cloud.pubsublite.proto.Topic.ReservationConfig |
The settings for this topic's Reservation usage.
|
com.google.cloud.pubsublite.proto.Topic.ReservationConfig.Builder |
The settings for this topic's Reservation usage.
|
com.google.cloud.pubsublite.proto.Topic.RetentionConfig |
The settings for a topic's message retention.
|
com.google.cloud.pubsublite.proto.Topic.RetentionConfig.Builder |
The settings for a topic's message retention.
|
com.google.cloud.pubsublite.proto.TopicName |
|
com.google.cloud.pubsublite.proto.TopicName.Builder |
Builder for projects/{project}/locations/{location}/topics/{topic}. |
com.google.cloud.pubsublite.proto.TopicPartitions |
Response for GetTopicPartitions.
|
com.google.cloud.pubsublite.proto.TopicPartitions.Builder |
Response for GetTopicPartitions.
|
com.google.cloud.pubsublite.proto.TopicStatsProto |
|
com.google.cloud.pubsublite.proto.TopicStatsServiceGrpc |
This service allows users to get stats about messages in their topic.
|
com.google.cloud.pubsublite.proto.TopicStatsServiceGrpc.TopicStatsServiceImplBase |
Base class for the server implementation of the service TopicStatsService.
This service allows users to get stats about messages in their topic. |
com.google.cloud.pubsublite.proto.UpdateReservationRequest |
Request for UpdateReservation.
|
com.google.cloud.pubsublite.proto.UpdateReservationRequest.Builder |
Request for UpdateReservation.
|
com.google.cloud.pubsublite.proto.UpdateSubscriptionRequest |
Request for UpdateSubscription.
|
com.google.cloud.pubsublite.proto.UpdateSubscriptionRequest.Builder |
Request for UpdateSubscription.
|
com.google.cloud.pubsublite.proto.UpdateTopicRequest |
Request for UpdateTopic.
|
com.google.cloud.pubsublite.proto.UpdateTopicRequest.Builder |
Request for UpdateTopic.
|