Skip to content

Commit d9c4bf6

Browse files
cloud-java-botBenWhitehead
cloud-java-bot
and
BenWhitehead
authored
chore: Update generation configuration at Wed Jan 8 02:23:03 UTC 2025 (googleapis#2863)
 BEGIN_COMMIT_OVERRIDE BEGIN_NESTED_COMMIT chore(storage/v2): Add new preview BidiReadObject API chore(storage/v2): Add new preview appendable Object to BidiWrite API chore(docs): Add IAM information to RPC comments for reference documentation PiperOrigin-RevId: 712942128 Source Link: [googleapis/googleapis@44ad570](googleapis/googleapis@44ad570) END_NESTED_COMMIT END_COMMIT_OVERRIDE --------- Co-authored-by: BenWhitehead <[email protected]>
1 parent 56e523c commit d9c4bf6

File tree

48 files changed

+18981
-880
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

48 files changed

+18981
-880
lines changed

‎gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageClient.java‎

Lines changed: 314 additions & 74 deletions
Large diffs are not rendered by default.

‎gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageSettings.java‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,12 @@ public ServerStreamingCallSettings<ReadObjectRequest, ReadObjectResponse> readOb
173173
return ((StorageStubSettings) getStubSettings()).readObjectSettings();
174174
}
175175

176+
/** Returns the object with the settings used for calls to bidiReadObject. */
177+
public StreamingCallSettings<BidiReadObjectRequest, BidiReadObjectResponse>
178+
bidiReadObjectSettings() {
179+
return ((StorageStubSettings) getStubSettings()).bidiReadObjectSettings();
180+
}
181+
176182
/** Returns the object with the settings used for calls to updateObject. */
177183
public UnaryCallSettings<UpdateObjectRequest, Object> updateObjectSettings() {
178184
return ((StorageStubSettings) getStubSettings()).updateObjectSettings();
@@ -393,6 +399,12 @@ public UnaryCallSettings.Builder<GetObjectRequest, Object> getObjectSettings() {
393399
return getStubSettingsBuilder().readObjectSettings();
394400
}
395401

402+
/** Returns the builder for the settings used for calls to bidiReadObject. */
403+
public StreamingCallSettings.Builder<BidiReadObjectRequest, BidiReadObjectResponse>
404+
bidiReadObjectSettings() {
405+
return getStubSettingsBuilder().bidiReadObjectSettings();
406+
}
407+
396408
/** Returns the builder for the settings used for calls to updateObject. */
397409
public UnaryCallSettings.Builder<UpdateObjectRequest, Object> updateObjectSettings() {
398410
return getStubSettingsBuilder().updateObjectSettings();

‎gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/stub/GrpcStorageStub.java‎

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,8 @@
3737
import com.google.iam.v1.TestIamPermissionsResponse;
3838
import com.google.longrunning.stub.GrpcOperationsStub;
3939
import com.google.protobuf.Empty;
40+
import com.google.storage.v2.BidiReadObjectRequest;
41+
import com.google.storage.v2.BidiReadObjectResponse;
4042
import com.google.storage.v2.BidiWriteObjectRequest;
4143
import com.google.storage.v2.BidiWriteObjectResponse;
4244
import com.google.storage.v2.Bucket;
@@ -217,6 +219,17 @@ public class GrpcStorageStub extends StorageStub {
217219
.setResponseMarshaller(ProtoUtils.marshaller(ReadObjectResponse.getDefaultInstance()))
218220
.build();
219221

222+
private static final MethodDescriptor<BidiReadObjectRequest, BidiReadObjectResponse>
223+
bidiReadObjectMethodDescriptor =
224+
MethodDescriptor.<BidiReadObjectRequest, BidiReadObjectResponse>newBuilder()
225+
.setType(MethodDescriptor.MethodType.BIDI_STREAMING)
226+
.setFullMethodName("google.storage.v2.Storage/BidiReadObject")
227+
.setRequestMarshaller(
228+
ProtoUtils.marshaller(BidiReadObjectRequest.getDefaultInstance()))
229+
.setResponseMarshaller(
230+
ProtoUtils.marshaller(BidiReadObjectResponse.getDefaultInstance()))
231+
.build();
232+
220233
private static final MethodDescriptor<UpdateObjectRequest, Object> updateObjectMethodDescriptor =
221234
MethodDescriptor.<UpdateObjectRequest, Object>newBuilder()
222235
.setType(MethodDescriptor.MethodType.UNARY)
@@ -316,6 +329,8 @@ public class GrpcStorageStub extends StorageStub {
316329
cancelResumableWriteCallable;
317330
private final UnaryCallable<GetObjectRequest, Object> getObjectCallable;
318331
private final ServerStreamingCallable<ReadObjectRequest, ReadObjectResponse> readObjectCallable;
332+
private final BidiStreamingCallable<BidiReadObjectRequest, BidiReadObjectResponse>
333+
bidiReadObjectCallable;
319334
private final UnaryCallable<UpdateObjectRequest, Object> updateObjectCallable;
320335
private final ClientStreamingCallable<WriteObjectRequest, WriteObjectResponse>
321336
writeObjectCallable;
@@ -369,6 +384,8 @@ public class GrpcStorageStub extends StorageStub {
369384
private static final PathTemplate GET_OBJECT_0_PATH_TEMPLATE = PathTemplate.create("{bucket=**}");
370385
private static final PathTemplate READ_OBJECT_0_PATH_TEMPLATE =
371386
PathTemplate.create("{bucket=**}");
387+
private static final PathTemplate BIDI_READ_OBJECT_0_PATH_TEMPLATE =
388+
PathTemplate.create("{bucket=**}");
372389
private static final PathTemplate UPDATE_OBJECT_0_PATH_TEMPLATE =
373390
PathTemplate.create("{bucket=**}");
374391
private static final PathTemplate LIST_OBJECTS_0_PATH_TEMPLATE =
@@ -593,6 +610,22 @@ protected GrpcStorageStub(
593610
return builder.build();
594611
})
595612
.build();
613+
GrpcCallSettings<BidiReadObjectRequest, BidiReadObjectResponse>
614+
bidiReadObjectTransportSettings =
615+
GrpcCallSettings.<BidiReadObjectRequest, BidiReadObjectResponse>newBuilder()
616+
.setMethodDescriptor(bidiReadObjectMethodDescriptor)
617+
.setParamsExtractor(
618+
request -> {
619+
RequestParamsBuilder builder = RequestParamsBuilder.create();
620+
if (request.getReadObjectSpec() != null) {
621+
builder.add(
622+
request.getReadObjectSpec().getBucket(),
623+
"bucket",
624+
BIDI_READ_OBJECT_0_PATH_TEMPLATE);
625+
}
626+
return builder.build();
627+
})
628+
.build();
596629
GrpcCallSettings<UpdateObjectRequest, Object> updateObjectTransportSettings =
597630
GrpcCallSettings.<UpdateObjectRequest, Object>newBuilder()
598631
.setMethodDescriptor(updateObjectMethodDescriptor)
@@ -732,6 +765,9 @@ protected GrpcStorageStub(
732765
this.readObjectCallable =
733766
callableFactory.createServerStreamingCallable(
734767
readObjectTransportSettings, settings.readObjectSettings(), clientContext);
768+
this.bidiReadObjectCallable =
769+
callableFactory.createBidiStreamingCallable(
770+
bidiReadObjectTransportSettings, settings.bidiReadObjectSettings(), clientContext);
735771
this.updateObjectCallable =
736772
callableFactory.createUnaryCallable(
737773
updateObjectTransportSettings, settings.updateObjectSettings(), clientContext);
@@ -853,6 +889,12 @@ public ServerStreamingCallable<ReadObjectRequest, ReadObjectResponse> readObject
853889
return readObjectCallable;
854890
}
855891

892+
@Override
893+
public BidiStreamingCallable<BidiReadObjectRequest, BidiReadObjectResponse>
894+
bidiReadObjectCallable() {
895+
return bidiReadObjectCallable;
896+
}
897+
856898
@Override
857899
public UnaryCallable<UpdateObjectRequest, Object> updateObjectCallable() {
858900
return updateObjectCallable;

‎gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/stub/StorageStub.java‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,8 @@
3030
import com.google.iam.v1.TestIamPermissionsRequest;
3131
import com.google.iam.v1.TestIamPermissionsResponse;
3232
import com.google.protobuf.Empty;
33+
import com.google.storage.v2.BidiReadObjectRequest;
34+
import com.google.storage.v2.BidiReadObjectResponse;
3335
import com.google.storage.v2.BidiWriteObjectRequest;
3436
import com.google.storage.v2.BidiWriteObjectResponse;
3537
import com.google.storage.v2.Bucket;
@@ -139,6 +141,11 @@ public ServerStreamingCallable<ReadObjectRequest, ReadObjectResponse> readObject
139141
throw new UnsupportedOperationException("Not implemented: readObjectCallable()");
140142
}
141143

144+
public BidiStreamingCallable<BidiReadObjectRequest, BidiReadObjectResponse>
145+
bidiReadObjectCallable() {
146+
throw new UnsupportedOperationException("Not implemented: bidiReadObjectCallable()");
147+
}
148+
142149
public UnaryCallable<UpdateObjectRequest, Object> updateObjectCallable() {
143150
throw new UnsupportedOperationException("Not implemented: updateObjectCallable()");
144151
}

‎gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/stub/StorageStubSettings.java‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,8 @@
5353
import com.google.iam.v1.TestIamPermissionsRequest;
5454
import com.google.iam.v1.TestIamPermissionsResponse;
5555
import com.google.protobuf.Empty;
56+
import com.google.storage.v2.BidiReadObjectRequest;
57+
import com.google.storage.v2.BidiReadObjectResponse;
5658
import com.google.storage.v2.BidiWriteObjectRequest;
5759
import com.google.storage.v2.BidiWriteObjectResponse;
5860
import com.google.storage.v2.Bucket;
@@ -170,6 +172,8 @@ public class StorageStubSettings extends StubSettings<StorageStubSettings> {
170172
private final UnaryCallSettings<GetObjectRequest, Object> getObjectSettings;
171173
private final ServerStreamingCallSettings<ReadObjectRequest, ReadObjectResponse>
172174
readObjectSettings;
175+
private final StreamingCallSettings<BidiReadObjectRequest, BidiReadObjectResponse>
176+
bidiReadObjectSettings;
173177
private final UnaryCallSettings<UpdateObjectRequest, Object> updateObjectSettings;
174178
private final StreamingCallSettings<WriteObjectRequest, WriteObjectResponse> writeObjectSettings;
175179
private final StreamingCallSettings<BidiWriteObjectRequest, BidiWriteObjectResponse>
@@ -364,6 +368,12 @@ public ServerStreamingCallSettings<ReadObjectRequest, ReadObjectResponse> readOb
364368
return readObjectSettings;
365369
}
366370

371+
/** Returns the object with the settings used for calls to bidiReadObject. */
372+
public StreamingCallSettings<BidiReadObjectRequest, BidiReadObjectResponse>
373+
bidiReadObjectSettings() {
374+
return bidiReadObjectSettings;
375+
}
376+
367377
/** Returns the object with the settings used for calls to updateObject. */
368378
public UnaryCallSettings<UpdateObjectRequest, Object> updateObjectSettings() {
369379
return updateObjectSettings;
@@ -503,6 +513,7 @@ protected StorageStubSettings(Builder settingsBuilder) throws IOException {
503513
cancelResumableWriteSettings = settingsBuilder.cancelResumableWriteSettings().build();
504514
getObjectSettings = settingsBuilder.getObjectSettings().build();
505515
readObjectSettings = settingsBuilder.readObjectSettings().build();
516+
bidiReadObjectSettings = settingsBuilder.bidiReadObjectSettings().build();
506517
updateObjectSettings = settingsBuilder.updateObjectSettings().build();
507518
writeObjectSettings = settingsBuilder.writeObjectSettings().build();
508519
bidiWriteObjectSettings = settingsBuilder.bidiWriteObjectSettings().build();
@@ -538,6 +549,8 @@ public static class Builder extends StubSettings.Builder<StorageStubSettings, Bu
538549
private final UnaryCallSettings.Builder<GetObjectRequest, Object> getObjectSettings;
539550
private final ServerStreamingCallSettings.Builder<ReadObjectRequest, ReadObjectResponse>
540551
readObjectSettings;
552+
private final StreamingCallSettings.Builder<BidiReadObjectRequest, BidiReadObjectResponse>
553+
bidiReadObjectSettings;
541554
private final UnaryCallSettings.Builder<UpdateObjectRequest, Object> updateObjectSettings;
542555
private final StreamingCallSettings.Builder<WriteObjectRequest, WriteObjectResponse>
543556
writeObjectSettings;
@@ -608,6 +621,7 @@ protected Builder(ClientContext clientContext) {
608621
cancelResumableWriteSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
609622
getObjectSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
610623
readObjectSettings = ServerStreamingCallSettings.newBuilder();
624+
bidiReadObjectSettings = StreamingCallSettings.newBuilder();
611625
updateObjectSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
612626
writeObjectSettings = StreamingCallSettings.newBuilder();
613627
bidiWriteObjectSettings = StreamingCallSettings.newBuilder();
@@ -660,6 +674,7 @@ protected Builder(StorageStubSettings settings) {
660674
cancelResumableWriteSettings = settings.cancelResumableWriteSettings.toBuilder();
661675
getObjectSettings = settings.getObjectSettings.toBuilder();
662676
readObjectSettings = settings.readObjectSettings.toBuilder();
677+
bidiReadObjectSettings = settings.bidiReadObjectSettings.toBuilder();
663678
updateObjectSettings = settings.updateObjectSettings.toBuilder();
664679
writeObjectSettings = settings.writeObjectSettings.toBuilder();
665680
bidiWriteObjectSettings = settings.bidiWriteObjectSettings.toBuilder();
@@ -910,6 +925,12 @@ public UnaryCallSettings.Builder<GetObjectRequest, Object> getObjectSettings() {
910925
return readObjectSettings;
911926
}
912927

928+
/** Returns the builder for the settings used for calls to bidiReadObject. */
929+
public StreamingCallSettings.Builder<BidiReadObjectRequest, BidiReadObjectResponse>
930+
bidiReadObjectSettings() {
931+
return bidiReadObjectSettings;
932+
}
933+
913934
/** Returns the builder for the settings used for calls to updateObject. */
914935
public UnaryCallSettings.Builder<UpdateObjectRequest, Object> updateObjectSettings() {
915936
return updateObjectSettings;

0 commit comments

Comments
 (0)