{
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 io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateDeviceRegistryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets a device registry configuration.
*
*/
public com.google.cloud.iot.v1.DeviceRegistry getDeviceRegistry(
com.google.cloud.iot.v1.GetDeviceRegistryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetDeviceRegistryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a device registry configuration.
*
*/
public com.google.cloud.iot.v1.DeviceRegistry updateDeviceRegistry(
com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateDeviceRegistryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a device registry configuration.
*
*/
public com.google.protobuf.Empty deleteDeviceRegistry(
com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteDeviceRegistryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists device registries.
*
*/
public com.google.cloud.iot.v1.ListDeviceRegistriesResponse listDeviceRegistries(
com.google.cloud.iot.v1.ListDeviceRegistriesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListDeviceRegistriesMethod(), 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 io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateDeviceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details about a device.
*
*/
public com.google.cloud.iot.v1.Device getDevice(
com.google.cloud.iot.v1.GetDeviceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetDeviceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a device.
*
*/
public com.google.cloud.iot.v1.Device updateDevice(
com.google.cloud.iot.v1.UpdateDeviceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateDeviceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a device.
*
*/
public com.google.protobuf.Empty deleteDevice(
com.google.cloud.iot.v1.DeleteDeviceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteDeviceMethod(), getCallOptions(), request);
}
/**
*
*
*
* List devices in a device registry.
*
*/
public com.google.cloud.iot.v1.ListDevicesResponse listDevices(
com.google.cloud.iot.v1.ListDevicesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListDevicesMethod(), 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 io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getModifyCloudToDeviceConfigMethod(), 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 io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListDeviceConfigVersionsMethod(), 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 io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListDeviceStatesMethod(), 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 io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetIamPolicyMethod(), 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 io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetIamPolicyMethod(), 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 io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sends a command to the specified device. In order for a device to be able
* to receive commands, it must:
* 1) be connected to Cloud IoT Core using the MQTT protocol, and
* 2) be subscribed to the group of MQTT topics specified by
* /devices/{device-id}/commands/#. This subscription will receive commands
* at the top-level topic /devices/{device-id}/commands as well as commands
* for subfolders, like /devices/{device-id}/commands/subfolder.
* Note that subscribing to specific subfolders is not supported.
* If the command could not be delivered to the device, this method will
* return an error; in particular, if the device is not subscribed, this
* method will return FAILED_PRECONDITION. Otherwise, this method will
* return OK. If the subscription is QoS 1, at least once delivery will be
* guaranteed; for QoS 0, no acknowledgment will be expected from the device.
*
*/
public com.google.cloud.iot.v1.SendCommandToDeviceResponse sendCommandToDevice(
com.google.cloud.iot.v1.SendCommandToDeviceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSendCommandToDeviceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Associates the device with the gateway.
*
*/
public com.google.cloud.iot.v1.BindDeviceToGatewayResponse bindDeviceToGateway(
com.google.cloud.iot.v1.BindDeviceToGatewayRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getBindDeviceToGatewayMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes the association between the device and the gateway.
*
*/
public com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse unbindDeviceFromGateway(
com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUnbindDeviceFromGatewayMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service DeviceManager.
*
*
* Internet of Things (IoT) service. Securely connect and manage IoT devices.
*
*/
public static final class DeviceManagerFutureStub
extends io.grpc.stub.AbstractFutureStub {
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<
com.google.cloud.iot.v1.DeviceRegistry>
createDeviceRegistry(com.google.cloud.iot.v1.CreateDeviceRegistryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateDeviceRegistryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets a device registry configuration.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.iot.v1.DeviceRegistry>
getDeviceRegistry(com.google.cloud.iot.v1.GetDeviceRegistryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetDeviceRegistryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a device registry configuration.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.iot.v1.DeviceRegistry>
updateDeviceRegistry(com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateDeviceRegistryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a device registry configuration.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteDeviceRegistry(com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteDeviceRegistryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists device registries.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.iot.v1.ListDeviceRegistriesResponse>
listDeviceRegistries(com.google.cloud.iot.v1.ListDeviceRegistriesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListDeviceRegistriesMethod(), 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 io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateDeviceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details about a device.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getDevice(com.google.cloud.iot.v1.GetDeviceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetDeviceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a device.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateDevice(com.google.cloud.iot.v1.UpdateDeviceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateDeviceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a device.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteDevice(com.google.cloud.iot.v1.DeleteDeviceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteDeviceMethod(), getCallOptions()), request);
}
/**
*
*
*
* List devices in a device registry.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.iot.v1.ListDevicesResponse>
listDevices(com.google.cloud.iot.v1.ListDevicesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListDevicesMethod(), 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 io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getModifyCloudToDeviceConfigMethod(), 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<
com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse>
listDeviceConfigVersions(com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListDeviceConfigVersionsMethod(), 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<
com.google.cloud.iot.v1.ListDeviceStatesResponse>
listDeviceStates(com.google.cloud.iot.v1.ListDeviceStatesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListDeviceStatesMethod(), 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 io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetIamPolicyMethod(), 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 io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetIamPolicyMethod(), 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<
com.google.iam.v1.TestIamPermissionsResponse>
testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sends a command to the specified device. In order for a device to be able
* to receive commands, it must:
* 1) be connected to Cloud IoT Core using the MQTT protocol, and
* 2) be subscribed to the group of MQTT topics specified by
* /devices/{device-id}/commands/#. This subscription will receive commands
* at the top-level topic /devices/{device-id}/commands as well as commands
* for subfolders, like /devices/{device-id}/commands/subfolder.
* Note that subscribing to specific subfolders is not supported.
* If the command could not be delivered to the device, this method will
* return an error; in particular, if the device is not subscribed, this
* method will return FAILED_PRECONDITION. Otherwise, this method will
* return OK. If the subscription is QoS 1, at least once delivery will be
* guaranteed; for QoS 0, no acknowledgment will be expected from the device.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.iot.v1.SendCommandToDeviceResponse>
sendCommandToDevice(com.google.cloud.iot.v1.SendCommandToDeviceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSendCommandToDeviceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Associates the device with the gateway.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.iot.v1.BindDeviceToGatewayResponse>
bindDeviceToGateway(com.google.cloud.iot.v1.BindDeviceToGatewayRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getBindDeviceToGatewayMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes the association between the device and the gateway.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse>
unbindDeviceFromGateway(com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUnbindDeviceFromGatewayMethod(), 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 int METHODID_SEND_COMMAND_TO_DEVICE = 16;
private static final int METHODID_BIND_DEVICE_TO_GATEWAY = 17;
private static final int METHODID_UNBIND_DEVICE_FROM_GATEWAY = 18;
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 AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService 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<
com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse>)
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;
case METHODID_SEND_COMMAND_TO_DEVICE:
serviceImpl.sendCommandToDevice(
(com.google.cloud.iot.v1.SendCommandToDeviceRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_BIND_DEVICE_TO_GATEWAY:
serviceImpl.bindDeviceToGateway(
(com.google.cloud.iot.v1.BindDeviceToGatewayRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UNBIND_DEVICE_FROM_GATEWAY:
serviceImpl.unbindDeviceFromGateway(
(com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest) 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();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateDeviceRegistryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.CreateDeviceRegistryRequest,
com.google.cloud.iot.v1.DeviceRegistry>(
service, METHODID_CREATE_DEVICE_REGISTRY)))
.addMethod(
getGetDeviceRegistryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.GetDeviceRegistryRequest,
com.google.cloud.iot.v1.DeviceRegistry>(service, METHODID_GET_DEVICE_REGISTRY)))
.addMethod(
getUpdateDeviceRegistryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.UpdateDeviceRegistryRequest,
com.google.cloud.iot.v1.DeviceRegistry>(
service, METHODID_UPDATE_DEVICE_REGISTRY)))
.addMethod(
getDeleteDeviceRegistryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.DeleteDeviceRegistryRequest, com.google.protobuf.Empty>(
service, METHODID_DELETE_DEVICE_REGISTRY)))
.addMethod(
getListDeviceRegistriesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.ListDeviceRegistriesRequest,
com.google.cloud.iot.v1.ListDeviceRegistriesResponse>(
service, METHODID_LIST_DEVICE_REGISTRIES)))
.addMethod(
getCreateDeviceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.CreateDeviceRequest, com.google.cloud.iot.v1.Device>(
service, METHODID_CREATE_DEVICE)))
.addMethod(
getGetDeviceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.GetDeviceRequest, com.google.cloud.iot.v1.Device>(
service, METHODID_GET_DEVICE)))
.addMethod(
getUpdateDeviceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.UpdateDeviceRequest, com.google.cloud.iot.v1.Device>(
service, METHODID_UPDATE_DEVICE)))
.addMethod(
getDeleteDeviceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.DeleteDeviceRequest, com.google.protobuf.Empty>(
service, METHODID_DELETE_DEVICE)))
.addMethod(
getListDevicesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.ListDevicesRequest,
com.google.cloud.iot.v1.ListDevicesResponse>(service, METHODID_LIST_DEVICES)))
.addMethod(
getModifyCloudToDeviceConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest,
com.google.cloud.iot.v1.DeviceConfig>(
service, METHODID_MODIFY_CLOUD_TO_DEVICE_CONFIG)))
.addMethod(
getListDeviceConfigVersionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest,
com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse>(
service, METHODID_LIST_DEVICE_CONFIG_VERSIONS)))
.addMethod(
getListDeviceStatesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.ListDeviceStatesRequest,
com.google.cloud.iot.v1.ListDeviceStatesResponse>(
service, METHODID_LIST_DEVICE_STATES)))
.addMethod(
getSetIamPolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers(
service, METHODID_SET_IAM_POLICY)))
.addMethod(
getGetIamPolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers(
service, METHODID_GET_IAM_POLICY)))
.addMethod(
getTestIamPermissionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v1.TestIamPermissionsRequest,
com.google.iam.v1.TestIamPermissionsResponse>(
service, METHODID_TEST_IAM_PERMISSIONS)))
.addMethod(
getSendCommandToDeviceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.SendCommandToDeviceRequest,
com.google.cloud.iot.v1.SendCommandToDeviceResponse>(
service, METHODID_SEND_COMMAND_TO_DEVICE)))
.addMethod(
getBindDeviceToGatewayMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.BindDeviceToGatewayRequest,
com.google.cloud.iot.v1.BindDeviceToGatewayResponse>(
service, METHODID_BIND_DEVICE_TO_GATEWAY)))
.addMethod(
getUnbindDeviceFromGatewayMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest,
com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse>(
service, METHODID_UNBIND_DEVICE_FROM_GATEWAY)))
.build();
}
private abstract static 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(getCreateDeviceRegistryMethod())
.addMethod(getGetDeviceRegistryMethod())
.addMethod(getUpdateDeviceRegistryMethod())
.addMethod(getDeleteDeviceRegistryMethod())
.addMethod(getListDeviceRegistriesMethod())
.addMethod(getCreateDeviceMethod())
.addMethod(getGetDeviceMethod())
.addMethod(getUpdateDeviceMethod())
.addMethod(getDeleteDeviceMethod())
.addMethod(getListDevicesMethod())
.addMethod(getModifyCloudToDeviceConfigMethod())
.addMethod(getListDeviceConfigVersionsMethod())
.addMethod(getListDeviceStatesMethod())
.addMethod(getSetIamPolicyMethod())
.addMethod(getGetIamPolicyMethod())
.addMethod(getTestIamPermissionsMethod())
.addMethod(getSendCommandToDeviceMethod())
.addMethod(getBindDeviceToGatewayMethod())
.addMethod(getUnbindDeviceFromGatewayMethod())
.build();
}
}
}
return result;
}
}