Skip to content
This repository was archived by the owner on Sep 16, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ public void reset() {

@Override
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
Expand All @@ -79,15 +79,15 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
}

@Override
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
Expand All @@ -99,7 +99,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
Expand All @@ -109,7 +109,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> res
public void testIamPermissions(
TestIamPermissionsRequest request,
StreamObserver<TestIamPermissionsResponse> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof TestIamPermissionsResponse) {
requests.add(request);
responseObserver.onNext(((TestIamPermissionsResponse) response));
Expand All @@ -121,7 +121,7 @@ public void testIamPermissions(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
TestIamPermissionsResponse.class.getName(),
Exception.class.getName())));
}
Expand All @@ -131,7 +131,7 @@ public void testIamPermissions(
public void getVulnerabilityOccurrencesSummary(
GetVulnerabilityOccurrencesSummaryRequest request,
StreamObserver<VulnerabilityOccurrencesSummary> responseObserver) {
Object response = responses.remove();
Object response = responses.poll();
if (response instanceof VulnerabilityOccurrencesSummary) {
requests.add(request);
responseObserver.onNext(((VulnerabilityOccurrencesSummary) response));
Expand All @@ -143,7 +143,7 @@ public void getVulnerabilityOccurrencesSummary(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetVulnerabilityOccurrencesSummary, expected %s or %s",
response.getClass().getName(),
response == null ? "null" : response.getClass().getName(),
VulnerabilityOccurrencesSummary.class.getName(),
Exception.class.getName())));
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,6 @@
package com.google.containeranalysis.v1;

import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ClientCalls.asyncUnaryCall;
import static io.grpc.stub.ClientCalls.blockingUnaryCall;
import static io.grpc.stub.ClientCalls.futureUnaryCall;
import static io.grpc.stub.ServerCalls.asyncUnaryCall;
import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;

/**
*
Expand Down Expand Up @@ -302,7 +297,8 @@ public abstract static class ContainerAnalysisImplBase implements io.grpc.Bindab
public void setIamPolicy(
com.google.iam.v1.SetIamPolicyRequest request,
io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) {
asyncUnimplementedUnaryCall(getSetIamPolicyMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getSetIamPolicyMethod(), responseObserver);
}

/**
Expand All @@ -321,7 +317,8 @@ public void setIamPolicy(
public void getIamPolicy(
com.google.iam.v1.GetIamPolicyRequest request,
io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) {
asyncUnimplementedUnaryCall(getGetIamPolicyMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getGetIamPolicyMethod(), responseObserver);
}

/**
Expand All @@ -340,7 +337,8 @@ public void testIamPermissions(
com.google.iam.v1.TestIamPermissionsRequest request,
io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse>
responseObserver) {
asyncUnimplementedUnaryCall(getTestIamPermissionsMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getTestIamPermissionsMethod(), responseObserver);
}

/**
Expand All @@ -354,34 +352,35 @@ public void getVulnerabilityOccurrencesSummary(
com.google.containeranalysis.v1.GetVulnerabilityOccurrencesSummaryRequest request,
io.grpc.stub.StreamObserver<com.google.containeranalysis.v1.VulnerabilityOccurrencesSummary>
responseObserver) {
asyncUnimplementedUnaryCall(getGetVulnerabilityOccurrencesSummaryMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getGetVulnerabilityOccurrencesSummaryMethod(), responseObserver);
}

@java.lang.Override
public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getSetIamPolicyMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy>(
this, METHODID_SET_IAM_POLICY)))
.addMethod(
getGetIamPolicyMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy>(
this, METHODID_GET_IAM_POLICY)))
.addMethod(
getTestIamPermissionsMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v1.TestIamPermissionsRequest,
com.google.iam.v1.TestIamPermissionsResponse>(
this, METHODID_TEST_IAM_PERMISSIONS)))
.addMethod(
getGetVulnerabilityOccurrencesSummaryMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.containeranalysis.v1.GetVulnerabilityOccurrencesSummaryRequest,
com.google.containeranalysis.v1.VulnerabilityOccurrencesSummary>(
Expand Down Expand Up @@ -435,7 +434,7 @@ protected ContainerAnalysisStub build(
public void setIamPolicy(
com.google.iam.v1.SetIamPolicyRequest request,
io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -457,7 +456,7 @@ public void setIamPolicy(
public void getIamPolicy(
com.google.iam.v1.GetIamPolicyRequest request,
io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -479,7 +478,7 @@ public void testIamPermissions(
com.google.iam.v1.TestIamPermissionsRequest request,
io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -496,7 +495,7 @@ public void getVulnerabilityOccurrencesSummary(
com.google.containeranalysis.v1.GetVulnerabilityOccurrencesSummaryRequest request,
io.grpc.stub.StreamObserver<com.google.containeranalysis.v1.VulnerabilityOccurrencesSummary>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGetVulnerabilityOccurrencesSummaryMethod(), getCallOptions()),
request,
responseObserver);
Expand Down Expand Up @@ -547,7 +546,8 @@ protected ContainerAnalysisBlockingStub build(
* </pre>
*/
public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
return blockingUnaryCall(getChannel(), getSetIamPolicyMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetIamPolicyMethod(), getCallOptions(), request);
}

/**
Expand All @@ -564,7 +564,8 @@ public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyReque
* </pre>
*/
public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
return blockingUnaryCall(getChannel(), getGetIamPolicyMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetIamPolicyMethod(), getCallOptions(), request);
}

/**
Expand All @@ -581,7 +582,7 @@ public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyReque
*/
public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions(
com.google.iam.v1.TestIamPermissionsRequest request) {
return blockingUnaryCall(
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request);
}

Expand All @@ -595,7 +596,7 @@ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions(
public com.google.containeranalysis.v1.VulnerabilityOccurrencesSummary
getVulnerabilityOccurrencesSummary(
com.google.containeranalysis.v1.GetVulnerabilityOccurrencesSummaryRequest request) {
return blockingUnaryCall(
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetVulnerabilityOccurrencesSummaryMethod(), getCallOptions(), request);
}
}
Expand Down Expand Up @@ -644,7 +645,7 @@ protected ContainerAnalysisFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.iam.v1.Policy>
setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()), request);
}

Expand All @@ -663,7 +664,7 @@ protected ContainerAnalysisFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.iam.v1.Policy>
getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()), request);
}

Expand All @@ -682,7 +683,7 @@ protected ContainerAnalysisFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.iam.v1.TestIamPermissionsResponse>
testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()), request);
}

Expand All @@ -697,7 +698,7 @@ protected ContainerAnalysisFutureStub build(
com.google.containeranalysis.v1.VulnerabilityOccurrencesSummary>
getVulnerabilityOccurrencesSummary(
com.google.containeranalysis.v1.GetVulnerabilityOccurrencesSummaryRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetVulnerabilityOccurrencesSummaryMethod(), getCallOptions()),
request);
}
Expand Down
6 changes: 3 additions & 3 deletions synth.metadata
Original file line number Diff line number Diff line change
Expand Up @@ -4,15 +4,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-containeranalysis.git",
"sha": "ac77c884216856daa5f816e212c08ae5e83c5789"
"sha": "ea6c7da86428cab27fbb1f198dc32222956f4dc9"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
"sha": "3befd26ca55723d3e8111909331eac1249837987",
"internalRef": "360805639"
"sha": "1305ca41d554eb0725237561e34129373bb8cbc1",
"internalRef": "362856902"
}
},
{
Expand Down