1 /* 2 * Copyright 2020 Google LLC 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * https://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 package com.google.cloud.iot.v1; 17 18 import static io.grpc.MethodDescriptor.generateFullMethodName; 19 20 /** 21 * 22 * 23 * <pre> 24 * Internet of Things (IoT) service. Securely connect and manage IoT devices. 25 * </pre> 26 */ 27 @javax.annotation.Generated( 28 value = "by gRPC proto compiler", 29 comments = "Source: google/cloud/iot/v1/device_manager.proto") 30 @io.grpc.stub.annotations.GrpcGenerated 31 public final class DeviceManagerGrpc { 32 DeviceManagerGrpc()33 private DeviceManagerGrpc() {} 34 35 public static final String SERVICE_NAME = "google.cloud.iot.v1.DeviceManager"; 36 37 // Static method descriptors that strictly reflect the proto. 38 private static volatile io.grpc.MethodDescriptor< 39 com.google.cloud.iot.v1.CreateDeviceRegistryRequest, 40 com.google.cloud.iot.v1.DeviceRegistry> 41 getCreateDeviceRegistryMethod; 42 43 @io.grpc.stub.annotations.RpcMethod( 44 fullMethodName = SERVICE_NAME + '/' + "CreateDeviceRegistry", 45 requestType = com.google.cloud.iot.v1.CreateDeviceRegistryRequest.class, 46 responseType = com.google.cloud.iot.v1.DeviceRegistry.class, 47 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 48 public static io.grpc.MethodDescriptor< 49 com.google.cloud.iot.v1.CreateDeviceRegistryRequest, 50 com.google.cloud.iot.v1.DeviceRegistry> getCreateDeviceRegistryMethod()51 getCreateDeviceRegistryMethod() { 52 io.grpc.MethodDescriptor< 53 com.google.cloud.iot.v1.CreateDeviceRegistryRequest, 54 com.google.cloud.iot.v1.DeviceRegistry> 55 getCreateDeviceRegistryMethod; 56 if ((getCreateDeviceRegistryMethod = DeviceManagerGrpc.getCreateDeviceRegistryMethod) == null) { 57 synchronized (DeviceManagerGrpc.class) { 58 if ((getCreateDeviceRegistryMethod = DeviceManagerGrpc.getCreateDeviceRegistryMethod) 59 == null) { 60 DeviceManagerGrpc.getCreateDeviceRegistryMethod = 61 getCreateDeviceRegistryMethod = 62 io.grpc.MethodDescriptor 63 .<com.google.cloud.iot.v1.CreateDeviceRegistryRequest, 64 com.google.cloud.iot.v1.DeviceRegistry> 65 newBuilder() 66 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 67 .setFullMethodName( 68 generateFullMethodName(SERVICE_NAME, "CreateDeviceRegistry")) 69 .setSampledToLocalTracing(true) 70 .setRequestMarshaller( 71 io.grpc.protobuf.ProtoUtils.marshaller( 72 com.google.cloud.iot.v1.CreateDeviceRegistryRequest 73 .getDefaultInstance())) 74 .setResponseMarshaller( 75 io.grpc.protobuf.ProtoUtils.marshaller( 76 com.google.cloud.iot.v1.DeviceRegistry.getDefaultInstance())) 77 .setSchemaDescriptor( 78 new DeviceManagerMethodDescriptorSupplier("CreateDeviceRegistry")) 79 .build(); 80 } 81 } 82 } 83 return getCreateDeviceRegistryMethod; 84 } 85 86 private static volatile io.grpc.MethodDescriptor< 87 com.google.cloud.iot.v1.GetDeviceRegistryRequest, com.google.cloud.iot.v1.DeviceRegistry> 88 getGetDeviceRegistryMethod; 89 90 @io.grpc.stub.annotations.RpcMethod( 91 fullMethodName = SERVICE_NAME + '/' + "GetDeviceRegistry", 92 requestType = com.google.cloud.iot.v1.GetDeviceRegistryRequest.class, 93 responseType = com.google.cloud.iot.v1.DeviceRegistry.class, 94 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 95 public static io.grpc.MethodDescriptor< 96 com.google.cloud.iot.v1.GetDeviceRegistryRequest, com.google.cloud.iot.v1.DeviceRegistry> getGetDeviceRegistryMethod()97 getGetDeviceRegistryMethod() { 98 io.grpc.MethodDescriptor< 99 com.google.cloud.iot.v1.GetDeviceRegistryRequest, 100 com.google.cloud.iot.v1.DeviceRegistry> 101 getGetDeviceRegistryMethod; 102 if ((getGetDeviceRegistryMethod = DeviceManagerGrpc.getGetDeviceRegistryMethod) == null) { 103 synchronized (DeviceManagerGrpc.class) { 104 if ((getGetDeviceRegistryMethod = DeviceManagerGrpc.getGetDeviceRegistryMethod) == null) { 105 DeviceManagerGrpc.getGetDeviceRegistryMethod = 106 getGetDeviceRegistryMethod = 107 io.grpc.MethodDescriptor 108 .<com.google.cloud.iot.v1.GetDeviceRegistryRequest, 109 com.google.cloud.iot.v1.DeviceRegistry> 110 newBuilder() 111 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 112 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetDeviceRegistry")) 113 .setSampledToLocalTracing(true) 114 .setRequestMarshaller( 115 io.grpc.protobuf.ProtoUtils.marshaller( 116 com.google.cloud.iot.v1.GetDeviceRegistryRequest 117 .getDefaultInstance())) 118 .setResponseMarshaller( 119 io.grpc.protobuf.ProtoUtils.marshaller( 120 com.google.cloud.iot.v1.DeviceRegistry.getDefaultInstance())) 121 .setSchemaDescriptor( 122 new DeviceManagerMethodDescriptorSupplier("GetDeviceRegistry")) 123 .build(); 124 } 125 } 126 } 127 return getGetDeviceRegistryMethod; 128 } 129 130 private static volatile io.grpc.MethodDescriptor< 131 com.google.cloud.iot.v1.UpdateDeviceRegistryRequest, 132 com.google.cloud.iot.v1.DeviceRegistry> 133 getUpdateDeviceRegistryMethod; 134 135 @io.grpc.stub.annotations.RpcMethod( 136 fullMethodName = SERVICE_NAME + '/' + "UpdateDeviceRegistry", 137 requestType = com.google.cloud.iot.v1.UpdateDeviceRegistryRequest.class, 138 responseType = com.google.cloud.iot.v1.DeviceRegistry.class, 139 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 140 public static io.grpc.MethodDescriptor< 141 com.google.cloud.iot.v1.UpdateDeviceRegistryRequest, 142 com.google.cloud.iot.v1.DeviceRegistry> getUpdateDeviceRegistryMethod()143 getUpdateDeviceRegistryMethod() { 144 io.grpc.MethodDescriptor< 145 com.google.cloud.iot.v1.UpdateDeviceRegistryRequest, 146 com.google.cloud.iot.v1.DeviceRegistry> 147 getUpdateDeviceRegistryMethod; 148 if ((getUpdateDeviceRegistryMethod = DeviceManagerGrpc.getUpdateDeviceRegistryMethod) == null) { 149 synchronized (DeviceManagerGrpc.class) { 150 if ((getUpdateDeviceRegistryMethod = DeviceManagerGrpc.getUpdateDeviceRegistryMethod) 151 == null) { 152 DeviceManagerGrpc.getUpdateDeviceRegistryMethod = 153 getUpdateDeviceRegistryMethod = 154 io.grpc.MethodDescriptor 155 .<com.google.cloud.iot.v1.UpdateDeviceRegistryRequest, 156 com.google.cloud.iot.v1.DeviceRegistry> 157 newBuilder() 158 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 159 .setFullMethodName( 160 generateFullMethodName(SERVICE_NAME, "UpdateDeviceRegistry")) 161 .setSampledToLocalTracing(true) 162 .setRequestMarshaller( 163 io.grpc.protobuf.ProtoUtils.marshaller( 164 com.google.cloud.iot.v1.UpdateDeviceRegistryRequest 165 .getDefaultInstance())) 166 .setResponseMarshaller( 167 io.grpc.protobuf.ProtoUtils.marshaller( 168 com.google.cloud.iot.v1.DeviceRegistry.getDefaultInstance())) 169 .setSchemaDescriptor( 170 new DeviceManagerMethodDescriptorSupplier("UpdateDeviceRegistry")) 171 .build(); 172 } 173 } 174 } 175 return getUpdateDeviceRegistryMethod; 176 } 177 178 private static volatile io.grpc.MethodDescriptor< 179 com.google.cloud.iot.v1.DeleteDeviceRegistryRequest, com.google.protobuf.Empty> 180 getDeleteDeviceRegistryMethod; 181 182 @io.grpc.stub.annotations.RpcMethod( 183 fullMethodName = SERVICE_NAME + '/' + "DeleteDeviceRegistry", 184 requestType = com.google.cloud.iot.v1.DeleteDeviceRegistryRequest.class, 185 responseType = com.google.protobuf.Empty.class, 186 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 187 public static io.grpc.MethodDescriptor< 188 com.google.cloud.iot.v1.DeleteDeviceRegistryRequest, com.google.protobuf.Empty> getDeleteDeviceRegistryMethod()189 getDeleteDeviceRegistryMethod() { 190 io.grpc.MethodDescriptor< 191 com.google.cloud.iot.v1.DeleteDeviceRegistryRequest, com.google.protobuf.Empty> 192 getDeleteDeviceRegistryMethod; 193 if ((getDeleteDeviceRegistryMethod = DeviceManagerGrpc.getDeleteDeviceRegistryMethod) == null) { 194 synchronized (DeviceManagerGrpc.class) { 195 if ((getDeleteDeviceRegistryMethod = DeviceManagerGrpc.getDeleteDeviceRegistryMethod) 196 == null) { 197 DeviceManagerGrpc.getDeleteDeviceRegistryMethod = 198 getDeleteDeviceRegistryMethod = 199 io.grpc.MethodDescriptor 200 .<com.google.cloud.iot.v1.DeleteDeviceRegistryRequest, 201 com.google.protobuf.Empty> 202 newBuilder() 203 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 204 .setFullMethodName( 205 generateFullMethodName(SERVICE_NAME, "DeleteDeviceRegistry")) 206 .setSampledToLocalTracing(true) 207 .setRequestMarshaller( 208 io.grpc.protobuf.ProtoUtils.marshaller( 209 com.google.cloud.iot.v1.DeleteDeviceRegistryRequest 210 .getDefaultInstance())) 211 .setResponseMarshaller( 212 io.grpc.protobuf.ProtoUtils.marshaller( 213 com.google.protobuf.Empty.getDefaultInstance())) 214 .setSchemaDescriptor( 215 new DeviceManagerMethodDescriptorSupplier("DeleteDeviceRegistry")) 216 .build(); 217 } 218 } 219 } 220 return getDeleteDeviceRegistryMethod; 221 } 222 223 private static volatile io.grpc.MethodDescriptor< 224 com.google.cloud.iot.v1.ListDeviceRegistriesRequest, 225 com.google.cloud.iot.v1.ListDeviceRegistriesResponse> 226 getListDeviceRegistriesMethod; 227 228 @io.grpc.stub.annotations.RpcMethod( 229 fullMethodName = SERVICE_NAME + '/' + "ListDeviceRegistries", 230 requestType = com.google.cloud.iot.v1.ListDeviceRegistriesRequest.class, 231 responseType = com.google.cloud.iot.v1.ListDeviceRegistriesResponse.class, 232 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 233 public static io.grpc.MethodDescriptor< 234 com.google.cloud.iot.v1.ListDeviceRegistriesRequest, 235 com.google.cloud.iot.v1.ListDeviceRegistriesResponse> getListDeviceRegistriesMethod()236 getListDeviceRegistriesMethod() { 237 io.grpc.MethodDescriptor< 238 com.google.cloud.iot.v1.ListDeviceRegistriesRequest, 239 com.google.cloud.iot.v1.ListDeviceRegistriesResponse> 240 getListDeviceRegistriesMethod; 241 if ((getListDeviceRegistriesMethod = DeviceManagerGrpc.getListDeviceRegistriesMethod) == null) { 242 synchronized (DeviceManagerGrpc.class) { 243 if ((getListDeviceRegistriesMethod = DeviceManagerGrpc.getListDeviceRegistriesMethod) 244 == null) { 245 DeviceManagerGrpc.getListDeviceRegistriesMethod = 246 getListDeviceRegistriesMethod = 247 io.grpc.MethodDescriptor 248 .<com.google.cloud.iot.v1.ListDeviceRegistriesRequest, 249 com.google.cloud.iot.v1.ListDeviceRegistriesResponse> 250 newBuilder() 251 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 252 .setFullMethodName( 253 generateFullMethodName(SERVICE_NAME, "ListDeviceRegistries")) 254 .setSampledToLocalTracing(true) 255 .setRequestMarshaller( 256 io.grpc.protobuf.ProtoUtils.marshaller( 257 com.google.cloud.iot.v1.ListDeviceRegistriesRequest 258 .getDefaultInstance())) 259 .setResponseMarshaller( 260 io.grpc.protobuf.ProtoUtils.marshaller( 261 com.google.cloud.iot.v1.ListDeviceRegistriesResponse 262 .getDefaultInstance())) 263 .setSchemaDescriptor( 264 new DeviceManagerMethodDescriptorSupplier("ListDeviceRegistries")) 265 .build(); 266 } 267 } 268 } 269 return getListDeviceRegistriesMethod; 270 } 271 272 private static volatile io.grpc.MethodDescriptor< 273 com.google.cloud.iot.v1.CreateDeviceRequest, com.google.cloud.iot.v1.Device> 274 getCreateDeviceMethod; 275 276 @io.grpc.stub.annotations.RpcMethod( 277 fullMethodName = SERVICE_NAME + '/' + "CreateDevice", 278 requestType = com.google.cloud.iot.v1.CreateDeviceRequest.class, 279 responseType = com.google.cloud.iot.v1.Device.class, 280 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 281 public static io.grpc.MethodDescriptor< 282 com.google.cloud.iot.v1.CreateDeviceRequest, com.google.cloud.iot.v1.Device> getCreateDeviceMethod()283 getCreateDeviceMethod() { 284 io.grpc.MethodDescriptor< 285 com.google.cloud.iot.v1.CreateDeviceRequest, com.google.cloud.iot.v1.Device> 286 getCreateDeviceMethod; 287 if ((getCreateDeviceMethod = DeviceManagerGrpc.getCreateDeviceMethod) == null) { 288 synchronized (DeviceManagerGrpc.class) { 289 if ((getCreateDeviceMethod = DeviceManagerGrpc.getCreateDeviceMethod) == null) { 290 DeviceManagerGrpc.getCreateDeviceMethod = 291 getCreateDeviceMethod = 292 io.grpc.MethodDescriptor 293 .<com.google.cloud.iot.v1.CreateDeviceRequest, com.google.cloud.iot.v1.Device> 294 newBuilder() 295 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 296 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateDevice")) 297 .setSampledToLocalTracing(true) 298 .setRequestMarshaller( 299 io.grpc.protobuf.ProtoUtils.marshaller( 300 com.google.cloud.iot.v1.CreateDeviceRequest.getDefaultInstance())) 301 .setResponseMarshaller( 302 io.grpc.protobuf.ProtoUtils.marshaller( 303 com.google.cloud.iot.v1.Device.getDefaultInstance())) 304 .setSchemaDescriptor( 305 new DeviceManagerMethodDescriptorSupplier("CreateDevice")) 306 .build(); 307 } 308 } 309 } 310 return getCreateDeviceMethod; 311 } 312 313 private static volatile io.grpc.MethodDescriptor< 314 com.google.cloud.iot.v1.GetDeviceRequest, com.google.cloud.iot.v1.Device> 315 getGetDeviceMethod; 316 317 @io.grpc.stub.annotations.RpcMethod( 318 fullMethodName = SERVICE_NAME + '/' + "GetDevice", 319 requestType = com.google.cloud.iot.v1.GetDeviceRequest.class, 320 responseType = com.google.cloud.iot.v1.Device.class, 321 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 322 public static io.grpc.MethodDescriptor< 323 com.google.cloud.iot.v1.GetDeviceRequest, com.google.cloud.iot.v1.Device> getGetDeviceMethod()324 getGetDeviceMethod() { 325 io.grpc.MethodDescriptor< 326 com.google.cloud.iot.v1.GetDeviceRequest, com.google.cloud.iot.v1.Device> 327 getGetDeviceMethod; 328 if ((getGetDeviceMethod = DeviceManagerGrpc.getGetDeviceMethod) == null) { 329 synchronized (DeviceManagerGrpc.class) { 330 if ((getGetDeviceMethod = DeviceManagerGrpc.getGetDeviceMethod) == null) { 331 DeviceManagerGrpc.getGetDeviceMethod = 332 getGetDeviceMethod = 333 io.grpc.MethodDescriptor 334 .<com.google.cloud.iot.v1.GetDeviceRequest, com.google.cloud.iot.v1.Device> 335 newBuilder() 336 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 337 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetDevice")) 338 .setSampledToLocalTracing(true) 339 .setRequestMarshaller( 340 io.grpc.protobuf.ProtoUtils.marshaller( 341 com.google.cloud.iot.v1.GetDeviceRequest.getDefaultInstance())) 342 .setResponseMarshaller( 343 io.grpc.protobuf.ProtoUtils.marshaller( 344 com.google.cloud.iot.v1.Device.getDefaultInstance())) 345 .setSchemaDescriptor(new DeviceManagerMethodDescriptorSupplier("GetDevice")) 346 .build(); 347 } 348 } 349 } 350 return getGetDeviceMethod; 351 } 352 353 private static volatile io.grpc.MethodDescriptor< 354 com.google.cloud.iot.v1.UpdateDeviceRequest, com.google.cloud.iot.v1.Device> 355 getUpdateDeviceMethod; 356 357 @io.grpc.stub.annotations.RpcMethod( 358 fullMethodName = SERVICE_NAME + '/' + "UpdateDevice", 359 requestType = com.google.cloud.iot.v1.UpdateDeviceRequest.class, 360 responseType = com.google.cloud.iot.v1.Device.class, 361 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 362 public static io.grpc.MethodDescriptor< 363 com.google.cloud.iot.v1.UpdateDeviceRequest, com.google.cloud.iot.v1.Device> getUpdateDeviceMethod()364 getUpdateDeviceMethod() { 365 io.grpc.MethodDescriptor< 366 com.google.cloud.iot.v1.UpdateDeviceRequest, com.google.cloud.iot.v1.Device> 367 getUpdateDeviceMethod; 368 if ((getUpdateDeviceMethod = DeviceManagerGrpc.getUpdateDeviceMethod) == null) { 369 synchronized (DeviceManagerGrpc.class) { 370 if ((getUpdateDeviceMethod = DeviceManagerGrpc.getUpdateDeviceMethod) == null) { 371 DeviceManagerGrpc.getUpdateDeviceMethod = 372 getUpdateDeviceMethod = 373 io.grpc.MethodDescriptor 374 .<com.google.cloud.iot.v1.UpdateDeviceRequest, com.google.cloud.iot.v1.Device> 375 newBuilder() 376 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 377 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateDevice")) 378 .setSampledToLocalTracing(true) 379 .setRequestMarshaller( 380 io.grpc.protobuf.ProtoUtils.marshaller( 381 com.google.cloud.iot.v1.UpdateDeviceRequest.getDefaultInstance())) 382 .setResponseMarshaller( 383 io.grpc.protobuf.ProtoUtils.marshaller( 384 com.google.cloud.iot.v1.Device.getDefaultInstance())) 385 .setSchemaDescriptor( 386 new DeviceManagerMethodDescriptorSupplier("UpdateDevice")) 387 .build(); 388 } 389 } 390 } 391 return getUpdateDeviceMethod; 392 } 393 394 private static volatile io.grpc.MethodDescriptor< 395 com.google.cloud.iot.v1.DeleteDeviceRequest, com.google.protobuf.Empty> 396 getDeleteDeviceMethod; 397 398 @io.grpc.stub.annotations.RpcMethod( 399 fullMethodName = SERVICE_NAME + '/' + "DeleteDevice", 400 requestType = com.google.cloud.iot.v1.DeleteDeviceRequest.class, 401 responseType = com.google.protobuf.Empty.class, 402 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 403 public static io.grpc.MethodDescriptor< 404 com.google.cloud.iot.v1.DeleteDeviceRequest, com.google.protobuf.Empty> getDeleteDeviceMethod()405 getDeleteDeviceMethod() { 406 io.grpc.MethodDescriptor<com.google.cloud.iot.v1.DeleteDeviceRequest, com.google.protobuf.Empty> 407 getDeleteDeviceMethod; 408 if ((getDeleteDeviceMethod = DeviceManagerGrpc.getDeleteDeviceMethod) == null) { 409 synchronized (DeviceManagerGrpc.class) { 410 if ((getDeleteDeviceMethod = DeviceManagerGrpc.getDeleteDeviceMethod) == null) { 411 DeviceManagerGrpc.getDeleteDeviceMethod = 412 getDeleteDeviceMethod = 413 io.grpc.MethodDescriptor 414 .<com.google.cloud.iot.v1.DeleteDeviceRequest, com.google.protobuf.Empty> 415 newBuilder() 416 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 417 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteDevice")) 418 .setSampledToLocalTracing(true) 419 .setRequestMarshaller( 420 io.grpc.protobuf.ProtoUtils.marshaller( 421 com.google.cloud.iot.v1.DeleteDeviceRequest.getDefaultInstance())) 422 .setResponseMarshaller( 423 io.grpc.protobuf.ProtoUtils.marshaller( 424 com.google.protobuf.Empty.getDefaultInstance())) 425 .setSchemaDescriptor( 426 new DeviceManagerMethodDescriptorSupplier("DeleteDevice")) 427 .build(); 428 } 429 } 430 } 431 return getDeleteDeviceMethod; 432 } 433 434 private static volatile io.grpc.MethodDescriptor< 435 com.google.cloud.iot.v1.ListDevicesRequest, com.google.cloud.iot.v1.ListDevicesResponse> 436 getListDevicesMethod; 437 438 @io.grpc.stub.annotations.RpcMethod( 439 fullMethodName = SERVICE_NAME + '/' + "ListDevices", 440 requestType = com.google.cloud.iot.v1.ListDevicesRequest.class, 441 responseType = com.google.cloud.iot.v1.ListDevicesResponse.class, 442 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 443 public static io.grpc.MethodDescriptor< 444 com.google.cloud.iot.v1.ListDevicesRequest, com.google.cloud.iot.v1.ListDevicesResponse> getListDevicesMethod()445 getListDevicesMethod() { 446 io.grpc.MethodDescriptor< 447 com.google.cloud.iot.v1.ListDevicesRequest, com.google.cloud.iot.v1.ListDevicesResponse> 448 getListDevicesMethod; 449 if ((getListDevicesMethod = DeviceManagerGrpc.getListDevicesMethod) == null) { 450 synchronized (DeviceManagerGrpc.class) { 451 if ((getListDevicesMethod = DeviceManagerGrpc.getListDevicesMethod) == null) { 452 DeviceManagerGrpc.getListDevicesMethod = 453 getListDevicesMethod = 454 io.grpc.MethodDescriptor 455 .<com.google.cloud.iot.v1.ListDevicesRequest, 456 com.google.cloud.iot.v1.ListDevicesResponse> 457 newBuilder() 458 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 459 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListDevices")) 460 .setSampledToLocalTracing(true) 461 .setRequestMarshaller( 462 io.grpc.protobuf.ProtoUtils.marshaller( 463 com.google.cloud.iot.v1.ListDevicesRequest.getDefaultInstance())) 464 .setResponseMarshaller( 465 io.grpc.protobuf.ProtoUtils.marshaller( 466 com.google.cloud.iot.v1.ListDevicesResponse.getDefaultInstance())) 467 .setSchemaDescriptor(new DeviceManagerMethodDescriptorSupplier("ListDevices")) 468 .build(); 469 } 470 } 471 } 472 return getListDevicesMethod; 473 } 474 475 private static volatile io.grpc.MethodDescriptor< 476 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest, 477 com.google.cloud.iot.v1.DeviceConfig> 478 getModifyCloudToDeviceConfigMethod; 479 480 @io.grpc.stub.annotations.RpcMethod( 481 fullMethodName = SERVICE_NAME + '/' + "ModifyCloudToDeviceConfig", 482 requestType = com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest.class, 483 responseType = com.google.cloud.iot.v1.DeviceConfig.class, 484 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 485 public static io.grpc.MethodDescriptor< 486 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest, 487 com.google.cloud.iot.v1.DeviceConfig> getModifyCloudToDeviceConfigMethod()488 getModifyCloudToDeviceConfigMethod() { 489 io.grpc.MethodDescriptor< 490 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest, 491 com.google.cloud.iot.v1.DeviceConfig> 492 getModifyCloudToDeviceConfigMethod; 493 if ((getModifyCloudToDeviceConfigMethod = DeviceManagerGrpc.getModifyCloudToDeviceConfigMethod) 494 == null) { 495 synchronized (DeviceManagerGrpc.class) { 496 if ((getModifyCloudToDeviceConfigMethod = 497 DeviceManagerGrpc.getModifyCloudToDeviceConfigMethod) 498 == null) { 499 DeviceManagerGrpc.getModifyCloudToDeviceConfigMethod = 500 getModifyCloudToDeviceConfigMethod = 501 io.grpc.MethodDescriptor 502 .<com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest, 503 com.google.cloud.iot.v1.DeviceConfig> 504 newBuilder() 505 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 506 .setFullMethodName( 507 generateFullMethodName(SERVICE_NAME, "ModifyCloudToDeviceConfig")) 508 .setSampledToLocalTracing(true) 509 .setRequestMarshaller( 510 io.grpc.protobuf.ProtoUtils.marshaller( 511 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest 512 .getDefaultInstance())) 513 .setResponseMarshaller( 514 io.grpc.protobuf.ProtoUtils.marshaller( 515 com.google.cloud.iot.v1.DeviceConfig.getDefaultInstance())) 516 .setSchemaDescriptor( 517 new DeviceManagerMethodDescriptorSupplier("ModifyCloudToDeviceConfig")) 518 .build(); 519 } 520 } 521 } 522 return getModifyCloudToDeviceConfigMethod; 523 } 524 525 private static volatile io.grpc.MethodDescriptor< 526 com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest, 527 com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> 528 getListDeviceConfigVersionsMethod; 529 530 @io.grpc.stub.annotations.RpcMethod( 531 fullMethodName = SERVICE_NAME + '/' + "ListDeviceConfigVersions", 532 requestType = com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest.class, 533 responseType = com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse.class, 534 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 535 public static io.grpc.MethodDescriptor< 536 com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest, 537 com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> getListDeviceConfigVersionsMethod()538 getListDeviceConfigVersionsMethod() { 539 io.grpc.MethodDescriptor< 540 com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest, 541 com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> 542 getListDeviceConfigVersionsMethod; 543 if ((getListDeviceConfigVersionsMethod = DeviceManagerGrpc.getListDeviceConfigVersionsMethod) 544 == null) { 545 synchronized (DeviceManagerGrpc.class) { 546 if ((getListDeviceConfigVersionsMethod = 547 DeviceManagerGrpc.getListDeviceConfigVersionsMethod) 548 == null) { 549 DeviceManagerGrpc.getListDeviceConfigVersionsMethod = 550 getListDeviceConfigVersionsMethod = 551 io.grpc.MethodDescriptor 552 .<com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest, 553 com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> 554 newBuilder() 555 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 556 .setFullMethodName( 557 generateFullMethodName(SERVICE_NAME, "ListDeviceConfigVersions")) 558 .setSampledToLocalTracing(true) 559 .setRequestMarshaller( 560 io.grpc.protobuf.ProtoUtils.marshaller( 561 com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest 562 .getDefaultInstance())) 563 .setResponseMarshaller( 564 io.grpc.protobuf.ProtoUtils.marshaller( 565 com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse 566 .getDefaultInstance())) 567 .setSchemaDescriptor( 568 new DeviceManagerMethodDescriptorSupplier("ListDeviceConfigVersions")) 569 .build(); 570 } 571 } 572 } 573 return getListDeviceConfigVersionsMethod; 574 } 575 576 private static volatile io.grpc.MethodDescriptor< 577 com.google.cloud.iot.v1.ListDeviceStatesRequest, 578 com.google.cloud.iot.v1.ListDeviceStatesResponse> 579 getListDeviceStatesMethod; 580 581 @io.grpc.stub.annotations.RpcMethod( 582 fullMethodName = SERVICE_NAME + '/' + "ListDeviceStates", 583 requestType = com.google.cloud.iot.v1.ListDeviceStatesRequest.class, 584 responseType = com.google.cloud.iot.v1.ListDeviceStatesResponse.class, 585 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 586 public static io.grpc.MethodDescriptor< 587 com.google.cloud.iot.v1.ListDeviceStatesRequest, 588 com.google.cloud.iot.v1.ListDeviceStatesResponse> getListDeviceStatesMethod()589 getListDeviceStatesMethod() { 590 io.grpc.MethodDescriptor< 591 com.google.cloud.iot.v1.ListDeviceStatesRequest, 592 com.google.cloud.iot.v1.ListDeviceStatesResponse> 593 getListDeviceStatesMethod; 594 if ((getListDeviceStatesMethod = DeviceManagerGrpc.getListDeviceStatesMethod) == null) { 595 synchronized (DeviceManagerGrpc.class) { 596 if ((getListDeviceStatesMethod = DeviceManagerGrpc.getListDeviceStatesMethod) == null) { 597 DeviceManagerGrpc.getListDeviceStatesMethod = 598 getListDeviceStatesMethod = 599 io.grpc.MethodDescriptor 600 .<com.google.cloud.iot.v1.ListDeviceStatesRequest, 601 com.google.cloud.iot.v1.ListDeviceStatesResponse> 602 newBuilder() 603 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 604 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListDeviceStates")) 605 .setSampledToLocalTracing(true) 606 .setRequestMarshaller( 607 io.grpc.protobuf.ProtoUtils.marshaller( 608 com.google.cloud.iot.v1.ListDeviceStatesRequest.getDefaultInstance())) 609 .setResponseMarshaller( 610 io.grpc.protobuf.ProtoUtils.marshaller( 611 com.google.cloud.iot.v1.ListDeviceStatesResponse 612 .getDefaultInstance())) 613 .setSchemaDescriptor( 614 new DeviceManagerMethodDescriptorSupplier("ListDeviceStates")) 615 .build(); 616 } 617 } 618 } 619 return getListDeviceStatesMethod; 620 } 621 622 private static volatile io.grpc.MethodDescriptor< 623 com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy> 624 getSetIamPolicyMethod; 625 626 @io.grpc.stub.annotations.RpcMethod( 627 fullMethodName = SERVICE_NAME + '/' + "SetIamPolicy", 628 requestType = com.google.iam.v1.SetIamPolicyRequest.class, 629 responseType = com.google.iam.v1.Policy.class, 630 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 631 public static io.grpc.MethodDescriptor< 632 com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy> getSetIamPolicyMethod()633 getSetIamPolicyMethod() { 634 io.grpc.MethodDescriptor<com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy> 635 getSetIamPolicyMethod; 636 if ((getSetIamPolicyMethod = DeviceManagerGrpc.getSetIamPolicyMethod) == null) { 637 synchronized (DeviceManagerGrpc.class) { 638 if ((getSetIamPolicyMethod = DeviceManagerGrpc.getSetIamPolicyMethod) == null) { 639 DeviceManagerGrpc.getSetIamPolicyMethod = 640 getSetIamPolicyMethod = 641 io.grpc.MethodDescriptor 642 .<com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy>newBuilder() 643 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 644 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SetIamPolicy")) 645 .setSampledToLocalTracing(true) 646 .setRequestMarshaller( 647 io.grpc.protobuf.ProtoUtils.marshaller( 648 com.google.iam.v1.SetIamPolicyRequest.getDefaultInstance())) 649 .setResponseMarshaller( 650 io.grpc.protobuf.ProtoUtils.marshaller( 651 com.google.iam.v1.Policy.getDefaultInstance())) 652 .setSchemaDescriptor( 653 new DeviceManagerMethodDescriptorSupplier("SetIamPolicy")) 654 .build(); 655 } 656 } 657 } 658 return getSetIamPolicyMethod; 659 } 660 661 private static volatile io.grpc.MethodDescriptor< 662 com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy> 663 getGetIamPolicyMethod; 664 665 @io.grpc.stub.annotations.RpcMethod( 666 fullMethodName = SERVICE_NAME + '/' + "GetIamPolicy", 667 requestType = com.google.iam.v1.GetIamPolicyRequest.class, 668 responseType = com.google.iam.v1.Policy.class, 669 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 670 public static io.grpc.MethodDescriptor< 671 com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy> getGetIamPolicyMethod()672 getGetIamPolicyMethod() { 673 io.grpc.MethodDescriptor<com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy> 674 getGetIamPolicyMethod; 675 if ((getGetIamPolicyMethod = DeviceManagerGrpc.getGetIamPolicyMethod) == null) { 676 synchronized (DeviceManagerGrpc.class) { 677 if ((getGetIamPolicyMethod = DeviceManagerGrpc.getGetIamPolicyMethod) == null) { 678 DeviceManagerGrpc.getGetIamPolicyMethod = 679 getGetIamPolicyMethod = 680 io.grpc.MethodDescriptor 681 .<com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy>newBuilder() 682 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 683 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetIamPolicy")) 684 .setSampledToLocalTracing(true) 685 .setRequestMarshaller( 686 io.grpc.protobuf.ProtoUtils.marshaller( 687 com.google.iam.v1.GetIamPolicyRequest.getDefaultInstance())) 688 .setResponseMarshaller( 689 io.grpc.protobuf.ProtoUtils.marshaller( 690 com.google.iam.v1.Policy.getDefaultInstance())) 691 .setSchemaDescriptor( 692 new DeviceManagerMethodDescriptorSupplier("GetIamPolicy")) 693 .build(); 694 } 695 } 696 } 697 return getGetIamPolicyMethod; 698 } 699 700 private static volatile io.grpc.MethodDescriptor< 701 com.google.iam.v1.TestIamPermissionsRequest, com.google.iam.v1.TestIamPermissionsResponse> 702 getTestIamPermissionsMethod; 703 704 @io.grpc.stub.annotations.RpcMethod( 705 fullMethodName = SERVICE_NAME + '/' + "TestIamPermissions", 706 requestType = com.google.iam.v1.TestIamPermissionsRequest.class, 707 responseType = com.google.iam.v1.TestIamPermissionsResponse.class, 708 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 709 public static io.grpc.MethodDescriptor< 710 com.google.iam.v1.TestIamPermissionsRequest, com.google.iam.v1.TestIamPermissionsResponse> getTestIamPermissionsMethod()711 getTestIamPermissionsMethod() { 712 io.grpc.MethodDescriptor< 713 com.google.iam.v1.TestIamPermissionsRequest, 714 com.google.iam.v1.TestIamPermissionsResponse> 715 getTestIamPermissionsMethod; 716 if ((getTestIamPermissionsMethod = DeviceManagerGrpc.getTestIamPermissionsMethod) == null) { 717 synchronized (DeviceManagerGrpc.class) { 718 if ((getTestIamPermissionsMethod = DeviceManagerGrpc.getTestIamPermissionsMethod) == null) { 719 DeviceManagerGrpc.getTestIamPermissionsMethod = 720 getTestIamPermissionsMethod = 721 io.grpc.MethodDescriptor 722 .<com.google.iam.v1.TestIamPermissionsRequest, 723 com.google.iam.v1.TestIamPermissionsResponse> 724 newBuilder() 725 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 726 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "TestIamPermissions")) 727 .setSampledToLocalTracing(true) 728 .setRequestMarshaller( 729 io.grpc.protobuf.ProtoUtils.marshaller( 730 com.google.iam.v1.TestIamPermissionsRequest.getDefaultInstance())) 731 .setResponseMarshaller( 732 io.grpc.protobuf.ProtoUtils.marshaller( 733 com.google.iam.v1.TestIamPermissionsResponse.getDefaultInstance())) 734 .setSchemaDescriptor( 735 new DeviceManagerMethodDescriptorSupplier("TestIamPermissions")) 736 .build(); 737 } 738 } 739 } 740 return getTestIamPermissionsMethod; 741 } 742 743 private static volatile io.grpc.MethodDescriptor< 744 com.google.cloud.iot.v1.SendCommandToDeviceRequest, 745 com.google.cloud.iot.v1.SendCommandToDeviceResponse> 746 getSendCommandToDeviceMethod; 747 748 @io.grpc.stub.annotations.RpcMethod( 749 fullMethodName = SERVICE_NAME + '/' + "SendCommandToDevice", 750 requestType = com.google.cloud.iot.v1.SendCommandToDeviceRequest.class, 751 responseType = com.google.cloud.iot.v1.SendCommandToDeviceResponse.class, 752 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 753 public static io.grpc.MethodDescriptor< 754 com.google.cloud.iot.v1.SendCommandToDeviceRequest, 755 com.google.cloud.iot.v1.SendCommandToDeviceResponse> getSendCommandToDeviceMethod()756 getSendCommandToDeviceMethod() { 757 io.grpc.MethodDescriptor< 758 com.google.cloud.iot.v1.SendCommandToDeviceRequest, 759 com.google.cloud.iot.v1.SendCommandToDeviceResponse> 760 getSendCommandToDeviceMethod; 761 if ((getSendCommandToDeviceMethod = DeviceManagerGrpc.getSendCommandToDeviceMethod) == null) { 762 synchronized (DeviceManagerGrpc.class) { 763 if ((getSendCommandToDeviceMethod = DeviceManagerGrpc.getSendCommandToDeviceMethod) 764 == null) { 765 DeviceManagerGrpc.getSendCommandToDeviceMethod = 766 getSendCommandToDeviceMethod = 767 io.grpc.MethodDescriptor 768 .<com.google.cloud.iot.v1.SendCommandToDeviceRequest, 769 com.google.cloud.iot.v1.SendCommandToDeviceResponse> 770 newBuilder() 771 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 772 .setFullMethodName( 773 generateFullMethodName(SERVICE_NAME, "SendCommandToDevice")) 774 .setSampledToLocalTracing(true) 775 .setRequestMarshaller( 776 io.grpc.protobuf.ProtoUtils.marshaller( 777 com.google.cloud.iot.v1.SendCommandToDeviceRequest 778 .getDefaultInstance())) 779 .setResponseMarshaller( 780 io.grpc.protobuf.ProtoUtils.marshaller( 781 com.google.cloud.iot.v1.SendCommandToDeviceResponse 782 .getDefaultInstance())) 783 .setSchemaDescriptor( 784 new DeviceManagerMethodDescriptorSupplier("SendCommandToDevice")) 785 .build(); 786 } 787 } 788 } 789 return getSendCommandToDeviceMethod; 790 } 791 792 private static volatile io.grpc.MethodDescriptor< 793 com.google.cloud.iot.v1.BindDeviceToGatewayRequest, 794 com.google.cloud.iot.v1.BindDeviceToGatewayResponse> 795 getBindDeviceToGatewayMethod; 796 797 @io.grpc.stub.annotations.RpcMethod( 798 fullMethodName = SERVICE_NAME + '/' + "BindDeviceToGateway", 799 requestType = com.google.cloud.iot.v1.BindDeviceToGatewayRequest.class, 800 responseType = com.google.cloud.iot.v1.BindDeviceToGatewayResponse.class, 801 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 802 public static io.grpc.MethodDescriptor< 803 com.google.cloud.iot.v1.BindDeviceToGatewayRequest, 804 com.google.cloud.iot.v1.BindDeviceToGatewayResponse> getBindDeviceToGatewayMethod()805 getBindDeviceToGatewayMethod() { 806 io.grpc.MethodDescriptor< 807 com.google.cloud.iot.v1.BindDeviceToGatewayRequest, 808 com.google.cloud.iot.v1.BindDeviceToGatewayResponse> 809 getBindDeviceToGatewayMethod; 810 if ((getBindDeviceToGatewayMethod = DeviceManagerGrpc.getBindDeviceToGatewayMethod) == null) { 811 synchronized (DeviceManagerGrpc.class) { 812 if ((getBindDeviceToGatewayMethod = DeviceManagerGrpc.getBindDeviceToGatewayMethod) 813 == null) { 814 DeviceManagerGrpc.getBindDeviceToGatewayMethod = 815 getBindDeviceToGatewayMethod = 816 io.grpc.MethodDescriptor 817 .<com.google.cloud.iot.v1.BindDeviceToGatewayRequest, 818 com.google.cloud.iot.v1.BindDeviceToGatewayResponse> 819 newBuilder() 820 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 821 .setFullMethodName( 822 generateFullMethodName(SERVICE_NAME, "BindDeviceToGateway")) 823 .setSampledToLocalTracing(true) 824 .setRequestMarshaller( 825 io.grpc.protobuf.ProtoUtils.marshaller( 826 com.google.cloud.iot.v1.BindDeviceToGatewayRequest 827 .getDefaultInstance())) 828 .setResponseMarshaller( 829 io.grpc.protobuf.ProtoUtils.marshaller( 830 com.google.cloud.iot.v1.BindDeviceToGatewayResponse 831 .getDefaultInstance())) 832 .setSchemaDescriptor( 833 new DeviceManagerMethodDescriptorSupplier("BindDeviceToGateway")) 834 .build(); 835 } 836 } 837 } 838 return getBindDeviceToGatewayMethod; 839 } 840 841 private static volatile io.grpc.MethodDescriptor< 842 com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest, 843 com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> 844 getUnbindDeviceFromGatewayMethod; 845 846 @io.grpc.stub.annotations.RpcMethod( 847 fullMethodName = SERVICE_NAME + '/' + "UnbindDeviceFromGateway", 848 requestType = com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest.class, 849 responseType = com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse.class, 850 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 851 public static io.grpc.MethodDescriptor< 852 com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest, 853 com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> getUnbindDeviceFromGatewayMethod()854 getUnbindDeviceFromGatewayMethod() { 855 io.grpc.MethodDescriptor< 856 com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest, 857 com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> 858 getUnbindDeviceFromGatewayMethod; 859 if ((getUnbindDeviceFromGatewayMethod = DeviceManagerGrpc.getUnbindDeviceFromGatewayMethod) 860 == null) { 861 synchronized (DeviceManagerGrpc.class) { 862 if ((getUnbindDeviceFromGatewayMethod = DeviceManagerGrpc.getUnbindDeviceFromGatewayMethod) 863 == null) { 864 DeviceManagerGrpc.getUnbindDeviceFromGatewayMethod = 865 getUnbindDeviceFromGatewayMethod = 866 io.grpc.MethodDescriptor 867 .<com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest, 868 com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> 869 newBuilder() 870 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 871 .setFullMethodName( 872 generateFullMethodName(SERVICE_NAME, "UnbindDeviceFromGateway")) 873 .setSampledToLocalTracing(true) 874 .setRequestMarshaller( 875 io.grpc.protobuf.ProtoUtils.marshaller( 876 com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest 877 .getDefaultInstance())) 878 .setResponseMarshaller( 879 io.grpc.protobuf.ProtoUtils.marshaller( 880 com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse 881 .getDefaultInstance())) 882 .setSchemaDescriptor( 883 new DeviceManagerMethodDescriptorSupplier("UnbindDeviceFromGateway")) 884 .build(); 885 } 886 } 887 } 888 return getUnbindDeviceFromGatewayMethod; 889 } 890 891 /** Creates a new async stub that supports all call types for the service */ newStub(io.grpc.Channel channel)892 public static DeviceManagerStub newStub(io.grpc.Channel channel) { 893 io.grpc.stub.AbstractStub.StubFactory<DeviceManagerStub> factory = 894 new io.grpc.stub.AbstractStub.StubFactory<DeviceManagerStub>() { 895 @java.lang.Override 896 public DeviceManagerStub newStub( 897 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 898 return new DeviceManagerStub(channel, callOptions); 899 } 900 }; 901 return DeviceManagerStub.newStub(factory, channel); 902 } 903 904 /** 905 * Creates a new blocking-style stub that supports unary and streaming output calls on the service 906 */ newBlockingStub(io.grpc.Channel channel)907 public static DeviceManagerBlockingStub newBlockingStub(io.grpc.Channel channel) { 908 io.grpc.stub.AbstractStub.StubFactory<DeviceManagerBlockingStub> factory = 909 new io.grpc.stub.AbstractStub.StubFactory<DeviceManagerBlockingStub>() { 910 @java.lang.Override 911 public DeviceManagerBlockingStub newStub( 912 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 913 return new DeviceManagerBlockingStub(channel, callOptions); 914 } 915 }; 916 return DeviceManagerBlockingStub.newStub(factory, channel); 917 } 918 919 /** Creates a new ListenableFuture-style stub that supports unary calls on the service */ newFutureStub(io.grpc.Channel channel)920 public static DeviceManagerFutureStub newFutureStub(io.grpc.Channel channel) { 921 io.grpc.stub.AbstractStub.StubFactory<DeviceManagerFutureStub> factory = 922 new io.grpc.stub.AbstractStub.StubFactory<DeviceManagerFutureStub>() { 923 @java.lang.Override 924 public DeviceManagerFutureStub newStub( 925 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 926 return new DeviceManagerFutureStub(channel, callOptions); 927 } 928 }; 929 return DeviceManagerFutureStub.newStub(factory, channel); 930 } 931 932 /** 933 * 934 * 935 * <pre> 936 * Internet of Things (IoT) service. Securely connect and manage IoT devices. 937 * </pre> 938 */ 939 public interface AsyncService { 940 941 /** 942 * 943 * 944 * <pre> 945 * Creates a device registry that contains devices. 946 * </pre> 947 */ createDeviceRegistry( com.google.cloud.iot.v1.CreateDeviceRegistryRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver)948 default void createDeviceRegistry( 949 com.google.cloud.iot.v1.CreateDeviceRegistryRequest request, 950 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver) { 951 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 952 getCreateDeviceRegistryMethod(), responseObserver); 953 } 954 955 /** 956 * 957 * 958 * <pre> 959 * Gets a device registry configuration. 960 * </pre> 961 */ getDeviceRegistry( com.google.cloud.iot.v1.GetDeviceRegistryRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver)962 default void getDeviceRegistry( 963 com.google.cloud.iot.v1.GetDeviceRegistryRequest request, 964 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver) { 965 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 966 getGetDeviceRegistryMethod(), responseObserver); 967 } 968 969 /** 970 * 971 * 972 * <pre> 973 * Updates a device registry configuration. 974 * </pre> 975 */ updateDeviceRegistry( com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver)976 default void updateDeviceRegistry( 977 com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request, 978 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver) { 979 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 980 getUpdateDeviceRegistryMethod(), responseObserver); 981 } 982 983 /** 984 * 985 * 986 * <pre> 987 * Deletes a device registry configuration. 988 * </pre> 989 */ deleteDeviceRegistry( com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)990 default void deleteDeviceRegistry( 991 com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request, 992 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 993 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 994 getDeleteDeviceRegistryMethod(), responseObserver); 995 } 996 997 /** 998 * 999 * 1000 * <pre> 1001 * Lists device registries. 1002 * </pre> 1003 */ listDeviceRegistries( com.google.cloud.iot.v1.ListDeviceRegistriesRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceRegistriesResponse> responseObserver)1004 default void listDeviceRegistries( 1005 com.google.cloud.iot.v1.ListDeviceRegistriesRequest request, 1006 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceRegistriesResponse> 1007 responseObserver) { 1008 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1009 getListDeviceRegistriesMethod(), responseObserver); 1010 } 1011 1012 /** 1013 * 1014 * 1015 * <pre> 1016 * Creates a device in a device registry. 1017 * </pre> 1018 */ createDevice( com.google.cloud.iot.v1.CreateDeviceRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver)1019 default void createDevice( 1020 com.google.cloud.iot.v1.CreateDeviceRequest request, 1021 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver) { 1022 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1023 getCreateDeviceMethod(), responseObserver); 1024 } 1025 1026 /** 1027 * 1028 * 1029 * <pre> 1030 * Gets details about a device. 1031 * </pre> 1032 */ getDevice( com.google.cloud.iot.v1.GetDeviceRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver)1033 default void getDevice( 1034 com.google.cloud.iot.v1.GetDeviceRequest request, 1035 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver) { 1036 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetDeviceMethod(), responseObserver); 1037 } 1038 1039 /** 1040 * 1041 * 1042 * <pre> 1043 * Updates a device. 1044 * </pre> 1045 */ updateDevice( com.google.cloud.iot.v1.UpdateDeviceRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver)1046 default void updateDevice( 1047 com.google.cloud.iot.v1.UpdateDeviceRequest request, 1048 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver) { 1049 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1050 getUpdateDeviceMethod(), responseObserver); 1051 } 1052 1053 /** 1054 * 1055 * 1056 * <pre> 1057 * Deletes a device. 1058 * </pre> 1059 */ deleteDevice( com.google.cloud.iot.v1.DeleteDeviceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1060 default void deleteDevice( 1061 com.google.cloud.iot.v1.DeleteDeviceRequest request, 1062 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1063 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1064 getDeleteDeviceMethod(), responseObserver); 1065 } 1066 1067 /** 1068 * 1069 * 1070 * <pre> 1071 * List devices in a device registry. 1072 * </pre> 1073 */ listDevices( com.google.cloud.iot.v1.ListDevicesRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDevicesResponse> responseObserver)1074 default void listDevices( 1075 com.google.cloud.iot.v1.ListDevicesRequest request, 1076 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDevicesResponse> responseObserver) { 1077 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1078 getListDevicesMethod(), responseObserver); 1079 } 1080 1081 /** 1082 * 1083 * 1084 * <pre> 1085 * Modifies the configuration for the device, which is eventually sent from 1086 * the Cloud IoT Core servers. Returns the modified configuration version and 1087 * its metadata. 1088 * </pre> 1089 */ modifyCloudToDeviceConfig( com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceConfig> responseObserver)1090 default void modifyCloudToDeviceConfig( 1091 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request, 1092 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceConfig> responseObserver) { 1093 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1094 getModifyCloudToDeviceConfigMethod(), responseObserver); 1095 } 1096 1097 /** 1098 * 1099 * 1100 * <pre> 1101 * Lists the last few versions of the device configuration in descending 1102 * order (i.e.: newest first). 1103 * </pre> 1104 */ listDeviceConfigVersions( com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> responseObserver)1105 default void listDeviceConfigVersions( 1106 com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request, 1107 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> 1108 responseObserver) { 1109 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1110 getListDeviceConfigVersionsMethod(), responseObserver); 1111 } 1112 1113 /** 1114 * 1115 * 1116 * <pre> 1117 * Lists the last few versions of the device state in descending order (i.e.: 1118 * newest first). 1119 * </pre> 1120 */ listDeviceStates( com.google.cloud.iot.v1.ListDeviceStatesRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceStatesResponse> responseObserver)1121 default void listDeviceStates( 1122 com.google.cloud.iot.v1.ListDeviceStatesRequest request, 1123 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceStatesResponse> 1124 responseObserver) { 1125 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1126 getListDeviceStatesMethod(), responseObserver); 1127 } 1128 1129 /** 1130 * 1131 * 1132 * <pre> 1133 * Sets the access control policy on the specified resource. Replaces any 1134 * existing policy. 1135 * </pre> 1136 */ setIamPolicy( com.google.iam.v1.SetIamPolicyRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver)1137 default void setIamPolicy( 1138 com.google.iam.v1.SetIamPolicyRequest request, 1139 io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) { 1140 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1141 getSetIamPolicyMethod(), responseObserver); 1142 } 1143 1144 /** 1145 * 1146 * 1147 * <pre> 1148 * Gets the access control policy for a resource. 1149 * Returns an empty policy if the resource exists and does not have a policy 1150 * set. 1151 * </pre> 1152 */ getIamPolicy( com.google.iam.v1.GetIamPolicyRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver)1153 default void getIamPolicy( 1154 com.google.iam.v1.GetIamPolicyRequest request, 1155 io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) { 1156 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1157 getGetIamPolicyMethod(), responseObserver); 1158 } 1159 1160 /** 1161 * 1162 * 1163 * <pre> 1164 * Returns permissions that a caller has on the specified resource. 1165 * If the resource does not exist, this will return an empty set of 1166 * permissions, not a NOT_FOUND error. 1167 * </pre> 1168 */ testIamPermissions( com.google.iam.v1.TestIamPermissionsRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> responseObserver)1169 default void testIamPermissions( 1170 com.google.iam.v1.TestIamPermissionsRequest request, 1171 io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> 1172 responseObserver) { 1173 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1174 getTestIamPermissionsMethod(), responseObserver); 1175 } 1176 1177 /** 1178 * 1179 * 1180 * <pre> 1181 * Sends a command to the specified device. In order for a device to be able 1182 * to receive commands, it must: 1183 * 1) be connected to Cloud IoT Core using the MQTT protocol, and 1184 * 2) be subscribed to the group of MQTT topics specified by 1185 * /devices/{device-id}/commands/#. This subscription will receive commands 1186 * at the top-level topic /devices/{device-id}/commands as well as commands 1187 * for subfolders, like /devices/{device-id}/commands/subfolder. 1188 * Note that subscribing to specific subfolders is not supported. 1189 * If the command could not be delivered to the device, this method will 1190 * return an error; in particular, if the device is not subscribed, this 1191 * method will return FAILED_PRECONDITION. Otherwise, this method will 1192 * return OK. If the subscription is QoS 1, at least once delivery will be 1193 * guaranteed; for QoS 0, no acknowledgment will be expected from the device. 1194 * </pre> 1195 */ sendCommandToDevice( com.google.cloud.iot.v1.SendCommandToDeviceRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.SendCommandToDeviceResponse> responseObserver)1196 default void sendCommandToDevice( 1197 com.google.cloud.iot.v1.SendCommandToDeviceRequest request, 1198 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.SendCommandToDeviceResponse> 1199 responseObserver) { 1200 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1201 getSendCommandToDeviceMethod(), responseObserver); 1202 } 1203 1204 /** 1205 * 1206 * 1207 * <pre> 1208 * Associates the device with the gateway. 1209 * </pre> 1210 */ bindDeviceToGateway( com.google.cloud.iot.v1.BindDeviceToGatewayRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.BindDeviceToGatewayResponse> responseObserver)1211 default void bindDeviceToGateway( 1212 com.google.cloud.iot.v1.BindDeviceToGatewayRequest request, 1213 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.BindDeviceToGatewayResponse> 1214 responseObserver) { 1215 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1216 getBindDeviceToGatewayMethod(), responseObserver); 1217 } 1218 1219 /** 1220 * 1221 * 1222 * <pre> 1223 * Deletes the association between the device and the gateway. 1224 * </pre> 1225 */ unbindDeviceFromGateway( com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> responseObserver)1226 default void unbindDeviceFromGateway( 1227 com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request, 1228 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> 1229 responseObserver) { 1230 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1231 getUnbindDeviceFromGatewayMethod(), responseObserver); 1232 } 1233 } 1234 1235 /** 1236 * Base class for the server implementation of the service DeviceManager. 1237 * 1238 * <pre> 1239 * Internet of Things (IoT) service. Securely connect and manage IoT devices. 1240 * </pre> 1241 */ 1242 public abstract static class DeviceManagerImplBase 1243 implements io.grpc.BindableService, AsyncService { 1244 1245 @java.lang.Override bindService()1246 public final io.grpc.ServerServiceDefinition bindService() { 1247 return DeviceManagerGrpc.bindService(this); 1248 } 1249 } 1250 1251 /** 1252 * A stub to allow clients to do asynchronous rpc calls to service DeviceManager. 1253 * 1254 * <pre> 1255 * Internet of Things (IoT) service. Securely connect and manage IoT devices. 1256 * </pre> 1257 */ 1258 public static final class DeviceManagerStub 1259 extends io.grpc.stub.AbstractAsyncStub<DeviceManagerStub> { DeviceManagerStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1260 private DeviceManagerStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1261 super(channel, callOptions); 1262 } 1263 1264 @java.lang.Override build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1265 protected DeviceManagerStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1266 return new DeviceManagerStub(channel, callOptions); 1267 } 1268 1269 /** 1270 * 1271 * 1272 * <pre> 1273 * Creates a device registry that contains devices. 1274 * </pre> 1275 */ createDeviceRegistry( com.google.cloud.iot.v1.CreateDeviceRegistryRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver)1276 public void createDeviceRegistry( 1277 com.google.cloud.iot.v1.CreateDeviceRegistryRequest request, 1278 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver) { 1279 io.grpc.stub.ClientCalls.asyncUnaryCall( 1280 getChannel().newCall(getCreateDeviceRegistryMethod(), getCallOptions()), 1281 request, 1282 responseObserver); 1283 } 1284 1285 /** 1286 * 1287 * 1288 * <pre> 1289 * Gets a device registry configuration. 1290 * </pre> 1291 */ getDeviceRegistry( com.google.cloud.iot.v1.GetDeviceRegistryRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver)1292 public void getDeviceRegistry( 1293 com.google.cloud.iot.v1.GetDeviceRegistryRequest request, 1294 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver) { 1295 io.grpc.stub.ClientCalls.asyncUnaryCall( 1296 getChannel().newCall(getGetDeviceRegistryMethod(), getCallOptions()), 1297 request, 1298 responseObserver); 1299 } 1300 1301 /** 1302 * 1303 * 1304 * <pre> 1305 * Updates a device registry configuration. 1306 * </pre> 1307 */ updateDeviceRegistry( com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver)1308 public void updateDeviceRegistry( 1309 com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request, 1310 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry> responseObserver) { 1311 io.grpc.stub.ClientCalls.asyncUnaryCall( 1312 getChannel().newCall(getUpdateDeviceRegistryMethod(), getCallOptions()), 1313 request, 1314 responseObserver); 1315 } 1316 1317 /** 1318 * 1319 * 1320 * <pre> 1321 * Deletes a device registry configuration. 1322 * </pre> 1323 */ deleteDeviceRegistry( com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1324 public void deleteDeviceRegistry( 1325 com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request, 1326 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1327 io.grpc.stub.ClientCalls.asyncUnaryCall( 1328 getChannel().newCall(getDeleteDeviceRegistryMethod(), getCallOptions()), 1329 request, 1330 responseObserver); 1331 } 1332 1333 /** 1334 * 1335 * 1336 * <pre> 1337 * Lists device registries. 1338 * </pre> 1339 */ listDeviceRegistries( com.google.cloud.iot.v1.ListDeviceRegistriesRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceRegistriesResponse> responseObserver)1340 public void listDeviceRegistries( 1341 com.google.cloud.iot.v1.ListDeviceRegistriesRequest request, 1342 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceRegistriesResponse> 1343 responseObserver) { 1344 io.grpc.stub.ClientCalls.asyncUnaryCall( 1345 getChannel().newCall(getListDeviceRegistriesMethod(), getCallOptions()), 1346 request, 1347 responseObserver); 1348 } 1349 1350 /** 1351 * 1352 * 1353 * <pre> 1354 * Creates a device in a device registry. 1355 * </pre> 1356 */ createDevice( com.google.cloud.iot.v1.CreateDeviceRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver)1357 public void createDevice( 1358 com.google.cloud.iot.v1.CreateDeviceRequest request, 1359 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver) { 1360 io.grpc.stub.ClientCalls.asyncUnaryCall( 1361 getChannel().newCall(getCreateDeviceMethod(), getCallOptions()), 1362 request, 1363 responseObserver); 1364 } 1365 1366 /** 1367 * 1368 * 1369 * <pre> 1370 * Gets details about a device. 1371 * </pre> 1372 */ getDevice( com.google.cloud.iot.v1.GetDeviceRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver)1373 public void getDevice( 1374 com.google.cloud.iot.v1.GetDeviceRequest request, 1375 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver) { 1376 io.grpc.stub.ClientCalls.asyncUnaryCall( 1377 getChannel().newCall(getGetDeviceMethod(), getCallOptions()), request, responseObserver); 1378 } 1379 1380 /** 1381 * 1382 * 1383 * <pre> 1384 * Updates a device. 1385 * </pre> 1386 */ updateDevice( com.google.cloud.iot.v1.UpdateDeviceRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver)1387 public void updateDevice( 1388 com.google.cloud.iot.v1.UpdateDeviceRequest request, 1389 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device> responseObserver) { 1390 io.grpc.stub.ClientCalls.asyncUnaryCall( 1391 getChannel().newCall(getUpdateDeviceMethod(), getCallOptions()), 1392 request, 1393 responseObserver); 1394 } 1395 1396 /** 1397 * 1398 * 1399 * <pre> 1400 * Deletes a device. 1401 * </pre> 1402 */ deleteDevice( com.google.cloud.iot.v1.DeleteDeviceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1403 public void deleteDevice( 1404 com.google.cloud.iot.v1.DeleteDeviceRequest request, 1405 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1406 io.grpc.stub.ClientCalls.asyncUnaryCall( 1407 getChannel().newCall(getDeleteDeviceMethod(), getCallOptions()), 1408 request, 1409 responseObserver); 1410 } 1411 1412 /** 1413 * 1414 * 1415 * <pre> 1416 * List devices in a device registry. 1417 * </pre> 1418 */ listDevices( com.google.cloud.iot.v1.ListDevicesRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDevicesResponse> responseObserver)1419 public void listDevices( 1420 com.google.cloud.iot.v1.ListDevicesRequest request, 1421 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDevicesResponse> responseObserver) { 1422 io.grpc.stub.ClientCalls.asyncUnaryCall( 1423 getChannel().newCall(getListDevicesMethod(), getCallOptions()), 1424 request, 1425 responseObserver); 1426 } 1427 1428 /** 1429 * 1430 * 1431 * <pre> 1432 * Modifies the configuration for the device, which is eventually sent from 1433 * the Cloud IoT Core servers. Returns the modified configuration version and 1434 * its metadata. 1435 * </pre> 1436 */ modifyCloudToDeviceConfig( com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceConfig> responseObserver)1437 public void modifyCloudToDeviceConfig( 1438 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request, 1439 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceConfig> responseObserver) { 1440 io.grpc.stub.ClientCalls.asyncUnaryCall( 1441 getChannel().newCall(getModifyCloudToDeviceConfigMethod(), getCallOptions()), 1442 request, 1443 responseObserver); 1444 } 1445 1446 /** 1447 * 1448 * 1449 * <pre> 1450 * Lists the last few versions of the device configuration in descending 1451 * order (i.e.: newest first). 1452 * </pre> 1453 */ listDeviceConfigVersions( com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> responseObserver)1454 public void listDeviceConfigVersions( 1455 com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request, 1456 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> 1457 responseObserver) { 1458 io.grpc.stub.ClientCalls.asyncUnaryCall( 1459 getChannel().newCall(getListDeviceConfigVersionsMethod(), getCallOptions()), 1460 request, 1461 responseObserver); 1462 } 1463 1464 /** 1465 * 1466 * 1467 * <pre> 1468 * Lists the last few versions of the device state in descending order (i.e.: 1469 * newest first). 1470 * </pre> 1471 */ listDeviceStates( com.google.cloud.iot.v1.ListDeviceStatesRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceStatesResponse> responseObserver)1472 public void listDeviceStates( 1473 com.google.cloud.iot.v1.ListDeviceStatesRequest request, 1474 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceStatesResponse> 1475 responseObserver) { 1476 io.grpc.stub.ClientCalls.asyncUnaryCall( 1477 getChannel().newCall(getListDeviceStatesMethod(), getCallOptions()), 1478 request, 1479 responseObserver); 1480 } 1481 1482 /** 1483 * 1484 * 1485 * <pre> 1486 * Sets the access control policy on the specified resource. Replaces any 1487 * existing policy. 1488 * </pre> 1489 */ setIamPolicy( com.google.iam.v1.SetIamPolicyRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver)1490 public void setIamPolicy( 1491 com.google.iam.v1.SetIamPolicyRequest request, 1492 io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) { 1493 io.grpc.stub.ClientCalls.asyncUnaryCall( 1494 getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()), 1495 request, 1496 responseObserver); 1497 } 1498 1499 /** 1500 * 1501 * 1502 * <pre> 1503 * Gets the access control policy for a resource. 1504 * Returns an empty policy if the resource exists and does not have a policy 1505 * set. 1506 * </pre> 1507 */ getIamPolicy( com.google.iam.v1.GetIamPolicyRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver)1508 public void getIamPolicy( 1509 com.google.iam.v1.GetIamPolicyRequest request, 1510 io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) { 1511 io.grpc.stub.ClientCalls.asyncUnaryCall( 1512 getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()), 1513 request, 1514 responseObserver); 1515 } 1516 1517 /** 1518 * 1519 * 1520 * <pre> 1521 * Returns permissions that a caller has on the specified resource. 1522 * If the resource does not exist, this will return an empty set of 1523 * permissions, not a NOT_FOUND error. 1524 * </pre> 1525 */ testIamPermissions( com.google.iam.v1.TestIamPermissionsRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> responseObserver)1526 public void testIamPermissions( 1527 com.google.iam.v1.TestIamPermissionsRequest request, 1528 io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> 1529 responseObserver) { 1530 io.grpc.stub.ClientCalls.asyncUnaryCall( 1531 getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()), 1532 request, 1533 responseObserver); 1534 } 1535 1536 /** 1537 * 1538 * 1539 * <pre> 1540 * Sends a command to the specified device. In order for a device to be able 1541 * to receive commands, it must: 1542 * 1) be connected to Cloud IoT Core using the MQTT protocol, and 1543 * 2) be subscribed to the group of MQTT topics specified by 1544 * /devices/{device-id}/commands/#. This subscription will receive commands 1545 * at the top-level topic /devices/{device-id}/commands as well as commands 1546 * for subfolders, like /devices/{device-id}/commands/subfolder. 1547 * Note that subscribing to specific subfolders is not supported. 1548 * If the command could not be delivered to the device, this method will 1549 * return an error; in particular, if the device is not subscribed, this 1550 * method will return FAILED_PRECONDITION. Otherwise, this method will 1551 * return OK. If the subscription is QoS 1, at least once delivery will be 1552 * guaranteed; for QoS 0, no acknowledgment will be expected from the device. 1553 * </pre> 1554 */ sendCommandToDevice( com.google.cloud.iot.v1.SendCommandToDeviceRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.SendCommandToDeviceResponse> responseObserver)1555 public void sendCommandToDevice( 1556 com.google.cloud.iot.v1.SendCommandToDeviceRequest request, 1557 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.SendCommandToDeviceResponse> 1558 responseObserver) { 1559 io.grpc.stub.ClientCalls.asyncUnaryCall( 1560 getChannel().newCall(getSendCommandToDeviceMethod(), getCallOptions()), 1561 request, 1562 responseObserver); 1563 } 1564 1565 /** 1566 * 1567 * 1568 * <pre> 1569 * Associates the device with the gateway. 1570 * </pre> 1571 */ bindDeviceToGateway( com.google.cloud.iot.v1.BindDeviceToGatewayRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.BindDeviceToGatewayResponse> responseObserver)1572 public void bindDeviceToGateway( 1573 com.google.cloud.iot.v1.BindDeviceToGatewayRequest request, 1574 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.BindDeviceToGatewayResponse> 1575 responseObserver) { 1576 io.grpc.stub.ClientCalls.asyncUnaryCall( 1577 getChannel().newCall(getBindDeviceToGatewayMethod(), getCallOptions()), 1578 request, 1579 responseObserver); 1580 } 1581 1582 /** 1583 * 1584 * 1585 * <pre> 1586 * Deletes the association between the device and the gateway. 1587 * </pre> 1588 */ unbindDeviceFromGateway( com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request, io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> responseObserver)1589 public void unbindDeviceFromGateway( 1590 com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request, 1591 io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> 1592 responseObserver) { 1593 io.grpc.stub.ClientCalls.asyncUnaryCall( 1594 getChannel().newCall(getUnbindDeviceFromGatewayMethod(), getCallOptions()), 1595 request, 1596 responseObserver); 1597 } 1598 } 1599 1600 /** 1601 * A stub to allow clients to do synchronous rpc calls to service DeviceManager. 1602 * 1603 * <pre> 1604 * Internet of Things (IoT) service. Securely connect and manage IoT devices. 1605 * </pre> 1606 */ 1607 public static final class DeviceManagerBlockingStub 1608 extends io.grpc.stub.AbstractBlockingStub<DeviceManagerBlockingStub> { DeviceManagerBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1609 private DeviceManagerBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1610 super(channel, callOptions); 1611 } 1612 1613 @java.lang.Override build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)1614 protected DeviceManagerBlockingStub build( 1615 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1616 return new DeviceManagerBlockingStub(channel, callOptions); 1617 } 1618 1619 /** 1620 * 1621 * 1622 * <pre> 1623 * Creates a device registry that contains devices. 1624 * </pre> 1625 */ createDeviceRegistry( com.google.cloud.iot.v1.CreateDeviceRegistryRequest request)1626 public com.google.cloud.iot.v1.DeviceRegistry createDeviceRegistry( 1627 com.google.cloud.iot.v1.CreateDeviceRegistryRequest request) { 1628 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1629 getChannel(), getCreateDeviceRegistryMethod(), getCallOptions(), request); 1630 } 1631 1632 /** 1633 * 1634 * 1635 * <pre> 1636 * Gets a device registry configuration. 1637 * </pre> 1638 */ getDeviceRegistry( com.google.cloud.iot.v1.GetDeviceRegistryRequest request)1639 public com.google.cloud.iot.v1.DeviceRegistry getDeviceRegistry( 1640 com.google.cloud.iot.v1.GetDeviceRegistryRequest request) { 1641 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1642 getChannel(), getGetDeviceRegistryMethod(), getCallOptions(), request); 1643 } 1644 1645 /** 1646 * 1647 * 1648 * <pre> 1649 * Updates a device registry configuration. 1650 * </pre> 1651 */ updateDeviceRegistry( com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request)1652 public com.google.cloud.iot.v1.DeviceRegistry updateDeviceRegistry( 1653 com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request) { 1654 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1655 getChannel(), getUpdateDeviceRegistryMethod(), getCallOptions(), request); 1656 } 1657 1658 /** 1659 * 1660 * 1661 * <pre> 1662 * Deletes a device registry configuration. 1663 * </pre> 1664 */ deleteDeviceRegistry( com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request)1665 public com.google.protobuf.Empty deleteDeviceRegistry( 1666 com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request) { 1667 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1668 getChannel(), getDeleteDeviceRegistryMethod(), getCallOptions(), request); 1669 } 1670 1671 /** 1672 * 1673 * 1674 * <pre> 1675 * Lists device registries. 1676 * </pre> 1677 */ listDeviceRegistries( com.google.cloud.iot.v1.ListDeviceRegistriesRequest request)1678 public com.google.cloud.iot.v1.ListDeviceRegistriesResponse listDeviceRegistries( 1679 com.google.cloud.iot.v1.ListDeviceRegistriesRequest request) { 1680 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1681 getChannel(), getListDeviceRegistriesMethod(), getCallOptions(), request); 1682 } 1683 1684 /** 1685 * 1686 * 1687 * <pre> 1688 * Creates a device in a device registry. 1689 * </pre> 1690 */ createDevice( com.google.cloud.iot.v1.CreateDeviceRequest request)1691 public com.google.cloud.iot.v1.Device createDevice( 1692 com.google.cloud.iot.v1.CreateDeviceRequest request) { 1693 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1694 getChannel(), getCreateDeviceMethod(), getCallOptions(), request); 1695 } 1696 1697 /** 1698 * 1699 * 1700 * <pre> 1701 * Gets details about a device. 1702 * </pre> 1703 */ getDevice( com.google.cloud.iot.v1.GetDeviceRequest request)1704 public com.google.cloud.iot.v1.Device getDevice( 1705 com.google.cloud.iot.v1.GetDeviceRequest request) { 1706 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1707 getChannel(), getGetDeviceMethod(), getCallOptions(), request); 1708 } 1709 1710 /** 1711 * 1712 * 1713 * <pre> 1714 * Updates a device. 1715 * </pre> 1716 */ updateDevice( com.google.cloud.iot.v1.UpdateDeviceRequest request)1717 public com.google.cloud.iot.v1.Device updateDevice( 1718 com.google.cloud.iot.v1.UpdateDeviceRequest request) { 1719 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1720 getChannel(), getUpdateDeviceMethod(), getCallOptions(), request); 1721 } 1722 1723 /** 1724 * 1725 * 1726 * <pre> 1727 * Deletes a device. 1728 * </pre> 1729 */ deleteDevice( com.google.cloud.iot.v1.DeleteDeviceRequest request)1730 public com.google.protobuf.Empty deleteDevice( 1731 com.google.cloud.iot.v1.DeleteDeviceRequest request) { 1732 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1733 getChannel(), getDeleteDeviceMethod(), getCallOptions(), request); 1734 } 1735 1736 /** 1737 * 1738 * 1739 * <pre> 1740 * List devices in a device registry. 1741 * </pre> 1742 */ listDevices( com.google.cloud.iot.v1.ListDevicesRequest request)1743 public com.google.cloud.iot.v1.ListDevicesResponse listDevices( 1744 com.google.cloud.iot.v1.ListDevicesRequest request) { 1745 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1746 getChannel(), getListDevicesMethod(), getCallOptions(), request); 1747 } 1748 1749 /** 1750 * 1751 * 1752 * <pre> 1753 * Modifies the configuration for the device, which is eventually sent from 1754 * the Cloud IoT Core servers. Returns the modified configuration version and 1755 * its metadata. 1756 * </pre> 1757 */ modifyCloudToDeviceConfig( com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request)1758 public com.google.cloud.iot.v1.DeviceConfig modifyCloudToDeviceConfig( 1759 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request) { 1760 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1761 getChannel(), getModifyCloudToDeviceConfigMethod(), getCallOptions(), request); 1762 } 1763 1764 /** 1765 * 1766 * 1767 * <pre> 1768 * Lists the last few versions of the device configuration in descending 1769 * order (i.e.: newest first). 1770 * </pre> 1771 */ listDeviceConfigVersions( com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request)1772 public com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse listDeviceConfigVersions( 1773 com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request) { 1774 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1775 getChannel(), getListDeviceConfigVersionsMethod(), getCallOptions(), request); 1776 } 1777 1778 /** 1779 * 1780 * 1781 * <pre> 1782 * Lists the last few versions of the device state in descending order (i.e.: 1783 * newest first). 1784 * </pre> 1785 */ listDeviceStates( com.google.cloud.iot.v1.ListDeviceStatesRequest request)1786 public com.google.cloud.iot.v1.ListDeviceStatesResponse listDeviceStates( 1787 com.google.cloud.iot.v1.ListDeviceStatesRequest request) { 1788 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1789 getChannel(), getListDeviceStatesMethod(), getCallOptions(), request); 1790 } 1791 1792 /** 1793 * 1794 * 1795 * <pre> 1796 * Sets the access control policy on the specified resource. Replaces any 1797 * existing policy. 1798 * </pre> 1799 */ setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request)1800 public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) { 1801 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1802 getChannel(), getSetIamPolicyMethod(), getCallOptions(), request); 1803 } 1804 1805 /** 1806 * 1807 * 1808 * <pre> 1809 * Gets the access control policy for a resource. 1810 * Returns an empty policy if the resource exists and does not have a policy 1811 * set. 1812 * </pre> 1813 */ getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request)1814 public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) { 1815 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1816 getChannel(), getGetIamPolicyMethod(), getCallOptions(), request); 1817 } 1818 1819 /** 1820 * 1821 * 1822 * <pre> 1823 * Returns permissions that a caller has on the specified resource. 1824 * If the resource does not exist, this will return an empty set of 1825 * permissions, not a NOT_FOUND error. 1826 * </pre> 1827 */ testIamPermissions( com.google.iam.v1.TestIamPermissionsRequest request)1828 public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions( 1829 com.google.iam.v1.TestIamPermissionsRequest request) { 1830 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1831 getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request); 1832 } 1833 1834 /** 1835 * 1836 * 1837 * <pre> 1838 * Sends a command to the specified device. In order for a device to be able 1839 * to receive commands, it must: 1840 * 1) be connected to Cloud IoT Core using the MQTT protocol, and 1841 * 2) be subscribed to the group of MQTT topics specified by 1842 * /devices/{device-id}/commands/#. This subscription will receive commands 1843 * at the top-level topic /devices/{device-id}/commands as well as commands 1844 * for subfolders, like /devices/{device-id}/commands/subfolder. 1845 * Note that subscribing to specific subfolders is not supported. 1846 * If the command could not be delivered to the device, this method will 1847 * return an error; in particular, if the device is not subscribed, this 1848 * method will return FAILED_PRECONDITION. Otherwise, this method will 1849 * return OK. If the subscription is QoS 1, at least once delivery will be 1850 * guaranteed; for QoS 0, no acknowledgment will be expected from the device. 1851 * </pre> 1852 */ sendCommandToDevice( com.google.cloud.iot.v1.SendCommandToDeviceRequest request)1853 public com.google.cloud.iot.v1.SendCommandToDeviceResponse sendCommandToDevice( 1854 com.google.cloud.iot.v1.SendCommandToDeviceRequest request) { 1855 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1856 getChannel(), getSendCommandToDeviceMethod(), getCallOptions(), request); 1857 } 1858 1859 /** 1860 * 1861 * 1862 * <pre> 1863 * Associates the device with the gateway. 1864 * </pre> 1865 */ bindDeviceToGateway( com.google.cloud.iot.v1.BindDeviceToGatewayRequest request)1866 public com.google.cloud.iot.v1.BindDeviceToGatewayResponse bindDeviceToGateway( 1867 com.google.cloud.iot.v1.BindDeviceToGatewayRequest request) { 1868 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1869 getChannel(), getBindDeviceToGatewayMethod(), getCallOptions(), request); 1870 } 1871 1872 /** 1873 * 1874 * 1875 * <pre> 1876 * Deletes the association between the device and the gateway. 1877 * </pre> 1878 */ unbindDeviceFromGateway( com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request)1879 public com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse unbindDeviceFromGateway( 1880 com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request) { 1881 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1882 getChannel(), getUnbindDeviceFromGatewayMethod(), getCallOptions(), request); 1883 } 1884 } 1885 1886 /** 1887 * A stub to allow clients to do ListenableFuture-style rpc calls to service DeviceManager. 1888 * 1889 * <pre> 1890 * Internet of Things (IoT) service. Securely connect and manage IoT devices. 1891 * </pre> 1892 */ 1893 public static final class DeviceManagerFutureStub 1894 extends io.grpc.stub.AbstractFutureStub<DeviceManagerFutureStub> { DeviceManagerFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1895 private DeviceManagerFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1896 super(channel, callOptions); 1897 } 1898 1899 @java.lang.Override build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)1900 protected DeviceManagerFutureStub build( 1901 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1902 return new DeviceManagerFutureStub(channel, callOptions); 1903 } 1904 1905 /** 1906 * 1907 * 1908 * <pre> 1909 * Creates a device registry that contains devices. 1910 * </pre> 1911 */ 1912 public com.google.common.util.concurrent.ListenableFuture< 1913 com.google.cloud.iot.v1.DeviceRegistry> createDeviceRegistry(com.google.cloud.iot.v1.CreateDeviceRegistryRequest request)1914 createDeviceRegistry(com.google.cloud.iot.v1.CreateDeviceRegistryRequest request) { 1915 return io.grpc.stub.ClientCalls.futureUnaryCall( 1916 getChannel().newCall(getCreateDeviceRegistryMethod(), getCallOptions()), request); 1917 } 1918 1919 /** 1920 * 1921 * 1922 * <pre> 1923 * Gets a device registry configuration. 1924 * </pre> 1925 */ 1926 public com.google.common.util.concurrent.ListenableFuture< 1927 com.google.cloud.iot.v1.DeviceRegistry> getDeviceRegistry(com.google.cloud.iot.v1.GetDeviceRegistryRequest request)1928 getDeviceRegistry(com.google.cloud.iot.v1.GetDeviceRegistryRequest request) { 1929 return io.grpc.stub.ClientCalls.futureUnaryCall( 1930 getChannel().newCall(getGetDeviceRegistryMethod(), getCallOptions()), request); 1931 } 1932 1933 /** 1934 * 1935 * 1936 * <pre> 1937 * Updates a device registry configuration. 1938 * </pre> 1939 */ 1940 public com.google.common.util.concurrent.ListenableFuture< 1941 com.google.cloud.iot.v1.DeviceRegistry> updateDeviceRegistry(com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request)1942 updateDeviceRegistry(com.google.cloud.iot.v1.UpdateDeviceRegistryRequest request) { 1943 return io.grpc.stub.ClientCalls.futureUnaryCall( 1944 getChannel().newCall(getUpdateDeviceRegistryMethod(), getCallOptions()), request); 1945 } 1946 1947 /** 1948 * 1949 * 1950 * <pre> 1951 * Deletes a device registry configuration. 1952 * </pre> 1953 */ 1954 public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteDeviceRegistry(com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request)1955 deleteDeviceRegistry(com.google.cloud.iot.v1.DeleteDeviceRegistryRequest request) { 1956 return io.grpc.stub.ClientCalls.futureUnaryCall( 1957 getChannel().newCall(getDeleteDeviceRegistryMethod(), getCallOptions()), request); 1958 } 1959 1960 /** 1961 * 1962 * 1963 * <pre> 1964 * Lists device registries. 1965 * </pre> 1966 */ 1967 public com.google.common.util.concurrent.ListenableFuture< 1968 com.google.cloud.iot.v1.ListDeviceRegistriesResponse> listDeviceRegistries(com.google.cloud.iot.v1.ListDeviceRegistriesRequest request)1969 listDeviceRegistries(com.google.cloud.iot.v1.ListDeviceRegistriesRequest request) { 1970 return io.grpc.stub.ClientCalls.futureUnaryCall( 1971 getChannel().newCall(getListDeviceRegistriesMethod(), getCallOptions()), request); 1972 } 1973 1974 /** 1975 * 1976 * 1977 * <pre> 1978 * Creates a device in a device registry. 1979 * </pre> 1980 */ 1981 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.iot.v1.Device> createDevice(com.google.cloud.iot.v1.CreateDeviceRequest request)1982 createDevice(com.google.cloud.iot.v1.CreateDeviceRequest request) { 1983 return io.grpc.stub.ClientCalls.futureUnaryCall( 1984 getChannel().newCall(getCreateDeviceMethod(), getCallOptions()), request); 1985 } 1986 1987 /** 1988 * 1989 * 1990 * <pre> 1991 * Gets details about a device. 1992 * </pre> 1993 */ 1994 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.iot.v1.Device> getDevice(com.google.cloud.iot.v1.GetDeviceRequest request)1995 getDevice(com.google.cloud.iot.v1.GetDeviceRequest request) { 1996 return io.grpc.stub.ClientCalls.futureUnaryCall( 1997 getChannel().newCall(getGetDeviceMethod(), getCallOptions()), request); 1998 } 1999 2000 /** 2001 * 2002 * 2003 * <pre> 2004 * Updates a device. 2005 * </pre> 2006 */ 2007 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.iot.v1.Device> updateDevice(com.google.cloud.iot.v1.UpdateDeviceRequest request)2008 updateDevice(com.google.cloud.iot.v1.UpdateDeviceRequest request) { 2009 return io.grpc.stub.ClientCalls.futureUnaryCall( 2010 getChannel().newCall(getUpdateDeviceMethod(), getCallOptions()), request); 2011 } 2012 2013 /** 2014 * 2015 * 2016 * <pre> 2017 * Deletes a device. 2018 * </pre> 2019 */ 2020 public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteDevice(com.google.cloud.iot.v1.DeleteDeviceRequest request)2021 deleteDevice(com.google.cloud.iot.v1.DeleteDeviceRequest request) { 2022 return io.grpc.stub.ClientCalls.futureUnaryCall( 2023 getChannel().newCall(getDeleteDeviceMethod(), getCallOptions()), request); 2024 } 2025 2026 /** 2027 * 2028 * 2029 * <pre> 2030 * List devices in a device registry. 2031 * </pre> 2032 */ 2033 public com.google.common.util.concurrent.ListenableFuture< 2034 com.google.cloud.iot.v1.ListDevicesResponse> listDevices(com.google.cloud.iot.v1.ListDevicesRequest request)2035 listDevices(com.google.cloud.iot.v1.ListDevicesRequest request) { 2036 return io.grpc.stub.ClientCalls.futureUnaryCall( 2037 getChannel().newCall(getListDevicesMethod(), getCallOptions()), request); 2038 } 2039 2040 /** 2041 * 2042 * 2043 * <pre> 2044 * Modifies the configuration for the device, which is eventually sent from 2045 * the Cloud IoT Core servers. Returns the modified configuration version and 2046 * its metadata. 2047 * </pre> 2048 */ 2049 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.iot.v1.DeviceConfig> modifyCloudToDeviceConfig( com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request)2050 modifyCloudToDeviceConfig( 2051 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest request) { 2052 return io.grpc.stub.ClientCalls.futureUnaryCall( 2053 getChannel().newCall(getModifyCloudToDeviceConfigMethod(), getCallOptions()), request); 2054 } 2055 2056 /** 2057 * 2058 * 2059 * <pre> 2060 * Lists the last few versions of the device configuration in descending 2061 * order (i.e.: newest first). 2062 * </pre> 2063 */ 2064 public com.google.common.util.concurrent.ListenableFuture< 2065 com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse> listDeviceConfigVersions(com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request)2066 listDeviceConfigVersions(com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest request) { 2067 return io.grpc.stub.ClientCalls.futureUnaryCall( 2068 getChannel().newCall(getListDeviceConfigVersionsMethod(), getCallOptions()), request); 2069 } 2070 2071 /** 2072 * 2073 * 2074 * <pre> 2075 * Lists the last few versions of the device state in descending order (i.e.: 2076 * newest first). 2077 * </pre> 2078 */ 2079 public com.google.common.util.concurrent.ListenableFuture< 2080 com.google.cloud.iot.v1.ListDeviceStatesResponse> listDeviceStates(com.google.cloud.iot.v1.ListDeviceStatesRequest request)2081 listDeviceStates(com.google.cloud.iot.v1.ListDeviceStatesRequest request) { 2082 return io.grpc.stub.ClientCalls.futureUnaryCall( 2083 getChannel().newCall(getListDeviceStatesMethod(), getCallOptions()), request); 2084 } 2085 2086 /** 2087 * 2088 * 2089 * <pre> 2090 * Sets the access control policy on the specified resource. Replaces any 2091 * existing policy. 2092 * </pre> 2093 */ 2094 public com.google.common.util.concurrent.ListenableFuture<com.google.iam.v1.Policy> setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request)2095 setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) { 2096 return io.grpc.stub.ClientCalls.futureUnaryCall( 2097 getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()), request); 2098 } 2099 2100 /** 2101 * 2102 * 2103 * <pre> 2104 * Gets the access control policy for a resource. 2105 * Returns an empty policy if the resource exists and does not have a policy 2106 * set. 2107 * </pre> 2108 */ 2109 public com.google.common.util.concurrent.ListenableFuture<com.google.iam.v1.Policy> getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request)2110 getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) { 2111 return io.grpc.stub.ClientCalls.futureUnaryCall( 2112 getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()), request); 2113 } 2114 2115 /** 2116 * 2117 * 2118 * <pre> 2119 * Returns permissions that a caller has on the specified resource. 2120 * If the resource does not exist, this will return an empty set of 2121 * permissions, not a NOT_FOUND error. 2122 * </pre> 2123 */ 2124 public com.google.common.util.concurrent.ListenableFuture< 2125 com.google.iam.v1.TestIamPermissionsResponse> testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request)2126 testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) { 2127 return io.grpc.stub.ClientCalls.futureUnaryCall( 2128 getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()), request); 2129 } 2130 2131 /** 2132 * 2133 * 2134 * <pre> 2135 * Sends a command to the specified device. In order for a device to be able 2136 * to receive commands, it must: 2137 * 1) be connected to Cloud IoT Core using the MQTT protocol, and 2138 * 2) be subscribed to the group of MQTT topics specified by 2139 * /devices/{device-id}/commands/#. This subscription will receive commands 2140 * at the top-level topic /devices/{device-id}/commands as well as commands 2141 * for subfolders, like /devices/{device-id}/commands/subfolder. 2142 * Note that subscribing to specific subfolders is not supported. 2143 * If the command could not be delivered to the device, this method will 2144 * return an error; in particular, if the device is not subscribed, this 2145 * method will return FAILED_PRECONDITION. Otherwise, this method will 2146 * return OK. If the subscription is QoS 1, at least once delivery will be 2147 * guaranteed; for QoS 0, no acknowledgment will be expected from the device. 2148 * </pre> 2149 */ 2150 public com.google.common.util.concurrent.ListenableFuture< 2151 com.google.cloud.iot.v1.SendCommandToDeviceResponse> sendCommandToDevice(com.google.cloud.iot.v1.SendCommandToDeviceRequest request)2152 sendCommandToDevice(com.google.cloud.iot.v1.SendCommandToDeviceRequest request) { 2153 return io.grpc.stub.ClientCalls.futureUnaryCall( 2154 getChannel().newCall(getSendCommandToDeviceMethod(), getCallOptions()), request); 2155 } 2156 2157 /** 2158 * 2159 * 2160 * <pre> 2161 * Associates the device with the gateway. 2162 * </pre> 2163 */ 2164 public com.google.common.util.concurrent.ListenableFuture< 2165 com.google.cloud.iot.v1.BindDeviceToGatewayResponse> bindDeviceToGateway(com.google.cloud.iot.v1.BindDeviceToGatewayRequest request)2166 bindDeviceToGateway(com.google.cloud.iot.v1.BindDeviceToGatewayRequest request) { 2167 return io.grpc.stub.ClientCalls.futureUnaryCall( 2168 getChannel().newCall(getBindDeviceToGatewayMethod(), getCallOptions()), request); 2169 } 2170 2171 /** 2172 * 2173 * 2174 * <pre> 2175 * Deletes the association between the device and the gateway. 2176 * </pre> 2177 */ 2178 public com.google.common.util.concurrent.ListenableFuture< 2179 com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse> unbindDeviceFromGateway(com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request)2180 unbindDeviceFromGateway(com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest request) { 2181 return io.grpc.stub.ClientCalls.futureUnaryCall( 2182 getChannel().newCall(getUnbindDeviceFromGatewayMethod(), getCallOptions()), request); 2183 } 2184 } 2185 2186 private static final int METHODID_CREATE_DEVICE_REGISTRY = 0; 2187 private static final int METHODID_GET_DEVICE_REGISTRY = 1; 2188 private static final int METHODID_UPDATE_DEVICE_REGISTRY = 2; 2189 private static final int METHODID_DELETE_DEVICE_REGISTRY = 3; 2190 private static final int METHODID_LIST_DEVICE_REGISTRIES = 4; 2191 private static final int METHODID_CREATE_DEVICE = 5; 2192 private static final int METHODID_GET_DEVICE = 6; 2193 private static final int METHODID_UPDATE_DEVICE = 7; 2194 private static final int METHODID_DELETE_DEVICE = 8; 2195 private static final int METHODID_LIST_DEVICES = 9; 2196 private static final int METHODID_MODIFY_CLOUD_TO_DEVICE_CONFIG = 10; 2197 private static final int METHODID_LIST_DEVICE_CONFIG_VERSIONS = 11; 2198 private static final int METHODID_LIST_DEVICE_STATES = 12; 2199 private static final int METHODID_SET_IAM_POLICY = 13; 2200 private static final int METHODID_GET_IAM_POLICY = 14; 2201 private static final int METHODID_TEST_IAM_PERMISSIONS = 15; 2202 private static final int METHODID_SEND_COMMAND_TO_DEVICE = 16; 2203 private static final int METHODID_BIND_DEVICE_TO_GATEWAY = 17; 2204 private static final int METHODID_UNBIND_DEVICE_FROM_GATEWAY = 18; 2205 2206 private static final class MethodHandlers<Req, Resp> 2207 implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>, 2208 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>, 2209 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>, 2210 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> { 2211 private final AsyncService serviceImpl; 2212 private final int methodId; 2213 MethodHandlers(AsyncService serviceImpl, int methodId)2214 MethodHandlers(AsyncService serviceImpl, int methodId) { 2215 this.serviceImpl = serviceImpl; 2216 this.methodId = methodId; 2217 } 2218 2219 @java.lang.Override 2220 @java.lang.SuppressWarnings("unchecked") invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver)2221 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { 2222 switch (methodId) { 2223 case METHODID_CREATE_DEVICE_REGISTRY: 2224 serviceImpl.createDeviceRegistry( 2225 (com.google.cloud.iot.v1.CreateDeviceRegistryRequest) request, 2226 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry>) 2227 responseObserver); 2228 break; 2229 case METHODID_GET_DEVICE_REGISTRY: 2230 serviceImpl.getDeviceRegistry( 2231 (com.google.cloud.iot.v1.GetDeviceRegistryRequest) request, 2232 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry>) 2233 responseObserver); 2234 break; 2235 case METHODID_UPDATE_DEVICE_REGISTRY: 2236 serviceImpl.updateDeviceRegistry( 2237 (com.google.cloud.iot.v1.UpdateDeviceRegistryRequest) request, 2238 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceRegistry>) 2239 responseObserver); 2240 break; 2241 case METHODID_DELETE_DEVICE_REGISTRY: 2242 serviceImpl.deleteDeviceRegistry( 2243 (com.google.cloud.iot.v1.DeleteDeviceRegistryRequest) request, 2244 (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver); 2245 break; 2246 case METHODID_LIST_DEVICE_REGISTRIES: 2247 serviceImpl.listDeviceRegistries( 2248 (com.google.cloud.iot.v1.ListDeviceRegistriesRequest) request, 2249 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceRegistriesResponse>) 2250 responseObserver); 2251 break; 2252 case METHODID_CREATE_DEVICE: 2253 serviceImpl.createDevice( 2254 (com.google.cloud.iot.v1.CreateDeviceRequest) request, 2255 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device>) responseObserver); 2256 break; 2257 case METHODID_GET_DEVICE: 2258 serviceImpl.getDevice( 2259 (com.google.cloud.iot.v1.GetDeviceRequest) request, 2260 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device>) responseObserver); 2261 break; 2262 case METHODID_UPDATE_DEVICE: 2263 serviceImpl.updateDevice( 2264 (com.google.cloud.iot.v1.UpdateDeviceRequest) request, 2265 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.Device>) responseObserver); 2266 break; 2267 case METHODID_DELETE_DEVICE: 2268 serviceImpl.deleteDevice( 2269 (com.google.cloud.iot.v1.DeleteDeviceRequest) request, 2270 (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver); 2271 break; 2272 case METHODID_LIST_DEVICES: 2273 serviceImpl.listDevices( 2274 (com.google.cloud.iot.v1.ListDevicesRequest) request, 2275 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDevicesResponse>) 2276 responseObserver); 2277 break; 2278 case METHODID_MODIFY_CLOUD_TO_DEVICE_CONFIG: 2279 serviceImpl.modifyCloudToDeviceConfig( 2280 (com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest) request, 2281 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.DeviceConfig>) responseObserver); 2282 break; 2283 case METHODID_LIST_DEVICE_CONFIG_VERSIONS: 2284 serviceImpl.listDeviceConfigVersions( 2285 (com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest) request, 2286 (io.grpc.stub.StreamObserver< 2287 com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse>) 2288 responseObserver); 2289 break; 2290 case METHODID_LIST_DEVICE_STATES: 2291 serviceImpl.listDeviceStates( 2292 (com.google.cloud.iot.v1.ListDeviceStatesRequest) request, 2293 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.ListDeviceStatesResponse>) 2294 responseObserver); 2295 break; 2296 case METHODID_SET_IAM_POLICY: 2297 serviceImpl.setIamPolicy( 2298 (com.google.iam.v1.SetIamPolicyRequest) request, 2299 (io.grpc.stub.StreamObserver<com.google.iam.v1.Policy>) responseObserver); 2300 break; 2301 case METHODID_GET_IAM_POLICY: 2302 serviceImpl.getIamPolicy( 2303 (com.google.iam.v1.GetIamPolicyRequest) request, 2304 (io.grpc.stub.StreamObserver<com.google.iam.v1.Policy>) responseObserver); 2305 break; 2306 case METHODID_TEST_IAM_PERMISSIONS: 2307 serviceImpl.testIamPermissions( 2308 (com.google.iam.v1.TestIamPermissionsRequest) request, 2309 (io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse>) 2310 responseObserver); 2311 break; 2312 case METHODID_SEND_COMMAND_TO_DEVICE: 2313 serviceImpl.sendCommandToDevice( 2314 (com.google.cloud.iot.v1.SendCommandToDeviceRequest) request, 2315 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.SendCommandToDeviceResponse>) 2316 responseObserver); 2317 break; 2318 case METHODID_BIND_DEVICE_TO_GATEWAY: 2319 serviceImpl.bindDeviceToGateway( 2320 (com.google.cloud.iot.v1.BindDeviceToGatewayRequest) request, 2321 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.BindDeviceToGatewayResponse>) 2322 responseObserver); 2323 break; 2324 case METHODID_UNBIND_DEVICE_FROM_GATEWAY: 2325 serviceImpl.unbindDeviceFromGateway( 2326 (com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest) request, 2327 (io.grpc.stub.StreamObserver<com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse>) 2328 responseObserver); 2329 break; 2330 default: 2331 throw new AssertionError(); 2332 } 2333 } 2334 2335 @java.lang.Override 2336 @java.lang.SuppressWarnings("unchecked") invoke( io.grpc.stub.StreamObserver<Resp> responseObserver)2337 public io.grpc.stub.StreamObserver<Req> invoke( 2338 io.grpc.stub.StreamObserver<Resp> responseObserver) { 2339 switch (methodId) { 2340 default: 2341 throw new AssertionError(); 2342 } 2343 } 2344 } 2345 bindService(AsyncService service)2346 public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) { 2347 return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) 2348 .addMethod( 2349 getCreateDeviceRegistryMethod(), 2350 io.grpc.stub.ServerCalls.asyncUnaryCall( 2351 new MethodHandlers< 2352 com.google.cloud.iot.v1.CreateDeviceRegistryRequest, 2353 com.google.cloud.iot.v1.DeviceRegistry>( 2354 service, METHODID_CREATE_DEVICE_REGISTRY))) 2355 .addMethod( 2356 getGetDeviceRegistryMethod(), 2357 io.grpc.stub.ServerCalls.asyncUnaryCall( 2358 new MethodHandlers< 2359 com.google.cloud.iot.v1.GetDeviceRegistryRequest, 2360 com.google.cloud.iot.v1.DeviceRegistry>(service, METHODID_GET_DEVICE_REGISTRY))) 2361 .addMethod( 2362 getUpdateDeviceRegistryMethod(), 2363 io.grpc.stub.ServerCalls.asyncUnaryCall( 2364 new MethodHandlers< 2365 com.google.cloud.iot.v1.UpdateDeviceRegistryRequest, 2366 com.google.cloud.iot.v1.DeviceRegistry>( 2367 service, METHODID_UPDATE_DEVICE_REGISTRY))) 2368 .addMethod( 2369 getDeleteDeviceRegistryMethod(), 2370 io.grpc.stub.ServerCalls.asyncUnaryCall( 2371 new MethodHandlers< 2372 com.google.cloud.iot.v1.DeleteDeviceRegistryRequest, com.google.protobuf.Empty>( 2373 service, METHODID_DELETE_DEVICE_REGISTRY))) 2374 .addMethod( 2375 getListDeviceRegistriesMethod(), 2376 io.grpc.stub.ServerCalls.asyncUnaryCall( 2377 new MethodHandlers< 2378 com.google.cloud.iot.v1.ListDeviceRegistriesRequest, 2379 com.google.cloud.iot.v1.ListDeviceRegistriesResponse>( 2380 service, METHODID_LIST_DEVICE_REGISTRIES))) 2381 .addMethod( 2382 getCreateDeviceMethod(), 2383 io.grpc.stub.ServerCalls.asyncUnaryCall( 2384 new MethodHandlers< 2385 com.google.cloud.iot.v1.CreateDeviceRequest, com.google.cloud.iot.v1.Device>( 2386 service, METHODID_CREATE_DEVICE))) 2387 .addMethod( 2388 getGetDeviceMethod(), 2389 io.grpc.stub.ServerCalls.asyncUnaryCall( 2390 new MethodHandlers< 2391 com.google.cloud.iot.v1.GetDeviceRequest, com.google.cloud.iot.v1.Device>( 2392 service, METHODID_GET_DEVICE))) 2393 .addMethod( 2394 getUpdateDeviceMethod(), 2395 io.grpc.stub.ServerCalls.asyncUnaryCall( 2396 new MethodHandlers< 2397 com.google.cloud.iot.v1.UpdateDeviceRequest, com.google.cloud.iot.v1.Device>( 2398 service, METHODID_UPDATE_DEVICE))) 2399 .addMethod( 2400 getDeleteDeviceMethod(), 2401 io.grpc.stub.ServerCalls.asyncUnaryCall( 2402 new MethodHandlers< 2403 com.google.cloud.iot.v1.DeleteDeviceRequest, com.google.protobuf.Empty>( 2404 service, METHODID_DELETE_DEVICE))) 2405 .addMethod( 2406 getListDevicesMethod(), 2407 io.grpc.stub.ServerCalls.asyncUnaryCall( 2408 new MethodHandlers< 2409 com.google.cloud.iot.v1.ListDevicesRequest, 2410 com.google.cloud.iot.v1.ListDevicesResponse>(service, METHODID_LIST_DEVICES))) 2411 .addMethod( 2412 getModifyCloudToDeviceConfigMethod(), 2413 io.grpc.stub.ServerCalls.asyncUnaryCall( 2414 new MethodHandlers< 2415 com.google.cloud.iot.v1.ModifyCloudToDeviceConfigRequest, 2416 com.google.cloud.iot.v1.DeviceConfig>( 2417 service, METHODID_MODIFY_CLOUD_TO_DEVICE_CONFIG))) 2418 .addMethod( 2419 getListDeviceConfigVersionsMethod(), 2420 io.grpc.stub.ServerCalls.asyncUnaryCall( 2421 new MethodHandlers< 2422 com.google.cloud.iot.v1.ListDeviceConfigVersionsRequest, 2423 com.google.cloud.iot.v1.ListDeviceConfigVersionsResponse>( 2424 service, METHODID_LIST_DEVICE_CONFIG_VERSIONS))) 2425 .addMethod( 2426 getListDeviceStatesMethod(), 2427 io.grpc.stub.ServerCalls.asyncUnaryCall( 2428 new MethodHandlers< 2429 com.google.cloud.iot.v1.ListDeviceStatesRequest, 2430 com.google.cloud.iot.v1.ListDeviceStatesResponse>( 2431 service, METHODID_LIST_DEVICE_STATES))) 2432 .addMethod( 2433 getSetIamPolicyMethod(), 2434 io.grpc.stub.ServerCalls.asyncUnaryCall( 2435 new MethodHandlers<com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy>( 2436 service, METHODID_SET_IAM_POLICY))) 2437 .addMethod( 2438 getGetIamPolicyMethod(), 2439 io.grpc.stub.ServerCalls.asyncUnaryCall( 2440 new MethodHandlers<com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy>( 2441 service, METHODID_GET_IAM_POLICY))) 2442 .addMethod( 2443 getTestIamPermissionsMethod(), 2444 io.grpc.stub.ServerCalls.asyncUnaryCall( 2445 new MethodHandlers< 2446 com.google.iam.v1.TestIamPermissionsRequest, 2447 com.google.iam.v1.TestIamPermissionsResponse>( 2448 service, METHODID_TEST_IAM_PERMISSIONS))) 2449 .addMethod( 2450 getSendCommandToDeviceMethod(), 2451 io.grpc.stub.ServerCalls.asyncUnaryCall( 2452 new MethodHandlers< 2453 com.google.cloud.iot.v1.SendCommandToDeviceRequest, 2454 com.google.cloud.iot.v1.SendCommandToDeviceResponse>( 2455 service, METHODID_SEND_COMMAND_TO_DEVICE))) 2456 .addMethod( 2457 getBindDeviceToGatewayMethod(), 2458 io.grpc.stub.ServerCalls.asyncUnaryCall( 2459 new MethodHandlers< 2460 com.google.cloud.iot.v1.BindDeviceToGatewayRequest, 2461 com.google.cloud.iot.v1.BindDeviceToGatewayResponse>( 2462 service, METHODID_BIND_DEVICE_TO_GATEWAY))) 2463 .addMethod( 2464 getUnbindDeviceFromGatewayMethod(), 2465 io.grpc.stub.ServerCalls.asyncUnaryCall( 2466 new MethodHandlers< 2467 com.google.cloud.iot.v1.UnbindDeviceFromGatewayRequest, 2468 com.google.cloud.iot.v1.UnbindDeviceFromGatewayResponse>( 2469 service, METHODID_UNBIND_DEVICE_FROM_GATEWAY))) 2470 .build(); 2471 } 2472 2473 private abstract static class DeviceManagerBaseDescriptorSupplier 2474 implements io.grpc.protobuf.ProtoFileDescriptorSupplier, 2475 io.grpc.protobuf.ProtoServiceDescriptorSupplier { DeviceManagerBaseDescriptorSupplier()2476 DeviceManagerBaseDescriptorSupplier() {} 2477 2478 @java.lang.Override getFileDescriptor()2479 public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { 2480 return com.google.cloud.iot.v1.DeviceManagerProto.getDescriptor(); 2481 } 2482 2483 @java.lang.Override getServiceDescriptor()2484 public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { 2485 return getFileDescriptor().findServiceByName("DeviceManager"); 2486 } 2487 } 2488 2489 private static final class DeviceManagerFileDescriptorSupplier 2490 extends DeviceManagerBaseDescriptorSupplier { DeviceManagerFileDescriptorSupplier()2491 DeviceManagerFileDescriptorSupplier() {} 2492 } 2493 2494 private static final class DeviceManagerMethodDescriptorSupplier 2495 extends DeviceManagerBaseDescriptorSupplier 2496 implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { 2497 private final String methodName; 2498 DeviceManagerMethodDescriptorSupplier(String methodName)2499 DeviceManagerMethodDescriptorSupplier(String methodName) { 2500 this.methodName = methodName; 2501 } 2502 2503 @java.lang.Override getMethodDescriptor()2504 public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { 2505 return getServiceDescriptor().findMethodByName(methodName); 2506 } 2507 } 2508 2509 private static volatile io.grpc.ServiceDescriptor serviceDescriptor; 2510 getServiceDescriptor()2511 public static io.grpc.ServiceDescriptor getServiceDescriptor() { 2512 io.grpc.ServiceDescriptor result = serviceDescriptor; 2513 if (result == null) { 2514 synchronized (DeviceManagerGrpc.class) { 2515 result = serviceDescriptor; 2516 if (result == null) { 2517 serviceDescriptor = 2518 result = 2519 io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) 2520 .setSchemaDescriptor(new DeviceManagerFileDescriptorSupplier()) 2521 .addMethod(getCreateDeviceRegistryMethod()) 2522 .addMethod(getGetDeviceRegistryMethod()) 2523 .addMethod(getUpdateDeviceRegistryMethod()) 2524 .addMethod(getDeleteDeviceRegistryMethod()) 2525 .addMethod(getListDeviceRegistriesMethod()) 2526 .addMethod(getCreateDeviceMethod()) 2527 .addMethod(getGetDeviceMethod()) 2528 .addMethod(getUpdateDeviceMethod()) 2529 .addMethod(getDeleteDeviceMethod()) 2530 .addMethod(getListDevicesMethod()) 2531 .addMethod(getModifyCloudToDeviceConfigMethod()) 2532 .addMethod(getListDeviceConfigVersionsMethod()) 2533 .addMethod(getListDeviceStatesMethod()) 2534 .addMethod(getSetIamPolicyMethod()) 2535 .addMethod(getGetIamPolicyMethod()) 2536 .addMethod(getTestIamPermissionsMethod()) 2537 .addMethod(getSendCommandToDeviceMethod()) 2538 .addMethod(getBindDeviceToGatewayMethod()) 2539 .addMethod(getUnbindDeviceFromGatewayMethod()) 2540 .build(); 2541 } 2542 } 2543 } 2544 return result; 2545 } 2546 } 2547