Skip to content

Commit

Permalink
chore: Update generation configuration at Wed Jan 8 02:23:03 UTC 2025 (…
Browse files Browse the repository at this point in the history 
…#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 <BenWhitehead@users.noreply.github.com>
  • Loading branch information
@cloud-java-bot @BenWhitehead
cloud-java-bot and BenWhitehead authored Jan 8, 2025
1 parent 56e523c commit d9c4bf6
Show file tree
Hide file tree
Showing 48 changed files with 18,981 additions and 880 deletions.
388 changes: 314 additions & 74 deletions gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageClient.java
View file

Large diffs are not rendered by default.

12 changes: 12 additions & 0 deletions gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageSettings.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -173,6 +173,12 @@ public ServerStreamingCallSettings<ReadObjectRequest, ReadObjectResponse> readOb
return ((StorageStubSettings) getStubSettings()).readObjectSettings();
}

/** Returns the object with the settings used for calls to bidiReadObject. */
public StreamingCallSettings<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectSettings() {
return ((StorageStubSettings) getStubSettings()).bidiReadObjectSettings();
}

/** Returns the object with the settings used for calls to updateObject. */
public UnaryCallSettings<UpdateObjectRequest, Object> updateObjectSettings() {
return ((StorageStubSettings) getStubSettings()).updateObjectSettings();
Expand Down Expand Up @@ -393,6 +399,12 @@ public UnaryCallSettings.Builder<GetObjectRequest, Object> getObjectSettings() {
return getStubSettingsBuilder().readObjectSettings();
}

/** Returns the builder for the settings used for calls to bidiReadObject. */
public StreamingCallSettings.Builder<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectSettings() {
return getStubSettingsBuilder().bidiReadObjectSettings();
}

/** Returns the builder for the settings used for calls to updateObject. */
public UnaryCallSettings.Builder<UpdateObjectRequest, Object> updateObjectSettings() {
return getStubSettingsBuilder().updateObjectSettings();
Expand Down
42 changes: 42 additions & 0 deletions gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/stub/GrpcStorageStub.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,8 @@
import com.google.iam.v1.TestIamPermissionsResponse;
import com.google.longrunning.stub.GrpcOperationsStub;
import com.google.protobuf.Empty;
import com.google.storage.v2.BidiReadObjectRequest;
import com.google.storage.v2.BidiReadObjectResponse;
import com.google.storage.v2.BidiWriteObjectRequest;
import com.google.storage.v2.BidiWriteObjectResponse;
import com.google.storage.v2.Bucket;
Expand Down Expand Up @@ -217,6 +219,17 @@ public class GrpcStorageStub extends StorageStub {
.setResponseMarshaller(ProtoUtils.marshaller(ReadObjectResponse.getDefaultInstance()))
.build();

private static final MethodDescriptor<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectMethodDescriptor =
MethodDescriptor.<BidiReadObjectRequest, BidiReadObjectResponse>newBuilder()
.setType(MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName("google.storage.v2.Storage/BidiReadObject")
.setRequestMarshaller(
ProtoUtils.marshaller(BidiReadObjectRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(BidiReadObjectResponse.getDefaultInstance()))
.build();

private static final MethodDescriptor<UpdateObjectRequest, Object> updateObjectMethodDescriptor =
MethodDescriptor.<UpdateObjectRequest, Object>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
Expand Down Expand Up @@ -316,6 +329,8 @@ public class GrpcStorageStub extends StorageStub {
cancelResumableWriteCallable;
private final UnaryCallable<GetObjectRequest, Object> getObjectCallable;
private final ServerStreamingCallable<ReadObjectRequest, ReadObjectResponse> readObjectCallable;
private final BidiStreamingCallable<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectCallable;
private final UnaryCallable<UpdateObjectRequest, Object> updateObjectCallable;
private final ClientStreamingCallable<WriteObjectRequest, WriteObjectResponse>
writeObjectCallable;
Expand Down Expand Up @@ -369,6 +384,8 @@ public class GrpcStorageStub extends StorageStub {
private static final PathTemplate GET_OBJECT_0_PATH_TEMPLATE = PathTemplate.create("{bucket=**}");
private static final PathTemplate READ_OBJECT_0_PATH_TEMPLATE =
PathTemplate.create("{bucket=**}");
private static final PathTemplate BIDI_READ_OBJECT_0_PATH_TEMPLATE =
PathTemplate.create("{bucket=**}");
private static final PathTemplate UPDATE_OBJECT_0_PATH_TEMPLATE =
PathTemplate.create("{bucket=**}");
private static final PathTemplate LIST_OBJECTS_0_PATH_TEMPLATE =
Expand Down Expand Up @@ -593,6 +610,22 @@ protected GrpcStorageStub(
return builder.build();
})
.build();
GrpcCallSettings<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectTransportSettings =
GrpcCallSettings.<BidiReadObjectRequest, BidiReadObjectResponse>newBuilder()
.setMethodDescriptor(bidiReadObjectMethodDescriptor)
.setParamsExtractor(
request -> {
RequestParamsBuilder builder = RequestParamsBuilder.create();
if (request.getReadObjectSpec() != null) {
builder.add(
request.getReadObjectSpec().getBucket(),
"bucket",
BIDI_READ_OBJECT_0_PATH_TEMPLATE);
}
return builder.build();
})
.build();
GrpcCallSettings<UpdateObjectRequest, Object> updateObjectTransportSettings =
GrpcCallSettings.<UpdateObjectRequest, Object>newBuilder()
.setMethodDescriptor(updateObjectMethodDescriptor)
Expand Down Expand Up @@ -732,6 +765,9 @@ protected GrpcStorageStub(
this.readObjectCallable =
callableFactory.createServerStreamingCallable(
readObjectTransportSettings, settings.readObjectSettings(), clientContext);
this.bidiReadObjectCallable =
callableFactory.createBidiStreamingCallable(
bidiReadObjectTransportSettings, settings.bidiReadObjectSettings(), clientContext);
this.updateObjectCallable =
callableFactory.createUnaryCallable(
updateObjectTransportSettings, settings.updateObjectSettings(), clientContext);
Expand Down Expand Up @@ -853,6 +889,12 @@ public ServerStreamingCallable<ReadObjectRequest, ReadObjectResponse> readObject
return readObjectCallable;
}

@Override
public BidiStreamingCallable<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectCallable() {
return bidiReadObjectCallable;
}

@Override
public UnaryCallable<UpdateObjectRequest, Object> updateObjectCallable() {
return updateObjectCallable;
Expand Down
7 changes: 7 additions & 0 deletions gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/stub/StorageStub.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,8 @@
import com.google.iam.v1.TestIamPermissionsRequest;
import com.google.iam.v1.TestIamPermissionsResponse;
import com.google.protobuf.Empty;
import com.google.storage.v2.BidiReadObjectRequest;
import com.google.storage.v2.BidiReadObjectResponse;
import com.google.storage.v2.BidiWriteObjectRequest;
import com.google.storage.v2.BidiWriteObjectResponse;
import com.google.storage.v2.Bucket;
Expand Down Expand Up @@ -139,6 +141,11 @@ public ServerStreamingCallable<ReadObjectRequest, ReadObjectResponse> readObject
throw new UnsupportedOperationException("Not implemented: readObjectCallable()");
}

public BidiStreamingCallable<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectCallable() {
throw new UnsupportedOperationException("Not implemented: bidiReadObjectCallable()");
}

public UnaryCallable<UpdateObjectRequest, Object> updateObjectCallable() {
throw new UnsupportedOperationException("Not implemented: updateObjectCallable()");
}
Expand Down
21 changes: 21 additions & 0 deletions ...google-cloud-storage-v2/src/main/java/com/google/storage/v2/stub/StorageStubSettings.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,8 @@
import com.google.iam.v1.TestIamPermissionsRequest;
import com.google.iam.v1.TestIamPermissionsResponse;
import com.google.protobuf.Empty;
import com.google.storage.v2.BidiReadObjectRequest;
import com.google.storage.v2.BidiReadObjectResponse;
import com.google.storage.v2.BidiWriteObjectRequest;
import com.google.storage.v2.BidiWriteObjectResponse;
import com.google.storage.v2.Bucket;
Expand Down Expand Up @@ -170,6 +172,8 @@ public class StorageStubSettings extends StubSettings<StorageStubSettings> {
private final UnaryCallSettings<GetObjectRequest, Object> getObjectSettings;
private final ServerStreamingCallSettings<ReadObjectRequest, ReadObjectResponse>
readObjectSettings;
private final StreamingCallSettings<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectSettings;
private final UnaryCallSettings<UpdateObjectRequest, Object> updateObjectSettings;
private final StreamingCallSettings<WriteObjectRequest, WriteObjectResponse> writeObjectSettings;
private final StreamingCallSettings<BidiWriteObjectRequest, BidiWriteObjectResponse>
Expand Down Expand Up @@ -364,6 +368,12 @@ public ServerStreamingCallSettings<ReadObjectRequest, ReadObjectResponse> readOb
return readObjectSettings;
}

/** Returns the object with the settings used for calls to bidiReadObject. */
public StreamingCallSettings<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectSettings() {
return bidiReadObjectSettings;
}

/** Returns the object with the settings used for calls to updateObject. */
public UnaryCallSettings<UpdateObjectRequest, Object> updateObjectSettings() {
return updateObjectSettings;
Expand Down Expand Up @@ -503,6 +513,7 @@ protected StorageStubSettings(Builder settingsBuilder) throws IOException {
cancelResumableWriteSettings = settingsBuilder.cancelResumableWriteSettings().build();
getObjectSettings = settingsBuilder.getObjectSettings().build();
readObjectSettings = settingsBuilder.readObjectSettings().build();
bidiReadObjectSettings = settingsBuilder.bidiReadObjectSettings().build();
updateObjectSettings = settingsBuilder.updateObjectSettings().build();
writeObjectSettings = settingsBuilder.writeObjectSettings().build();
bidiWriteObjectSettings = settingsBuilder.bidiWriteObjectSettings().build();
Expand Down Expand Up @@ -538,6 +549,8 @@ public static class Builder extends StubSettings.Builder<StorageStubSettings, Bu
private final UnaryCallSettings.Builder<GetObjectRequest, Object> getObjectSettings;
private final ServerStreamingCallSettings.Builder<ReadObjectRequest, ReadObjectResponse>
readObjectSettings;
private final StreamingCallSettings.Builder<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectSettings;
private final UnaryCallSettings.Builder<UpdateObjectRequest, Object> updateObjectSettings;
private final StreamingCallSettings.Builder<WriteObjectRequest, WriteObjectResponse>
writeObjectSettings;
Expand Down Expand Up @@ -608,6 +621,7 @@ protected Builder(ClientContext clientContext) {
cancelResumableWriteSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
getObjectSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
readObjectSettings = ServerStreamingCallSettings.newBuilder();
bidiReadObjectSettings = StreamingCallSettings.newBuilder();
updateObjectSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
writeObjectSettings = StreamingCallSettings.newBuilder();
bidiWriteObjectSettings = StreamingCallSettings.newBuilder();
Expand Down Expand Up @@ -660,6 +674,7 @@ protected Builder(StorageStubSettings settings) {
cancelResumableWriteSettings = settings.cancelResumableWriteSettings.toBuilder();
getObjectSettings = settings.getObjectSettings.toBuilder();
readObjectSettings = settings.readObjectSettings.toBuilder();
bidiReadObjectSettings = settings.bidiReadObjectSettings.toBuilder();
updateObjectSettings = settings.updateObjectSettings.toBuilder();
writeObjectSettings = settings.writeObjectSettings.toBuilder();
bidiWriteObjectSettings = settings.bidiWriteObjectSettings.toBuilder();
Expand Down Expand Up @@ -910,6 +925,12 @@ public UnaryCallSettings.Builder<GetObjectRequest, Object> getObjectSettings() {
return readObjectSettings;
}

/** Returns the builder for the settings used for calls to bidiReadObject. */
public StreamingCallSettings.Builder<BidiReadObjectRequest, BidiReadObjectResponse>
bidiReadObjectSettings() {
return bidiReadObjectSettings;
}

/** Returns the builder for the settings used for calls to updateObject. */
public UnaryCallSettings.Builder<UpdateObjectRequest, Object> updateObjectSettings() {
return updateObjectSettings;
Expand Down
Loading

0 comments on commit d9c4bf6

Please sign in to comment.