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 SubscriptionPathSubscriptionPath.Builder. build()Build a new SubscriptionPath.static SubscriptionPathSubscriptionPath. 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 ididif 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 ididif it exists.com.google.api.core.ApiFuture<Subscription>AdminClient. getSubscription(SubscriptionPath path)Get the subscription with ididif it exists.static intPartitionLookupUtils. numPartitions(SubscriptionPath subscription)Look up the number of partitions in the topic associated with a subscription.static intPartitionLookupUtils. 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 SubscriberServiceClientPartitionSubscriberClientSupplier. get(SubscriptionPath subscription, Partition partition)Creates a new SubscriberServiceClient for the specified subscription and partition.abstract SubscriberSettings.BuilderSubscriberSettings.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 SubscriptionPathUnitTestExamples. 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 RoutingMetadataRoutingMetadata. of(SubscriptionPath subscription, Partition partition)abstract AssignerSettings.BuilderAssignerSettings.Builder. setSubscriptionPath(SubscriptionPath path)abstract CommitterSettings.BuilderCommitterSettings.Builder. setSubscriptionPath(SubscriptionPath path)abstract SubscriberBuilder.BuilderSubscriberBuilder.Builder. setSubscriptionPath(SubscriptionPath path)
-