Uses of Class
com.google.cloud.pubsublite.proto.Subscription
-
Packages that use Subscription Package Description com.google.cloud.pubsublite com.google.cloud.pubsublite.internal com.google.cloud.pubsublite.internal.testing com.google.cloud.pubsublite.proto com.google.cloud.pubsublite.v1 A client to Pub/Sub Lite APIcom.google.cloud.pubsublite.v1.stub -
-
Uses of Subscription in com.google.cloud.pubsublite
Methods in com.google.cloud.pubsublite that return types with arguments of type Subscription Modifier and Type Method Description default com.google.api.core.ApiFuture<Subscription>
AdminClient. createSubscription(Subscription subscription)
Create the provided subscription if it does not yet exist.com.google.api.core.ApiFuture<Subscription>
AdminClient. createSubscription(Subscription subscription, BacklogLocation startingOffset)
Create the provided subscription at the given starting offset if it does not yet exist.com.google.api.core.ApiFuture<Subscription>
AdminClient. createSubscription(Subscription subscription, SeekTarget target)
Create the provided subscription at the given target location within the message backlog, if it does not yet exist.com.google.api.core.ApiFuture<Subscription>
AdminClient. getSubscription(SubscriptionPath path)
Get the subscription with idid
if it exists.com.google.api.core.ApiFuture<List<Subscription>>
AdminClient. listSubscriptions(LocationPath path)
List all subscriptions for the specified project.com.google.api.core.ApiFuture<Subscription>
AdminClient. updateSubscription(Subscription subscription, com.google.protobuf.FieldMask mask)
Update the subscription with pathsubscription.getPath()
if it exists.Methods in com.google.cloud.pubsublite with parameters of type Subscription Modifier and Type Method Description default com.google.api.core.ApiFuture<Subscription>
AdminClient. createSubscription(Subscription subscription)
Create the provided subscription if it does not yet exist.com.google.api.core.ApiFuture<Subscription>
AdminClient. createSubscription(Subscription subscription, BacklogLocation startingOffset)
Create the provided subscription at the given starting offset if it does not yet exist.com.google.api.core.ApiFuture<Subscription>
AdminClient. createSubscription(Subscription subscription, SeekTarget target)
Create the provided subscription at the given target location within the message backlog, if it does not yet exist.com.google.api.core.ApiFuture<Subscription>
AdminClient. updateSubscription(Subscription subscription, com.google.protobuf.FieldMask mask)
Update the subscription with pathsubscription.getPath()
if it exists. -
Uses of Subscription in com.google.cloud.pubsublite.internal
Methods in com.google.cloud.pubsublite.internal that return types with arguments of type Subscription Modifier and Type Method Description com.google.api.core.ApiFuture<Subscription>
AdminClientImpl. createSubscription(Subscription subscription, BacklogLocation startingOffset)
com.google.api.core.ApiFuture<Subscription>
AdminClientImpl. createSubscription(Subscription subscription, SeekTarget target)
com.google.api.core.ApiFuture<Subscription>
AdminClientImpl. getSubscription(SubscriptionPath path)
com.google.api.core.ApiFuture<List<Subscription>>
AdminClientImpl. listSubscriptions(LocationPath path)
com.google.api.core.ApiFuture<Subscription>
AdminClientImpl. updateSubscription(Subscription subscription, com.google.protobuf.FieldMask mask)
Methods in com.google.cloud.pubsublite.internal with parameters of type Subscription Modifier and Type Method Description com.google.api.core.ApiFuture<Subscription>
AdminClientImpl. createSubscription(Subscription subscription, BacklogLocation startingOffset)
com.google.api.core.ApiFuture<Subscription>
AdminClientImpl. createSubscription(Subscription subscription, SeekTarget target)
com.google.api.core.ApiFuture<Subscription>
AdminClientImpl. updateSubscription(Subscription subscription, com.google.protobuf.FieldMask mask)
-
Uses of Subscription in com.google.cloud.pubsublite.internal.testing
Methods in com.google.cloud.pubsublite.internal.testing that return Subscription Modifier and Type Method Description static Subscription
UnitTestExamples. exampleSubscription()
-
Uses of Subscription in com.google.cloud.pubsublite.proto
Methods in com.google.cloud.pubsublite.proto that return Subscription Modifier and Type Method Description Subscription
Subscription.Builder. build()
Subscription
Subscription.Builder. buildPartial()
Subscription
AdminServiceGrpc.AdminServiceBlockingStub. createSubscription(CreateSubscriptionRequest request)
Creates a new subscription.static Subscription
Subscription. getDefaultInstance()
Subscription
Subscription.Builder. getDefaultInstanceForType()
Subscription
Subscription. getDefaultInstanceForType()
Subscription
AdminServiceGrpc.AdminServiceBlockingStub. getSubscription(GetSubscriptionRequest request)
Returns the subscription configuration.Subscription
CreateSubscriptionRequest.Builder. getSubscription()
Required.Subscription
CreateSubscriptionRequest. getSubscription()
Required.Subscription
CreateSubscriptionRequestOrBuilder. getSubscription()
Required.Subscription
UpdateSubscriptionRequest.Builder. getSubscription()
Required.Subscription
UpdateSubscriptionRequest. getSubscription()
Required.Subscription
UpdateSubscriptionRequestOrBuilder. getSubscription()
Required.Subscription
ListSubscriptionsResponse.Builder. getSubscriptions(int index)
The list of subscriptions in the requested parent.Subscription
ListSubscriptionsResponse. getSubscriptions(int index)
The list of subscriptions in the requested parent.Subscription
ListSubscriptionsResponseOrBuilder. getSubscriptions(int index)
The list of subscriptions in the requested parent.static Subscription
Subscription. parseDelimitedFrom(InputStream input)
static Subscription
Subscription. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Subscription
Subscription. parseFrom(byte[] data)
static Subscription
Subscription. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Subscription
Subscription. parseFrom(com.google.protobuf.ByteString data)
static Subscription
Subscription. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Subscription
Subscription. parseFrom(com.google.protobuf.CodedInputStream input)
static Subscription
Subscription. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Subscription
Subscription. parseFrom(InputStream input)
static Subscription
Subscription. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Subscription
Subscription. parseFrom(ByteBuffer data)
static Subscription
Subscription. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Subscription
AdminServiceGrpc.AdminServiceBlockingStub. updateSubscription(UpdateSubscriptionRequest request)
Updates properties of the specified subscription.Methods in com.google.cloud.pubsublite.proto that return types with arguments of type Subscription Modifier and Type Method Description com.google.common.util.concurrent.ListenableFuture<Subscription>
AdminServiceGrpc.AdminServiceFutureStub. createSubscription(CreateSubscriptionRequest request)
Creates a new subscription.static io.grpc.MethodDescriptor<CreateSubscriptionRequest,Subscription>
AdminServiceGrpc. getCreateSubscriptionMethod()
static io.grpc.MethodDescriptor<GetSubscriptionRequest,Subscription>
AdminServiceGrpc. getGetSubscriptionMethod()
com.google.protobuf.Parser<Subscription>
Subscription. getParserForType()
com.google.common.util.concurrent.ListenableFuture<Subscription>
AdminServiceGrpc.AdminServiceFutureStub. getSubscription(GetSubscriptionRequest request)
Returns the subscription configuration.List<Subscription>
ListSubscriptionsResponse.Builder. getSubscriptionsList()
The list of subscriptions in the requested parent.List<Subscription>
ListSubscriptionsResponse. getSubscriptionsList()
The list of subscriptions in the requested parent.List<Subscription>
ListSubscriptionsResponseOrBuilder. getSubscriptionsList()
The list of subscriptions in the requested parent.static io.grpc.MethodDescriptor<UpdateSubscriptionRequest,Subscription>
AdminServiceGrpc. getUpdateSubscriptionMethod()
static com.google.protobuf.Parser<Subscription>
Subscription. parser()
com.google.common.util.concurrent.ListenableFuture<Subscription>
AdminServiceGrpc.AdminServiceFutureStub. updateSubscription(UpdateSubscriptionRequest request)
Updates properties of the specified subscription.Methods in com.google.cloud.pubsublite.proto with parameters of type Subscription Modifier and Type Method Description ListSubscriptionsResponse.Builder
ListSubscriptionsResponse.Builder. addSubscriptions(int index, Subscription value)
The list of subscriptions in the requested parent.ListSubscriptionsResponse.Builder
ListSubscriptionsResponse.Builder. addSubscriptions(Subscription value)
The list of subscriptions in the requested parent.Subscription.Builder
Subscription.Builder. mergeFrom(Subscription other)
CreateSubscriptionRequest.Builder
CreateSubscriptionRequest.Builder. mergeSubscription(Subscription value)
Required.UpdateSubscriptionRequest.Builder
UpdateSubscriptionRequest.Builder. mergeSubscription(Subscription value)
Required.static Subscription.Builder
Subscription. newBuilder(Subscription prototype)
CreateSubscriptionRequest.Builder
CreateSubscriptionRequest.Builder. setSubscription(Subscription value)
Required.UpdateSubscriptionRequest.Builder
UpdateSubscriptionRequest.Builder. setSubscription(Subscription value)
Required.ListSubscriptionsResponse.Builder
ListSubscriptionsResponse.Builder. setSubscriptions(int index, Subscription value)
The list of subscriptions in the requested parent.Method parameters in com.google.cloud.pubsublite.proto with type arguments of type Subscription Modifier and Type Method Description ListSubscriptionsResponse.Builder
ListSubscriptionsResponse.Builder. addAllSubscriptions(Iterable<? extends Subscription> values)
The list of subscriptions in the requested parent.void
AdminServiceGrpc.AdminServiceStub. createSubscription(CreateSubscriptionRequest request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
Creates a new subscription.default void
AdminServiceGrpc.AsyncService. createSubscription(CreateSubscriptionRequest request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
Creates a new subscription.void
AdminServiceGrpc.AdminServiceStub. getSubscription(GetSubscriptionRequest request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
Returns the subscription configuration.default void
AdminServiceGrpc.AsyncService. getSubscription(GetSubscriptionRequest request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
Returns the subscription configuration.void
AdminServiceGrpc.AdminServiceStub. updateSubscription(UpdateSubscriptionRequest request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
Updates properties of the specified subscription.default void
AdminServiceGrpc.AsyncService. updateSubscription(UpdateSubscriptionRequest request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
Updates properties of the specified subscription. -
Uses of Subscription in com.google.cloud.pubsublite.v1
Methods in com.google.cloud.pubsublite.v1 that return Subscription Modifier and Type Method Description Subscription
AdminServiceClient. createSubscription(CreateSubscriptionRequest request)
Creates a new subscription.Subscription
AdminServiceClient. createSubscription(LocationName parent, Subscription subscription, String subscriptionId)
Creates a new subscription.Subscription
AdminServiceClient. createSubscription(String parent, Subscription subscription, String subscriptionId)
Creates a new subscription.Subscription
AdminServiceClient. getSubscription(GetSubscriptionRequest request)
Returns the subscription configuration.Subscription
AdminServiceClient. getSubscription(SubscriptionName name)
Returns the subscription configuration.Subscription
AdminServiceClient. getSubscription(String name)
Returns the subscription configuration.Subscription
AdminServiceClient. updateSubscription(Subscription subscription, com.google.protobuf.FieldMask updateMask)
Updates properties of the specified subscription.Subscription
AdminServiceClient. updateSubscription(UpdateSubscriptionRequest request)
Updates properties of the specified subscription.Methods in com.google.cloud.pubsublite.v1 that return types with arguments of type Subscription Modifier and Type Method Description com.google.api.gax.rpc.UnaryCallable<CreateSubscriptionRequest,Subscription>
AdminServiceClient. createSubscriptionCallable()
Creates a new subscription.com.google.api.gax.rpc.UnaryCallSettings.Builder<CreateSubscriptionRequest,Subscription>
AdminServiceSettings.Builder. createSubscriptionSettings()
Returns the builder for the settings used for calls to createSubscription.com.google.api.gax.rpc.UnaryCallSettings<CreateSubscriptionRequest,Subscription>
AdminServiceSettings. createSubscriptionSettings()
Returns the object with the settings used for calls to createSubscription.com.google.api.gax.rpc.UnaryCallable<GetSubscriptionRequest,Subscription>
AdminServiceClient. getSubscriptionCallable()
Returns the subscription configuration.com.google.api.gax.rpc.UnaryCallSettings.Builder<GetSubscriptionRequest,Subscription>
AdminServiceSettings.Builder. getSubscriptionSettings()
Returns the builder for the settings used for calls to getSubscription.com.google.api.gax.rpc.UnaryCallSettings<GetSubscriptionRequest,Subscription>
AdminServiceSettings. getSubscriptionSettings()
Returns the object with the settings used for calls to getSubscription.com.google.api.gax.rpc.UnaryCallable<UpdateSubscriptionRequest,Subscription>
AdminServiceClient. updateSubscriptionCallable()
Updates properties of the specified subscription.com.google.api.gax.rpc.UnaryCallSettings.Builder<UpdateSubscriptionRequest,Subscription>
AdminServiceSettings.Builder. updateSubscriptionSettings()
Returns the builder for the settings used for calls to updateSubscription.com.google.api.gax.rpc.UnaryCallSettings<UpdateSubscriptionRequest,Subscription>
AdminServiceSettings. updateSubscriptionSettings()
Returns the object with the settings used for calls to updateSubscription.Methods in com.google.cloud.pubsublite.v1 with parameters of type Subscription Modifier and Type Method Description Subscription
AdminServiceClient. createSubscription(LocationName parent, Subscription subscription, String subscriptionId)
Creates a new subscription.Subscription
AdminServiceClient. createSubscription(String parent, Subscription subscription, String subscriptionId)
Creates a new subscription.Subscription
AdminServiceClient. updateSubscription(Subscription subscription, com.google.protobuf.FieldMask updateMask)
Updates properties of the specified subscription.Method parameters in com.google.cloud.pubsublite.v1 with type arguments of type Subscription Modifier and Type Method Description static com.google.api.core.ApiFuture<AdminServiceClient.ListSubscriptionsPagedResponse>
AdminServiceClient.ListSubscriptionsPagedResponse. createAsync(com.google.api.gax.rpc.PageContext<ListSubscriptionsRequest,ListSubscriptionsResponse,Subscription> context, com.google.api.core.ApiFuture<ListSubscriptionsResponse> futureResponse)
protected AdminServiceClient.ListSubscriptionsPage
AdminServiceClient.ListSubscriptionsPage. createPage(com.google.api.gax.rpc.PageContext<ListSubscriptionsRequest,ListSubscriptionsResponse,Subscription> context, ListSubscriptionsResponse response)
com.google.api.core.ApiFuture<AdminServiceClient.ListSubscriptionsPage>
AdminServiceClient.ListSubscriptionsPage. createPageAsync(com.google.api.gax.rpc.PageContext<ListSubscriptionsRequest,ListSubscriptionsResponse,Subscription> context, com.google.api.core.ApiFuture<ListSubscriptionsResponse> futureResponse)
-
Uses of Subscription in com.google.cloud.pubsublite.v1.stub
Methods in com.google.cloud.pubsublite.v1.stub that return types with arguments of type Subscription Modifier and Type Method Description com.google.api.gax.rpc.UnaryCallable<CreateSubscriptionRequest,Subscription>
AdminServiceStub. createSubscriptionCallable()
com.google.api.gax.rpc.UnaryCallable<CreateSubscriptionRequest,Subscription>
GrpcAdminServiceStub. createSubscriptionCallable()
com.google.api.gax.rpc.UnaryCallSettings.Builder<CreateSubscriptionRequest,Subscription>
AdminServiceStubSettings.Builder. createSubscriptionSettings()
Returns the builder for the settings used for calls to createSubscription.com.google.api.gax.rpc.UnaryCallSettings<CreateSubscriptionRequest,Subscription>
AdminServiceStubSettings. createSubscriptionSettings()
Returns the object with the settings used for calls to createSubscription.com.google.api.gax.rpc.UnaryCallable<GetSubscriptionRequest,Subscription>
AdminServiceStub. getSubscriptionCallable()
com.google.api.gax.rpc.UnaryCallable<GetSubscriptionRequest,Subscription>
GrpcAdminServiceStub. getSubscriptionCallable()
com.google.api.gax.rpc.UnaryCallSettings.Builder<GetSubscriptionRequest,Subscription>
AdminServiceStubSettings.Builder. getSubscriptionSettings()
Returns the builder for the settings used for calls to getSubscription.com.google.api.gax.rpc.UnaryCallSettings<GetSubscriptionRequest,Subscription>
AdminServiceStubSettings. getSubscriptionSettings()
Returns the object with the settings used for calls to getSubscription.com.google.api.gax.rpc.UnaryCallable<UpdateSubscriptionRequest,Subscription>
AdminServiceStub. updateSubscriptionCallable()
com.google.api.gax.rpc.UnaryCallable<UpdateSubscriptionRequest,Subscription>
GrpcAdminServiceStub. updateSubscriptionCallable()
com.google.api.gax.rpc.UnaryCallSettings.Builder<UpdateSubscriptionRequest,Subscription>
AdminServiceStubSettings.Builder. updateSubscriptionSettings()
Returns the builder for the settings used for calls to updateSubscription.com.google.api.gax.rpc.UnaryCallSettings<UpdateSubscriptionRequest,Subscription>
AdminServiceStubSettings. updateSubscriptionSettings()
Returns the object with the settings used for calls to updateSubscription.
-