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