Uses of Class
com.google.cloud.pubsublite.SubscriptionPath
-
-
Uses of SubscriptionPath in com.google.cloud.pubsublite
Methods in com.google.cloud.pubsublite that return SubscriptionPath Modifier and Type Method Description abstract SubscriptionPath
SubscriptionPath.Builder. build()
Build a new SubscriptionPath.static SubscriptionPath
SubscriptionPath. parse(String path)
Methods in com.google.cloud.pubsublite that return types with arguments of type SubscriptionPath Modifier and Type Method Description com.google.api.core.ApiFuture<List<SubscriptionPath>>
AdminClient. listTopicSubscriptions(TopicPath path)
Get the list of subscriptions for the topic with idid
if it exists.Methods in com.google.cloud.pubsublite with parameters of type SubscriptionPath Modifier and Type Method Description com.google.api.core.ApiFuture<Void>
AdminClient. deleteSubscription(SubscriptionPath path)
Delete the subscription with idid
if it exists.com.google.api.core.ApiFuture<Subscription>
AdminClient. getSubscription(SubscriptionPath path)
Get the subscription with idid
if it exists.static int
PartitionLookupUtils. numPartitions(SubscriptionPath subscription)
Look up the number of partitions in the topic associated with a subscription.static int
PartitionLookupUtils. numPartitions(SubscriptionPath subscription, AdminClient client)
Look up the number of partitions in the topic associated with a subscription using the provided AdminClient.com.google.api.gax.longrunning.OperationFuture<SeekSubscriptionResponse,OperationMetadata>
AdminClient. seekSubscription(SubscriptionPath path, SeekTarget target)
Initiate an out-of-band seek for a subscription to a specified target, which may be timestamps or named positions within the message backlog. -
Uses of SubscriptionPath in com.google.cloud.pubsublite.cloudpubsub
Methods in com.google.cloud.pubsublite.cloudpubsub with parameters of type SubscriptionPath Modifier and Type Method Description SubscriberServiceClient
PartitionSubscriberClientSupplier. get(SubscriptionPath subscription, Partition partition)
Creates a new SubscriberServiceClient for the specified subscription and partition.abstract SubscriberSettings.Builder
SubscriberSettings.Builder. setSubscriptionPath(SubscriptionPath path)
The subscription to use to receive messages. -
Uses of SubscriptionPath in com.google.cloud.pubsublite.internal
Methods in com.google.cloud.pubsublite.internal that return types with arguments of type SubscriptionPath Modifier and Type Method Description com.google.api.core.ApiFuture<List<SubscriptionPath>>
AdminClientImpl. listTopicSubscriptions(TopicPath path)
Methods in com.google.cloud.pubsublite.internal with parameters of type SubscriptionPath Modifier and Type Method Description com.google.api.core.ApiFuture<Void>
CursorClient. commitCursor(SubscriptionPath path, Partition partition, Offset offset)
Commit a single cursor.com.google.api.core.ApiFuture<Void>
CursorClientImpl. commitCursor(SubscriptionPath path, Partition partition, Offset offset)
com.google.api.core.ApiFuture<Void>
AdminClientImpl. deleteSubscription(SubscriptionPath path)
com.google.api.core.ApiFuture<Subscription>
AdminClientImpl. getSubscription(SubscriptionPath path)
com.google.api.core.ApiFuture<Map<Partition,Offset>>
CursorClient. listPartitionCursors(SubscriptionPath path)
List the cursors for a given subscription.com.google.api.core.ApiFuture<Map<Partition,Offset>>
CursorClientImpl. listPartitionCursors(SubscriptionPath path)
com.google.api.gax.longrunning.OperationFuture<SeekSubscriptionResponse,OperationMetadata>
AdminClientImpl. seekSubscription(SubscriptionPath path, SeekTarget target)
-
Uses of SubscriptionPath in com.google.cloud.pubsublite.internal.testing
Methods in com.google.cloud.pubsublite.internal.testing that return SubscriptionPath Modifier and Type Method Description static SubscriptionPath
UnitTestExamples. exampleSubscriptionPath()
-
Uses of SubscriptionPath in com.google.cloud.pubsublite.internal.wire
Methods in com.google.cloud.pubsublite.internal.wire with parameters of type SubscriptionPath Modifier and Type Method Description static RoutingMetadata
RoutingMetadata. of(SubscriptionPath subscription, Partition partition)
abstract AssignerSettings.Builder
AssignerSettings.Builder. setSubscriptionPath(SubscriptionPath path)
abstract CommitterSettings.Builder
CommitterSettings.Builder. setSubscriptionPath(SubscriptionPath path)
abstract SubscriberBuilder.Builder
SubscriberBuilder.Builder. setSubscriptionPath(SubscriptionPath path)
-