Uses of Class
com.google.cloud.pubsublite.TopicPath
-
-
Uses of TopicPath in com.google.cloud.pubsublite
Methods in com.google.cloud.pubsublite that return TopicPath Modifier and Type Method Description abstract TopicPathTopicPath.Builder. build()Build a new TopicPath.static TopicPathTopicPath. parse(String path)Methods in com.google.cloud.pubsublite that return types with arguments of type TopicPath Modifier and Type Method Description com.google.api.core.ApiFuture<List<TopicPath>>AdminClient. listReservationTopics(ReservationPath path)Get the list of topics for the reservation with ididif it exists.Methods in com.google.cloud.pubsublite with parameters of type TopicPath Modifier and Type Method Description com.google.api.core.ApiFuture<Void>AdminClient. deleteTopic(TopicPath path)Delete the topic with ididif it exists.com.google.api.core.ApiFuture<Topic>AdminClient. getTopic(TopicPath path)Get the topic with ididif it exists.com.google.api.core.ApiFuture<Long>AdminClient. getTopicPartitionCount(TopicPath path)Get the partitioning info for the topic with ididif it exists.com.google.api.core.ApiFuture<List<SubscriptionPath>>AdminClient. listTopicSubscriptions(TopicPath path)Get the list of subscriptions for the topic with ididif it exists.static intPartitionLookupUtils. numPartitions(TopicPath topic)Look up the number of partitions in a topic.static intPartitionLookupUtils. numPartitions(TopicPath topic, AdminClient client)Look up the number of partitions in a topic using the provided AdminClient. -
Uses of TopicPath in com.google.cloud.pubsublite.cloudpubsub
Methods in com.google.cloud.pubsublite.cloudpubsub with parameters of type TopicPath Modifier and Type Method Description abstract PublisherSettings.BuilderPublisherSettings.Builder. setTopicPath(TopicPath path)The topic path to publish to. -
Uses of TopicPath in com.google.cloud.pubsublite.internal
Methods in com.google.cloud.pubsublite.internal that return types with arguments of type TopicPath Modifier and Type Method Description com.google.api.core.ApiFuture<List<TopicPath>>AdminClientImpl. listReservationTopics(ReservationPath path)Methods in com.google.cloud.pubsublite.internal with parameters of type TopicPath Modifier and Type Method Description com.google.api.core.ApiFuture<Optional<Cursor>>TopicStatsClient. computeCursorForEventTime(TopicPath path, Partition partition, com.google.protobuf.Timestamp eventTime)Compute the cursor of the first message with event time greater than or equal to the specified event time, for a topic partition.com.google.api.core.ApiFuture<Optional<Cursor>>TopicStatsClientImpl. computeCursorForEventTime(TopicPath path, Partition partition, com.google.protobuf.Timestamp eventTime)com.google.api.core.ApiFuture<Optional<Cursor>>TopicStatsClient. computeCursorForPublishTime(TopicPath path, Partition partition, com.google.protobuf.Timestamp publishTime)Compute the cursor of the first message with publish time greater than or equal to the specified publish time, for a topic partition.com.google.api.core.ApiFuture<Optional<Cursor>>TopicStatsClientImpl. computeCursorForPublishTime(TopicPath path, Partition partition, com.google.protobuf.Timestamp publishTime)com.google.api.core.ApiFuture<Cursor>TopicStatsClient. computeHeadCursor(TopicPath path, Partition partition)Compute the head cursor for the partition.com.google.api.core.ApiFuture<Cursor>TopicStatsClientImpl. computeHeadCursor(TopicPath path, Partition partition)com.google.api.core.ApiFuture<ComputeMessageStatsResponse>TopicStatsClient. computeMessageStats(TopicPath path, Partition partition, Offset start, Offset end)Compute statistics about the messages between two cursors in a topic partition.com.google.api.core.ApiFuture<ComputeMessageStatsResponse>TopicStatsClientImpl. computeMessageStats(TopicPath path, Partition partition, Offset start, Offset end)com.google.api.core.ApiFuture<Void>AdminClientImpl. deleteTopic(TopicPath path)com.google.api.core.ApiFuture<Topic>AdminClientImpl. getTopic(TopicPath path)com.google.api.core.ApiFuture<Long>AdminClientImpl. getTopicPartitionCount(TopicPath path)com.google.api.core.ApiFuture<List<SubscriptionPath>>AdminClientImpl. listTopicSubscriptions(TopicPath path) -
Uses of TopicPath in com.google.cloud.pubsublite.internal.testing
Methods in com.google.cloud.pubsublite.internal.testing that return TopicPath Modifier and Type Method Description static TopicPathUnitTestExamples. exampleTopicPath() -
Uses of TopicPath in com.google.cloud.pubsublite.internal.wire
Methods in com.google.cloud.pubsublite.internal.wire with parameters of type TopicPath Modifier and Type Method Description static RoutingMetadataRoutingMetadata. of(TopicPath topic, Partition partition)abstract PartitionCountWatchingPublisherSettings.BuilderPartitionCountWatchingPublisherSettings.Builder. setTopic(TopicPath path)abstract PublisherBuilder.BuilderPublisherBuilder.Builder. setTopic(TopicPath path)abstract RoutingPublisherBuilder.BuilderRoutingPublisherBuilder.Builder. setTopic(TopicPath path)abstract SinglePartitionPublisherBuilder.BuilderSinglePartitionPublisherBuilder.Builder. setTopic(TopicPath topic)Constructors in com.google.cloud.pubsublite.internal.wire with parameters of type TopicPath Constructor Description Factory(TopicPath topicPath, AdminClient adminClient, AlarmFactory alarmFactory)
-