{
+ private StorageBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected StorageBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new StorageBlockingStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *
+ * Permanently deletes an empty bucket.
+ *
+ */
+ public com.google.protobuf.Empty deleteBucket(
+ com.google.storage.v2.DeleteBucketRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteBucketMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Returns metadata for the specified bucket.
+ *
+ */
+ public com.google.storage.v2.Bucket getBucket(com.google.storage.v2.GetBucketRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetBucketMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a new bucket.
+ *
+ */
+ public com.google.storage.v2.Bucket createBucket(
+ com.google.storage.v2.CreateBucketRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateBucketMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a list of buckets for a given project.
+ *
+ */
+ public com.google.storage.v2.ListBucketsResponse listBuckets(
+ com.google.storage.v2.ListBucketsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListBucketsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Locks retention policy on a bucket.
+ *
+ */
+ public com.google.storage.v2.Bucket lockBucketRetentionPolicy(
+ com.google.storage.v2.LockBucketRetentionPolicyRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getLockBucketRetentionPolicyMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets the IAM policy for a specified bucket or object.
+ *
+ */
+ public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetIamPolicyMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates an IAM policy for the specified bucket or object.
+ *
+ */
+ public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getSetIamPolicyMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Tests a set of permissions on the given bucket or object to see which, if
+ * any, are held by the caller.
+ *
+ */
+ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions(
+ com.google.iam.v1.TestIamPermissionsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates a bucket. Equivalent to JSON API's storage.buckets.patch method.
+ *
+ */
+ public com.google.storage.v2.Bucket updateBucket(
+ com.google.storage.v2.UpdateBucketRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getUpdateBucketMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Permanently deletes a notification subscription.
+ *
+ */
+ public com.google.protobuf.Empty deleteNotification(
+ com.google.storage.v2.DeleteNotificationRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteNotificationMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * View a notification config.
+ *
+ */
+ public com.google.storage.v2.Notification getNotification(
+ com.google.storage.v2.GetNotificationRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetNotificationMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a notification subscription for a given bucket.
+ * These notifications, when triggered, publish messages to the specified
+ * Pub/Sub topics.
+ * See https://cloud.google.com/storage/docs/pubsub-notifications.
+ *
+ */
+ public com.google.storage.v2.Notification createNotification(
+ com.google.storage.v2.CreateNotificationRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateNotificationMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a list of notification subscriptions for a given bucket.
+ *
+ */
+ public com.google.storage.v2.ListNotificationsResponse listNotifications(
+ com.google.storage.v2.ListNotificationsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListNotificationsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Concatenates a list of existing objects into a new object in the same
+ * bucket.
+ *
+ */
+ public com.google.storage.v2.Object composeObject(
+ com.google.storage.v2.ComposeObjectRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getComposeObjectMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Deletes an object and its metadata. Deletions are permanent if versioning
+ * is not enabled for the bucket, or if the `generation` parameter is used.
+ *
+ */
+ public com.google.protobuf.Empty deleteObject(
+ com.google.storage.v2.DeleteObjectRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteObjectMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Cancels an in-progress resumable upload.
+ *
+ */
+ public com.google.storage.v2.CancelResumableWriteResponse cancelResumableWrite(
+ com.google.storage.v2.CancelResumableWriteRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCancelResumableWriteMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves an object's metadata.
+ *
+ */
+ public com.google.storage.v2.Object getObject(com.google.storage.v2.GetObjectRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetObjectMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Reads an object's data.
+ *
+ */
+ public java.util.Iterator readObject(
+ com.google.storage.v2.ReadObjectRequest request) {
+ return io.grpc.stub.ClientCalls.blockingServerStreamingCall(
+ getChannel(), getReadObjectMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates an object's metadata.
+ * Equivalent to JSON API's storage.objects.patch.
+ *
+ */
+ public com.google.storage.v2.Object updateObject(
+ com.google.storage.v2.UpdateObjectRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getUpdateObjectMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a list of objects matching the criteria.
+ *
+ */
+ public com.google.storage.v2.ListObjectsResponse listObjects(
+ com.google.storage.v2.ListObjectsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListObjectsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Rewrites a source object to a destination object. Optionally overrides
+ * metadata.
+ *
+ */
+ public com.google.storage.v2.RewriteResponse rewriteObject(
+ com.google.storage.v2.RewriteObjectRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRewriteObjectMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Starts a resumable write. How long the write operation remains valid, and
+ * what happens when the write operation becomes invalid, are
+ * service-dependent.
+ *
+ */
+ public com.google.storage.v2.StartResumableWriteResponse startResumableWrite(
+ com.google.storage.v2.StartResumableWriteRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getStartResumableWriteMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Determines the `persisted_size` for an object that is being written, which
+ * can then be used as the `write_offset` for the next `Write()` call.
+ * If the object does not exist (i.e., the object has been deleted, or the
+ * first `Write()` has not yet reached the service), this method returns the
+ * error `NOT_FOUND`.
+ * The client **may** call `QueryWriteStatus()` at any time to determine how
+ * much data has been processed for this object. This is useful if the
+ * client is buffering data and needs to know which data can be safely
+ * evicted. For any sequence of `QueryWriteStatus()` calls for a given
+ * object name, the sequence of returned `persisted_size` values will be
+ * non-decreasing.
+ *
+ */
+ public com.google.storage.v2.QueryWriteStatusResponse queryWriteStatus(
+ com.google.storage.v2.QueryWriteStatusRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getQueryWriteStatusMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves the name of a project's Google Cloud Storage service account.
+ *
+ */
+ public com.google.storage.v2.ServiceAccount getServiceAccount(
+ com.google.storage.v2.GetServiceAccountRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetServiceAccountMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a new HMAC key for the given service account.
+ *
+ */
+ public com.google.storage.v2.CreateHmacKeyResponse createHmacKey(
+ com.google.storage.v2.CreateHmacKeyRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateHmacKeyMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Deletes a given HMAC key. Key must be in an INACTIVE state.
+ *
+ */
+ public com.google.protobuf.Empty deleteHmacKey(
+ com.google.storage.v2.DeleteHmacKeyRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteHmacKeyMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets an existing HMAC key metadata for the given id.
+ *
+ */
+ public com.google.storage.v2.HmacKeyMetadata getHmacKey(
+ com.google.storage.v2.GetHmacKeyRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetHmacKeyMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists HMAC keys under a given project with the additional filters provided.
+ *
+ */
+ public com.google.storage.v2.ListHmacKeysResponse listHmacKeys(
+ com.google.storage.v2.ListHmacKeysRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListHmacKeysMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates a given HMAC key state between ACTIVE and INACTIVE.
+ *
+ */
+ public com.google.storage.v2.HmacKeyMetadata updateHmacKey(
+ com.google.storage.v2.UpdateHmacKeyRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getUpdateHmacKeyMethod(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ *
+ *
+ *
+ * ## API Overview and Naming Syntax
+ * The Cloud Storage gRPC API allows applications to read and write data through
+ * the abstractions of buckets and objects. For a description of these
+ * abstractions please see https://cloud.google.com/storage/docs.
+ * Resources are named as follows:
+ * - Projects are referred to as they are defined by the Resource Manager API,
+ * using strings like `projects/123456` or `projects/my-string-id`.
+ * - Buckets are named using string names of the form:
+ * `projects/{project}/buckets/{bucket}`
+ * For globally unique buckets, `_` may be substituted for the project.
+ * - Objects are uniquely identified by their name along with the name of the
+ * bucket they belong to, as separate strings in this API. For example:
+ * ReadObjectRequest {
+ * bucket: 'projects/_/buckets/my-bucket'
+ * object: 'my-object'
+ * }
+ * Note that object names can contain `/` characters, which are treated as
+ * any other character (no special directory semantics).
+ *
+ */
+ public static final class StorageFutureStub
+ extends io.grpc.stub.AbstractFutureStub {
+ private StorageFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected StorageFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new StorageFutureStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *
+ * Permanently deletes an empty bucket.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ deleteBucket(com.google.storage.v2.DeleteBucketRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getDeleteBucketMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Returns metadata for the specified bucket.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ getBucket(com.google.storage.v2.GetBucketRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getGetBucketMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a new bucket.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ createBucket(com.google.storage.v2.CreateBucketRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getCreateBucketMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a list of buckets for a given project.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.storage.v2.ListBucketsResponse>
+ listBuckets(com.google.storage.v2.ListBucketsRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getListBucketsMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Locks retention policy on a bucket.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ lockBucketRetentionPolicy(com.google.storage.v2.LockBucketRetentionPolicyRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getLockBucketRetentionPolicyMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets the IAM policy for a specified bucket or object.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates an IAM policy for the specified bucket or object.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Tests a set of permissions on the given bucket or object to see which, if
+ * any, are held by the caller.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.iam.v1.TestIamPermissionsResponse>
+ testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates a bucket. Equivalent to JSON API's storage.buckets.patch method.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ updateBucket(com.google.storage.v2.UpdateBucketRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getUpdateBucketMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Permanently deletes a notification subscription.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ deleteNotification(com.google.storage.v2.DeleteNotificationRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getDeleteNotificationMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * View a notification config.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ getNotification(com.google.storage.v2.GetNotificationRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getGetNotificationMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a notification subscription for a given bucket.
+ * These notifications, when triggered, publish messages to the specified
+ * Pub/Sub topics.
+ * See https://cloud.google.com/storage/docs/pubsub-notifications.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ createNotification(com.google.storage.v2.CreateNotificationRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getCreateNotificationMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a list of notification subscriptions for a given bucket.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.storage.v2.ListNotificationsResponse>
+ listNotifications(com.google.storage.v2.ListNotificationsRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getListNotificationsMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Concatenates a list of existing objects into a new object in the same
+ * bucket.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ composeObject(com.google.storage.v2.ComposeObjectRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getComposeObjectMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Deletes an object and its metadata. Deletions are permanent if versioning
+ * is not enabled for the bucket, or if the `generation` parameter is used.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ deleteObject(com.google.storage.v2.DeleteObjectRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getDeleteObjectMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Cancels an in-progress resumable upload.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.storage.v2.CancelResumableWriteResponse>
+ cancelResumableWrite(com.google.storage.v2.CancelResumableWriteRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getCancelResumableWriteMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves an object's metadata.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ getObject(com.google.storage.v2.GetObjectRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getGetObjectMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates an object's metadata.
+ * Equivalent to JSON API's storage.objects.patch.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ updateObject(com.google.storage.v2.UpdateObjectRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getUpdateObjectMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves a list of objects matching the criteria.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.storage.v2.ListObjectsResponse>
+ listObjects(com.google.storage.v2.ListObjectsRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getListObjectsMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Rewrites a source object to a destination object. Optionally overrides
+ * metadata.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ rewriteObject(com.google.storage.v2.RewriteObjectRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getRewriteObjectMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Starts a resumable write. How long the write operation remains valid, and
+ * what happens when the write operation becomes invalid, are
+ * service-dependent.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.storage.v2.StartResumableWriteResponse>
+ startResumableWrite(com.google.storage.v2.StartResumableWriteRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getStartResumableWriteMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Determines the `persisted_size` for an object that is being written, which
+ * can then be used as the `write_offset` for the next `Write()` call.
+ * If the object does not exist (i.e., the object has been deleted, or the
+ * first `Write()` has not yet reached the service), this method returns the
+ * error `NOT_FOUND`.
+ * The client **may** call `QueryWriteStatus()` at any time to determine how
+ * much data has been processed for this object. This is useful if the
+ * client is buffering data and needs to know which data can be safely
+ * evicted. For any sequence of `QueryWriteStatus()` calls for a given
+ * object name, the sequence of returned `persisted_size` values will be
+ * non-decreasing.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.storage.v2.QueryWriteStatusResponse>
+ queryWriteStatus(com.google.storage.v2.QueryWriteStatusRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getQueryWriteStatusMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves the name of a project's Google Cloud Storage service account.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ getServiceAccount(com.google.storage.v2.GetServiceAccountRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getGetServiceAccountMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a new HMAC key for the given service account.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.storage.v2.CreateHmacKeyResponse>
+ createHmacKey(com.google.storage.v2.CreateHmacKeyRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getCreateHmacKeyMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Deletes a given HMAC key. Key must be in an INACTIVE state.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ deleteHmacKey(com.google.storage.v2.DeleteHmacKeyRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getDeleteHmacKeyMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets an existing HMAC key metadata for the given id.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ getHmacKey(com.google.storage.v2.GetHmacKeyRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getGetHmacKeyMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists HMAC keys under a given project with the additional filters provided.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.storage.v2.ListHmacKeysResponse>
+ listHmacKeys(com.google.storage.v2.ListHmacKeysRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getListHmacKeysMethod(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates a given HMAC key state between ACTIVE and INACTIVE.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ updateHmacKey(com.google.storage.v2.UpdateHmacKeyRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getUpdateHmacKeyMethod(), getCallOptions()), request);
+ }
+ }
+
+ private static final int METHODID_DELETE_BUCKET = 0;
+ private static final int METHODID_GET_BUCKET = 1;
+ private static final int METHODID_CREATE_BUCKET = 2;
+ private static final int METHODID_LIST_BUCKETS = 3;
+ private static final int METHODID_LOCK_BUCKET_RETENTION_POLICY = 4;
+ private static final int METHODID_GET_IAM_POLICY = 5;
+ private static final int METHODID_SET_IAM_POLICY = 6;
+ private static final int METHODID_TEST_IAM_PERMISSIONS = 7;
+ private static final int METHODID_UPDATE_BUCKET = 8;
+ private static final int METHODID_DELETE_NOTIFICATION = 9;
+ private static final int METHODID_GET_NOTIFICATION = 10;
+ private static final int METHODID_CREATE_NOTIFICATION = 11;
+ private static final int METHODID_LIST_NOTIFICATIONS = 12;
+ private static final int METHODID_COMPOSE_OBJECT = 13;
+ private static final int METHODID_DELETE_OBJECT = 14;
+ private static final int METHODID_CANCEL_RESUMABLE_WRITE = 15;
+ private static final int METHODID_GET_OBJECT = 16;
+ private static final int METHODID_READ_OBJECT = 17;
+ private static final int METHODID_UPDATE_OBJECT = 18;
+ private static final int METHODID_LIST_OBJECTS = 19;
+ private static final int METHODID_REWRITE_OBJECT = 20;
+ private static final int METHODID_START_RESUMABLE_WRITE = 21;
+ private static final int METHODID_QUERY_WRITE_STATUS = 22;
+ private static final int METHODID_GET_SERVICE_ACCOUNT = 23;
+ private static final int METHODID_CREATE_HMAC_KEY = 24;
+ private static final int METHODID_DELETE_HMAC_KEY = 25;
+ private static final int METHODID_GET_HMAC_KEY = 26;
+ private static final int METHODID_LIST_HMAC_KEYS = 27;
+ private static final int METHODID_UPDATE_HMAC_KEY = 28;
+ private static final int METHODID_WRITE_OBJECT = 29;
+
+ private static final class MethodHandlers
+ implements io.grpc.stub.ServerCalls.UnaryMethod,
+ io.grpc.stub.ServerCalls.ServerStreamingMethod,
+ io.grpc.stub.ServerCalls.ClientStreamingMethod,
+ io.grpc.stub.ServerCalls.BidiStreamingMethod {
+ private final StorageImplBase serviceImpl;
+ private final int methodId;
+
+ MethodHandlers(StorageImplBase serviceImpl, int methodId) {
+ this.serviceImpl = serviceImpl;
+ this.methodId = methodId;
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ case METHODID_DELETE_BUCKET:
+ serviceImpl.deleteBucket(
+ (com.google.storage.v2.DeleteBucketRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_BUCKET:
+ serviceImpl.getBucket(
+ (com.google.storage.v2.GetBucketRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_CREATE_BUCKET:
+ serviceImpl.createBucket(
+ (com.google.storage.v2.CreateBucketRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_LIST_BUCKETS:
+ serviceImpl.listBuckets(
+ (com.google.storage.v2.ListBucketsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_LOCK_BUCKET_RETENTION_POLICY:
+ serviceImpl.lockBucketRetentionPolicy(
+ (com.google.storage.v2.LockBucketRetentionPolicyRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_IAM_POLICY:
+ serviceImpl.getIamPolicy(
+ (com.google.iam.v1.GetIamPolicyRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_SET_IAM_POLICY:
+ serviceImpl.setIamPolicy(
+ (com.google.iam.v1.SetIamPolicyRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_TEST_IAM_PERMISSIONS:
+ serviceImpl.testIamPermissions(
+ (com.google.iam.v1.TestIamPermissionsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_UPDATE_BUCKET:
+ serviceImpl.updateBucket(
+ (com.google.storage.v2.UpdateBucketRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_DELETE_NOTIFICATION:
+ serviceImpl.deleteNotification(
+ (com.google.storage.v2.DeleteNotificationRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_NOTIFICATION:
+ serviceImpl.getNotification(
+ (com.google.storage.v2.GetNotificationRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_CREATE_NOTIFICATION:
+ serviceImpl.createNotification(
+ (com.google.storage.v2.CreateNotificationRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_LIST_NOTIFICATIONS:
+ serviceImpl.listNotifications(
+ (com.google.storage.v2.ListNotificationsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_COMPOSE_OBJECT:
+ serviceImpl.composeObject(
+ (com.google.storage.v2.ComposeObjectRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_DELETE_OBJECT:
+ serviceImpl.deleteObject(
+ (com.google.storage.v2.DeleteObjectRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_CANCEL_RESUMABLE_WRITE:
+ serviceImpl.cancelResumableWrite(
+ (com.google.storage.v2.CancelResumableWriteRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_GET_OBJECT:
+ serviceImpl.getObject(
+ (com.google.storage.v2.GetObjectRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_READ_OBJECT:
+ serviceImpl.readObject(
+ (com.google.storage.v2.ReadObjectRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_UPDATE_OBJECT:
+ serviceImpl.updateObject(
+ (com.google.storage.v2.UpdateObjectRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_LIST_OBJECTS:
+ serviceImpl.listObjects(
+ (com.google.storage.v2.ListObjectsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_REWRITE_OBJECT:
+ serviceImpl.rewriteObject(
+ (com.google.storage.v2.RewriteObjectRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_START_RESUMABLE_WRITE:
+ serviceImpl.startResumableWrite(
+ (com.google.storage.v2.StartResumableWriteRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_QUERY_WRITE_STATUS:
+ serviceImpl.queryWriteStatus(
+ (com.google.storage.v2.QueryWriteStatusRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_GET_SERVICE_ACCOUNT:
+ serviceImpl.getServiceAccount(
+ (com.google.storage.v2.GetServiceAccountRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_CREATE_HMAC_KEY:
+ serviceImpl.createHmacKey(
+ (com.google.storage.v2.CreateHmacKeyRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_DELETE_HMAC_KEY:
+ serviceImpl.deleteHmacKey(
+ (com.google.storage.v2.DeleteHmacKeyRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_HMAC_KEY:
+ serviceImpl.getHmacKey(
+ (com.google.storage.v2.GetHmacKeyRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_LIST_HMAC_KEYS:
+ serviceImpl.listHmacKeys(
+ (com.google.storage.v2.ListHmacKeysRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_UPDATE_HMAC_KEY:
+ serviceImpl.updateHmacKey(
+ (com.google.storage.v2.UpdateHmacKeyRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ default:
+ throw new AssertionError();
+ }
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public io.grpc.stub.StreamObserver invoke(
+ io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ case METHODID_WRITE_OBJECT:
+ return (io.grpc.stub.StreamObserver)
+ serviceImpl.writeObject(
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ default:
+ throw new AssertionError();
+ }
+ }
+ }
+
+ private abstract static class StorageBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
+ io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ StorageBaseDescriptorSupplier() {}
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
+ return com.google.storage.v2.StorageProto.getDescriptor();
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
+ return getFileDescriptor().findServiceByName("Storage");
+ }
+ }
+
+ private static final class StorageFileDescriptorSupplier extends StorageBaseDescriptorSupplier {
+ StorageFileDescriptorSupplier() {}
+ }
+
+ private static final class StorageMethodDescriptorSupplier extends StorageBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
+ private final String methodName;
+
+ StorageMethodDescriptorSupplier(String methodName) {
+ this.methodName = methodName;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
+ return getServiceDescriptor().findMethodByName(methodName);
+ }
+ }
+
+ private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
+
+ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
+ io.grpc.ServiceDescriptor result = serviceDescriptor;
+ if (result == null) {
+ synchronized (StorageGrpc.class) {
+ result = serviceDescriptor;
+ if (result == null) {
+ serviceDescriptor =
+ result =
+ io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new StorageFileDescriptorSupplier())
+ .addMethod(getDeleteBucketMethod())
+ .addMethod(getGetBucketMethod())
+ .addMethod(getCreateBucketMethod())
+ .addMethod(getListBucketsMethod())
+ .addMethod(getLockBucketRetentionPolicyMethod())
+ .addMethod(getGetIamPolicyMethod())
+ .addMethod(getSetIamPolicyMethod())
+ .addMethod(getTestIamPermissionsMethod())
+ .addMethod(getUpdateBucketMethod())
+ .addMethod(getDeleteNotificationMethod())
+ .addMethod(getGetNotificationMethod())
+ .addMethod(getCreateNotificationMethod())
+ .addMethod(getListNotificationsMethod())
+ .addMethod(getComposeObjectMethod())
+ .addMethod(getDeleteObjectMethod())
+ .addMethod(getCancelResumableWriteMethod())
+ .addMethod(getGetObjectMethod())
+ .addMethod(getReadObjectMethod())
+ .addMethod(getUpdateObjectMethod())
+ .addMethod(getWriteObjectMethod())
+ .addMethod(getListObjectsMethod())
+ .addMethod(getRewriteObjectMethod())
+ .addMethod(getStartResumableWriteMethod())
+ .addMethod(getQueryWriteStatusMethod())
+ .addMethod(getGetServiceAccountMethod())
+ .addMethod(getCreateHmacKeyMethod())
+ .addMethod(getDeleteHmacKeyMethod())
+ .addMethod(getGetHmacKeyMethod())
+ .addMethod(getListHmacKeysMethod())
+ .addMethod(getUpdateHmacKeyMethod())
+ .build();
+ }
+ }
+ }
+ return result;
+ }
+}
diff --git a/owl-bot-staging/v2/gapic-google-cloud-storage-v2/src/main/resources/com/google/storage/v2/gapic_metadata.json b/owl-bot-staging/v2/gapic-google-cloud-storage-v2/src/main/resources/com/google/storage/v2/gapic_metadata.json
deleted file mode 100644
index 9442f71159..0000000000
--- a/owl-bot-staging/v2/gapic-google-cloud-storage-v2/src/main/resources/com/google/storage/v2/gapic_metadata.json
+++ /dev/null
@@ -1,108 +0,0 @@
-{
- "schema": "1.0",
- "comment": "This file maps proto services/RPCs to the corresponding library clients/methods",
- "language": "java",
- "protoPackage": "google.storage.v2",
- "libraryPackage": "com.google.storage.v2",
- "services": {
- "Storage": {
- "clients": {
- "grpc": {
- "libraryClient": "StorageClient",
- "rpcs": {
- "CancelResumableWrite": {
- "methods": ["cancelResumableWrite", "cancelResumableWrite", "cancelResumableWriteCallable"]
- },
- "ComposeObject": {
- "methods": ["composeObject", "composeObjectCallable"]
- },
- "CreateBucket": {
- "methods": ["createBucket", "createBucket", "createBucket", "createBucketCallable"]
- },
- "CreateHmacKey": {
- "methods": ["createHmacKey", "createHmacKey", "createHmacKey", "createHmacKeyCallable"]
- },
- "CreateNotification": {
- "methods": ["createNotification", "createNotification", "createNotification", "createNotificationCallable"]
- },
- "DeleteBucket": {
- "methods": ["deleteBucket", "deleteBucket", "deleteBucket", "deleteBucketCallable"]
- },
- "DeleteHmacKey": {
- "methods": ["deleteHmacKey", "deleteHmacKey", "deleteHmacKey", "deleteHmacKeyCallable"]
- },
- "DeleteNotification": {
- "methods": ["deleteNotification", "deleteNotification", "deleteNotification", "deleteNotificationCallable"]
- },
- "DeleteObject": {
- "methods": ["deleteObject", "deleteObject", "deleteObject", "deleteObjectCallable"]
- },
- "GetBucket": {
- "methods": ["getBucket", "getBucket", "getBucket", "getBucketCallable"]
- },
- "GetHmacKey": {
- "methods": ["getHmacKey", "getHmacKey", "getHmacKey", "getHmacKeyCallable"]
- },
- "GetIamPolicy": {
- "methods": ["getIamPolicy", "getIamPolicy", "getIamPolicy", "getIamPolicyCallable"]
- },
- "GetNotification": {
- "methods": ["getNotification", "getNotification", "getNotification", "getNotificationCallable"]
- },
- "GetObject": {
- "methods": ["getObject", "getObject", "getObject", "getObjectCallable"]
- },
- "GetServiceAccount": {
- "methods": ["getServiceAccount", "getServiceAccount", "getServiceAccount", "getServiceAccountCallable"]
- },
- "ListBuckets": {
- "methods": ["listBuckets", "listBuckets", "listBuckets", "listBucketsPagedCallable", "listBucketsCallable"]
- },
- "ListHmacKeys": {
- "methods": ["listHmacKeys", "listHmacKeys", "listHmacKeys", "listHmacKeysPagedCallable", "listHmacKeysCallable"]
- },
- "ListNotifications": {
- "methods": ["listNotifications", "listNotifications", "listNotifications", "listNotificationsPagedCallable", "listNotificationsCallable"]
- },
- "ListObjects": {
- "methods": ["listObjects", "listObjects", "listObjects", "listObjectsPagedCallable", "listObjectsCallable"]
- },
- "LockBucketRetentionPolicy": {
- "methods": ["lockBucketRetentionPolicy", "lockBucketRetentionPolicy", "lockBucketRetentionPolicy", "lockBucketRetentionPolicyCallable"]
- },
- "QueryWriteStatus": {
- "methods": ["queryWriteStatus", "queryWriteStatus", "queryWriteStatusCallable"]
- },
- "ReadObject": {
- "methods": ["readObjectCallable"]
- },
- "RewriteObject": {
- "methods": ["rewriteObject", "rewriteObjectCallable"]
- },
- "SetIamPolicy": {
- "methods": ["setIamPolicy", "setIamPolicy", "setIamPolicy", "setIamPolicyCallable"]
- },
- "StartResumableWrite": {
- "methods": ["startResumableWrite", "startResumableWriteCallable"]
- },
- "TestIamPermissions": {
- "methods": ["testIamPermissions", "testIamPermissions", "testIamPermissions", "testIamPermissionsCallable"]
- },
- "UpdateBucket": {
- "methods": ["updateBucket", "updateBucket", "updateBucketCallable"]
- },
- "UpdateHmacKey": {
- "methods": ["updateHmacKey", "updateHmacKey", "updateHmacKeyCallable"]
- },
- "UpdateObject": {
- "methods": ["updateObject", "updateObject", "updateObjectCallable"]
- },
- "WriteObject": {
- "methods": ["writeObjectCallable"]
- }
- }
- }
- }
- }
- }
-}
\ No newline at end of file
diff --git a/owl-bot-staging/v2/grpc-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageGrpc.java b/owl-bot-staging/v2/grpc-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageGrpc.java
deleted file mode 100644
index 520c2a2d10..0000000000
--- a/owl-bot-staging/v2/grpc-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageGrpc.java
+++ /dev/null
@@ -1,3024 +0,0 @@
-package com.google.storage.v2;
-
-import static io.grpc.MethodDescriptor.generateFullMethodName;
-
-/**
- *
- * ## API Overview and Naming Syntax
- * The Cloud Storage gRPC API allows applications to read and write data through
- * the abstractions of buckets and objects. For a description of these
- * abstractions please see https://cloud.google.com/storage/docs.
- * Resources are named as follows:
- * - Projects are referred to as they are defined by the Resource Manager API,
- * using strings like `projects/123456` or `projects/my-string-id`.
- * - Buckets are named using string names of the form:
- * `projects/{project}/buckets/{bucket}`
- * For globally unique buckets, `_` may be substituted for the project.
- * - Objects are uniquely identified by their name along with the name of the
- * bucket they belong to, as separate strings in this API. For example:
- * ReadObjectRequest {
- * bucket: 'projects/_/buckets/my-bucket'
- * object: 'my-object'
- * }
- * Note that object names can contain `/` characters, which are treated as
- * any other character (no special directory semantics).
- *
- */
-@javax.annotation.Generated(
- value = "by gRPC proto compiler",
- comments = "Source: google/storage/v2/storage.proto")
-@io.grpc.stub.annotations.GrpcGenerated
-public final class StorageGrpc {
-
- private StorageGrpc() {}
-
- public static final String SERVICE_NAME = "google.storage.v2.Storage";
-
- // Static method descriptors that strictly reflect the proto.
- private static volatile io.grpc.MethodDescriptor getDeleteBucketMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "DeleteBucket",
- requestType = com.google.storage.v2.DeleteBucketRequest.class,
- responseType = com.google.protobuf.Empty.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getDeleteBucketMethod() {
- io.grpc.MethodDescriptor getDeleteBucketMethod;
- if ((getDeleteBucketMethod = StorageGrpc.getDeleteBucketMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getDeleteBucketMethod = StorageGrpc.getDeleteBucketMethod) == null) {
- StorageGrpc.getDeleteBucketMethod = getDeleteBucketMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteBucket"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.DeleteBucketRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.protobuf.Empty.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("DeleteBucket"))
- .build();
- }
- }
- }
- return getDeleteBucketMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getGetBucketMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "GetBucket",
- requestType = com.google.storage.v2.GetBucketRequest.class,
- responseType = com.google.storage.v2.Bucket.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGetBucketMethod() {
- io.grpc.MethodDescriptor getGetBucketMethod;
- if ((getGetBucketMethod = StorageGrpc.getGetBucketMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getGetBucketMethod = StorageGrpc.getGetBucketMethod) == null) {
- StorageGrpc.getGetBucketMethod = getGetBucketMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetBucket"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.GetBucketRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Bucket.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("GetBucket"))
- .build();
- }
- }
- }
- return getGetBucketMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getCreateBucketMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "CreateBucket",
- requestType = com.google.storage.v2.CreateBucketRequest.class,
- responseType = com.google.storage.v2.Bucket.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getCreateBucketMethod() {
- io.grpc.MethodDescriptor getCreateBucketMethod;
- if ((getCreateBucketMethod = StorageGrpc.getCreateBucketMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getCreateBucketMethod = StorageGrpc.getCreateBucketMethod) == null) {
- StorageGrpc.getCreateBucketMethod = getCreateBucketMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateBucket"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.CreateBucketRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Bucket.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("CreateBucket"))
- .build();
- }
- }
- }
- return getCreateBucketMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getListBucketsMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "ListBuckets",
- requestType = com.google.storage.v2.ListBucketsRequest.class,
- responseType = com.google.storage.v2.ListBucketsResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getListBucketsMethod() {
- io.grpc.MethodDescriptor getListBucketsMethod;
- if ((getListBucketsMethod = StorageGrpc.getListBucketsMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getListBucketsMethod = StorageGrpc.getListBucketsMethod) == null) {
- StorageGrpc.getListBucketsMethod = getListBucketsMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListBuckets"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ListBucketsRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ListBucketsResponse.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("ListBuckets"))
- .build();
- }
- }
- }
- return getListBucketsMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getLockBucketRetentionPolicyMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "LockBucketRetentionPolicy",
- requestType = com.google.storage.v2.LockBucketRetentionPolicyRequest.class,
- responseType = com.google.storage.v2.Bucket.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getLockBucketRetentionPolicyMethod() {
- io.grpc.MethodDescriptor getLockBucketRetentionPolicyMethod;
- if ((getLockBucketRetentionPolicyMethod = StorageGrpc.getLockBucketRetentionPolicyMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getLockBucketRetentionPolicyMethod = StorageGrpc.getLockBucketRetentionPolicyMethod) == null) {
- StorageGrpc.getLockBucketRetentionPolicyMethod = getLockBucketRetentionPolicyMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "LockBucketRetentionPolicy"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.LockBucketRetentionPolicyRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Bucket.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("LockBucketRetentionPolicy"))
- .build();
- }
- }
- }
- return getLockBucketRetentionPolicyMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getGetIamPolicyMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "GetIamPolicy",
- requestType = com.google.iam.v1.GetIamPolicyRequest.class,
- responseType = com.google.iam.v1.Policy.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGetIamPolicyMethod() {
- io.grpc.MethodDescriptor getGetIamPolicyMethod;
- if ((getGetIamPolicyMethod = StorageGrpc.getGetIamPolicyMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getGetIamPolicyMethod = StorageGrpc.getGetIamPolicyMethod) == null) {
- StorageGrpc.getGetIamPolicyMethod = getGetIamPolicyMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetIamPolicy"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.iam.v1.GetIamPolicyRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.iam.v1.Policy.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("GetIamPolicy"))
- .build();
- }
- }
- }
- return getGetIamPolicyMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getSetIamPolicyMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "SetIamPolicy",
- requestType = com.google.iam.v1.SetIamPolicyRequest.class,
- responseType = com.google.iam.v1.Policy.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getSetIamPolicyMethod() {
- io.grpc.MethodDescriptor getSetIamPolicyMethod;
- if ((getSetIamPolicyMethod = StorageGrpc.getSetIamPolicyMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getSetIamPolicyMethod = StorageGrpc.getSetIamPolicyMethod) == null) {
- StorageGrpc.getSetIamPolicyMethod = getSetIamPolicyMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetIamPolicy"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.iam.v1.SetIamPolicyRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.iam.v1.Policy.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("SetIamPolicy"))
- .build();
- }
- }
- }
- return getSetIamPolicyMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getTestIamPermissionsMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "TestIamPermissions",
- requestType = com.google.iam.v1.TestIamPermissionsRequest.class,
- responseType = com.google.iam.v1.TestIamPermissionsResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getTestIamPermissionsMethod() {
- io.grpc.MethodDescriptor getTestIamPermissionsMethod;
- if ((getTestIamPermissionsMethod = StorageGrpc.getTestIamPermissionsMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getTestIamPermissionsMethod = StorageGrpc.getTestIamPermissionsMethod) == null) {
- StorageGrpc.getTestIamPermissionsMethod = getTestIamPermissionsMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "TestIamPermissions"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.iam.v1.TestIamPermissionsRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.iam.v1.TestIamPermissionsResponse.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("TestIamPermissions"))
- .build();
- }
- }
- }
- return getTestIamPermissionsMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getUpdateBucketMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "UpdateBucket",
- requestType = com.google.storage.v2.UpdateBucketRequest.class,
- responseType = com.google.storage.v2.Bucket.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getUpdateBucketMethod() {
- io.grpc.MethodDescriptor getUpdateBucketMethod;
- if ((getUpdateBucketMethod = StorageGrpc.getUpdateBucketMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getUpdateBucketMethod = StorageGrpc.getUpdateBucketMethod) == null) {
- StorageGrpc.getUpdateBucketMethod = getUpdateBucketMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateBucket"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.UpdateBucketRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Bucket.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("UpdateBucket"))
- .build();
- }
- }
- }
- return getUpdateBucketMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getDeleteNotificationMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "DeleteNotification",
- requestType = com.google.storage.v2.DeleteNotificationRequest.class,
- responseType = com.google.protobuf.Empty.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getDeleteNotificationMethod() {
- io.grpc.MethodDescriptor getDeleteNotificationMethod;
- if ((getDeleteNotificationMethod = StorageGrpc.getDeleteNotificationMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getDeleteNotificationMethod = StorageGrpc.getDeleteNotificationMethod) == null) {
- StorageGrpc.getDeleteNotificationMethod = getDeleteNotificationMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteNotification"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.DeleteNotificationRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.protobuf.Empty.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("DeleteNotification"))
- .build();
- }
- }
- }
- return getDeleteNotificationMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getGetNotificationMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "GetNotification",
- requestType = com.google.storage.v2.GetNotificationRequest.class,
- responseType = com.google.storage.v2.Notification.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGetNotificationMethod() {
- io.grpc.MethodDescriptor getGetNotificationMethod;
- if ((getGetNotificationMethod = StorageGrpc.getGetNotificationMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getGetNotificationMethod = StorageGrpc.getGetNotificationMethod) == null) {
- StorageGrpc.getGetNotificationMethod = getGetNotificationMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetNotification"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.GetNotificationRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Notification.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("GetNotification"))
- .build();
- }
- }
- }
- return getGetNotificationMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getCreateNotificationMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "CreateNotification",
- requestType = com.google.storage.v2.CreateNotificationRequest.class,
- responseType = com.google.storage.v2.Notification.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getCreateNotificationMethod() {
- io.grpc.MethodDescriptor getCreateNotificationMethod;
- if ((getCreateNotificationMethod = StorageGrpc.getCreateNotificationMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getCreateNotificationMethod = StorageGrpc.getCreateNotificationMethod) == null) {
- StorageGrpc.getCreateNotificationMethod = getCreateNotificationMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateNotification"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.CreateNotificationRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Notification.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("CreateNotification"))
- .build();
- }
- }
- }
- return getCreateNotificationMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getListNotificationsMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "ListNotifications",
- requestType = com.google.storage.v2.ListNotificationsRequest.class,
- responseType = com.google.storage.v2.ListNotificationsResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getListNotificationsMethod() {
- io.grpc.MethodDescriptor getListNotificationsMethod;
- if ((getListNotificationsMethod = StorageGrpc.getListNotificationsMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getListNotificationsMethod = StorageGrpc.getListNotificationsMethod) == null) {
- StorageGrpc.getListNotificationsMethod = getListNotificationsMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListNotifications"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ListNotificationsRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ListNotificationsResponse.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("ListNotifications"))
- .build();
- }
- }
- }
- return getListNotificationsMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getComposeObjectMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "ComposeObject",
- requestType = com.google.storage.v2.ComposeObjectRequest.class,
- responseType = com.google.storage.v2.Object.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getComposeObjectMethod() {
- io.grpc.MethodDescriptor getComposeObjectMethod;
- if ((getComposeObjectMethod = StorageGrpc.getComposeObjectMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getComposeObjectMethod = StorageGrpc.getComposeObjectMethod) == null) {
- StorageGrpc.getComposeObjectMethod = getComposeObjectMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ComposeObject"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ComposeObjectRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Object.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("ComposeObject"))
- .build();
- }
- }
- }
- return getComposeObjectMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getDeleteObjectMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "DeleteObject",
- requestType = com.google.storage.v2.DeleteObjectRequest.class,
- responseType = com.google.protobuf.Empty.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getDeleteObjectMethod() {
- io.grpc.MethodDescriptor getDeleteObjectMethod;
- if ((getDeleteObjectMethod = StorageGrpc.getDeleteObjectMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getDeleteObjectMethod = StorageGrpc.getDeleteObjectMethod) == null) {
- StorageGrpc.getDeleteObjectMethod = getDeleteObjectMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteObject"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.DeleteObjectRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.protobuf.Empty.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("DeleteObject"))
- .build();
- }
- }
- }
- return getDeleteObjectMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getCancelResumableWriteMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "CancelResumableWrite",
- requestType = com.google.storage.v2.CancelResumableWriteRequest.class,
- responseType = com.google.storage.v2.CancelResumableWriteResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getCancelResumableWriteMethod() {
- io.grpc.MethodDescriptor getCancelResumableWriteMethod;
- if ((getCancelResumableWriteMethod = StorageGrpc.getCancelResumableWriteMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getCancelResumableWriteMethod = StorageGrpc.getCancelResumableWriteMethod) == null) {
- StorageGrpc.getCancelResumableWriteMethod = getCancelResumableWriteMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CancelResumableWrite"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.CancelResumableWriteRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.CancelResumableWriteResponse.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("CancelResumableWrite"))
- .build();
- }
- }
- }
- return getCancelResumableWriteMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getGetObjectMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "GetObject",
- requestType = com.google.storage.v2.GetObjectRequest.class,
- responseType = com.google.storage.v2.Object.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getGetObjectMethod() {
- io.grpc.MethodDescriptor getGetObjectMethod;
- if ((getGetObjectMethod = StorageGrpc.getGetObjectMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getGetObjectMethod = StorageGrpc.getGetObjectMethod) == null) {
- StorageGrpc.getGetObjectMethod = getGetObjectMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetObject"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.GetObjectRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Object.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("GetObject"))
- .build();
- }
- }
- }
- return getGetObjectMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getReadObjectMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "ReadObject",
- requestType = com.google.storage.v2.ReadObjectRequest.class,
- responseType = com.google.storage.v2.ReadObjectResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
- public static io.grpc.MethodDescriptor getReadObjectMethod() {
- io.grpc.MethodDescriptor getReadObjectMethod;
- if ((getReadObjectMethod = StorageGrpc.getReadObjectMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getReadObjectMethod = StorageGrpc.getReadObjectMethod) == null) {
- StorageGrpc.getReadObjectMethod = getReadObjectMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ReadObject"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ReadObjectRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ReadObjectResponse.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("ReadObject"))
- .build();
- }
- }
- }
- return getReadObjectMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getUpdateObjectMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "UpdateObject",
- requestType = com.google.storage.v2.UpdateObjectRequest.class,
- responseType = com.google.storage.v2.Object.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getUpdateObjectMethod() {
- io.grpc.MethodDescriptor getUpdateObjectMethod;
- if ((getUpdateObjectMethod = StorageGrpc.getUpdateObjectMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getUpdateObjectMethod = StorageGrpc.getUpdateObjectMethod) == null) {
- StorageGrpc.getUpdateObjectMethod = getUpdateObjectMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateObject"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.UpdateObjectRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.Object.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("UpdateObject"))
- .build();
- }
- }
- }
- return getUpdateObjectMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getWriteObjectMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "WriteObject",
- requestType = com.google.storage.v2.WriteObjectRequest.class,
- responseType = com.google.storage.v2.WriteObjectResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
- public static io.grpc.MethodDescriptor getWriteObjectMethod() {
- io.grpc.MethodDescriptor getWriteObjectMethod;
- if ((getWriteObjectMethod = StorageGrpc.getWriteObjectMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getWriteObjectMethod = StorageGrpc.getWriteObjectMethod) == null) {
- StorageGrpc.getWriteObjectMethod = getWriteObjectMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "WriteObject"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.WriteObjectRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.WriteObjectResponse.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("WriteObject"))
- .build();
- }
- }
- }
- return getWriteObjectMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getListObjectsMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "ListObjects",
- requestType = com.google.storage.v2.ListObjectsRequest.class,
- responseType = com.google.storage.v2.ListObjectsResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getListObjectsMethod() {
- io.grpc.MethodDescriptor getListObjectsMethod;
- if ((getListObjectsMethod = StorageGrpc.getListObjectsMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getListObjectsMethod = StorageGrpc.getListObjectsMethod) == null) {
- StorageGrpc.getListObjectsMethod = getListObjectsMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListObjects"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ListObjectsRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.storage.v2.ListObjectsResponse.getDefaultInstance()))
- .setSchemaDescriptor(new StorageMethodDescriptorSupplier("ListObjects"))
- .build();
- }
- }
- }
- return getListObjectsMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor getRewriteObjectMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "RewriteObject",
- requestType = com.google.storage.v2.RewriteObjectRequest.class,
- responseType = com.google.storage.v2.RewriteResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor getRewriteObjectMethod() {
- io.grpc.MethodDescriptor getRewriteObjectMethod;
- if ((getRewriteObjectMethod = StorageGrpc.getRewriteObjectMethod) == null) {
- synchronized (StorageGrpc.class) {
- if ((getRewriteObjectMethod = StorageGrpc.getRewriteObjectMethod) == null) {
- StorageGrpc.getRewriteObjectMethod = getRewriteObjectMethod =
- io.grpc.MethodDescriptor.