google-cloud-functions
diff --git a/google-cloud-functions/src/main/java/com/google/cloud/functions/v1/CloudFunctionsServiceClient.java b/google-cloud-functions/src/main/java/com/google/cloud/functions/v1/CloudFunctionsServiceClient.java
index 9e285fa7..1c1e3a15 100644
--- a/google-cloud-functions/src/main/java/com/google/cloud/functions/v1/CloudFunctionsServiceClient.java
+++ b/google-cloud-functions/src/main/java/com/google/cloud/functions/v1/CloudFunctionsServiceClient.java
@@ -239,6 +239,12 @@ public final ListFunctionsPagedResponse listFunctions(ListFunctionsRequest reque
* {@code
* try (CloudFunctionsServiceClient cloudFunctionsServiceClient =
* CloudFunctionsServiceClient.create()) {
+ * ListFunctionsRequest request =
+ * ListFunctionsRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
* while (true) {
* ListFunctionsResponse response =
* cloudFunctionsServiceClient.listFunctionsCallable().call(request);
diff --git a/google-cloud-functions/src/test/java/com/google/cloud/functions/v1/MockCloudFunctionsServiceImpl.java b/google-cloud-functions/src/test/java/com/google/cloud/functions/v1/MockCloudFunctionsServiceImpl.java
index 3a0df98d..8dbaa98a 100644
--- a/google-cloud-functions/src/test/java/com/google/cloud/functions/v1/MockCloudFunctionsServiceImpl.java
+++ b/google-cloud-functions/src/test/java/com/google/cloud/functions/v1/MockCloudFunctionsServiceImpl.java
@@ -67,7 +67,7 @@ public void reset() {
@Override
public void listFunctions(
ListFunctionsRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListFunctionsResponse) {
requests.add(request);
responseObserver.onNext(((ListFunctionsResponse) response));
@@ -79,7 +79,7 @@ public void listFunctions(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListFunctions, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListFunctionsResponse.class.getName(),
Exception.class.getName())));
}
@@ -88,7 +88,7 @@ public void listFunctions(
@Override
public void getFunction(
GetFunctionRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof CloudFunction) {
requests.add(request);
responseObserver.onNext(((CloudFunction) response));
@@ -100,7 +100,7 @@ public void getFunction(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetFunction, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
CloudFunction.class.getName(),
Exception.class.getName())));
}
@@ -109,7 +109,7 @@ public void getFunction(
@Override
public void createFunction(
CreateFunctionRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -121,7 +121,7 @@ public void createFunction(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateFunction, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -130,7 +130,7 @@ public void createFunction(
@Override
public void updateFunction(
UpdateFunctionRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -142,7 +142,7 @@ public void updateFunction(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateFunction, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -151,7 +151,7 @@ public void updateFunction(
@Override
public void deleteFunction(
DeleteFunctionRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -163,7 +163,7 @@ public void deleteFunction(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteFunction, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -172,7 +172,7 @@ public void deleteFunction(
@Override
public void callFunction(
CallFunctionRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof CallFunctionResponse) {
requests.add(request);
responseObserver.onNext(((CallFunctionResponse) response));
@@ -184,7 +184,7 @@ public void callFunction(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CallFunction, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
CallFunctionResponse.class.getName(),
Exception.class.getName())));
}
@@ -194,7 +194,7 @@ public void callFunction(
public void generateUploadUrl(
GenerateUploadUrlRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof GenerateUploadUrlResponse) {
requests.add(request);
responseObserver.onNext(((GenerateUploadUrlResponse) response));
@@ -206,7 +206,7 @@ public void generateUploadUrl(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GenerateUploadUrl, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
GenerateUploadUrlResponse.class.getName(),
Exception.class.getName())));
}
@@ -216,7 +216,7 @@ public void generateUploadUrl(
public void generateDownloadUrl(
GenerateDownloadUrlRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof GenerateDownloadUrlResponse) {
requests.add(request);
responseObserver.onNext(((GenerateDownloadUrlResponse) response));
@@ -228,7 +228,7 @@ public void generateDownloadUrl(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GenerateDownloadUrl, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
GenerateDownloadUrlResponse.class.getName(),
Exception.class.getName())));
}
@@ -236,7 +236,7 @@ public void generateDownloadUrl(
@Override
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -248,7 +248,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver 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())));
}
@@ -256,7 +256,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
@Override
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -268,7 +268,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver 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())));
}
@@ -278,7 +278,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
public void testIamPermissions(
TestIamPermissionsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TestIamPermissionsResponse) {
requests.add(request);
responseObserver.onNext(((TestIamPermissionsResponse) response));
@@ -290,7 +290,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())));
}
diff --git a/grpc-google-cloud-functions-v1/pom.xml b/grpc-google-cloud-functions-v1/pom.xml
index 1700a613..e22cd0ef 100644
--- a/grpc-google-cloud-functions-v1/pom.xml
+++ b/grpc-google-cloud-functions-v1/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
grpc-google-cloud-functions-v1
- 1.1.0
+ 1.1.1
grpc-google-cloud-functions-v1
GRPC library for grpc-google-cloud-functions-v1
com.google.cloud
google-cloud-functions-parent
- 1.1.0
+ 1.1.1
diff --git a/grpc-google-cloud-functions-v1/src/main/java/com/google/cloud/functions/v1/CloudFunctionsServiceGrpc.java b/grpc-google-cloud-functions-v1/src/main/java/com/google/cloud/functions/v1/CloudFunctionsServiceGrpc.java
index 82b16a58..5cbf85c4 100644
--- a/grpc-google-cloud-functions-v1/src/main/java/com/google/cloud/functions/v1/CloudFunctionsServiceGrpc.java
+++ b/grpc-google-cloud-functions-v1/src/main/java/com/google/cloud/functions/v1/CloudFunctionsServiceGrpc.java
@@ -16,11 +16,6 @@
package com.google.cloud.functions.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;
/**
*
@@ -591,7 +586,8 @@ public void listFunctions(
com.google.cloud.functions.v1.ListFunctionsRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnimplementedUnaryCall(getListFunctionsMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getListFunctionsMethod(), responseObserver);
}
/**
@@ -604,7 +600,8 @@ public void listFunctions(
public void getFunction(
com.google.cloud.functions.v1.GetFunctionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnimplementedUnaryCall(getGetFunctionMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getGetFunctionMethod(), responseObserver);
}
/**
@@ -619,7 +616,8 @@ public void getFunction(
public void createFunction(
com.google.cloud.functions.v1.CreateFunctionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnimplementedUnaryCall(getCreateFunctionMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getCreateFunctionMethod(), responseObserver);
}
/**
@@ -632,7 +630,8 @@ public void createFunction(
public void updateFunction(
com.google.cloud.functions.v1.UpdateFunctionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnimplementedUnaryCall(getUpdateFunctionMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getUpdateFunctionMethod(), responseObserver);
}
/**
@@ -647,7 +646,8 @@ public void updateFunction(
public void deleteFunction(
com.google.cloud.functions.v1.DeleteFunctionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnimplementedUnaryCall(getDeleteFunctionMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getDeleteFunctionMethod(), responseObserver);
}
/**
@@ -664,7 +664,8 @@ public void callFunction(
com.google.cloud.functions.v1.CallFunctionRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnimplementedUnaryCall(getCallFunctionMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getCallFunctionMethod(), responseObserver);
}
/**
@@ -696,7 +697,8 @@ public void generateUploadUrl(
com.google.cloud.functions.v1.GenerateUploadUrlRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnimplementedUnaryCall(getGenerateUploadUrlMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getGenerateUploadUrlMethod(), responseObserver);
}
/**
@@ -714,7 +716,8 @@ public void generateDownloadUrl(
com.google.cloud.functions.v1.GenerateDownloadUrlRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnimplementedUnaryCall(getGenerateDownloadUrlMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getGenerateDownloadUrlMethod(), responseObserver);
}
/**
@@ -728,7 +731,8 @@ public void generateDownloadUrl(
public void setIamPolicy(
com.google.iam.v1.SetIamPolicyRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnimplementedUnaryCall(getSetIamPolicyMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getSetIamPolicyMethod(), responseObserver);
}
/**
@@ -743,7 +747,8 @@ public void setIamPolicy(
public void getIamPolicy(
com.google.iam.v1.GetIamPolicyRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnimplementedUnaryCall(getGetIamPolicyMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getGetIamPolicyMethod(), responseObserver);
}
/**
@@ -760,7 +765,8 @@ public void testIamPermissions(
com.google.iam.v1.TestIamPermissionsRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnimplementedUnaryCall(getTestIamPermissionsMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
+ getTestIamPermissionsMethod(), responseObserver);
}
@java.lang.Override
@@ -768,71 +774,71 @@ public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getListFunctionsMethod(),
- asyncUnaryCall(
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.functions.v1.ListFunctionsRequest,
com.google.cloud.functions.v1.ListFunctionsResponse>(
this, METHODID_LIST_FUNCTIONS)))
.addMethod(
getGetFunctionMethod(),
- asyncUnaryCall(
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.functions.v1.GetFunctionRequest,
com.google.cloud.functions.v1.CloudFunction>(this, METHODID_GET_FUNCTION)))
.addMethod(
getCreateFunctionMethod(),
- asyncUnaryCall(
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.functions.v1.CreateFunctionRequest,
com.google.longrunning.Operation>(this, METHODID_CREATE_FUNCTION)))
.addMethod(
getUpdateFunctionMethod(),
- asyncUnaryCall(
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.functions.v1.UpdateFunctionRequest,
com.google.longrunning.Operation>(this, METHODID_UPDATE_FUNCTION)))
.addMethod(
getDeleteFunctionMethod(),
- asyncUnaryCall(
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.functions.v1.DeleteFunctionRequest,
com.google.longrunning.Operation>(this, METHODID_DELETE_FUNCTION)))
.addMethod(
getCallFunctionMethod(),
- asyncUnaryCall(
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.functions.v1.CallFunctionRequest,
com.google.cloud.functions.v1.CallFunctionResponse>(
this, METHODID_CALL_FUNCTION)))
.addMethod(
getGenerateUploadUrlMethod(),
- asyncUnaryCall(
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.functions.v1.GenerateUploadUrlRequest,
com.google.cloud.functions.v1.GenerateUploadUrlResponse>(
this, METHODID_GENERATE_UPLOAD_URL)))
.addMethod(
getGenerateDownloadUrlMethod(),
- asyncUnaryCall(
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.functions.v1.GenerateDownloadUrlRequest,
com.google.cloud.functions.v1.GenerateDownloadUrlResponse>(
this, METHODID_GENERATE_DOWNLOAD_URL)))
.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>(
@@ -871,7 +877,7 @@ public void listFunctions(
com.google.cloud.functions.v1.ListFunctionsRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getListFunctionsMethod(), getCallOptions()),
request,
responseObserver);
@@ -887,7 +893,7 @@ public void listFunctions(
public void getFunction(
com.google.cloud.functions.v1.GetFunctionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGetFunctionMethod(), getCallOptions()),
request,
responseObserver);
@@ -905,7 +911,7 @@ public void getFunction(
public void createFunction(
com.google.cloud.functions.v1.CreateFunctionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getCreateFunctionMethod(), getCallOptions()),
request,
responseObserver);
@@ -921,7 +927,7 @@ public void createFunction(
public void updateFunction(
com.google.cloud.functions.v1.UpdateFunctionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getUpdateFunctionMethod(), getCallOptions()),
request,
responseObserver);
@@ -939,7 +945,7 @@ public void updateFunction(
public void deleteFunction(
com.google.cloud.functions.v1.DeleteFunctionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getDeleteFunctionMethod(), getCallOptions()),
request,
responseObserver);
@@ -959,7 +965,7 @@ public void callFunction(
com.google.cloud.functions.v1.CallFunctionRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getCallFunctionMethod(), getCallOptions()),
request,
responseObserver);
@@ -994,7 +1000,7 @@ public void generateUploadUrl(
com.google.cloud.functions.v1.GenerateUploadUrlRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGenerateUploadUrlMethod(), getCallOptions()),
request,
responseObserver);
@@ -1015,7 +1021,7 @@ public void generateDownloadUrl(
com.google.cloud.functions.v1.GenerateDownloadUrlRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGenerateDownloadUrlMethod(), getCallOptions()),
request,
responseObserver);
@@ -1032,7 +1038,7 @@ public void generateDownloadUrl(
public void setIamPolicy(
com.google.iam.v1.SetIamPolicyRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()),
request,
responseObserver);
@@ -1050,7 +1056,7 @@ public void setIamPolicy(
public void getIamPolicy(
com.google.iam.v1.GetIamPolicyRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()),
request,
responseObserver);
@@ -1070,7 +1076,7 @@ public void testIamPermissions(
com.google.iam.v1.TestIamPermissionsRequest request,
io.grpc.stub.StreamObserver
responseObserver) {
- asyncUnaryCall(
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()),
request,
responseObserver);
@@ -1106,7 +1112,8 @@ protected CloudFunctionsServiceBlockingStub build(
*/
public com.google.cloud.functions.v1.ListFunctionsResponse listFunctions(
com.google.cloud.functions.v1.ListFunctionsRequest request) {
- return blockingUnaryCall(getChannel(), getListFunctionsMethod(), getCallOptions(), request);
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListFunctionsMethod(), getCallOptions(), request);
}
/**
@@ -1118,7 +1125,8 @@ public com.google.cloud.functions.v1.ListFunctionsResponse listFunctions(
*/
public com.google.cloud.functions.v1.CloudFunction getFunction(
com.google.cloud.functions.v1.GetFunctionRequest request) {
- return blockingUnaryCall(getChannel(), getGetFunctionMethod(), getCallOptions(), request);
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetFunctionMethod(), getCallOptions(), request);
}
/**
@@ -1132,7 +1140,8 @@ public com.google.cloud.functions.v1.CloudFunction getFunction(
*/
public com.google.longrunning.Operation createFunction(
com.google.cloud.functions.v1.CreateFunctionRequest request) {
- return blockingUnaryCall(getChannel(), getCreateFunctionMethod(), getCallOptions(), request);
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateFunctionMethod(), getCallOptions(), request);
}
/**
@@ -1144,7 +1153,8 @@ public com.google.longrunning.Operation createFunction(
*/
public com.google.longrunning.Operation updateFunction(
com.google.cloud.functions.v1.UpdateFunctionRequest request) {
- return blockingUnaryCall(getChannel(), getUpdateFunctionMethod(), getCallOptions(), request);
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getUpdateFunctionMethod(), getCallOptions(), request);
}
/**
@@ -1158,7 +1168,8 @@ public com.google.longrunning.Operation updateFunction(
*/
public com.google.longrunning.Operation deleteFunction(
com.google.cloud.functions.v1.DeleteFunctionRequest request) {
- return blockingUnaryCall(getChannel(), getDeleteFunctionMethod(), getCallOptions(), request);
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteFunctionMethod(), getCallOptions(), request);
}
/**
@@ -1173,7 +1184,8 @@ public com.google.longrunning.Operation deleteFunction(
*/
public com.google.cloud.functions.v1.CallFunctionResponse callFunction(
com.google.cloud.functions.v1.CallFunctionRequest request) {
- return blockingUnaryCall(getChannel(), getCallFunctionMethod(), getCallOptions(), request);
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCallFunctionMethod(), getCallOptions(), request);
}
/**
@@ -1203,7 +1215,7 @@ public com.google.cloud.functions.v1.CallFunctionResponse callFunction(
*/
public com.google.cloud.functions.v1.GenerateUploadUrlResponse generateUploadUrl(
com.google.cloud.functions.v1.GenerateUploadUrlRequest request) {
- return blockingUnaryCall(
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGenerateUploadUrlMethod(), getCallOptions(), request);
}
@@ -1220,7 +1232,7 @@ public com.google.cloud.functions.v1.GenerateUploadUrlResponse generateUploadUrl
*/
public com.google.cloud.functions.v1.GenerateDownloadUrlResponse generateDownloadUrl(
com.google.cloud.functions.v1.GenerateDownloadUrlRequest request) {
- return blockingUnaryCall(
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGenerateDownloadUrlMethod(), getCallOptions(), request);
}
@@ -1233,7 +1245,8 @@ public com.google.cloud.functions.v1.GenerateDownloadUrlResponse generateDownloa
*
*/
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);
}
/**
@@ -1246,7 +1259,8 @@ public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyReque
*
*/
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);
}
/**
@@ -1261,7 +1275,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);
}
}
@@ -1296,7 +1310,7 @@ protected CloudFunctionsServiceFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.functions.v1.ListFunctionsResponse>
listFunctions(com.google.cloud.functions.v1.ListFunctionsRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListFunctionsMethod(), getCallOptions()), request);
}
@@ -1310,7 +1324,7 @@ protected CloudFunctionsServiceFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.functions.v1.CloudFunction>
getFunction(com.google.cloud.functions.v1.GetFunctionRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetFunctionMethod(), getCallOptions()), request);
}
@@ -1325,7 +1339,7 @@ protected CloudFunctionsServiceFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture
createFunction(com.google.cloud.functions.v1.CreateFunctionRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateFunctionMethod(), getCallOptions()), request);
}
@@ -1338,7 +1352,7 @@ protected CloudFunctionsServiceFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture
updateFunction(com.google.cloud.functions.v1.UpdateFunctionRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateFunctionMethod(), getCallOptions()), request);
}
@@ -1353,7 +1367,7 @@ protected CloudFunctionsServiceFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture
deleteFunction(com.google.cloud.functions.v1.DeleteFunctionRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteFunctionMethod(), getCallOptions()), request);
}
@@ -1370,7 +1384,7 @@ protected CloudFunctionsServiceFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.functions.v1.CallFunctionResponse>
callFunction(com.google.cloud.functions.v1.CallFunctionRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCallFunctionMethod(), getCallOptions()), request);
}
@@ -1402,7 +1416,7 @@ protected CloudFunctionsServiceFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.functions.v1.GenerateUploadUrlResponse>
generateUploadUrl(com.google.cloud.functions.v1.GenerateUploadUrlRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGenerateUploadUrlMethod(), getCallOptions()), request);
}
@@ -1420,7 +1434,7 @@ protected CloudFunctionsServiceFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.functions.v1.GenerateDownloadUrlResponse>
generateDownloadUrl(com.google.cloud.functions.v1.GenerateDownloadUrlRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGenerateDownloadUrlMethod(), getCallOptions()), request);
}
@@ -1434,7 +1448,7 @@ protected CloudFunctionsServiceFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture
setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()), request);
}
@@ -1449,7 +1463,7 @@ protected CloudFunctionsServiceFutureStub build(
*/
public com.google.common.util.concurrent.ListenableFuture
getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
- return futureUnaryCall(
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()), request);
}
@@ -1466,7 +1480,7 @@ protected CloudFunctionsServiceFutureStub 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);
}
}
diff --git a/pom.xml b/pom.xml
index dbed17ad..89fba7a0 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
com.google.cloud
google-cloud-functions-parent
pom
- 1.1.0
+ 1.1.1
Google Cloud Functions Parent
https://github.com/googleapis/java-functions
@@ -70,23 +70,23 @@
com.google.cloud
google-cloud-functions
- 1.1.0
+ 1.1.1
com.google.api.grpc
proto-google-cloud-functions-v1
- 1.1.0
+ 1.1.1
com.google.api.grpc
grpc-google-cloud-functions-v1
- 1.1.0
+ 1.1.1
com.google.cloud
google-cloud-shared-dependencies
- 0.20.1
+ 0.21.0
pom
import
diff --git a/proto-google-cloud-functions-v1/pom.xml b/proto-google-cloud-functions-v1/pom.xml
index 829a03c0..56b61e54 100644
--- a/proto-google-cloud-functions-v1/pom.xml
+++ b/proto-google-cloud-functions-v1/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
proto-google-cloud-functions-v1
- 1.1.0
+ 1.1.1
proto-google-cloud-functions-v1
PROTO library for proto-google-cloud-functions-v1
com.google.cloud
google-cloud-functions-parent
- 1.1.0
+ 1.1.1
diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml
index b7e74a4e..0be8c1c8 100644
--- a/samples/install-without-bom/pom.xml
+++ b/samples/install-without-bom/pom.xml
@@ -14,7 +14,7 @@
com.google.cloud.samples
shared-configuration
- 1.0.21
+ 1.0.22
@@ -29,7 +29,7 @@
com.google.cloud
google-cloud-functions
- 1.0.8
+ 1.1.0
diff --git a/samples/pom.xml b/samples/pom.xml
index 5d282d5d..edade2a1 100644
--- a/samples/pom.xml
+++ b/samples/pom.xml
@@ -18,7 +18,7 @@
com.google.cloud.samples
shared-configuration
- 1.0.21
+ 1.0.22
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index 0336006c..193849ff 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -14,7 +14,7 @@
com.google.cloud.samples
shared-configuration
- 1.0.21
+ 1.0.22
@@ -28,7 +28,7 @@
com.google.cloud
google-cloud-functions
- 1.0.8
+ 1.1.0
diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml
index e2791414..451b5a3d 100644
--- a/samples/snippets/pom.xml
+++ b/samples/snippets/pom.xml
@@ -14,7 +14,7 @@
com.google.cloud.samples
shared-configuration
- 1.0.21
+ 1.0.22
@@ -28,7 +28,7 @@
com.google.cloud
google-cloud-functions
- 1.0.8
+ 1.1.0
diff --git a/synth.metadata b/synth.metadata
index 2dfed99f..a4596497 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,22 +4,22 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-functions.git",
- "sha": "6c4280fc4ca080c2992be1401df151560fc6c593"
+ "sha": "1357e53d05acc3bac671ecee92a7bddd801f6e19"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "3befd26ca55723d3e8111909331eac1249837987",
- "internalRef": "360805639"
+ "sha": "1305ca41d554eb0725237561e34129373bb8cbc1",
+ "internalRef": "362856902"
}
},
{
"git": {
"name": "synthtool",
"remote": "https://github.com/googleapis/synthtool.git",
- "sha": "0b064d767537e0675fc053e53fca473c5c701fb8"
+ "sha": "572ef8f70edd9041f5bcfa71511aed6aecfc2098"
}
}
],
diff --git a/versions.txt b/versions.txt
index 4724abe7..8f9c1505 100644
--- a/versions.txt
+++ b/versions.txt
@@ -1,6 +1,6 @@
# Format:
# module:released-version:current-version
-google-cloud-functions:1.1.0:1.1.0
-proto-google-cloud-functions-v1:1.1.0:1.1.0
-grpc-google-cloud-functions-v1:1.1.0:1.1.0
+google-cloud-functions:1.1.1:1.1.1
+proto-google-cloud-functions-v1:1.1.1:1.1.1
+grpc-google-cloud-functions-v1:1.1.1:1.1.1