{
+ private DeviceManagerBlockingStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private DeviceManagerBlockingStub(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected DeviceManagerBlockingStub build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ return new DeviceManagerBlockingStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Creates a device registry that contains devices.
+ *
+ */
+ public com.google.cloud.iot.v1.DeviceRegistry createDeviceRegistry(com.google.cloud.iot.v1.CreateDeviceRegistryRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCreateDeviceRegistryMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Gets a device registry configuration.
+ *
+ */
+ public com.google.cloud.iot.v1.DeviceRegistry getDeviceRegistry(com.google.cloud.iot.v1.GetDeviceRegistryRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetDeviceRegistryMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Updates a device registry configuration.
+ *
+ */
+ public com.google.cloud.iot.v1.DeviceRegistry updateDeviceRegistry(com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateDeviceRegistryMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Deletes a device registry configuration.
+ *
+ */
+ public com.google.protobuf.Empty deleteDeviceRegistry(com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getDeleteDeviceRegistryMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Lists device registries.
+ *
+ */
+ public com.google.cloud.iot.v1.ListDeviceRegistriesResponse listDeviceRegistries(com.google.cloud.iot.v1.ListDeviceRegistriesRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListDeviceRegistriesMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Creates a device in a device registry.
+ *
+ */
+ public com.google.cloud.iot.v1.Device createDevice(com.google.cloud.iot.v1.CreateDeviceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCreateDeviceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Gets details about a device.
+ *
+ */
+ public com.google.cloud.iot.v1.Device getDevice(com.google.cloud.iot.v1.GetDeviceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetDeviceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Updates a device.
+ *
+ */
+ public com.google.cloud.iot.v1.Device updateDevice(com.google.cloud.iot.v1.UpdateDeviceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateDeviceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Deletes a device.
+ *
+ */
+ public com.google.protobuf.Empty deleteDevice(com.google.cloud.iot.v1.DeleteDeviceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getDeleteDeviceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * List devices in a device registry.
+ *
+ */
+ public com.google.cloud.iot.v1.ListDevicesResponse listDevices(com.google.cloud.iot.v1.ListDevicesRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListDevicesMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Modifies the configuration for the device, which is eventually sent from
+ * the Cloud IoT Core servers. Returns the modified configuration version and
+ * its metadata.
+ *
+ */
+ public com.google.cloud.iot.v1.DeviceConfig modifyCloudToDeviceConfig(com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getModifyCloudToDeviceConfigMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Lists the last few versions of the device configuration in descending
+ * order (i.e.: newest first).
+ *
+ */
+ public com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse listDeviceConfigVersions(com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListDeviceConfigVersionsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Lists the last few versions of the device state in descending order (i.e.:
+ * newest first).
+ *
+ */
+ public com.google.cloud.iot.v1.ListDeviceStatesResponse listDeviceStates(com.google.cloud.iot.v1.ListDeviceStatesRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListDeviceStatesMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Sets the access control policy on the specified resource. Replaces any
+ * existing policy.
+ *
+ */
+ public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getSetIamPolicyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Gets the access control policy for a resource.
+ * Returns an empty policy if the resource exists and does not have a policy
+ * set.
+ *
+ */
+ public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetIamPolicyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Returns permissions that a caller has on the specified resource.
+ * If the resource does not exist, this will return an empty set of
+ * permissions, not a NOT_FOUND error.
+ *
+ */
+ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getTestIamPermissionsMethodHelper(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ *
+ * Internet of things (IoT) service. Allows to manipulate device registry
+ * instances and the registration of devices (Things) to the cloud.
+ *
+ */
+ public static final class DeviceManagerFutureStub extends io.grpc.stub.AbstractStub {
+ private DeviceManagerFutureStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private DeviceManagerFutureStub(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected DeviceManagerFutureStub build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ return new DeviceManagerFutureStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Creates a device registry that contains devices.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture createDeviceRegistry(
+ com.google.cloud.iot.v1.CreateDeviceRegistryRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCreateDeviceRegistryMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Gets a device registry configuration.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getDeviceRegistry(
+ com.google.cloud.iot.v1.GetDeviceRegistryRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetDeviceRegistryMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Updates a device registry configuration.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture updateDeviceRegistry(
+ com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateDeviceRegistryMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Deletes a device registry configuration.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture deleteDeviceRegistry(
+ com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getDeleteDeviceRegistryMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Lists device registries.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture listDeviceRegistries(
+ com.google.cloud.iot.v1.ListDeviceRegistriesRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListDeviceRegistriesMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Creates a device in a device registry.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture createDevice(
+ com.google.cloud.iot.v1.CreateDeviceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCreateDeviceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Gets details about a device.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getDevice(
+ com.google.cloud.iot.v1.GetDeviceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetDeviceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Updates a device.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture updateDevice(
+ com.google.cloud.iot.v1.UpdateDeviceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateDeviceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Deletes a device.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture deleteDevice(
+ com.google.cloud.iot.v1.DeleteDeviceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getDeleteDeviceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * List devices in a device registry.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture listDevices(
+ com.google.cloud.iot.v1.ListDevicesRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListDevicesMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Modifies the configuration for the device, which is eventually sent from
+ * the Cloud IoT Core servers. Returns the modified configuration version and
+ * its metadata.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture modifyCloudToDeviceConfig(
+ com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getModifyCloudToDeviceConfigMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Lists the last few versions of the device configuration in descending
+ * order (i.e.: newest first).
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture listDeviceConfigVersions(
+ com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListDeviceConfigVersionsMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Lists the last few versions of the device state in descending order (i.e.:
+ * newest first).
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture listDeviceStates(
+ com.google.cloud.iot.v1.ListDeviceStatesRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListDeviceStatesMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Sets the access control policy on the specified resource. Replaces any
+ * existing policy.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture setIamPolicy(
+ com.google.iam.v1.SetIamPolicyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getSetIamPolicyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Gets the access control policy for a resource.
+ * Returns an empty policy if the resource exists and does not have a policy
+ * set.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getIamPolicy(
+ com.google.iam.v1.GetIamPolicyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetIamPolicyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Returns permissions that a caller has on the specified resource.
+ * If the resource does not exist, this will return an empty set of
+ * permissions, not a NOT_FOUND error.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture testIamPermissions(
+ com.google.iam.v1.TestIamPermissionsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getTestIamPermissionsMethodHelper(), getCallOptions()), request);
+ }
+ }
+
+ private static final int METHODID_CREATE_DEVICE_REGISTRY = 0;
+ private static final int METHODID_GET_DEVICE_REGISTRY = 1;
+ private static final int METHODID_UPDATE_DEVICE_REGISTRY = 2;
+ private static final int METHODID_DELETE_DEVICE_REGISTRY = 3;
+ private static final int METHODID_LIST_DEVICE_REGISTRIES = 4;
+ private static final int METHODID_CREATE_DEVICE = 5;
+ private static final int METHODID_GET_DEVICE = 6;
+ private static final int METHODID_UPDATE_DEVICE = 7;
+ private static final int METHODID_DELETE_DEVICE = 8;
+ private static final int METHODID_LIST_DEVICES = 9;
+ private static final int METHODID_MODIFY_CLOUD_TO_DEVICE_CONFIG = 10;
+ private static final int METHODID_LIST_DEVICE_CONFIG_VERSIONS = 11;
+ private static final int METHODID_LIST_DEVICE_STATES = 12;
+ private static final int METHODID_SET_IAM_POLICY = 13;
+ private static final int METHODID_GET_IAM_POLICY = 14;
+ private static final int METHODID_TEST_IAM_PERMISSIONS = 15;
+
+ 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 DeviceManagerImplBase serviceImpl;
+ private final int methodId;
+
+ MethodHandlers(DeviceManagerImplBase 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_CREATE_DEVICE_REGISTRY:
+ serviceImpl.createDeviceRegistry((com.google.cloud.iot.v1.CreateDeviceRegistryRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_DEVICE_REGISTRY:
+ serviceImpl.getDeviceRegistry((com.google.cloud.iot.v1.GetDeviceRegistryRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_UPDATE_DEVICE_REGISTRY:
+ serviceImpl.updateDeviceRegistry((com.google.cloud.iot.v1.UpdateDeviceRegistryRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_DELETE_DEVICE_REGISTRY:
+ serviceImpl.deleteDeviceRegistry((com.google.cloud.iot.v1.DeleteDeviceRegistryRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_LIST_DEVICE_REGISTRIES:
+ serviceImpl.listDeviceRegistries((com.google.cloud.iot.v1.ListDeviceRegistriesRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_CREATE_DEVICE:
+ serviceImpl.createDevice((com.google.cloud.iot.v1.CreateDeviceRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_DEVICE:
+ serviceImpl.getDevice((com.google.cloud.iot.v1.GetDeviceRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_UPDATE_DEVICE:
+ serviceImpl.updateDevice((com.google.cloud.iot.v1.UpdateDeviceRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_DELETE_DEVICE:
+ serviceImpl.deleteDevice((com.google.cloud.iot.v1.DeleteDeviceRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_LIST_DEVICES:
+ serviceImpl.listDevices((com.google.cloud.iot.v1.ListDevicesRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_MODIFY_CLOUD_TO_DEVICE_CONFIG:
+ serviceImpl.modifyCloudToDeviceConfig((com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_LIST_DEVICE_CONFIG_VERSIONS:
+ serviceImpl.listDeviceConfigVersions((com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_LIST_DEVICE_STATES:
+ serviceImpl.listDeviceStates((com.google.cloud.iot.v1.ListDeviceStatesRequest) 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_GET_IAM_POLICY:
+ serviceImpl.getIamPolicy((com.google.iam.v1.GetIamPolicyRequest) 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;
+ default:
+ throw new AssertionError();
+ }
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public io.grpc.stub.StreamObserver invoke(
+ io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ default:
+ throw new AssertionError();
+ }
+ }
+ }
+
+ private static abstract class DeviceManagerBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ DeviceManagerBaseDescriptorSupplier() {}
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
+ return com.google.cloud.iot.v1.DeviceManagerProto.getDescriptor();
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
+ return getFileDescriptor().findServiceByName("DeviceManager");
+ }
+ }
+
+ private static final class DeviceManagerFileDescriptorSupplier
+ extends DeviceManagerBaseDescriptorSupplier {
+ DeviceManagerFileDescriptorSupplier() {}
+ }
+
+ private static final class DeviceManagerMethodDescriptorSupplier
+ extends DeviceManagerBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
+ private final String methodName;
+
+ DeviceManagerMethodDescriptorSupplier(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 (DeviceManagerGrpc.class) {
+ result = serviceDescriptor;
+ if (result == null) {
+ serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new DeviceManagerFileDescriptorSupplier())
+ .addMethod(getCreateDeviceRegistryMethodHelper())
+ .addMethod(getGetDeviceRegistryMethodHelper())
+ .addMethod(getUpdateDeviceRegistryMethodHelper())
+ .addMethod(getDeleteDeviceRegistryMethodHelper())
+ .addMethod(getListDeviceRegistriesMethodHelper())
+ .addMethod(getCreateDeviceMethodHelper())
+ .addMethod(getGetDeviceMethodHelper())
+ .addMethod(getUpdateDeviceMethodHelper())
+ .addMethod(getDeleteDeviceMethodHelper())
+ .addMethod(getListDevicesMethodHelper())
+ .addMethod(getModifyCloudToDeviceConfigMethodHelper())
+ .addMethod(getListDeviceConfigVersionsMethodHelper())
+ .addMethod(getListDeviceStatesMethodHelper())
+ .addMethod(getSetIamPolicyMethodHelper())
+ .addMethod(getGetIamPolicyMethodHelper())
+ .addMethod(getTestIamPermissionsMethodHelper())
+ .build();
+ }
+ }
+ }
+ return result;
+ }
+}
diff --git a/google-api-grpc/grpc-google-cloud-container-v1/pom.xml b/google-api-grpc/grpc-google-cloud-container-v1/pom.xml
index 7ac524e795d2..7f87f75e1434 100644
--- a/google-api-grpc/grpc-google-cloud-container-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-container-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-container-v1
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-container-v1
GRPC library for grpc-google-cloud-container-v1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-dataproc-v1/pom.xml b/google-api-grpc/grpc-google-cloud-dataproc-v1/pom.xml
index aea05e8cc7ee..8202cd600ec6 100644
--- a/google-api-grpc/grpc-google-cloud-dataproc-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-dataproc-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-dataproc-v1
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-dataproc-v1
GRPC library for grpc-google-cloud-dataproc-v1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-dialogflow-v2/pom.xml b/google-api-grpc/grpc-google-cloud-dialogflow-v2/pom.xml
index b0625f760fec..669a6fcd94a3 100644
--- a/google-api-grpc/grpc-google-cloud-dialogflow-v2/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-dialogflow-v2/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-dialogflow-v2
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-dialogflow-v2
GRPC library for grpc-google-cloud-dialogflow-v2
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-dialogflow-v2beta1/pom.xml b/google-api-grpc/grpc-google-cloud-dialogflow-v2beta1/pom.xml
index 88dfae11c59f..f46bac9d841a 100644
--- a/google-api-grpc/grpc-google-cloud-dialogflow-v2beta1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-dialogflow-v2beta1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-dialogflow-v2beta1
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-dialogflow-v2beta1
GRPC library for grpc-google-cloud-dialogflow-v2beta1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-dlp-v2/pom.xml b/google-api-grpc/grpc-google-cloud-dlp-v2/pom.xml
index 6877524734fd..f8e96658fa02 100644
--- a/google-api-grpc/grpc-google-cloud-dlp-v2/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-dlp-v2/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-dlp-v2
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-dlp-v2
GRPC library for grpc-google-cloud-dlp-v2
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-dlp-v2beta1/pom.xml b/google-api-grpc/grpc-google-cloud-dlp-v2beta1/pom.xml
index 003ca8d70f19..c5d0689e585b 100644
--- a/google-api-grpc/grpc-google-cloud-dlp-v2beta1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-dlp-v2beta1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-dlp-v2beta1
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-dlp-v2beta1
GRPC library for grpc-google-cloud-dlp-v2beta1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-error-reporting-v1beta1/pom.xml b/google-api-grpc/grpc-google-cloud-error-reporting-v1beta1/pom.xml
index 348a214f6b0e..33d136008180 100644
--- a/google-api-grpc/grpc-google-cloud-error-reporting-v1beta1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-error-reporting-v1beta1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-error-reporting-v1beta1
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-error-reporting-v1beta1
GRPC library for grpc-google-cloud-error-reporting-v1beta1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-firestore-v1beta1/pom.xml b/google-api-grpc/grpc-google-cloud-firestore-v1beta1/pom.xml
index 26bd6a9a8cc9..6f14092bd6f3 100644
--- a/google-api-grpc/grpc-google-cloud-firestore-v1beta1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-firestore-v1beta1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-firestore-v1beta1
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-firestore-v1beta1
GRPC library for grpc-google-cloud-firestore-v1beta1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-language-v1/pom.xml b/google-api-grpc/grpc-google-cloud-language-v1/pom.xml
index a13363a36fd3..d7c28cb01ef3 100644
--- a/google-api-grpc/grpc-google-cloud-language-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-language-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-language-v1
- 1.10.1-SNAPSHOT
+ 1.11.1-SNAPSHOT
grpc-google-cloud-language-v1
GRPC library for grpc-google-cloud-language-v1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-language-v1beta2/pom.xml b/google-api-grpc/grpc-google-cloud-language-v1beta2/pom.xml
index aa61710bbe54..bb743ac126fc 100644
--- a/google-api-grpc/grpc-google-cloud-language-v1beta2/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-language-v1beta2/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-language-v1beta2
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-language-v1beta2
GRPC library for grpc-google-cloud-language-v1beta2
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-logging-v2/pom.xml b/google-api-grpc/grpc-google-cloud-logging-v2/pom.xml
index e32bf29feb65..60d659911329 100644
--- a/google-api-grpc/grpc-google-cloud-logging-v2/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-logging-v2/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-logging-v2
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-logging-v2
GRPC library for grpc-google-cloud-logging-v2
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-monitoring-v3/pom.xml b/google-api-grpc/grpc-google-cloud-monitoring-v3/pom.xml
index 252e35c022d2..d4dc516d79bb 100644
--- a/google-api-grpc/grpc-google-cloud-monitoring-v3/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-monitoring-v3/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-monitoring-v3
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-monitoring-v3
GRPC library for grpc-google-cloud-monitoring-v3
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-os-login-v1/pom.xml b/google-api-grpc/grpc-google-cloud-os-login-v1/pom.xml
index 43be6d99e941..194d396f2b90 100644
--- a/google-api-grpc/grpc-google-cloud-os-login-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-os-login-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-os-login-v1
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-os-login-v1
GRPC library for grpc-google-cloud-os-login-v1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-pubsub-v1/pom.xml b/google-api-grpc/grpc-google-cloud-pubsub-v1/pom.xml
index 59b104028970..6f254b8449a7 100644
--- a/google-api-grpc/grpc-google-cloud-pubsub-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-pubsub-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-pubsub-v1
- 0.11.1-SNAPSHOT
+ 0.12.1-SNAPSHOT
grpc-google-cloud-pubsub-v1
GRPC library for grpc-google-cloud-pubsub-v1
com.google.api.grpc
- google-api-grpc-pom
- 0.11.1-SNAPSHOT
+ google-api-grpc
+ 0.12.1-SNAPSHOT
diff --git a/google-api-grpc/grpc-google-cloud-redis-v1beta1/pom.xml b/google-api-grpc/grpc-google-cloud-redis-v1beta1/pom.xml
new file mode 100644
index 000000000000..dd0d57031dfb
--- /dev/null
+++ b/google-api-grpc/grpc-google-cloud-redis-v1beta1/pom.xml
@@ -0,0 +1,31 @@
+
+ 4.0.0
+ grpc-google-cloud-redis-v1beta1
+ 0.12.1-SNAPSHOT
+ grpc-google-cloud-redis-v1beta1
+ GRPC library for grpc-google-cloud-redis-v1beta1
+
+ com.google.api.grpc
+ google-api-grpc
+ 0.12.1-SNAPSHOT
+
+
+
+ io.grpc
+ grpc-stub
+ compile
+
+
+ io.grpc
+ grpc-protobuf
+ compile
+
+
+ com.google.api.grpc
+ proto-google-cloud-redis-v1beta1
+ compile
+
+
+
\ No newline at end of file
diff --git a/google-api-grpc/grpc-google-cloud-redis-v1beta1/src/main/java/com/google/cloud/redis/v1beta1/CloudRedisGrpc.java b/google-api-grpc/grpc-google-cloud-redis-v1beta1/src/main/java/com/google/cloud/redis/v1beta1/CloudRedisGrpc.java
new file mode 100644
index 000000000000..fad6f93de51f
--- /dev/null
+++ b/google-api-grpc/grpc-google-cloud-redis-v1beta1/src/main/java/com/google/cloud/redis/v1beta1/CloudRedisGrpc.java
@@ -0,0 +1,804 @@
+package com.google.cloud.redis.v1beta1;
+
+import static io.grpc.MethodDescriptor.generateFullMethodName;
+import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncUnaryCall;
+import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
+import static io.grpc.stub.ClientCalls.blockingUnaryCall;
+import static io.grpc.stub.ClientCalls.futureUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
+
+/**
+ *
+ * Configures and manages Cloud Memorystore for Redis instances
+ * Google Cloud Memorystore for Redis v1beta1
+ * The `redis.googleapis.com` service implements the Google Cloud Memorystore
+ * for Redis API and defines the following resource model for managing Redis
+ * instances:
+ * * The service works with a collection of cloud projects, named: `/projects/*`
+ * * Each project has a collection of available locations, named: `/locations/*`
+ * * Each location has a collection of Redis instances, named: `/instances/*`
+ * * As such, Redis instances are resources of the form:
+ * `/projects/{project_id}/locations/{location_id}/instances/{instance_id}`
+ * Note that location_id must be refering to a GCP `region`; for example:
+ * * `projects/redpepper-1290/locations/us-central1/instances/my-redis`
+ *
+ */
+@javax.annotation.Generated(
+ value = "by gRPC proto compiler (version 1.10.0)",
+ comments = "Source: google/cloud/redis/v1beta1/cloud_redis.proto")
+public final class CloudRedisGrpc {
+
+ private CloudRedisGrpc() {}
+
+ public static final String SERVICE_NAME = "google.cloud.redis.v1beta1.CloudRedis";
+
+ // Static method descriptors that strictly reflect the proto.
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getListInstancesMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_LIST_INSTANCES = getListInstancesMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getListInstancesMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getListInstancesMethod() {
+ return getListInstancesMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getListInstancesMethodHelper() {
+ io.grpc.MethodDescriptor getListInstancesMethod;
+ if ((getListInstancesMethod = CloudRedisGrpc.getListInstancesMethod) == null) {
+ synchronized (CloudRedisGrpc.class) {
+ if ((getListInstancesMethod = CloudRedisGrpc.getListInstancesMethod) == null) {
+ CloudRedisGrpc.getListInstancesMethod = getListInstancesMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.redis.v1beta1.CloudRedis", "ListInstances"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.redis.v1beta1.ListInstancesRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.redis.v1beta1.ListInstancesResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudRedisMethodDescriptorSupplier("ListInstances"))
+ .build();
+ }
+ }
+ }
+ return getListInstancesMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getGetInstanceMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_GET_INSTANCE = getGetInstanceMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getGetInstanceMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getGetInstanceMethod() {
+ return getGetInstanceMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getGetInstanceMethodHelper() {
+ io.grpc.MethodDescriptor getGetInstanceMethod;
+ if ((getGetInstanceMethod = CloudRedisGrpc.getGetInstanceMethod) == null) {
+ synchronized (CloudRedisGrpc.class) {
+ if ((getGetInstanceMethod = CloudRedisGrpc.getGetInstanceMethod) == null) {
+ CloudRedisGrpc.getGetInstanceMethod = getGetInstanceMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.redis.v1beta1.CloudRedis", "GetInstance"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.redis.v1beta1.GetInstanceRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.redis.v1beta1.Instance.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudRedisMethodDescriptorSupplier("GetInstance"))
+ .build();
+ }
+ }
+ }
+ return getGetInstanceMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getCreateInstanceMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_CREATE_INSTANCE = getCreateInstanceMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getCreateInstanceMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getCreateInstanceMethod() {
+ return getCreateInstanceMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getCreateInstanceMethodHelper() {
+ io.grpc.MethodDescriptor getCreateInstanceMethod;
+ if ((getCreateInstanceMethod = CloudRedisGrpc.getCreateInstanceMethod) == null) {
+ synchronized (CloudRedisGrpc.class) {
+ if ((getCreateInstanceMethod = CloudRedisGrpc.getCreateInstanceMethod) == null) {
+ CloudRedisGrpc.getCreateInstanceMethod = getCreateInstanceMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.redis.v1beta1.CloudRedis", "CreateInstance"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.redis.v1beta1.CreateInstanceRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudRedisMethodDescriptorSupplier("CreateInstance"))
+ .build();
+ }
+ }
+ }
+ return getCreateInstanceMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getUpdateInstanceMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_UPDATE_INSTANCE = getUpdateInstanceMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getUpdateInstanceMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getUpdateInstanceMethod() {
+ return getUpdateInstanceMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getUpdateInstanceMethodHelper() {
+ io.grpc.MethodDescriptor getUpdateInstanceMethod;
+ if ((getUpdateInstanceMethod = CloudRedisGrpc.getUpdateInstanceMethod) == null) {
+ synchronized (CloudRedisGrpc.class) {
+ if ((getUpdateInstanceMethod = CloudRedisGrpc.getUpdateInstanceMethod) == null) {
+ CloudRedisGrpc.getUpdateInstanceMethod = getUpdateInstanceMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.redis.v1beta1.CloudRedis", "UpdateInstance"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.redis.v1beta1.UpdateInstanceRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudRedisMethodDescriptorSupplier("UpdateInstance"))
+ .build();
+ }
+ }
+ }
+ return getUpdateInstanceMethod;
+ }
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getDeleteInstanceMethod()} instead.
+ public static final io.grpc.MethodDescriptor METHOD_DELETE_INSTANCE = getDeleteInstanceMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor getDeleteInstanceMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor getDeleteInstanceMethod() {
+ return getDeleteInstanceMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor getDeleteInstanceMethodHelper() {
+ io.grpc.MethodDescriptor getDeleteInstanceMethod;
+ if ((getDeleteInstanceMethod = CloudRedisGrpc.getDeleteInstanceMethod) == null) {
+ synchronized (CloudRedisGrpc.class) {
+ if ((getDeleteInstanceMethod = CloudRedisGrpc.getDeleteInstanceMethod) == null) {
+ CloudRedisGrpc.getDeleteInstanceMethod = getDeleteInstanceMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(
+ "google.cloud.redis.v1beta1.CloudRedis", "DeleteInstance"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.redis.v1beta1.DeleteInstanceRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.longrunning.Operation.getDefaultInstance()))
+ .setSchemaDescriptor(new CloudRedisMethodDescriptorSupplier("DeleteInstance"))
+ .build();
+ }
+ }
+ }
+ return getDeleteInstanceMethod;
+ }
+
+ /**
+ * Creates a new async stub that supports all call types for the service
+ */
+ public static CloudRedisStub newStub(io.grpc.Channel channel) {
+ return new CloudRedisStub(channel);
+ }
+
+ /**
+ * Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ */
+ public static CloudRedisBlockingStub newBlockingStub(
+ io.grpc.Channel channel) {
+ return new CloudRedisBlockingStub(channel);
+ }
+
+ /**
+ * Creates a new ListenableFuture-style stub that supports unary calls on the service
+ */
+ public static CloudRedisFutureStub newFutureStub(
+ io.grpc.Channel channel) {
+ return new CloudRedisFutureStub(channel);
+ }
+
+ /**
+ *
+ * Configures and manages Cloud Memorystore for Redis instances
+ * Google Cloud Memorystore for Redis v1beta1
+ * The `redis.googleapis.com` service implements the Google Cloud Memorystore
+ * for Redis API and defines the following resource model for managing Redis
+ * instances:
+ * * The service works with a collection of cloud projects, named: `/projects/*`
+ * * Each project has a collection of available locations, named: `/locations/*`
+ * * Each location has a collection of Redis instances, named: `/instances/*`
+ * * As such, Redis instances are resources of the form:
+ * `/projects/{project_id}/locations/{location_id}/instances/{instance_id}`
+ * Note that location_id must be refering to a GCP `region`; for example:
+ * * `projects/redpepper-1290/locations/us-central1/instances/my-redis`
+ *
+ */
+ public static abstract class CloudRedisImplBase implements io.grpc.BindableService {
+
+ /**
+ *
+ * Lists all Redis instances owned by a project in either the specified
+ * location (region) or all locations.
+ * The location should have the following format:
+ * * `projects/{project_id}/locations/{location_id}`
+ * If `location_id` is specified as `-` (wildcard), then all regions
+ * available to the project are queried, and the results are aggregated.
+ *
+ */
+ public void listInstances(com.google.cloud.redis.v1beta1.ListInstancesRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getListInstancesMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Gets the details of a specific Redis instance.
+ *
+ */
+ public void getInstance(com.google.cloud.redis.v1beta1.GetInstanceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getGetInstanceMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Creates a Redis instance based on the specified tier and memory size.
+ * By default, the instance is peered to the project's
+ * [default network](/compute/docs/networks-and-firewalls#networks).
+ * The creation is executed asynchronously and callers may check the returned
+ * operation to track its progress. Once the operation is completed the Redis
+ * instance will be fully functional. Completed longrunning.Operation will
+ * contain the new instance object in the response field.
+ * The returned operation is automatically deleted after a few hours, so there
+ * is no need to call DeleteOperation.
+ *
+ */
+ public void createInstance(com.google.cloud.redis.v1beta1.CreateInstanceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getCreateInstanceMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Updates the metadata and configuration of a specific Redis instance.
+ * Completed longrunning.Operation will contain the new instance object
+ * in the response field. The returned operation is automatically deleted
+ * after a few hours, so there is no need to call DeleteOperation.
+ *
+ */
+ public void updateInstance(com.google.cloud.redis.v1beta1.UpdateInstanceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getUpdateInstanceMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ * Deletes a specific Redis instance. Instance stops serving and data is
+ * deleted.
+ *
+ */
+ public void deleteInstance(com.google.cloud.redis.v1beta1.DeleteInstanceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getDeleteInstanceMethodHelper(), responseObserver);
+ }
+
+ @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
+ return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+ .addMethod(
+ getListInstancesMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.redis.v1beta1.ListInstancesRequest,
+ com.google.cloud.redis.v1beta1.ListInstancesResponse>(
+ this, METHODID_LIST_INSTANCES)))
+ .addMethod(
+ getGetInstanceMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.redis.v1beta1.GetInstanceRequest,
+ com.google.cloud.redis.v1beta1.Instance>(
+ this, METHODID_GET_INSTANCE)))
+ .addMethod(
+ getCreateInstanceMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.redis.v1beta1.CreateInstanceRequest,
+ com.google.longrunning.Operation>(
+ this, METHODID_CREATE_INSTANCE)))
+ .addMethod(
+ getUpdateInstanceMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.redis.v1beta1.UpdateInstanceRequest,
+ com.google.longrunning.Operation>(
+ this, METHODID_UPDATE_INSTANCE)))
+ .addMethod(
+ getDeleteInstanceMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.redis.v1beta1.DeleteInstanceRequest,
+ com.google.longrunning.Operation>(
+ this, METHODID_DELETE_INSTANCE)))
+ .build();
+ }
+ }
+
+ /**
+ *
+ * Configures and manages Cloud Memorystore for Redis instances
+ * Google Cloud Memorystore for Redis v1beta1
+ * The `redis.googleapis.com` service implements the Google Cloud Memorystore
+ * for Redis API and defines the following resource model for managing Redis
+ * instances:
+ * * The service works with a collection of cloud projects, named: `/projects/*`
+ * * Each project has a collection of available locations, named: `/locations/*`
+ * * Each location has a collection of Redis instances, named: `/instances/*`
+ * * As such, Redis instances are resources of the form:
+ * `/projects/{project_id}/locations/{location_id}/instances/{instance_id}`
+ * Note that location_id must be refering to a GCP `region`; for example:
+ * * `projects/redpepper-1290/locations/us-central1/instances/my-redis`
+ *
+ */
+ public static final class CloudRedisStub extends io.grpc.stub.AbstractStub {
+ private CloudRedisStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CloudRedisStub(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CloudRedisStub build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ return new CloudRedisStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Lists all Redis instances owned by a project in either the specified
+ * location (region) or all locations.
+ * The location should have the following format:
+ * * `projects/{project_id}/locations/{location_id}`
+ * If `location_id` is specified as `-` (wildcard), then all regions
+ * available to the project are queried, and the results are aggregated.
+ *
+ */
+ public void listInstances(com.google.cloud.redis.v1beta1.ListInstancesRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getListInstancesMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Gets the details of a specific Redis instance.
+ *
+ */
+ public void getInstance(com.google.cloud.redis.v1beta1.GetInstanceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getGetInstanceMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Creates a Redis instance based on the specified tier and memory size.
+ * By default, the instance is peered to the project's
+ * [default network](/compute/docs/networks-and-firewalls#networks).
+ * The creation is executed asynchronously and callers may check the returned
+ * operation to track its progress. Once the operation is completed the Redis
+ * instance will be fully functional. Completed longrunning.Operation will
+ * contain the new instance object in the response field.
+ * The returned operation is automatically deleted after a few hours, so there
+ * is no need to call DeleteOperation.
+ *
+ */
+ public void createInstance(com.google.cloud.redis.v1beta1.CreateInstanceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getCreateInstanceMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Updates the metadata and configuration of a specific Redis instance.
+ * Completed longrunning.Operation will contain the new instance object
+ * in the response field. The returned operation is automatically deleted
+ * after a few hours, so there is no need to call DeleteOperation.
+ *
+ */
+ public void updateInstance(com.google.cloud.redis.v1beta1.UpdateInstanceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getUpdateInstanceMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+
+ /**
+ *
+ * Deletes a specific Redis instance. Instance stops serving and data is
+ * deleted.
+ *
+ */
+ public void deleteInstance(com.google.cloud.redis.v1beta1.DeleteInstanceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getDeleteInstanceMethodHelper(), getCallOptions()), request, responseObserver);
+ }
+ }
+
+ /**
+ *
+ * Configures and manages Cloud Memorystore for Redis instances
+ * Google Cloud Memorystore for Redis v1beta1
+ * The `redis.googleapis.com` service implements the Google Cloud Memorystore
+ * for Redis API and defines the following resource model for managing Redis
+ * instances:
+ * * The service works with a collection of cloud projects, named: `/projects/*`
+ * * Each project has a collection of available locations, named: `/locations/*`
+ * * Each location has a collection of Redis instances, named: `/instances/*`
+ * * As such, Redis instances are resources of the form:
+ * `/projects/{project_id}/locations/{location_id}/instances/{instance_id}`
+ * Note that location_id must be refering to a GCP `region`; for example:
+ * * `projects/redpepper-1290/locations/us-central1/instances/my-redis`
+ *
+ */
+ public static final class CloudRedisBlockingStub extends io.grpc.stub.AbstractStub {
+ private CloudRedisBlockingStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CloudRedisBlockingStub(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CloudRedisBlockingStub build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ return new CloudRedisBlockingStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Lists all Redis instances owned by a project in either the specified
+ * location (region) or all locations.
+ * The location should have the following format:
+ * * `projects/{project_id}/locations/{location_id}`
+ * If `location_id` is specified as `-` (wildcard), then all regions
+ * available to the project are queried, and the results are aggregated.
+ *
+ */
+ public com.google.cloud.redis.v1beta1.ListInstancesResponse listInstances(com.google.cloud.redis.v1beta1.ListInstancesRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListInstancesMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Gets the details of a specific Redis instance.
+ *
+ */
+ public com.google.cloud.redis.v1beta1.Instance getInstance(com.google.cloud.redis.v1beta1.GetInstanceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetInstanceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Creates a Redis instance based on the specified tier and memory size.
+ * By default, the instance is peered to the project's
+ * [default network](/compute/docs/networks-and-firewalls#networks).
+ * The creation is executed asynchronously and callers may check the returned
+ * operation to track its progress. Once the operation is completed the Redis
+ * instance will be fully functional. Completed longrunning.Operation will
+ * contain the new instance object in the response field.
+ * The returned operation is automatically deleted after a few hours, so there
+ * is no need to call DeleteOperation.
+ *
+ */
+ public com.google.longrunning.Operation createInstance(com.google.cloud.redis.v1beta1.CreateInstanceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCreateInstanceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Updates the metadata and configuration of a specific Redis instance.
+ * Completed longrunning.Operation will contain the new instance object
+ * in the response field. The returned operation is automatically deleted
+ * after a few hours, so there is no need to call DeleteOperation.
+ *
+ */
+ public com.google.longrunning.Operation updateInstance(com.google.cloud.redis.v1beta1.UpdateInstanceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateInstanceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Deletes a specific Redis instance. Instance stops serving and data is
+ * deleted.
+ *
+ */
+ public com.google.longrunning.Operation deleteInstance(com.google.cloud.redis.v1beta1.DeleteInstanceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getDeleteInstanceMethodHelper(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ *
+ * Configures and manages Cloud Memorystore for Redis instances
+ * Google Cloud Memorystore for Redis v1beta1
+ * The `redis.googleapis.com` service implements the Google Cloud Memorystore
+ * for Redis API and defines the following resource model for managing Redis
+ * instances:
+ * * The service works with a collection of cloud projects, named: `/projects/*`
+ * * Each project has a collection of available locations, named: `/locations/*`
+ * * Each location has a collection of Redis instances, named: `/instances/*`
+ * * As such, Redis instances are resources of the form:
+ * `/projects/{project_id}/locations/{location_id}/instances/{instance_id}`
+ * Note that location_id must be refering to a GCP `region`; for example:
+ * * `projects/redpepper-1290/locations/us-central1/instances/my-redis`
+ *
+ */
+ public static final class CloudRedisFutureStub extends io.grpc.stub.AbstractStub {
+ private CloudRedisFutureStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CloudRedisFutureStub(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CloudRedisFutureStub build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) {
+ return new CloudRedisFutureStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Lists all Redis instances owned by a project in either the specified
+ * location (region) or all locations.
+ * The location should have the following format:
+ * * `projects/{project_id}/locations/{location_id}`
+ * If `location_id` is specified as `-` (wildcard), then all regions
+ * available to the project are queried, and the results are aggregated.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture listInstances(
+ com.google.cloud.redis.v1beta1.ListInstancesRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListInstancesMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Gets the details of a specific Redis instance.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getInstance(
+ com.google.cloud.redis.v1beta1.GetInstanceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetInstanceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Creates a Redis instance based on the specified tier and memory size.
+ * By default, the instance is peered to the project's
+ * [default network](/compute/docs/networks-and-firewalls#networks).
+ * The creation is executed asynchronously and callers may check the returned
+ * operation to track its progress. Once the operation is completed the Redis
+ * instance will be fully functional. Completed longrunning.Operation will
+ * contain the new instance object in the response field.
+ * The returned operation is automatically deleted after a few hours, so there
+ * is no need to call DeleteOperation.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture createInstance(
+ com.google.cloud.redis.v1beta1.CreateInstanceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCreateInstanceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Updates the metadata and configuration of a specific Redis instance.
+ * Completed longrunning.Operation will contain the new instance object
+ * in the response field. The returned operation is automatically deleted
+ * after a few hours, so there is no need to call DeleteOperation.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture updateInstance(
+ com.google.cloud.redis.v1beta1.UpdateInstanceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateInstanceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ * Deletes a specific Redis instance. Instance stops serving and data is
+ * deleted.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture deleteInstance(
+ com.google.cloud.redis.v1beta1.DeleteInstanceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getDeleteInstanceMethodHelper(), getCallOptions()), request);
+ }
+ }
+
+ private static final int METHODID_LIST_INSTANCES = 0;
+ private static final int METHODID_GET_INSTANCE = 1;
+ private static final int METHODID_CREATE_INSTANCE = 2;
+ private static final int METHODID_UPDATE_INSTANCE = 3;
+ private static final int METHODID_DELETE_INSTANCE = 4;
+
+ private static final class MethodHandlers implements
+ io.grpc.stub.ServerCalls.UnaryMethod