Send feedback
Class AdminClientImpl (1.13.5)
Stay organized with collections
Save and categorize content based on your preferences.
Version 1.13.5 keyboard_arrow_down
public class AdminClientImpl extends ApiResourceAggregation implements AdminClient
Constructors
AdminClientImpl(CloudRegion region, AdminServiceClient serviceClient)
public AdminClientImpl ( CloudRegion region , AdminServiceClient serviceClient )
Methods
createReservation(Reservation reservation)
public ApiFuture<Reservation> createReservation ( Reservation reservation )
Create the provided reservation if it does not yet exist.
createSubscription(Subscription subscription, BacklogLocation startingOffset)
public ApiFuture<Subscription> createSubscription ( Subscription subscription , BacklogLocation startingOffset )
Create the provided subscription at the given starting offset if it does not yet exist.
createSubscription(Subscription subscription, SeekTarget target)
public ApiFuture<Subscription> createSubscription ( Subscription subscription , SeekTarget target )
Create the provided subscription at the given target location within the message backlog, if it
does not yet exist.
A seek is initiated if the target location is a publish or event time. If the seek fails,
the created subscription is not deleted.
createTopic(Topic topic)
public ApiFuture<Topic> createTopic ( Topic topic )
Create the provided topic if it does not yet exist.
Parameter
Name
Description
topic
Topic
deleteReservation(ReservationPath path)
public ApiFuture<Void> deleteReservation ( ReservationPath path )
Delete the reservation with id id
if it exists.
deleteSubscription(SubscriptionPath path)
public ApiFuture<Void> deleteSubscription ( SubscriptionPath path )
Delete the subscription with id id
if it exists.
deleteTopic(TopicPath path)
public ApiFuture<Void> deleteTopic ( TopicPath path )
Delete the topic with id id
if it exists.
getReservation(ReservationPath path)
public ApiFuture<Reservation> getReservation ( ReservationPath path )
Get the reservation with id id
if it exists.
getSubscription(SubscriptionPath path)
public ApiFuture<Subscription> getSubscription ( SubscriptionPath path )
Get the subscription with id id
if it exists.
getTopic(TopicPath path)
public ApiFuture<Topic> getTopic ( TopicPath path )
Get the topic with id id
if it exists.
getTopicPartitionCount(TopicPath path)
public ApiFuture<Long> getTopicPartitionCount ( TopicPath path )
Get the partitioning info for the topic with id id
if it exists.
listReservationTopics(ReservationPath path)
public ApiFuture<List<TopicPath> > listReservationTopics ( ReservationPath path )
Get the list of topics for the reservation with id id
if it exists.
listReservations(LocationPath path)
public ApiFuture<List<Reservation> > listReservations ( LocationPath path )
List all reservations for the specified project.
listSubscriptions(LocationPath path)
public ApiFuture<List<Subscription> > listSubscriptions ( LocationPath path )
List all subscriptions for the specified project.
listTopicSubscriptions(TopicPath path)
public ApiFuture<List<SubscriptionPath> > listTopicSubscriptions ( TopicPath path )
Get the list of subscriptions for the topic with id id
if it exists.
listTopics(LocationPath path)
public ApiFuture<List<Topic> > listTopics ( LocationPath path )
List all topics for the specified project.
region()
public CloudRegion region ()
The Google Cloud region this client operates on.
seekSubscription(SubscriptionPath path, SeekTarget target)
public OperationFuture<SeekSubscriptionResponse , OperationMetadata > seekSubscription ( SubscriptionPath path , SeekTarget target )
updateReservation(Reservation reservation, FieldMask mask)
public ApiFuture<Reservation> updateReservation ( Reservation reservation , FieldMask mask )
Update the reservation with path reservation.getPath()
if it exists.
updateSubscription(Subscription subscription, FieldMask mask)
public ApiFuture<Subscription> updateSubscription ( Subscription subscription , FieldMask mask )
Update the subscription with path subscription.getPath()
if it exists.
updateTopic(Topic topic, FieldMask mask)
public ApiFuture<Topic> updateTopic ( Topic topic , FieldMask mask )
Update the topic with path topic.getPath()
if it exists.
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2024-12-05 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-12-05 UTC."],[],[]]