Class AdminClientImpl (1.14.0)
Stay organized with collections
Save and categorize content based on your preferences.
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.
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-10-04 UTC.
[{
"type": "thumb-down",
"id": "hardToUnderstand",
"label":"Hard to understand"
},{
"type": "thumb-down",
"id": "incorrectInformationOrSampleCode",
"label":"Incorrect information or sample code"
},{
"type": "thumb-down",
"id": "missingTheInformationSamplesINeed",
"label":"Missing the information/samples I need"
},{
"type": "thumb-down",
"id": "otherDown",
"label":"Other"
}]
[{
"type": "thumb-up",
"id": "easyToUnderstand",
"label":"Easy to understand"
},{
"type": "thumb-up",
"id": "solvedMyProblem",
"label":"Solved my problem"
},{
"type": "thumb-up",
"id": "otherUp",
"label":"Other"
}]
{"lastModified": "Last updated 2024-10-04 UTC."}
[[["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-10-04 UTC."]]