Interface AdminClient (1.14.4)

public interface AdminClient extends ApiBackgroundResource

A client for performing Pub/Sub Lite admin operations.

Static Methods

create(AdminClientSettings settings)

public static AdminClient create(AdminClientSettings settings)
Parameter
Name Description
settings AdminClientSettings
Returns
Type Description
AdminClient
Exceptions
Type Description
ApiException

Methods

createReservation(Reservation reservation)

public abstract ApiFuture<Reservation> createReservation(Reservation reservation)

Create the provided reservation if it does not yet exist.

Parameter
Name Description
reservation Reservation

The reservation to create.

Returns
Type Description
ApiFuture<Reservation>

A future that will have either an error com.google.api.gax.rpc.ApiException or the reservation on success.

createSubscription(Subscription subscription)

public default ApiFuture<Subscription> createSubscription(Subscription subscription)

Create the provided subscription if it does not yet exist.

By default, a new subscription will only receive messages published after the subscription was created.

Parameter
Name Description
subscription Subscription

The subscription to create.

Returns
Type Description
ApiFuture<Subscription>

A future that will have either an error com.google.api.gax.rpc.ApiException or the subscription on success.

createSubscription(Subscription subscription, BacklogLocation startingOffset)

public abstract 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

The subscription to create.

startingOffset BacklogLocation

The offset at which the new subscription will start receiving messages.

Returns
Type Description
ApiFuture<Subscription>

A future that will have either an error com.google.api.gax.rpc.ApiException or the subscription on success.

createSubscription(Subscription subscription, SeekTarget target)

public abstract 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
Name Description
subscription Subscription

The subscription to create.

target SeekTarget

The target location that the subscription should be initialized to.

Returns
Type Description
ApiFuture<Subscription>

A future that will have either an error com.google.api.gax.rpc.ApiException or the subscription on success.

createTopic(Topic topic)

public abstract ApiFuture<Topic> createTopic(Topic topic)

Create the provided topic if it does not yet exist.

Parameter
Name Description
topic Topic

The topic to create.

Returns
Type Description
ApiFuture<Topic>

A future that will have either an error com.google.api.gax.rpc.ApiException or the topic on success.

deleteReservation(ReservationPath path)

public abstract ApiFuture<Void> deleteReservation(ReservationPath path)

Delete the reservation with id id if it exists.

Parameter
Name Description
path ReservationPath

The path of the reservation to retrieve.

Returns
Type Description
ApiFuture<Void>

A future that will have either an error com.google.api.gax.rpc.ApiException or void on success. Deleting nonexistent reservations will cause the future to have an exception with status com.google.api.gax.rpc.StatusCode.Code#NOT_FOUND

deleteSubscription(SubscriptionPath path)

public abstract ApiFuture<Void> deleteSubscription(SubscriptionPath path)

Delete the subscription with id id if it exists.

Parameter
Name Description
path SubscriptionPath

The path of the subscription to retrieve.

Returns
Type Description
ApiFuture<Void>

A future that will have either an error com.google.api.gax.rpc.ApiException or void on success. Deleting nonexistent subscriptions will cause the future to have an exception with status com.google.api.gax.rpc.StatusCode.Code#NOT_FOUND

deleteTopic(TopicPath path)

public abstract ApiFuture<Void> deleteTopic(TopicPath path)

Delete the topic with id id if it exists.

Parameter
Name Description
path TopicPath

The path of the topic to retrieve.

Returns
Type Description
ApiFuture<Void>

A future that will have either an error com.google.api.gax.rpc.ApiException or void on success. Deleting nonexistent topics will cause the future to have an exception with status com.google.api.gax.rpc.StatusCode.Code#NOT_FOUND

getReservation(ReservationPath path)

public abstract ApiFuture<Reservation> getReservation(ReservationPath path)

Get the reservation with id id if it exists.

Parameter
Name Description
path ReservationPath

The path of the reservation to retrieve.

Returns
Type Description
ApiFuture<Reservation>

A future that will have either an error com.google.api.gax.rpc.ApiException or the reservation on success.

getSubscription(SubscriptionPath path)

public abstract ApiFuture<Subscription> getSubscription(SubscriptionPath path)

Get the subscription with id id if it exists.

Parameter
Name Description
path SubscriptionPath

The path of the subscription to retrieve.

Returns
Type Description
ApiFuture<Subscription>

A future that will have either an error com.google.api.gax.rpc.ApiException or the subscription on success.

getTopic(TopicPath path)

public abstract ApiFuture<Topic> getTopic(TopicPath path)

Get the topic with id id if it exists.

Parameter
Name Description
path TopicPath

The path of the topic to retrieve.

Returns
Type Description
ApiFuture<Topic>

A future that will have either an error com.google.api.gax.rpc.ApiException or the topic on success.

getTopicPartitionCount(TopicPath path)

public abstract ApiFuture<Long> getTopicPartitionCount(TopicPath path)

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

Parameter
Name Description
path TopicPath

The path of the topic to retrieve.

Returns
Type Description
ApiFuture<Long>

A future that will have either an error com.google.api.gax.rpc.ApiException or the number of topic partitions on success.

listReservationTopics(ReservationPath path)

public abstract 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

The path of the reservation to retrieve.

Returns
Type Description
ApiFuture<List<TopicPath>>

A future that will have either an error com.google.api.gax.rpc.ApiException or the list of topics on success.

listReservations(LocationPath path)

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

List all reservations for the specified project.

Parameter
Name Description
path LocationPath

The path of the project to list reservations for.

Returns
Type Description
ApiFuture<List<Reservation>>

A future that will have either an error com.google.api.gax.rpc.ApiException or the list of reservation paths on success.

listSubscriptions(LocationPath path)

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

List all subscriptions for the specified project.

Parameter
Name Description
path LocationPath

The path of the project to list subscriptions for.

Returns
Type Description
ApiFuture<List<Subscription>>

A future that will have either an error com.google.api.gax.rpc.ApiException or the list of subscription paths on success.

listTopicSubscriptions(TopicPath path)

public abstract 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

The path of the topic to retrieve.

Returns
Type Description
ApiFuture<List<SubscriptionPath>>

A future that will have either an error com.google.api.gax.rpc.ApiException or the list of subscriptions on success.

listTopics(LocationPath path)

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

List all topics for the specified project.

Parameter
Name Description
path LocationPath

The path of the project to list topics for.

Returns
Type Description
ApiFuture<List<Topic>>

A future that will have either an error com.google.api.gax.rpc.ApiException or the list of topic paths on success.

region()

public abstract CloudRegion region()

The Google Cloud region this client operates on.

Returns
Type Description
CloudRegion

seekSubscription(SubscriptionPath path, SeekTarget target)

public abstract 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

The path of the subscription to seek.

target SeekTarget

The location to seek to.

Returns
Type Description
OperationFuture<SeekSubscriptionResponse,OperationMetadata>

A com.google.api.gax.longrunning.OperationFuture that returns an operation name if the seek was successfully initiated, or otherwise throw an com.google.api.gax.rpc.ApiException. com.google.api.gax.longrunning.OperationFuture#get() will return a response if the seek operation completes successfully, or otherwise throw an com.google.api.gax.rpc.ApiException.

updateReservation(Reservation reservation, FieldMask mask)

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

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

Parameters
Name Description
reservation Reservation

The reservation to update.

mask FieldMask

The mask indicating which fields should be updated.

Returns
Type Description
ApiFuture<Reservation>

A future that will have either an error com.google.api.gax.rpc.ApiException or the resulting reservation on success. Updating nonexistent reservations will cause the future to have an exception with status com.google.api.gax.rpc.StatusCode.Code#NOT_FOUND

updateSubscription(Subscription subscription, FieldMask mask)

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

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

Parameters
Name Description
subscription Subscription

The subscription to update.

mask FieldMask

The mask indicating which fields should be updated.

Returns
Type Description
ApiFuture<Subscription>

A future that will have either an error com.google.api.gax.rpc.ApiException or the resulting subscription on success. Updating nonexistent subscriptions will cause the future to have an exception with status com.google.api.gax.rpc.StatusCode.Code#NOT_FOUND

updateTopic(Topic topic, FieldMask mask)

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

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

Parameters
Name Description
topic Topic

The topic to update.

mask FieldMask

The mask indicating which fields should be updated.

Returns
Type Description
ApiFuture<Topic>

A future that will have either an error com.google.api.gax.rpc.ApiException or the resulting topic on success. Updating nonexistent topics will cause the future to have an exception with status com.google.api.gax.rpc.StatusCode.Code#NOT_FOUND