Class AdminClientImpl (1.7.1)

public class AdminClientImpl extends ApiResourceAggregation implements AdminClient

Inheritance

java.lang.Object > ApiResourceAggregation > AdminClientImpl

Implements

AdminClient

Inherited Members

ApiResourceAggregation.awaitTermination(long,TimeUnit)

ApiResourceAggregation.close()

ApiResourceAggregation.isShutdown()

ApiResourceAggregation.isTerminated()

ApiResourceAggregation.shutdown()

ApiResourceAggregation.shutdownNow()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

AdminClientImpl(CloudRegion region, AdminServiceClient serviceClient)

public AdminClientImpl(CloudRegion region, AdminServiceClient serviceClient)

Parameters

Name	Description
region	`CloudRegion`
serviceClient	`AdminServiceClient`

Methods

createReservation(Reservation reservation)

public ApiFuture<Reservation> createReservation(Reservation reservation)

Create the provided reservation if it does not yet exist.

Parameter

Name	Description
reservation	`Reservation`

Returns

Type	Description
ApiFuture<Reservation>

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

Name	Description
subscription	`Subscription`
startingOffset	`BacklogLocation`

Returns

Type	Description
ApiFuture<Subscription>

createTopic(Topic topic)

public ApiFuture<Topic> createTopic(Topic topic)

Create the provided topic if it does not yet exist.

Parameter

Name	Description
topic	`Topic`

Returns

Type	Description
ApiFuture<Topic>

deleteReservation(ReservationPath path)

public ApiFuture<Void> deleteReservation(ReservationPath path)

Delete the reservation with id id if it exists.

Parameter

Name	Description
path	`ReservationPath`

Returns

Type	Description
ApiFuture<Void>

deleteSubscription(SubscriptionPath path)

public ApiFuture<Void> deleteSubscription(SubscriptionPath path)

Delete the subscription with id id if it exists.

Parameter

Name	Description
path	`SubscriptionPath`

Returns

Type	Description
ApiFuture<Void>

deleteTopic(TopicPath path)

public ApiFuture<Void> deleteTopic(TopicPath path)

Delete the topic with id id if it exists.

Parameter

Name	Description
path	`TopicPath`

Returns

Type	Description
ApiFuture<Void>

getReservation(ReservationPath path)

public ApiFuture<Reservation> getReservation(ReservationPath path)

Get the reservation with id id if it exists.

Parameter

Name	Description
path	`ReservationPath`

Returns

Type	Description
ApiFuture<Reservation>

getSubscription(SubscriptionPath path)

public ApiFuture<Subscription> getSubscription(SubscriptionPath path)

Get the subscription with id id if it exists.

Parameter

Name	Description
path	`SubscriptionPath`

Returns

Type	Description
ApiFuture<Subscription>

getTopic(TopicPath path)

public ApiFuture<Topic> getTopic(TopicPath path)

Get the topic with id id if it exists.

Parameter

Name	Description
path	`TopicPath`

Returns

Type	Description
ApiFuture<Topic>

getTopicPartitionCount(TopicPath path)

public ApiFuture<Long> getTopicPartitionCount(TopicPath path)

Get the partitioning info for the topic with id id if it exists.

Parameter

Name	Description
path	`TopicPath`

Returns

Type	Description
ApiFuture<Long>

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

Name	Description
path	`ReservationPath`

Returns

Type	Description
ApiFuture<List<TopicPath>>

listReservations(LocationPath path)

public ApiFuture<List<Reservation>> listReservations(LocationPath path)

List all reservations for the specified project.

Parameter

Name	Description
path	`LocationPath`

Returns

Type	Description
ApiFuture<List<Reservation>>

listSubscriptions(LocationPath path)

public ApiFuture<List<Subscription>> listSubscriptions(LocationPath path)

List all subscriptions for the specified project.

Parameter

Name	Description
path	`LocationPath`

Returns

Type	Description
ApiFuture<List<Subscription>>

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

Name	Description
path	`TopicPath`

Returns

Type	Description
ApiFuture<List<SubscriptionPath>>

listTopics(LocationPath path)

public ApiFuture<List<Topic>> listTopics(LocationPath path)

List all topics for the specified project.

Parameter

Name	Description
path	`LocationPath`

Returns

Type	Description
ApiFuture<List<Topic>>

region()

public CloudRegion region()

The Google Cloud region this client operates on.

Returns

Type	Description
CloudRegion

seekSubscription(SubscriptionPath path, SeekTarget target)

public OperationFuture<SeekSubscriptionResponse,OperationMetadata> 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.

See https://cloud.google.com/pubsub/lite/docs/seek for more information.

Parameters

Name	Description
path	`SubscriptionPath`
target	`SeekTarget`

Returns

Type	Description
OperationFuture<SeekSubscriptionResponse,OperationMetadata>

updateReservation(Reservation reservation, FieldMask mask)

public ApiFuture<Reservation> updateReservation(Reservation reservation, FieldMask mask)

Update the reservation with path reservation.getPath() if it exists.

Parameters

Name	Description
reservation	`Reservation`
mask	`FieldMask`

Returns

Type	Description
ApiFuture<Reservation>

updateSubscription(Subscription subscription, FieldMask mask)

public ApiFuture<Subscription> updateSubscription(Subscription subscription, FieldMask mask)

Update the subscription with path subscription.getPath() if it exists.

Parameters

Name	Description
subscription	`Subscription`
mask	`FieldMask`

Returns

Type	Description
ApiFuture<Subscription>

updateTopic(Topic topic, FieldMask mask)

public ApiFuture<Topic> updateTopic(Topic topic, FieldMask mask)

Update the topic with path topic.getPath() if it exists.

Parameters

Name	Description
topic	`Topic`
mask	`FieldMask`

Returns

Type	Description
ApiFuture<Topic>