Send feedback
Class AdminClientImpl (1.9.4)
Stay organized with collections
Save and categorize content based on your preferences.
Version 1.9.4 keyboard_arrow_down
public class AdminClientImpl extends ApiResourceAggregation implements AdminClient
Constructors
AdminClientImpl(CloudRegion region, AdminServiceClient serviceClient)
public AdminClientImpl ( CloudRegion region , AdminServiceClient serviceClient )
Parameters
Methods
createReservation(Reservation reservation)
public ApiFuture<Reservation> createReservation ( Reservation reservation )
Create the provided reservation if it does not yet exist.
Parameter
Returns
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.
Parameters
Returns
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.
Parameters
Returns
createTopic(Topic topic)
public ApiFuture<Topic> createTopic ( Topic topic )
Create the provided topic if it does not yet exist.
Parameter
Name Description topicTopic
Returns
deleteReservation(ReservationPath path)
public ApiFuture<Void> deleteReservation ( ReservationPath path )
Delete the reservation with id id if it exists.
Parameter
Returns
deleteSubscription(SubscriptionPath path)
public ApiFuture<Void> deleteSubscription ( SubscriptionPath path )
Delete the subscription with id id if it exists.
Parameter
Returns
deleteTopic(TopicPath path)
public ApiFuture<Void> deleteTopic ( TopicPath path )
Delete the topic with id id if it exists.
Parameter
Returns
getReservation(ReservationPath path)
public ApiFuture<Reservation> getReservation ( ReservationPath path )
Get the reservation with id id if it exists.
Parameter
Returns
getSubscription(SubscriptionPath path)
public ApiFuture<Subscription> getSubscription ( SubscriptionPath path )
Get the subscription with id id if it exists.
Parameter
Returns
getTopic(TopicPath path)
public ApiFuture<Topic> getTopic ( TopicPath path )
Get the topic with id id if it exists.
Parameter
Returns
getTopicPartitionCount(TopicPath path)
public ApiFuture<Long> getTopicPartitionCount ( TopicPath path )
Get the partitioning info for the topic with id id if it exists.
Parameter
Returns
listReservationTopics(ReservationPath path)
public ApiFuture<List<TopicPath> > listReservationTopics ( ReservationPath path )
Get the list of topics for the reservation with id id if it exists.
Parameter
Returns
listReservations(LocationPath path)
public ApiFuture<List<Reservation> > listReservations ( LocationPath path )
List all reservations for the specified project.
Parameter
Returns
listSubscriptions(LocationPath path)
public ApiFuture<List<Subscription> > listSubscriptions ( LocationPath path )
List all subscriptions for the specified project.
Parameter
Returns
listTopicSubscriptions(TopicPath path)
public ApiFuture<List<SubscriptionPath> > listTopicSubscriptions ( TopicPath path )
Get the list of subscriptions for the topic with id id if it exists.
Parameter
Returns
listTopics(LocationPath path)
public ApiFuture<List<Topic> > listTopics ( LocationPath path )
List all topics for the specified project.
Parameter
Returns
region()
public CloudRegion region ()
The Google Cloud region this client operates on.
Returns
seekSubscription(SubscriptionPath path, SeekTarget target)
public OperationFuture<SeekSubscriptionResponse , OperationMetadata > seekSubscription ( SubscriptionPath path , SeekTarget target )
Parameters
Returns
updateReservation(Reservation reservation, FieldMask mask)
public ApiFuture<Reservation> updateReservation ( Reservation reservation , FieldMask mask )
Update the reservation with path reservation.getPath() if it exists.
Parameters
Returns
updateSubscription(Subscription subscription, FieldMask mask)
public ApiFuture<Subscription> updateSubscription ( Subscription subscription , FieldMask mask )
Update the subscription with path subscription.getPath() if it exists.
Parameters
Returns
updateTopic(Topic topic, FieldMask mask)
public ApiFuture<Topic> updateTopic ( Topic topic , FieldMask mask )
Update the topic with path topic.getPath() if it exists.
Parameters
Returns
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-19 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-19 UTC."],[],[]]
