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.v2beta2; 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/v2beta2/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.v2beta2.CloudTasks"; 37 38 // Static method descriptors that strictly reflect the proto. 39 private static volatile io.grpc.MethodDescriptor< 40 com.google.cloud.tasks.v2beta2.ListQueuesRequest, 41 com.google.cloud.tasks.v2beta2.ListQueuesResponse> 42 getListQueuesMethod; 43 44 @io.grpc.stub.annotations.RpcMethod( 45 fullMethodName = SERVICE_NAME + '/' + "ListQueues", 46 requestType = com.google.cloud.tasks.v2beta2.ListQueuesRequest.class, 47 responseType = com.google.cloud.tasks.v2beta2.ListQueuesResponse.class, 48 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 49 public static io.grpc.MethodDescriptor< 50 com.google.cloud.tasks.v2beta2.ListQueuesRequest, 51 com.google.cloud.tasks.v2beta2.ListQueuesResponse> getListQueuesMethod()52 getListQueuesMethod() { 53 io.grpc.MethodDescriptor< 54 com.google.cloud.tasks.v2beta2.ListQueuesRequest, 55 com.google.cloud.tasks.v2beta2.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.v2beta2.ListQueuesRequest, 64 com.google.cloud.tasks.v2beta2.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.v2beta2.ListQueuesRequest 72 .getDefaultInstance())) 73 .setResponseMarshaller( 74 io.grpc.protobuf.ProtoUtils.marshaller( 75 com.google.cloud.tasks.v2beta2.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.v2beta2.GetQueueRequest, com.google.cloud.tasks.v2beta2.Queue> 87 getGetQueueMethod; 88 89 @io.grpc.stub.annotations.RpcMethod( 90 fullMethodName = SERVICE_NAME + '/' + "GetQueue", 91 requestType = com.google.cloud.tasks.v2beta2.GetQueueRequest.class, 92 responseType = com.google.cloud.tasks.v2beta2.Queue.class, 93 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 94 public static io.grpc.MethodDescriptor< 95 com.google.cloud.tasks.v2beta2.GetQueueRequest, com.google.cloud.tasks.v2beta2.Queue> getGetQueueMethod()96 getGetQueueMethod() { 97 io.grpc.MethodDescriptor< 98 com.google.cloud.tasks.v2beta2.GetQueueRequest, com.google.cloud.tasks.v2beta2.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.v2beta2.GetQueueRequest, 107 com.google.cloud.tasks.v2beta2.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.v2beta2.GetQueueRequest.getDefaultInstance())) 115 .setResponseMarshaller( 116 io.grpc.protobuf.ProtoUtils.marshaller( 117 com.google.cloud.tasks.v2beta2.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.v2beta2.CreateQueueRequest, com.google.cloud.tasks.v2beta2.Queue> 128 getCreateQueueMethod; 129 130 @io.grpc.stub.annotations.RpcMethod( 131 fullMethodName = SERVICE_NAME + '/' + "CreateQueue", 132 requestType = com.google.cloud.tasks.v2beta2.CreateQueueRequest.class, 133 responseType = com.google.cloud.tasks.v2beta2.Queue.class, 134 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 135 public static io.grpc.MethodDescriptor< 136 com.google.cloud.tasks.v2beta2.CreateQueueRequest, com.google.cloud.tasks.v2beta2.Queue> getCreateQueueMethod()137 getCreateQueueMethod() { 138 io.grpc.MethodDescriptor< 139 com.google.cloud.tasks.v2beta2.CreateQueueRequest, com.google.cloud.tasks.v2beta2.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.v2beta2.CreateQueueRequest, 148 com.google.cloud.tasks.v2beta2.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.v2beta2.CreateQueueRequest 156 .getDefaultInstance())) 157 .setResponseMarshaller( 158 io.grpc.protobuf.ProtoUtils.marshaller( 159 com.google.cloud.tasks.v2beta2.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.v2beta2.UpdateQueueRequest, com.google.cloud.tasks.v2beta2.Queue> 170 getUpdateQueueMethod; 171 172 @io.grpc.stub.annotations.RpcMethod( 173 fullMethodName = SERVICE_NAME + '/' + "UpdateQueue", 174 requestType = com.google.cloud.tasks.v2beta2.UpdateQueueRequest.class, 175 responseType = com.google.cloud.tasks.v2beta2.Queue.class, 176 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 177 public static io.grpc.MethodDescriptor< 178 com.google.cloud.tasks.v2beta2.UpdateQueueRequest, com.google.cloud.tasks.v2beta2.Queue> getUpdateQueueMethod()179 getUpdateQueueMethod() { 180 io.grpc.MethodDescriptor< 181 com.google.cloud.tasks.v2beta2.UpdateQueueRequest, com.google.cloud.tasks.v2beta2.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.v2beta2.UpdateQueueRequest, 190 com.google.cloud.tasks.v2beta2.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.v2beta2.UpdateQueueRequest 198 .getDefaultInstance())) 199 .setResponseMarshaller( 200 io.grpc.protobuf.ProtoUtils.marshaller( 201 com.google.cloud.tasks.v2beta2.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.v2beta2.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.v2beta2.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.v2beta2.DeleteQueueRequest, com.google.protobuf.Empty> getDeleteQueueMethod()221 getDeleteQueueMethod() { 222 io.grpc.MethodDescriptor< 223 com.google.cloud.tasks.v2beta2.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.v2beta2.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.v2beta2.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.v2beta2.PurgeQueueRequest, com.google.cloud.tasks.v2beta2.Queue> 254 getPurgeQueueMethod; 255 256 @io.grpc.stub.annotations.RpcMethod( 257 fullMethodName = SERVICE_NAME + '/' + "PurgeQueue", 258 requestType = com.google.cloud.tasks.v2beta2.PurgeQueueRequest.class, 259 responseType = com.google.cloud.tasks.v2beta2.Queue.class, 260 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 261 public static io.grpc.MethodDescriptor< 262 com.google.cloud.tasks.v2beta2.PurgeQueueRequest, com.google.cloud.tasks.v2beta2.Queue> getPurgeQueueMethod()263 getPurgeQueueMethod() { 264 io.grpc.MethodDescriptor< 265 com.google.cloud.tasks.v2beta2.PurgeQueueRequest, com.google.cloud.tasks.v2beta2.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.v2beta2.PurgeQueueRequest, 274 com.google.cloud.tasks.v2beta2.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.v2beta2.PurgeQueueRequest 282 .getDefaultInstance())) 283 .setResponseMarshaller( 284 io.grpc.protobuf.ProtoUtils.marshaller( 285 com.google.cloud.tasks.v2beta2.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.v2beta2.PauseQueueRequest, com.google.cloud.tasks.v2beta2.Queue> 296 getPauseQueueMethod; 297 298 @io.grpc.stub.annotations.RpcMethod( 299 fullMethodName = SERVICE_NAME + '/' + "PauseQueue", 300 requestType = com.google.cloud.tasks.v2beta2.PauseQueueRequest.class, 301 responseType = com.google.cloud.tasks.v2beta2.Queue.class, 302 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 303 public static io.grpc.MethodDescriptor< 304 com.google.cloud.tasks.v2beta2.PauseQueueRequest, com.google.cloud.tasks.v2beta2.Queue> getPauseQueueMethod()305 getPauseQueueMethod() { 306 io.grpc.MethodDescriptor< 307 com.google.cloud.tasks.v2beta2.PauseQueueRequest, com.google.cloud.tasks.v2beta2.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.v2beta2.PauseQueueRequest, 316 com.google.cloud.tasks.v2beta2.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.v2beta2.PauseQueueRequest 324 .getDefaultInstance())) 325 .setResponseMarshaller( 326 io.grpc.protobuf.ProtoUtils.marshaller( 327 com.google.cloud.tasks.v2beta2.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.v2beta2.ResumeQueueRequest, com.google.cloud.tasks.v2beta2.Queue> 338 getResumeQueueMethod; 339 340 @io.grpc.stub.annotations.RpcMethod( 341 fullMethodName = SERVICE_NAME + '/' + "ResumeQueue", 342 requestType = com.google.cloud.tasks.v2beta2.ResumeQueueRequest.class, 343 responseType = com.google.cloud.tasks.v2beta2.Queue.class, 344 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 345 public static io.grpc.MethodDescriptor< 346 com.google.cloud.tasks.v2beta2.ResumeQueueRequest, com.google.cloud.tasks.v2beta2.Queue> getResumeQueueMethod()347 getResumeQueueMethod() { 348 io.grpc.MethodDescriptor< 349 com.google.cloud.tasks.v2beta2.ResumeQueueRequest, com.google.cloud.tasks.v2beta2.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.v2beta2.ResumeQueueRequest, 358 com.google.cloud.tasks.v2beta2.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.v2beta2.ResumeQueueRequest 366 .getDefaultInstance())) 367 .setResponseMarshaller( 368 io.grpc.protobuf.ProtoUtils.marshaller( 369 com.google.cloud.tasks.v2beta2.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.v2beta2.ListTasksRequest, 499 com.google.cloud.tasks.v2beta2.ListTasksResponse> 500 getListTasksMethod; 501 502 @io.grpc.stub.annotations.RpcMethod( 503 fullMethodName = SERVICE_NAME + '/' + "ListTasks", 504 requestType = com.google.cloud.tasks.v2beta2.ListTasksRequest.class, 505 responseType = com.google.cloud.tasks.v2beta2.ListTasksResponse.class, 506 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 507 public static io.grpc.MethodDescriptor< 508 com.google.cloud.tasks.v2beta2.ListTasksRequest, 509 com.google.cloud.tasks.v2beta2.ListTasksResponse> getListTasksMethod()510 getListTasksMethod() { 511 io.grpc.MethodDescriptor< 512 com.google.cloud.tasks.v2beta2.ListTasksRequest, 513 com.google.cloud.tasks.v2beta2.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.v2beta2.ListTasksRequest, 522 com.google.cloud.tasks.v2beta2.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.v2beta2.ListTasksRequest.getDefaultInstance())) 530 .setResponseMarshaller( 531 io.grpc.protobuf.ProtoUtils.marshaller( 532 com.google.cloud.tasks.v2beta2.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.v2beta2.GetTaskRequest, com.google.cloud.tasks.v2beta2.Task> 544 getGetTaskMethod; 545 546 @io.grpc.stub.annotations.RpcMethod( 547 fullMethodName = SERVICE_NAME + '/' + "GetTask", 548 requestType = com.google.cloud.tasks.v2beta2.GetTaskRequest.class, 549 responseType = com.google.cloud.tasks.v2beta2.Task.class, 550 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 551 public static io.grpc.MethodDescriptor< 552 com.google.cloud.tasks.v2beta2.GetTaskRequest, com.google.cloud.tasks.v2beta2.Task> getGetTaskMethod()553 getGetTaskMethod() { 554 io.grpc.MethodDescriptor< 555 com.google.cloud.tasks.v2beta2.GetTaskRequest, com.google.cloud.tasks.v2beta2.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.v2beta2.GetTaskRequest, 564 com.google.cloud.tasks.v2beta2.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.v2beta2.GetTaskRequest.getDefaultInstance())) 572 .setResponseMarshaller( 573 io.grpc.protobuf.ProtoUtils.marshaller( 574 com.google.cloud.tasks.v2beta2.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.v2beta2.CreateTaskRequest, com.google.cloud.tasks.v2beta2.Task> 585 getCreateTaskMethod; 586 587 @io.grpc.stub.annotations.RpcMethod( 588 fullMethodName = SERVICE_NAME + '/' + "CreateTask", 589 requestType = com.google.cloud.tasks.v2beta2.CreateTaskRequest.class, 590 responseType = com.google.cloud.tasks.v2beta2.Task.class, 591 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 592 public static io.grpc.MethodDescriptor< 593 com.google.cloud.tasks.v2beta2.CreateTaskRequest, com.google.cloud.tasks.v2beta2.Task> getCreateTaskMethod()594 getCreateTaskMethod() { 595 io.grpc.MethodDescriptor< 596 com.google.cloud.tasks.v2beta2.CreateTaskRequest, com.google.cloud.tasks.v2beta2.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.v2beta2.CreateTaskRequest, 605 com.google.cloud.tasks.v2beta2.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.v2beta2.CreateTaskRequest 613 .getDefaultInstance())) 614 .setResponseMarshaller( 615 io.grpc.protobuf.ProtoUtils.marshaller( 616 com.google.cloud.tasks.v2beta2.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.v2beta2.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.v2beta2.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.v2beta2.DeleteTaskRequest, com.google.protobuf.Empty> getDeleteTaskMethod()636 getDeleteTaskMethod() { 637 io.grpc.MethodDescriptor< 638 com.google.cloud.tasks.v2beta2.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.v2beta2.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.v2beta2.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.v2beta2.LeaseTasksRequest, 668 com.google.cloud.tasks.v2beta2.LeaseTasksResponse> 669 getLeaseTasksMethod; 670 671 @io.grpc.stub.annotations.RpcMethod( 672 fullMethodName = SERVICE_NAME + '/' + "LeaseTasks", 673 requestType = com.google.cloud.tasks.v2beta2.LeaseTasksRequest.class, 674 responseType = com.google.cloud.tasks.v2beta2.LeaseTasksResponse.class, 675 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 676 public static io.grpc.MethodDescriptor< 677 com.google.cloud.tasks.v2beta2.LeaseTasksRequest, 678 com.google.cloud.tasks.v2beta2.LeaseTasksResponse> getLeaseTasksMethod()679 getLeaseTasksMethod() { 680 io.grpc.MethodDescriptor< 681 com.google.cloud.tasks.v2beta2.LeaseTasksRequest, 682 com.google.cloud.tasks.v2beta2.LeaseTasksResponse> 683 getLeaseTasksMethod; 684 if ((getLeaseTasksMethod = CloudTasksGrpc.getLeaseTasksMethod) == null) { 685 synchronized (CloudTasksGrpc.class) { 686 if ((getLeaseTasksMethod = CloudTasksGrpc.getLeaseTasksMethod) == null) { 687 CloudTasksGrpc.getLeaseTasksMethod = 688 getLeaseTasksMethod = 689 io.grpc.MethodDescriptor 690 .<com.google.cloud.tasks.v2beta2.LeaseTasksRequest, 691 com.google.cloud.tasks.v2beta2.LeaseTasksResponse> 692 newBuilder() 693 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 694 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "LeaseTasks")) 695 .setSampledToLocalTracing(true) 696 .setRequestMarshaller( 697 io.grpc.protobuf.ProtoUtils.marshaller( 698 com.google.cloud.tasks.v2beta2.LeaseTasksRequest 699 .getDefaultInstance())) 700 .setResponseMarshaller( 701 io.grpc.protobuf.ProtoUtils.marshaller( 702 com.google.cloud.tasks.v2beta2.LeaseTasksResponse 703 .getDefaultInstance())) 704 .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("LeaseTasks")) 705 .build(); 706 } 707 } 708 } 709 return getLeaseTasksMethod; 710 } 711 712 private static volatile io.grpc.MethodDescriptor< 713 com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest, com.google.protobuf.Empty> 714 getAcknowledgeTaskMethod; 715 716 @io.grpc.stub.annotations.RpcMethod( 717 fullMethodName = SERVICE_NAME + '/' + "AcknowledgeTask", 718 requestType = com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest.class, 719 responseType = com.google.protobuf.Empty.class, 720 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 721 public static io.grpc.MethodDescriptor< 722 com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest, com.google.protobuf.Empty> getAcknowledgeTaskMethod()723 getAcknowledgeTaskMethod() { 724 io.grpc.MethodDescriptor< 725 com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest, com.google.protobuf.Empty> 726 getAcknowledgeTaskMethod; 727 if ((getAcknowledgeTaskMethod = CloudTasksGrpc.getAcknowledgeTaskMethod) == null) { 728 synchronized (CloudTasksGrpc.class) { 729 if ((getAcknowledgeTaskMethod = CloudTasksGrpc.getAcknowledgeTaskMethod) == null) { 730 CloudTasksGrpc.getAcknowledgeTaskMethod = 731 getAcknowledgeTaskMethod = 732 io.grpc.MethodDescriptor 733 .<com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest, 734 com.google.protobuf.Empty> 735 newBuilder() 736 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 737 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "AcknowledgeTask")) 738 .setSampledToLocalTracing(true) 739 .setRequestMarshaller( 740 io.grpc.protobuf.ProtoUtils.marshaller( 741 com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest 742 .getDefaultInstance())) 743 .setResponseMarshaller( 744 io.grpc.protobuf.ProtoUtils.marshaller( 745 com.google.protobuf.Empty.getDefaultInstance())) 746 .setSchemaDescriptor( 747 new CloudTasksMethodDescriptorSupplier("AcknowledgeTask")) 748 .build(); 749 } 750 } 751 } 752 return getAcknowledgeTaskMethod; 753 } 754 755 private static volatile io.grpc.MethodDescriptor< 756 com.google.cloud.tasks.v2beta2.RenewLeaseRequest, com.google.cloud.tasks.v2beta2.Task> 757 getRenewLeaseMethod; 758 759 @io.grpc.stub.annotations.RpcMethod( 760 fullMethodName = SERVICE_NAME + '/' + "RenewLease", 761 requestType = com.google.cloud.tasks.v2beta2.RenewLeaseRequest.class, 762 responseType = com.google.cloud.tasks.v2beta2.Task.class, 763 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 764 public static io.grpc.MethodDescriptor< 765 com.google.cloud.tasks.v2beta2.RenewLeaseRequest, com.google.cloud.tasks.v2beta2.Task> getRenewLeaseMethod()766 getRenewLeaseMethod() { 767 io.grpc.MethodDescriptor< 768 com.google.cloud.tasks.v2beta2.RenewLeaseRequest, com.google.cloud.tasks.v2beta2.Task> 769 getRenewLeaseMethod; 770 if ((getRenewLeaseMethod = CloudTasksGrpc.getRenewLeaseMethod) == null) { 771 synchronized (CloudTasksGrpc.class) { 772 if ((getRenewLeaseMethod = CloudTasksGrpc.getRenewLeaseMethod) == null) { 773 CloudTasksGrpc.getRenewLeaseMethod = 774 getRenewLeaseMethod = 775 io.grpc.MethodDescriptor 776 .<com.google.cloud.tasks.v2beta2.RenewLeaseRequest, 777 com.google.cloud.tasks.v2beta2.Task> 778 newBuilder() 779 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 780 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RenewLease")) 781 .setSampledToLocalTracing(true) 782 .setRequestMarshaller( 783 io.grpc.protobuf.ProtoUtils.marshaller( 784 com.google.cloud.tasks.v2beta2.RenewLeaseRequest 785 .getDefaultInstance())) 786 .setResponseMarshaller( 787 io.grpc.protobuf.ProtoUtils.marshaller( 788 com.google.cloud.tasks.v2beta2.Task.getDefaultInstance())) 789 .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("RenewLease")) 790 .build(); 791 } 792 } 793 } 794 return getRenewLeaseMethod; 795 } 796 797 private static volatile io.grpc.MethodDescriptor< 798 com.google.cloud.tasks.v2beta2.CancelLeaseRequest, com.google.cloud.tasks.v2beta2.Task> 799 getCancelLeaseMethod; 800 801 @io.grpc.stub.annotations.RpcMethod( 802 fullMethodName = SERVICE_NAME + '/' + "CancelLease", 803 requestType = com.google.cloud.tasks.v2beta2.CancelLeaseRequest.class, 804 responseType = com.google.cloud.tasks.v2beta2.Task.class, 805 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 806 public static io.grpc.MethodDescriptor< 807 com.google.cloud.tasks.v2beta2.CancelLeaseRequest, com.google.cloud.tasks.v2beta2.Task> getCancelLeaseMethod()808 getCancelLeaseMethod() { 809 io.grpc.MethodDescriptor< 810 com.google.cloud.tasks.v2beta2.CancelLeaseRequest, com.google.cloud.tasks.v2beta2.Task> 811 getCancelLeaseMethod; 812 if ((getCancelLeaseMethod = CloudTasksGrpc.getCancelLeaseMethod) == null) { 813 synchronized (CloudTasksGrpc.class) { 814 if ((getCancelLeaseMethod = CloudTasksGrpc.getCancelLeaseMethod) == null) { 815 CloudTasksGrpc.getCancelLeaseMethod = 816 getCancelLeaseMethod = 817 io.grpc.MethodDescriptor 818 .<com.google.cloud.tasks.v2beta2.CancelLeaseRequest, 819 com.google.cloud.tasks.v2beta2.Task> 820 newBuilder() 821 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 822 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CancelLease")) 823 .setSampledToLocalTracing(true) 824 .setRequestMarshaller( 825 io.grpc.protobuf.ProtoUtils.marshaller( 826 com.google.cloud.tasks.v2beta2.CancelLeaseRequest 827 .getDefaultInstance())) 828 .setResponseMarshaller( 829 io.grpc.protobuf.ProtoUtils.marshaller( 830 com.google.cloud.tasks.v2beta2.Task.getDefaultInstance())) 831 .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("CancelLease")) 832 .build(); 833 } 834 } 835 } 836 return getCancelLeaseMethod; 837 } 838 839 private static volatile io.grpc.MethodDescriptor< 840 com.google.cloud.tasks.v2beta2.RunTaskRequest, com.google.cloud.tasks.v2beta2.Task> 841 getRunTaskMethod; 842 843 @io.grpc.stub.annotations.RpcMethod( 844 fullMethodName = SERVICE_NAME + '/' + "RunTask", 845 requestType = com.google.cloud.tasks.v2beta2.RunTaskRequest.class, 846 responseType = com.google.cloud.tasks.v2beta2.Task.class, 847 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 848 public static io.grpc.MethodDescriptor< 849 com.google.cloud.tasks.v2beta2.RunTaskRequest, com.google.cloud.tasks.v2beta2.Task> getRunTaskMethod()850 getRunTaskMethod() { 851 io.grpc.MethodDescriptor< 852 com.google.cloud.tasks.v2beta2.RunTaskRequest, com.google.cloud.tasks.v2beta2.Task> 853 getRunTaskMethod; 854 if ((getRunTaskMethod = CloudTasksGrpc.getRunTaskMethod) == null) { 855 synchronized (CloudTasksGrpc.class) { 856 if ((getRunTaskMethod = CloudTasksGrpc.getRunTaskMethod) == null) { 857 CloudTasksGrpc.getRunTaskMethod = 858 getRunTaskMethod = 859 io.grpc.MethodDescriptor 860 .<com.google.cloud.tasks.v2beta2.RunTaskRequest, 861 com.google.cloud.tasks.v2beta2.Task> 862 newBuilder() 863 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 864 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RunTask")) 865 .setSampledToLocalTracing(true) 866 .setRequestMarshaller( 867 io.grpc.protobuf.ProtoUtils.marshaller( 868 com.google.cloud.tasks.v2beta2.RunTaskRequest.getDefaultInstance())) 869 .setResponseMarshaller( 870 io.grpc.protobuf.ProtoUtils.marshaller( 871 com.google.cloud.tasks.v2beta2.Task.getDefaultInstance())) 872 .setSchemaDescriptor(new CloudTasksMethodDescriptorSupplier("RunTask")) 873 .build(); 874 } 875 } 876 } 877 return getRunTaskMethod; 878 } 879 880 /** Creates a new async stub that supports all call types for the service */ newStub(io.grpc.Channel channel)881 public static CloudTasksStub newStub(io.grpc.Channel channel) { 882 io.grpc.stub.AbstractStub.StubFactory<CloudTasksStub> factory = 883 new io.grpc.stub.AbstractStub.StubFactory<CloudTasksStub>() { 884 @java.lang.Override 885 public CloudTasksStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 886 return new CloudTasksStub(channel, callOptions); 887 } 888 }; 889 return CloudTasksStub.newStub(factory, channel); 890 } 891 892 /** 893 * Creates a new blocking-style stub that supports unary and streaming output calls on the service 894 */ newBlockingStub(io.grpc.Channel channel)895 public static CloudTasksBlockingStub newBlockingStub(io.grpc.Channel channel) { 896 io.grpc.stub.AbstractStub.StubFactory<CloudTasksBlockingStub> factory = 897 new io.grpc.stub.AbstractStub.StubFactory<CloudTasksBlockingStub>() { 898 @java.lang.Override 899 public CloudTasksBlockingStub newStub( 900 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 901 return new CloudTasksBlockingStub(channel, callOptions); 902 } 903 }; 904 return CloudTasksBlockingStub.newStub(factory, channel); 905 } 906 907 /** Creates a new ListenableFuture-style stub that supports unary calls on the service */ newFutureStub(io.grpc.Channel channel)908 public static CloudTasksFutureStub newFutureStub(io.grpc.Channel channel) { 909 io.grpc.stub.AbstractStub.StubFactory<CloudTasksFutureStub> factory = 910 new io.grpc.stub.AbstractStub.StubFactory<CloudTasksFutureStub>() { 911 @java.lang.Override 912 public CloudTasksFutureStub newStub( 913 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 914 return new CloudTasksFutureStub(channel, callOptions); 915 } 916 }; 917 return CloudTasksFutureStub.newStub(factory, channel); 918 } 919 920 /** 921 * 922 * 923 * <pre> 924 * Cloud Tasks allows developers to manage the execution of background 925 * work in their applications. 926 * </pre> 927 */ 928 public interface AsyncService { 929 930 /** 931 * 932 * 933 * <pre> 934 * Lists queues. 935 * Queues are returned in lexicographical order. 936 * </pre> 937 */ listQueues( com.google.cloud.tasks.v2beta2.ListQueuesRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListQueuesResponse> responseObserver)938 default void listQueues( 939 com.google.cloud.tasks.v2beta2.ListQueuesRequest request, 940 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListQueuesResponse> 941 responseObserver) { 942 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListQueuesMethod(), responseObserver); 943 } 944 945 /** 946 * 947 * 948 * <pre> 949 * Gets a queue. 950 * </pre> 951 */ getQueue( com.google.cloud.tasks.v2beta2.GetQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)952 default void getQueue( 953 com.google.cloud.tasks.v2beta2.GetQueueRequest request, 954 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 955 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetQueueMethod(), responseObserver); 956 } 957 958 /** 959 * 960 * 961 * <pre> 962 * Creates a queue. 963 * Queues created with this method allow tasks to live for a maximum of 31 964 * days. After a task is 31 days old, the task will be deleted regardless of 965 * whether it was dispatched or not. 966 * WARNING: Using this method may have unintended side effects if you are 967 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 968 * Read 969 * [Overview of Queue Management and 970 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 971 * this method. 972 * </pre> 973 */ createQueue( com.google.cloud.tasks.v2beta2.CreateQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)974 default void createQueue( 975 com.google.cloud.tasks.v2beta2.CreateQueueRequest request, 976 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 977 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 978 getCreateQueueMethod(), responseObserver); 979 } 980 981 /** 982 * 983 * 984 * <pre> 985 * Updates a queue. 986 * This method creates the queue if it does not exist and updates 987 * the queue if it does exist. 988 * Queues created with this method allow tasks to live for a maximum of 31 989 * days. After a task is 31 days old, the task will be deleted regardless of 990 * whether it was dispatched or not. 991 * WARNING: Using this method may have unintended side effects if you are 992 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 993 * Read 994 * [Overview of Queue Management and 995 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 996 * this method. 997 * </pre> 998 */ updateQueue( com.google.cloud.tasks.v2beta2.UpdateQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)999 default void updateQueue( 1000 com.google.cloud.tasks.v2beta2.UpdateQueueRequest request, 1001 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1002 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1003 getUpdateQueueMethod(), responseObserver); 1004 } 1005 1006 /** 1007 * 1008 * 1009 * <pre> 1010 * Deletes a queue. 1011 * This command will delete the queue even if it has tasks in it. 1012 * Note: If you delete a queue, a queue with the same name can't be created 1013 * for 7 days. 1014 * WARNING: Using this method may have unintended side effects if you are 1015 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1016 * Read 1017 * [Overview of Queue Management and 1018 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1019 * this method. 1020 * </pre> 1021 */ deleteQueue( com.google.cloud.tasks.v2beta2.DeleteQueueRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1022 default void deleteQueue( 1023 com.google.cloud.tasks.v2beta2.DeleteQueueRequest request, 1024 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1025 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1026 getDeleteQueueMethod(), responseObserver); 1027 } 1028 1029 /** 1030 * 1031 * 1032 * <pre> 1033 * Purges a queue by deleting all of its tasks. 1034 * All tasks created before this method is called are permanently deleted. 1035 * Purge operations can take up to one minute to take effect. Tasks 1036 * might be dispatched before the purge takes effect. A purge is irreversible. 1037 * </pre> 1038 */ purgeQueue( com.google.cloud.tasks.v2beta2.PurgeQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1039 default void purgeQueue( 1040 com.google.cloud.tasks.v2beta2.PurgeQueueRequest request, 1041 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1042 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getPurgeQueueMethod(), responseObserver); 1043 } 1044 1045 /** 1046 * 1047 * 1048 * <pre> 1049 * Pauses the queue. 1050 * If a queue is paused then the system will stop dispatching tasks 1051 * until the queue is resumed via 1052 * [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can 1053 * still be added when the queue is paused. A queue is paused if its 1054 * [state][google.cloud.tasks.v2beta2.Queue.state] is 1055 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED]. 1056 * </pre> 1057 */ pauseQueue( com.google.cloud.tasks.v2beta2.PauseQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1058 default void pauseQueue( 1059 com.google.cloud.tasks.v2beta2.PauseQueueRequest request, 1060 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1061 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getPauseQueueMethod(), responseObserver); 1062 } 1063 1064 /** 1065 * 1066 * 1067 * <pre> 1068 * Resume a queue. 1069 * This method resumes a queue after it has been 1070 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or 1071 * [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a 1072 * queue is stored in the queue's 1073 * [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method 1074 * it will be set to 1075 * [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING]. 1076 * WARNING: Resuming many high-QPS queues at the same time can 1077 * lead to target overloading. If you are resuming high-QPS 1078 * queues, follow the 500/50/5 pattern described in 1079 * [Managing Cloud Tasks Scaling 1080 * Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). 1081 * </pre> 1082 */ resumeQueue( com.google.cloud.tasks.v2beta2.ResumeQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1083 default void resumeQueue( 1084 com.google.cloud.tasks.v2beta2.ResumeQueueRequest request, 1085 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1086 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1087 getResumeQueueMethod(), responseObserver); 1088 } 1089 1090 /** 1091 * 1092 * 1093 * <pre> 1094 * Gets the access control policy for a 1095 * [Queue][google.cloud.tasks.v2beta2.Queue]. Returns an empty policy if the 1096 * resource exists and does not have a policy set. 1097 * Authorization requires the following 1098 * [Google IAM](https://cloud.google.com/iam) permission on the specified 1099 * resource parent: 1100 * * `cloudtasks.queues.getIamPolicy` 1101 * </pre> 1102 */ getIamPolicy( com.google.iam.v1.GetIamPolicyRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver)1103 default void getIamPolicy( 1104 com.google.iam.v1.GetIamPolicyRequest request, 1105 io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) { 1106 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1107 getGetIamPolicyMethod(), responseObserver); 1108 } 1109 1110 /** 1111 * 1112 * 1113 * <pre> 1114 * Sets the access control policy for a 1115 * [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing policy. 1116 * Note: The Cloud Console does not check queue-level IAM permissions yet. 1117 * Project-level permissions are required to use the Cloud Console. 1118 * Authorization requires the following 1119 * [Google IAM](https://cloud.google.com/iam) permission on the specified 1120 * resource parent: 1121 * * `cloudtasks.queues.setIamPolicy` 1122 * </pre> 1123 */ setIamPolicy( com.google.iam.v1.SetIamPolicyRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver)1124 default void setIamPolicy( 1125 com.google.iam.v1.SetIamPolicyRequest request, 1126 io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) { 1127 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1128 getSetIamPolicyMethod(), responseObserver); 1129 } 1130 1131 /** 1132 * 1133 * 1134 * <pre> 1135 * Returns permissions that a caller has on a 1136 * [Queue][google.cloud.tasks.v2beta2.Queue]. If the resource does not exist, 1137 * this will return an empty set of permissions, not a 1138 * [NOT_FOUND][google.rpc.Code.NOT_FOUND] error. 1139 * Note: This operation is designed to be used for building permission-aware 1140 * UIs and command-line tools, not for authorization checking. This operation 1141 * may "fail open" without warning. 1142 * </pre> 1143 */ testIamPermissions( com.google.iam.v1.TestIamPermissionsRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> responseObserver)1144 default void testIamPermissions( 1145 com.google.iam.v1.TestIamPermissionsRequest request, 1146 io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> 1147 responseObserver) { 1148 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1149 getTestIamPermissionsMethod(), responseObserver); 1150 } 1151 1152 /** 1153 * 1154 * 1155 * <pre> 1156 * Lists the tasks in a queue. 1157 * By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] 1158 * view is retrieved due to performance considerations; 1159 * [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] 1160 * controls the subset of information which is returned. 1161 * The tasks may be returned in any order. The ordering may change at any 1162 * time. 1163 * </pre> 1164 */ listTasks( com.google.cloud.tasks.v2beta2.ListTasksRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListTasksResponse> responseObserver)1165 default void listTasks( 1166 com.google.cloud.tasks.v2beta2.ListTasksRequest request, 1167 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListTasksResponse> 1168 responseObserver) { 1169 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListTasksMethod(), responseObserver); 1170 } 1171 1172 /** 1173 * 1174 * 1175 * <pre> 1176 * Gets a task. 1177 * </pre> 1178 */ getTask( com.google.cloud.tasks.v2beta2.GetTaskRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1179 default void getTask( 1180 com.google.cloud.tasks.v2beta2.GetTaskRequest request, 1181 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1182 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetTaskMethod(), responseObserver); 1183 } 1184 1185 /** 1186 * 1187 * 1188 * <pre> 1189 * Creates a task and adds it to a queue. 1190 * Tasks cannot be updated after creation; there is no UpdateTask command. 1191 * * For [App Engine queues][google.cloud.tasks.v2beta2.AppEngineHttpTarget], 1192 * the maximum task size is 1193 * 100KB. 1194 * * For [pull queues][google.cloud.tasks.v2beta2.PullTarget], the maximum 1195 * task size is 1MB. 1196 * </pre> 1197 */ createTask( com.google.cloud.tasks.v2beta2.CreateTaskRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1198 default void createTask( 1199 com.google.cloud.tasks.v2beta2.CreateTaskRequest request, 1200 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1201 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateTaskMethod(), responseObserver); 1202 } 1203 1204 /** 1205 * 1206 * 1207 * <pre> 1208 * Deletes a task. 1209 * A task can be deleted if it is scheduled or dispatched. A task 1210 * cannot be deleted if it has completed successfully or permanently 1211 * failed. 1212 * </pre> 1213 */ deleteTask( com.google.cloud.tasks.v2beta2.DeleteTaskRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1214 default void deleteTask( 1215 com.google.cloud.tasks.v2beta2.DeleteTaskRequest request, 1216 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1217 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDeleteTaskMethod(), responseObserver); 1218 } 1219 1220 /** 1221 * 1222 * 1223 * <pre> 1224 * Leases tasks from a pull queue for 1225 * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration]. 1226 * This method is invoked by the worker to obtain a lease. The 1227 * worker must acknowledge the task via 1228 * [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] 1229 * after they have performed the work associated with the task. 1230 * The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended 1231 * to store data that the worker needs to perform the work associated with the 1232 * task. To return the payloads in the 1233 * [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set 1234 * [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] 1235 * to [FULL][google.cloud.tasks.v2beta2.Task.View.FULL]. 1236 * A maximum of 10 qps of 1237 * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] requests are 1238 * allowed per queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED] 1239 * is returned when this limit is 1240 * exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED] 1241 * is also returned when 1242 * [max_tasks_dispatched_per_second][google.cloud.tasks.v2beta2.RateLimits.max_tasks_dispatched_per_second] 1243 * is exceeded. 1244 * </pre> 1245 */ leaseTasks( com.google.cloud.tasks.v2beta2.LeaseTasksRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.LeaseTasksResponse> responseObserver)1246 default void leaseTasks( 1247 com.google.cloud.tasks.v2beta2.LeaseTasksRequest request, 1248 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.LeaseTasksResponse> 1249 responseObserver) { 1250 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getLeaseTasksMethod(), responseObserver); 1251 } 1252 1253 /** 1254 * 1255 * 1256 * <pre> 1257 * Acknowledges a pull task. 1258 * The worker, that is, the entity that 1259 * [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must 1260 * call this method to indicate that the work associated with the task has 1261 * finished. 1262 * The worker must acknowledge a task within the 1263 * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] 1264 * or the lease will expire and the task will become available to be leased 1265 * again. After the task is acknowledged, it will not be returned 1266 * by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks], 1267 * [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or 1268 * [ListTasks][google.cloud.tasks.v2beta2.CloudTasks.ListTasks]. 1269 * </pre> 1270 */ acknowledgeTask( com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1271 default void acknowledgeTask( 1272 com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request, 1273 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1274 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1275 getAcknowledgeTaskMethod(), responseObserver); 1276 } 1277 1278 /** 1279 * 1280 * 1281 * <pre> 1282 * Renew the current lease of a pull task. 1283 * The worker can use this method to extend the lease by a new 1284 * duration, starting from now. The new task lease will be 1285 * returned in the task's 1286 * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time]. 1287 * </pre> 1288 */ renewLease( com.google.cloud.tasks.v2beta2.RenewLeaseRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1289 default void renewLease( 1290 com.google.cloud.tasks.v2beta2.RenewLeaseRequest request, 1291 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1292 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRenewLeaseMethod(), responseObserver); 1293 } 1294 1295 /** 1296 * 1297 * 1298 * <pre> 1299 * Cancel a pull task's lease. 1300 * The worker can use this method to cancel a task's lease by 1301 * setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] 1302 * to now. This will make the task available to be leased to the next caller 1303 * of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]. 1304 * </pre> 1305 */ cancelLease( com.google.cloud.tasks.v2beta2.CancelLeaseRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1306 default void cancelLease( 1307 com.google.cloud.tasks.v2beta2.CancelLeaseRequest request, 1308 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1309 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( 1310 getCancelLeaseMethod(), responseObserver); 1311 } 1312 1313 /** 1314 * 1315 * 1316 * <pre> 1317 * Forces a task to run now. 1318 * When this method is called, Cloud Tasks will dispatch the task, even if 1319 * the task is already running, the queue has reached its 1320 * [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or is 1321 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED]. 1322 * This command is meant to be used for manual debugging. For 1323 * example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be 1324 * used to retry a failed task after a fix has been made or to manually force 1325 * a task to be dispatched now. 1326 * The dispatched task is returned. That is, the task that is returned 1327 * contains the [status][google.cloud.tasks.v2beta2.Task.status] after the 1328 * task is dispatched but before the task is received by its target. 1329 * If Cloud Tasks receives a successful response from the task's 1330 * target, then the task will be deleted; otherwise the task's 1331 * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be 1332 * reset to the time that 1333 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus 1334 * the retry delay specified in the queue's 1335 * [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig]. 1336 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns 1337 * [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a 1338 * task that has already succeeded or permanently failed. 1339 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called 1340 * on a [pull task][google.cloud.tasks.v2beta2.PullMessage]. 1341 * </pre> 1342 */ runTask( com.google.cloud.tasks.v2beta2.RunTaskRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1343 default void runTask( 1344 com.google.cloud.tasks.v2beta2.RunTaskRequest request, 1345 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1346 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getRunTaskMethod(), responseObserver); 1347 } 1348 } 1349 1350 /** 1351 * Base class for the server implementation of the service CloudTasks. 1352 * 1353 * <pre> 1354 * Cloud Tasks allows developers to manage the execution of background 1355 * work in their applications. 1356 * </pre> 1357 */ 1358 public abstract static class CloudTasksImplBase implements io.grpc.BindableService, AsyncService { 1359 1360 @java.lang.Override bindService()1361 public final io.grpc.ServerServiceDefinition bindService() { 1362 return CloudTasksGrpc.bindService(this); 1363 } 1364 } 1365 1366 /** 1367 * A stub to allow clients to do asynchronous rpc calls to service CloudTasks. 1368 * 1369 * <pre> 1370 * Cloud Tasks allows developers to manage the execution of background 1371 * work in their applications. 1372 * </pre> 1373 */ 1374 public static final class CloudTasksStub extends io.grpc.stub.AbstractAsyncStub<CloudTasksStub> { CloudTasksStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1375 private CloudTasksStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1376 super(channel, callOptions); 1377 } 1378 1379 @java.lang.Override build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1380 protected CloudTasksStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1381 return new CloudTasksStub(channel, callOptions); 1382 } 1383 1384 /** 1385 * 1386 * 1387 * <pre> 1388 * Lists queues. 1389 * Queues are returned in lexicographical order. 1390 * </pre> 1391 */ listQueues( com.google.cloud.tasks.v2beta2.ListQueuesRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListQueuesResponse> responseObserver)1392 public void listQueues( 1393 com.google.cloud.tasks.v2beta2.ListQueuesRequest request, 1394 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListQueuesResponse> 1395 responseObserver) { 1396 io.grpc.stub.ClientCalls.asyncUnaryCall( 1397 getChannel().newCall(getListQueuesMethod(), getCallOptions()), request, responseObserver); 1398 } 1399 1400 /** 1401 * 1402 * 1403 * <pre> 1404 * Gets a queue. 1405 * </pre> 1406 */ getQueue( com.google.cloud.tasks.v2beta2.GetQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1407 public void getQueue( 1408 com.google.cloud.tasks.v2beta2.GetQueueRequest request, 1409 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1410 io.grpc.stub.ClientCalls.asyncUnaryCall( 1411 getChannel().newCall(getGetQueueMethod(), getCallOptions()), request, responseObserver); 1412 } 1413 1414 /** 1415 * 1416 * 1417 * <pre> 1418 * Creates a queue. 1419 * Queues created with this method allow tasks to live for a maximum of 31 1420 * days. After a task is 31 days old, the task will be deleted regardless of 1421 * whether it was dispatched or not. 1422 * WARNING: Using this method may have unintended side effects if you are 1423 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1424 * Read 1425 * [Overview of Queue Management and 1426 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1427 * this method. 1428 * </pre> 1429 */ createQueue( com.google.cloud.tasks.v2beta2.CreateQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1430 public void createQueue( 1431 com.google.cloud.tasks.v2beta2.CreateQueueRequest request, 1432 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1433 io.grpc.stub.ClientCalls.asyncUnaryCall( 1434 getChannel().newCall(getCreateQueueMethod(), getCallOptions()), 1435 request, 1436 responseObserver); 1437 } 1438 1439 /** 1440 * 1441 * 1442 * <pre> 1443 * Updates a queue. 1444 * This method creates the queue if it does not exist and updates 1445 * the queue if it does exist. 1446 * Queues created with this method allow tasks to live for a maximum of 31 1447 * days. After a task is 31 days old, the task will be deleted regardless of 1448 * whether it was dispatched or not. 1449 * WARNING: Using this method may have unintended side effects if you are 1450 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1451 * Read 1452 * [Overview of Queue Management and 1453 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1454 * this method. 1455 * </pre> 1456 */ updateQueue( com.google.cloud.tasks.v2beta2.UpdateQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1457 public void updateQueue( 1458 com.google.cloud.tasks.v2beta2.UpdateQueueRequest request, 1459 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1460 io.grpc.stub.ClientCalls.asyncUnaryCall( 1461 getChannel().newCall(getUpdateQueueMethod(), getCallOptions()), 1462 request, 1463 responseObserver); 1464 } 1465 1466 /** 1467 * 1468 * 1469 * <pre> 1470 * Deletes a queue. 1471 * This command will delete the queue even if it has tasks in it. 1472 * Note: If you delete a queue, a queue with the same name can't be created 1473 * for 7 days. 1474 * WARNING: Using this method may have unintended side effects if you are 1475 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1476 * Read 1477 * [Overview of Queue Management and 1478 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1479 * this method. 1480 * </pre> 1481 */ deleteQueue( com.google.cloud.tasks.v2beta2.DeleteQueueRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1482 public void deleteQueue( 1483 com.google.cloud.tasks.v2beta2.DeleteQueueRequest request, 1484 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1485 io.grpc.stub.ClientCalls.asyncUnaryCall( 1486 getChannel().newCall(getDeleteQueueMethod(), getCallOptions()), 1487 request, 1488 responseObserver); 1489 } 1490 1491 /** 1492 * 1493 * 1494 * <pre> 1495 * Purges a queue by deleting all of its tasks. 1496 * All tasks created before this method is called are permanently deleted. 1497 * Purge operations can take up to one minute to take effect. Tasks 1498 * might be dispatched before the purge takes effect. A purge is irreversible. 1499 * </pre> 1500 */ purgeQueue( com.google.cloud.tasks.v2beta2.PurgeQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1501 public void purgeQueue( 1502 com.google.cloud.tasks.v2beta2.PurgeQueueRequest request, 1503 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1504 io.grpc.stub.ClientCalls.asyncUnaryCall( 1505 getChannel().newCall(getPurgeQueueMethod(), getCallOptions()), request, responseObserver); 1506 } 1507 1508 /** 1509 * 1510 * 1511 * <pre> 1512 * Pauses the queue. 1513 * If a queue is paused then the system will stop dispatching tasks 1514 * until the queue is resumed via 1515 * [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can 1516 * still be added when the queue is paused. A queue is paused if its 1517 * [state][google.cloud.tasks.v2beta2.Queue.state] is 1518 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED]. 1519 * </pre> 1520 */ pauseQueue( com.google.cloud.tasks.v2beta2.PauseQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1521 public void pauseQueue( 1522 com.google.cloud.tasks.v2beta2.PauseQueueRequest request, 1523 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1524 io.grpc.stub.ClientCalls.asyncUnaryCall( 1525 getChannel().newCall(getPauseQueueMethod(), getCallOptions()), request, responseObserver); 1526 } 1527 1528 /** 1529 * 1530 * 1531 * <pre> 1532 * Resume a queue. 1533 * This method resumes a queue after it has been 1534 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or 1535 * [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a 1536 * queue is stored in the queue's 1537 * [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method 1538 * it will be set to 1539 * [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING]. 1540 * WARNING: Resuming many high-QPS queues at the same time can 1541 * lead to target overloading. If you are resuming high-QPS 1542 * queues, follow the 500/50/5 pattern described in 1543 * [Managing Cloud Tasks Scaling 1544 * Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). 1545 * </pre> 1546 */ resumeQueue( com.google.cloud.tasks.v2beta2.ResumeQueueRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver)1547 public void resumeQueue( 1548 com.google.cloud.tasks.v2beta2.ResumeQueueRequest request, 1549 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue> responseObserver) { 1550 io.grpc.stub.ClientCalls.asyncUnaryCall( 1551 getChannel().newCall(getResumeQueueMethod(), getCallOptions()), 1552 request, 1553 responseObserver); 1554 } 1555 1556 /** 1557 * 1558 * 1559 * <pre> 1560 * Gets the access control policy for a 1561 * [Queue][google.cloud.tasks.v2beta2.Queue]. Returns an empty policy if the 1562 * resource exists and does not have a policy set. 1563 * Authorization requires the following 1564 * [Google IAM](https://cloud.google.com/iam) permission on the specified 1565 * resource parent: 1566 * * `cloudtasks.queues.getIamPolicy` 1567 * </pre> 1568 */ getIamPolicy( com.google.iam.v1.GetIamPolicyRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver)1569 public void getIamPolicy( 1570 com.google.iam.v1.GetIamPolicyRequest request, 1571 io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) { 1572 io.grpc.stub.ClientCalls.asyncUnaryCall( 1573 getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()), 1574 request, 1575 responseObserver); 1576 } 1577 1578 /** 1579 * 1580 * 1581 * <pre> 1582 * Sets the access control policy for a 1583 * [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing policy. 1584 * Note: The Cloud Console does not check queue-level IAM permissions yet. 1585 * Project-level permissions are required to use the Cloud Console. 1586 * Authorization requires the following 1587 * [Google IAM](https://cloud.google.com/iam) permission on the specified 1588 * resource parent: 1589 * * `cloudtasks.queues.setIamPolicy` 1590 * </pre> 1591 */ setIamPolicy( com.google.iam.v1.SetIamPolicyRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver)1592 public void setIamPolicy( 1593 com.google.iam.v1.SetIamPolicyRequest request, 1594 io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> responseObserver) { 1595 io.grpc.stub.ClientCalls.asyncUnaryCall( 1596 getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()), 1597 request, 1598 responseObserver); 1599 } 1600 1601 /** 1602 * 1603 * 1604 * <pre> 1605 * Returns permissions that a caller has on a 1606 * [Queue][google.cloud.tasks.v2beta2.Queue]. If the resource does not exist, 1607 * this will return an empty set of permissions, not a 1608 * [NOT_FOUND][google.rpc.Code.NOT_FOUND] error. 1609 * Note: This operation is designed to be used for building permission-aware 1610 * UIs and command-line tools, not for authorization checking. This operation 1611 * may "fail open" without warning. 1612 * </pre> 1613 */ testIamPermissions( com.google.iam.v1.TestIamPermissionsRequest request, io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> responseObserver)1614 public void testIamPermissions( 1615 com.google.iam.v1.TestIamPermissionsRequest request, 1616 io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> 1617 responseObserver) { 1618 io.grpc.stub.ClientCalls.asyncUnaryCall( 1619 getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()), 1620 request, 1621 responseObserver); 1622 } 1623 1624 /** 1625 * 1626 * 1627 * <pre> 1628 * Lists the tasks in a queue. 1629 * By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] 1630 * view is retrieved due to performance considerations; 1631 * [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] 1632 * controls the subset of information which is returned. 1633 * The tasks may be returned in any order. The ordering may change at any 1634 * time. 1635 * </pre> 1636 */ listTasks( com.google.cloud.tasks.v2beta2.ListTasksRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListTasksResponse> responseObserver)1637 public void listTasks( 1638 com.google.cloud.tasks.v2beta2.ListTasksRequest request, 1639 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListTasksResponse> 1640 responseObserver) { 1641 io.grpc.stub.ClientCalls.asyncUnaryCall( 1642 getChannel().newCall(getListTasksMethod(), getCallOptions()), request, responseObserver); 1643 } 1644 1645 /** 1646 * 1647 * 1648 * <pre> 1649 * Gets a task. 1650 * </pre> 1651 */ getTask( com.google.cloud.tasks.v2beta2.GetTaskRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1652 public void getTask( 1653 com.google.cloud.tasks.v2beta2.GetTaskRequest request, 1654 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1655 io.grpc.stub.ClientCalls.asyncUnaryCall( 1656 getChannel().newCall(getGetTaskMethod(), getCallOptions()), request, responseObserver); 1657 } 1658 1659 /** 1660 * 1661 * 1662 * <pre> 1663 * Creates a task and adds it to a queue. 1664 * Tasks cannot be updated after creation; there is no UpdateTask command. 1665 * * For [App Engine queues][google.cloud.tasks.v2beta2.AppEngineHttpTarget], 1666 * the maximum task size is 1667 * 100KB. 1668 * * For [pull queues][google.cloud.tasks.v2beta2.PullTarget], the maximum 1669 * task size is 1MB. 1670 * </pre> 1671 */ createTask( com.google.cloud.tasks.v2beta2.CreateTaskRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1672 public void createTask( 1673 com.google.cloud.tasks.v2beta2.CreateTaskRequest request, 1674 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1675 io.grpc.stub.ClientCalls.asyncUnaryCall( 1676 getChannel().newCall(getCreateTaskMethod(), getCallOptions()), request, responseObserver); 1677 } 1678 1679 /** 1680 * 1681 * 1682 * <pre> 1683 * Deletes a task. 1684 * A task can be deleted if it is scheduled or dispatched. A task 1685 * cannot be deleted if it has completed successfully or permanently 1686 * failed. 1687 * </pre> 1688 */ deleteTask( com.google.cloud.tasks.v2beta2.DeleteTaskRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1689 public void deleteTask( 1690 com.google.cloud.tasks.v2beta2.DeleteTaskRequest request, 1691 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1692 io.grpc.stub.ClientCalls.asyncUnaryCall( 1693 getChannel().newCall(getDeleteTaskMethod(), getCallOptions()), request, responseObserver); 1694 } 1695 1696 /** 1697 * 1698 * 1699 * <pre> 1700 * Leases tasks from a pull queue for 1701 * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration]. 1702 * This method is invoked by the worker to obtain a lease. The 1703 * worker must acknowledge the task via 1704 * [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] 1705 * after they have performed the work associated with the task. 1706 * The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended 1707 * to store data that the worker needs to perform the work associated with the 1708 * task. To return the payloads in the 1709 * [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set 1710 * [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] 1711 * to [FULL][google.cloud.tasks.v2beta2.Task.View.FULL]. 1712 * A maximum of 10 qps of 1713 * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] requests are 1714 * allowed per queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED] 1715 * is returned when this limit is 1716 * exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED] 1717 * is also returned when 1718 * [max_tasks_dispatched_per_second][google.cloud.tasks.v2beta2.RateLimits.max_tasks_dispatched_per_second] 1719 * is exceeded. 1720 * </pre> 1721 */ leaseTasks( com.google.cloud.tasks.v2beta2.LeaseTasksRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.LeaseTasksResponse> responseObserver)1722 public void leaseTasks( 1723 com.google.cloud.tasks.v2beta2.LeaseTasksRequest request, 1724 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.LeaseTasksResponse> 1725 responseObserver) { 1726 io.grpc.stub.ClientCalls.asyncUnaryCall( 1727 getChannel().newCall(getLeaseTasksMethod(), getCallOptions()), request, responseObserver); 1728 } 1729 1730 /** 1731 * 1732 * 1733 * <pre> 1734 * Acknowledges a pull task. 1735 * The worker, that is, the entity that 1736 * [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must 1737 * call this method to indicate that the work associated with the task has 1738 * finished. 1739 * The worker must acknowledge a task within the 1740 * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] 1741 * or the lease will expire and the task will become available to be leased 1742 * again. After the task is acknowledged, it will not be returned 1743 * by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks], 1744 * [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or 1745 * [ListTasks][google.cloud.tasks.v2beta2.CloudTasks.ListTasks]. 1746 * </pre> 1747 */ acknowledgeTask( com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)1748 public void acknowledgeTask( 1749 com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request, 1750 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) { 1751 io.grpc.stub.ClientCalls.asyncUnaryCall( 1752 getChannel().newCall(getAcknowledgeTaskMethod(), getCallOptions()), 1753 request, 1754 responseObserver); 1755 } 1756 1757 /** 1758 * 1759 * 1760 * <pre> 1761 * Renew the current lease of a pull task. 1762 * The worker can use this method to extend the lease by a new 1763 * duration, starting from now. The new task lease will be 1764 * returned in the task's 1765 * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time]. 1766 * </pre> 1767 */ renewLease( com.google.cloud.tasks.v2beta2.RenewLeaseRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1768 public void renewLease( 1769 com.google.cloud.tasks.v2beta2.RenewLeaseRequest request, 1770 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1771 io.grpc.stub.ClientCalls.asyncUnaryCall( 1772 getChannel().newCall(getRenewLeaseMethod(), getCallOptions()), request, responseObserver); 1773 } 1774 1775 /** 1776 * 1777 * 1778 * <pre> 1779 * Cancel a pull task's lease. 1780 * The worker can use this method to cancel a task's lease by 1781 * setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] 1782 * to now. This will make the task available to be leased to the next caller 1783 * of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]. 1784 * </pre> 1785 */ cancelLease( com.google.cloud.tasks.v2beta2.CancelLeaseRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1786 public void cancelLease( 1787 com.google.cloud.tasks.v2beta2.CancelLeaseRequest request, 1788 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1789 io.grpc.stub.ClientCalls.asyncUnaryCall( 1790 getChannel().newCall(getCancelLeaseMethod(), getCallOptions()), 1791 request, 1792 responseObserver); 1793 } 1794 1795 /** 1796 * 1797 * 1798 * <pre> 1799 * Forces a task to run now. 1800 * When this method is called, Cloud Tasks will dispatch the task, even if 1801 * the task is already running, the queue has reached its 1802 * [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or is 1803 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED]. 1804 * This command is meant to be used for manual debugging. For 1805 * example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be 1806 * used to retry a failed task after a fix has been made or to manually force 1807 * a task to be dispatched now. 1808 * The dispatched task is returned. That is, the task that is returned 1809 * contains the [status][google.cloud.tasks.v2beta2.Task.status] after the 1810 * task is dispatched but before the task is received by its target. 1811 * If Cloud Tasks receives a successful response from the task's 1812 * target, then the task will be deleted; otherwise the task's 1813 * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be 1814 * reset to the time that 1815 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus 1816 * the retry delay specified in the queue's 1817 * [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig]. 1818 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns 1819 * [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a 1820 * task that has already succeeded or permanently failed. 1821 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called 1822 * on a [pull task][google.cloud.tasks.v2beta2.PullMessage]. 1823 * </pre> 1824 */ runTask( com.google.cloud.tasks.v2beta2.RunTaskRequest request, io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver)1825 public void runTask( 1826 com.google.cloud.tasks.v2beta2.RunTaskRequest request, 1827 io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task> responseObserver) { 1828 io.grpc.stub.ClientCalls.asyncUnaryCall( 1829 getChannel().newCall(getRunTaskMethod(), getCallOptions()), request, responseObserver); 1830 } 1831 } 1832 1833 /** 1834 * A stub to allow clients to do synchronous rpc calls to service CloudTasks. 1835 * 1836 * <pre> 1837 * Cloud Tasks allows developers to manage the execution of background 1838 * work in their applications. 1839 * </pre> 1840 */ 1841 public static final class CloudTasksBlockingStub 1842 extends io.grpc.stub.AbstractBlockingStub<CloudTasksBlockingStub> { CloudTasksBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1843 private CloudTasksBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1844 super(channel, callOptions); 1845 } 1846 1847 @java.lang.Override build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)1848 protected CloudTasksBlockingStub build( 1849 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 1850 return new CloudTasksBlockingStub(channel, callOptions); 1851 } 1852 1853 /** 1854 * 1855 * 1856 * <pre> 1857 * Lists queues. 1858 * Queues are returned in lexicographical order. 1859 * </pre> 1860 */ listQueues( com.google.cloud.tasks.v2beta2.ListQueuesRequest request)1861 public com.google.cloud.tasks.v2beta2.ListQueuesResponse listQueues( 1862 com.google.cloud.tasks.v2beta2.ListQueuesRequest request) { 1863 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1864 getChannel(), getListQueuesMethod(), getCallOptions(), request); 1865 } 1866 1867 /** 1868 * 1869 * 1870 * <pre> 1871 * Gets a queue. 1872 * </pre> 1873 */ getQueue( com.google.cloud.tasks.v2beta2.GetQueueRequest request)1874 public com.google.cloud.tasks.v2beta2.Queue getQueue( 1875 com.google.cloud.tasks.v2beta2.GetQueueRequest request) { 1876 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1877 getChannel(), getGetQueueMethod(), getCallOptions(), request); 1878 } 1879 1880 /** 1881 * 1882 * 1883 * <pre> 1884 * Creates a queue. 1885 * Queues created with this method allow tasks to live for a maximum of 31 1886 * days. After a task is 31 days old, the task will be deleted regardless of 1887 * whether it was dispatched or not. 1888 * WARNING: Using this method may have unintended side effects if you are 1889 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1890 * Read 1891 * [Overview of Queue Management and 1892 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1893 * this method. 1894 * </pre> 1895 */ createQueue( com.google.cloud.tasks.v2beta2.CreateQueueRequest request)1896 public com.google.cloud.tasks.v2beta2.Queue createQueue( 1897 com.google.cloud.tasks.v2beta2.CreateQueueRequest request) { 1898 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1899 getChannel(), getCreateQueueMethod(), getCallOptions(), request); 1900 } 1901 1902 /** 1903 * 1904 * 1905 * <pre> 1906 * Updates a queue. 1907 * This method creates the queue if it does not exist and updates 1908 * the queue if it does exist. 1909 * Queues created with this method allow tasks to live for a maximum of 31 1910 * days. After a task is 31 days old, the task will be deleted regardless of 1911 * whether it was dispatched or not. 1912 * WARNING: Using this method may have unintended side effects if you are 1913 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1914 * Read 1915 * [Overview of Queue Management and 1916 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1917 * this method. 1918 * </pre> 1919 */ updateQueue( com.google.cloud.tasks.v2beta2.UpdateQueueRequest request)1920 public com.google.cloud.tasks.v2beta2.Queue updateQueue( 1921 com.google.cloud.tasks.v2beta2.UpdateQueueRequest request) { 1922 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1923 getChannel(), getUpdateQueueMethod(), getCallOptions(), request); 1924 } 1925 1926 /** 1927 * 1928 * 1929 * <pre> 1930 * Deletes a queue. 1931 * This command will delete the queue even if it has tasks in it. 1932 * Note: If you delete a queue, a queue with the same name can't be created 1933 * for 7 days. 1934 * WARNING: Using this method may have unintended side effects if you are 1935 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1936 * Read 1937 * [Overview of Queue Management and 1938 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1939 * this method. 1940 * </pre> 1941 */ deleteQueue( com.google.cloud.tasks.v2beta2.DeleteQueueRequest request)1942 public com.google.protobuf.Empty deleteQueue( 1943 com.google.cloud.tasks.v2beta2.DeleteQueueRequest request) { 1944 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1945 getChannel(), getDeleteQueueMethod(), getCallOptions(), request); 1946 } 1947 1948 /** 1949 * 1950 * 1951 * <pre> 1952 * Purges a queue by deleting all of its tasks. 1953 * All tasks created before this method is called are permanently deleted. 1954 * Purge operations can take up to one minute to take effect. Tasks 1955 * might be dispatched before the purge takes effect. A purge is irreversible. 1956 * </pre> 1957 */ purgeQueue( com.google.cloud.tasks.v2beta2.PurgeQueueRequest request)1958 public com.google.cloud.tasks.v2beta2.Queue purgeQueue( 1959 com.google.cloud.tasks.v2beta2.PurgeQueueRequest request) { 1960 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1961 getChannel(), getPurgeQueueMethod(), getCallOptions(), request); 1962 } 1963 1964 /** 1965 * 1966 * 1967 * <pre> 1968 * Pauses the queue. 1969 * If a queue is paused then the system will stop dispatching tasks 1970 * until the queue is resumed via 1971 * [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can 1972 * still be added when the queue is paused. A queue is paused if its 1973 * [state][google.cloud.tasks.v2beta2.Queue.state] is 1974 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED]. 1975 * </pre> 1976 */ pauseQueue( com.google.cloud.tasks.v2beta2.PauseQueueRequest request)1977 public com.google.cloud.tasks.v2beta2.Queue pauseQueue( 1978 com.google.cloud.tasks.v2beta2.PauseQueueRequest request) { 1979 return io.grpc.stub.ClientCalls.blockingUnaryCall( 1980 getChannel(), getPauseQueueMethod(), getCallOptions(), request); 1981 } 1982 1983 /** 1984 * 1985 * 1986 * <pre> 1987 * Resume a queue. 1988 * This method resumes a queue after it has been 1989 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or 1990 * [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a 1991 * queue is stored in the queue's 1992 * [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method 1993 * it will be set to 1994 * [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING]. 1995 * WARNING: Resuming many high-QPS queues at the same time can 1996 * lead to target overloading. If you are resuming high-QPS 1997 * queues, follow the 500/50/5 pattern described in 1998 * [Managing Cloud Tasks Scaling 1999 * Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). 2000 * </pre> 2001 */ resumeQueue( com.google.cloud.tasks.v2beta2.ResumeQueueRequest request)2002 public com.google.cloud.tasks.v2beta2.Queue resumeQueue( 2003 com.google.cloud.tasks.v2beta2.ResumeQueueRequest request) { 2004 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2005 getChannel(), getResumeQueueMethod(), getCallOptions(), request); 2006 } 2007 2008 /** 2009 * 2010 * 2011 * <pre> 2012 * Gets the access control policy for a 2013 * [Queue][google.cloud.tasks.v2beta2.Queue]. Returns an empty policy if the 2014 * resource exists and does not have a policy set. 2015 * Authorization requires the following 2016 * [Google IAM](https://cloud.google.com/iam) permission on the specified 2017 * resource parent: 2018 * * `cloudtasks.queues.getIamPolicy` 2019 * </pre> 2020 */ getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request)2021 public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) { 2022 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2023 getChannel(), getGetIamPolicyMethod(), getCallOptions(), request); 2024 } 2025 2026 /** 2027 * 2028 * 2029 * <pre> 2030 * Sets the access control policy for a 2031 * [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing policy. 2032 * Note: The Cloud Console does not check queue-level IAM permissions yet. 2033 * Project-level permissions are required to use the Cloud Console. 2034 * Authorization requires the following 2035 * [Google IAM](https://cloud.google.com/iam) permission on the specified 2036 * resource parent: 2037 * * `cloudtasks.queues.setIamPolicy` 2038 * </pre> 2039 */ setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request)2040 public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) { 2041 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2042 getChannel(), getSetIamPolicyMethod(), getCallOptions(), request); 2043 } 2044 2045 /** 2046 * 2047 * 2048 * <pre> 2049 * Returns permissions that a caller has on a 2050 * [Queue][google.cloud.tasks.v2beta2.Queue]. If the resource does not exist, 2051 * this will return an empty set of permissions, not a 2052 * [NOT_FOUND][google.rpc.Code.NOT_FOUND] error. 2053 * Note: This operation is designed to be used for building permission-aware 2054 * UIs and command-line tools, not for authorization checking. This operation 2055 * may "fail open" without warning. 2056 * </pre> 2057 */ testIamPermissions( com.google.iam.v1.TestIamPermissionsRequest request)2058 public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions( 2059 com.google.iam.v1.TestIamPermissionsRequest request) { 2060 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2061 getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request); 2062 } 2063 2064 /** 2065 * 2066 * 2067 * <pre> 2068 * Lists the tasks in a queue. 2069 * By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] 2070 * view is retrieved due to performance considerations; 2071 * [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] 2072 * controls the subset of information which is returned. 2073 * The tasks may be returned in any order. The ordering may change at any 2074 * time. 2075 * </pre> 2076 */ listTasks( com.google.cloud.tasks.v2beta2.ListTasksRequest request)2077 public com.google.cloud.tasks.v2beta2.ListTasksResponse listTasks( 2078 com.google.cloud.tasks.v2beta2.ListTasksRequest request) { 2079 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2080 getChannel(), getListTasksMethod(), getCallOptions(), request); 2081 } 2082 2083 /** 2084 * 2085 * 2086 * <pre> 2087 * Gets a task. 2088 * </pre> 2089 */ getTask( com.google.cloud.tasks.v2beta2.GetTaskRequest request)2090 public com.google.cloud.tasks.v2beta2.Task getTask( 2091 com.google.cloud.tasks.v2beta2.GetTaskRequest request) { 2092 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2093 getChannel(), getGetTaskMethod(), getCallOptions(), request); 2094 } 2095 2096 /** 2097 * 2098 * 2099 * <pre> 2100 * Creates a task and adds it to a queue. 2101 * Tasks cannot be updated after creation; there is no UpdateTask command. 2102 * * For [App Engine queues][google.cloud.tasks.v2beta2.AppEngineHttpTarget], 2103 * the maximum task size is 2104 * 100KB. 2105 * * For [pull queues][google.cloud.tasks.v2beta2.PullTarget], the maximum 2106 * task size is 1MB. 2107 * </pre> 2108 */ createTask( com.google.cloud.tasks.v2beta2.CreateTaskRequest request)2109 public com.google.cloud.tasks.v2beta2.Task createTask( 2110 com.google.cloud.tasks.v2beta2.CreateTaskRequest request) { 2111 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2112 getChannel(), getCreateTaskMethod(), getCallOptions(), request); 2113 } 2114 2115 /** 2116 * 2117 * 2118 * <pre> 2119 * Deletes a task. 2120 * A task can be deleted if it is scheduled or dispatched. A task 2121 * cannot be deleted if it has completed successfully or permanently 2122 * failed. 2123 * </pre> 2124 */ deleteTask( com.google.cloud.tasks.v2beta2.DeleteTaskRequest request)2125 public com.google.protobuf.Empty deleteTask( 2126 com.google.cloud.tasks.v2beta2.DeleteTaskRequest request) { 2127 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2128 getChannel(), getDeleteTaskMethod(), getCallOptions(), request); 2129 } 2130 2131 /** 2132 * 2133 * 2134 * <pre> 2135 * Leases tasks from a pull queue for 2136 * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration]. 2137 * This method is invoked by the worker to obtain a lease. The 2138 * worker must acknowledge the task via 2139 * [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] 2140 * after they have performed the work associated with the task. 2141 * The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended 2142 * to store data that the worker needs to perform the work associated with the 2143 * task. To return the payloads in the 2144 * [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set 2145 * [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] 2146 * to [FULL][google.cloud.tasks.v2beta2.Task.View.FULL]. 2147 * A maximum of 10 qps of 2148 * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] requests are 2149 * allowed per queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED] 2150 * is returned when this limit is 2151 * exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED] 2152 * is also returned when 2153 * [max_tasks_dispatched_per_second][google.cloud.tasks.v2beta2.RateLimits.max_tasks_dispatched_per_second] 2154 * is exceeded. 2155 * </pre> 2156 */ leaseTasks( com.google.cloud.tasks.v2beta2.LeaseTasksRequest request)2157 public com.google.cloud.tasks.v2beta2.LeaseTasksResponse leaseTasks( 2158 com.google.cloud.tasks.v2beta2.LeaseTasksRequest request) { 2159 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2160 getChannel(), getLeaseTasksMethod(), getCallOptions(), request); 2161 } 2162 2163 /** 2164 * 2165 * 2166 * <pre> 2167 * Acknowledges a pull task. 2168 * The worker, that is, the entity that 2169 * [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must 2170 * call this method to indicate that the work associated with the task has 2171 * finished. 2172 * The worker must acknowledge a task within the 2173 * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] 2174 * or the lease will expire and the task will become available to be leased 2175 * again. After the task is acknowledged, it will not be returned 2176 * by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks], 2177 * [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or 2178 * [ListTasks][google.cloud.tasks.v2beta2.CloudTasks.ListTasks]. 2179 * </pre> 2180 */ acknowledgeTask( com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request)2181 public com.google.protobuf.Empty acknowledgeTask( 2182 com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request) { 2183 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2184 getChannel(), getAcknowledgeTaskMethod(), getCallOptions(), request); 2185 } 2186 2187 /** 2188 * 2189 * 2190 * <pre> 2191 * Renew the current lease of a pull task. 2192 * The worker can use this method to extend the lease by a new 2193 * duration, starting from now. The new task lease will be 2194 * returned in the task's 2195 * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time]. 2196 * </pre> 2197 */ renewLease( com.google.cloud.tasks.v2beta2.RenewLeaseRequest request)2198 public com.google.cloud.tasks.v2beta2.Task renewLease( 2199 com.google.cloud.tasks.v2beta2.RenewLeaseRequest request) { 2200 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2201 getChannel(), getRenewLeaseMethod(), getCallOptions(), request); 2202 } 2203 2204 /** 2205 * 2206 * 2207 * <pre> 2208 * Cancel a pull task's lease. 2209 * The worker can use this method to cancel a task's lease by 2210 * setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] 2211 * to now. This will make the task available to be leased to the next caller 2212 * of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]. 2213 * </pre> 2214 */ cancelLease( com.google.cloud.tasks.v2beta2.CancelLeaseRequest request)2215 public com.google.cloud.tasks.v2beta2.Task cancelLease( 2216 com.google.cloud.tasks.v2beta2.CancelLeaseRequest request) { 2217 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2218 getChannel(), getCancelLeaseMethod(), getCallOptions(), request); 2219 } 2220 2221 /** 2222 * 2223 * 2224 * <pre> 2225 * Forces a task to run now. 2226 * When this method is called, Cloud Tasks will dispatch the task, even if 2227 * the task is already running, the queue has reached its 2228 * [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or is 2229 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED]. 2230 * This command is meant to be used for manual debugging. For 2231 * example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be 2232 * used to retry a failed task after a fix has been made or to manually force 2233 * a task to be dispatched now. 2234 * The dispatched task is returned. That is, the task that is returned 2235 * contains the [status][google.cloud.tasks.v2beta2.Task.status] after the 2236 * task is dispatched but before the task is received by its target. 2237 * If Cloud Tasks receives a successful response from the task's 2238 * target, then the task will be deleted; otherwise the task's 2239 * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be 2240 * reset to the time that 2241 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus 2242 * the retry delay specified in the queue's 2243 * [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig]. 2244 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns 2245 * [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a 2246 * task that has already succeeded or permanently failed. 2247 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called 2248 * on a [pull task][google.cloud.tasks.v2beta2.PullMessage]. 2249 * </pre> 2250 */ runTask( com.google.cloud.tasks.v2beta2.RunTaskRequest request)2251 public com.google.cloud.tasks.v2beta2.Task runTask( 2252 com.google.cloud.tasks.v2beta2.RunTaskRequest request) { 2253 return io.grpc.stub.ClientCalls.blockingUnaryCall( 2254 getChannel(), getRunTaskMethod(), getCallOptions(), request); 2255 } 2256 } 2257 2258 /** 2259 * A stub to allow clients to do ListenableFuture-style rpc calls to service CloudTasks. 2260 * 2261 * <pre> 2262 * Cloud Tasks allows developers to manage the execution of background 2263 * work in their applications. 2264 * </pre> 2265 */ 2266 public static final class CloudTasksFutureStub 2267 extends io.grpc.stub.AbstractFutureStub<CloudTasksFutureStub> { CloudTasksFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)2268 private CloudTasksFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 2269 super(channel, callOptions); 2270 } 2271 2272 @java.lang.Override build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)2273 protected CloudTasksFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 2274 return new CloudTasksFutureStub(channel, callOptions); 2275 } 2276 2277 /** 2278 * 2279 * 2280 * <pre> 2281 * Lists queues. 2282 * Queues are returned in lexicographical order. 2283 * </pre> 2284 */ 2285 public com.google.common.util.concurrent.ListenableFuture< 2286 com.google.cloud.tasks.v2beta2.ListQueuesResponse> listQueues(com.google.cloud.tasks.v2beta2.ListQueuesRequest request)2287 listQueues(com.google.cloud.tasks.v2beta2.ListQueuesRequest request) { 2288 return io.grpc.stub.ClientCalls.futureUnaryCall( 2289 getChannel().newCall(getListQueuesMethod(), getCallOptions()), request); 2290 } 2291 2292 /** 2293 * 2294 * 2295 * <pre> 2296 * Gets a queue. 2297 * </pre> 2298 */ 2299 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Queue> getQueue(com.google.cloud.tasks.v2beta2.GetQueueRequest request)2300 getQueue(com.google.cloud.tasks.v2beta2.GetQueueRequest request) { 2301 return io.grpc.stub.ClientCalls.futureUnaryCall( 2302 getChannel().newCall(getGetQueueMethod(), getCallOptions()), request); 2303 } 2304 2305 /** 2306 * 2307 * 2308 * <pre> 2309 * Creates a queue. 2310 * Queues created with this method allow tasks to live for a maximum of 31 2311 * days. After a task is 31 days old, the task will be deleted regardless of 2312 * whether it was dispatched or not. 2313 * WARNING: Using this method may have unintended side effects if you are 2314 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 2315 * Read 2316 * [Overview of Queue Management and 2317 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 2318 * this method. 2319 * </pre> 2320 */ 2321 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Queue> createQueue(com.google.cloud.tasks.v2beta2.CreateQueueRequest request)2322 createQueue(com.google.cloud.tasks.v2beta2.CreateQueueRequest request) { 2323 return io.grpc.stub.ClientCalls.futureUnaryCall( 2324 getChannel().newCall(getCreateQueueMethod(), getCallOptions()), request); 2325 } 2326 2327 /** 2328 * 2329 * 2330 * <pre> 2331 * Updates a queue. 2332 * This method creates the queue if it does not exist and updates 2333 * the queue if it does exist. 2334 * Queues created with this method allow tasks to live for a maximum of 31 2335 * days. After a task is 31 days old, the task will be deleted regardless of 2336 * whether it was dispatched or not. 2337 * WARNING: Using this method may have unintended side effects if you are 2338 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 2339 * Read 2340 * [Overview of Queue Management and 2341 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 2342 * this method. 2343 * </pre> 2344 */ 2345 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Queue> updateQueue(com.google.cloud.tasks.v2beta2.UpdateQueueRequest request)2346 updateQueue(com.google.cloud.tasks.v2beta2.UpdateQueueRequest request) { 2347 return io.grpc.stub.ClientCalls.futureUnaryCall( 2348 getChannel().newCall(getUpdateQueueMethod(), getCallOptions()), request); 2349 } 2350 2351 /** 2352 * 2353 * 2354 * <pre> 2355 * Deletes a queue. 2356 * This command will delete the queue even if it has tasks in it. 2357 * Note: If you delete a queue, a queue with the same name can't be created 2358 * for 7 days. 2359 * WARNING: Using this method may have unintended side effects if you are 2360 * using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 2361 * Read 2362 * [Overview of Queue Management and 2363 * queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 2364 * this method. 2365 * </pre> 2366 */ 2367 public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteQueue(com.google.cloud.tasks.v2beta2.DeleteQueueRequest request)2368 deleteQueue(com.google.cloud.tasks.v2beta2.DeleteQueueRequest request) { 2369 return io.grpc.stub.ClientCalls.futureUnaryCall( 2370 getChannel().newCall(getDeleteQueueMethod(), getCallOptions()), request); 2371 } 2372 2373 /** 2374 * 2375 * 2376 * <pre> 2377 * Purges a queue by deleting all of its tasks. 2378 * All tasks created before this method is called are permanently deleted. 2379 * Purge operations can take up to one minute to take effect. Tasks 2380 * might be dispatched before the purge takes effect. A purge is irreversible. 2381 * </pre> 2382 */ 2383 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Queue> purgeQueue(com.google.cloud.tasks.v2beta2.PurgeQueueRequest request)2384 purgeQueue(com.google.cloud.tasks.v2beta2.PurgeQueueRequest request) { 2385 return io.grpc.stub.ClientCalls.futureUnaryCall( 2386 getChannel().newCall(getPurgeQueueMethod(), getCallOptions()), request); 2387 } 2388 2389 /** 2390 * 2391 * 2392 * <pre> 2393 * Pauses the queue. 2394 * If a queue is paused then the system will stop dispatching tasks 2395 * until the queue is resumed via 2396 * [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can 2397 * still be added when the queue is paused. A queue is paused if its 2398 * [state][google.cloud.tasks.v2beta2.Queue.state] is 2399 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED]. 2400 * </pre> 2401 */ 2402 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Queue> pauseQueue(com.google.cloud.tasks.v2beta2.PauseQueueRequest request)2403 pauseQueue(com.google.cloud.tasks.v2beta2.PauseQueueRequest request) { 2404 return io.grpc.stub.ClientCalls.futureUnaryCall( 2405 getChannel().newCall(getPauseQueueMethod(), getCallOptions()), request); 2406 } 2407 2408 /** 2409 * 2410 * 2411 * <pre> 2412 * Resume a queue. 2413 * This method resumes a queue after it has been 2414 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or 2415 * [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a 2416 * queue is stored in the queue's 2417 * [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method 2418 * it will be set to 2419 * [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING]. 2420 * WARNING: Resuming many high-QPS queues at the same time can 2421 * lead to target overloading. If you are resuming high-QPS 2422 * queues, follow the 500/50/5 pattern described in 2423 * [Managing Cloud Tasks Scaling 2424 * Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). 2425 * </pre> 2426 */ 2427 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Queue> resumeQueue(com.google.cloud.tasks.v2beta2.ResumeQueueRequest request)2428 resumeQueue(com.google.cloud.tasks.v2beta2.ResumeQueueRequest request) { 2429 return io.grpc.stub.ClientCalls.futureUnaryCall( 2430 getChannel().newCall(getResumeQueueMethod(), getCallOptions()), request); 2431 } 2432 2433 /** 2434 * 2435 * 2436 * <pre> 2437 * Gets the access control policy for a 2438 * [Queue][google.cloud.tasks.v2beta2.Queue]. Returns an empty policy if the 2439 * resource exists and does not have a policy set. 2440 * Authorization requires the following 2441 * [Google IAM](https://cloud.google.com/iam) permission on the specified 2442 * resource parent: 2443 * * `cloudtasks.queues.getIamPolicy` 2444 * </pre> 2445 */ 2446 public com.google.common.util.concurrent.ListenableFuture<com.google.iam.v1.Policy> getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request)2447 getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) { 2448 return io.grpc.stub.ClientCalls.futureUnaryCall( 2449 getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()), request); 2450 } 2451 2452 /** 2453 * 2454 * 2455 * <pre> 2456 * Sets the access control policy for a 2457 * [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing policy. 2458 * Note: The Cloud Console does not check queue-level IAM permissions yet. 2459 * Project-level permissions are required to use the Cloud Console. 2460 * Authorization requires the following 2461 * [Google IAM](https://cloud.google.com/iam) permission on the specified 2462 * resource parent: 2463 * * `cloudtasks.queues.setIamPolicy` 2464 * </pre> 2465 */ 2466 public com.google.common.util.concurrent.ListenableFuture<com.google.iam.v1.Policy> setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request)2467 setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) { 2468 return io.grpc.stub.ClientCalls.futureUnaryCall( 2469 getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()), request); 2470 } 2471 2472 /** 2473 * 2474 * 2475 * <pre> 2476 * Returns permissions that a caller has on a 2477 * [Queue][google.cloud.tasks.v2beta2.Queue]. If the resource does not exist, 2478 * this will return an empty set of permissions, not a 2479 * [NOT_FOUND][google.rpc.Code.NOT_FOUND] error. 2480 * Note: This operation is designed to be used for building permission-aware 2481 * UIs and command-line tools, not for authorization checking. This operation 2482 * may "fail open" without warning. 2483 * </pre> 2484 */ 2485 public com.google.common.util.concurrent.ListenableFuture< 2486 com.google.iam.v1.TestIamPermissionsResponse> testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request)2487 testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) { 2488 return io.grpc.stub.ClientCalls.futureUnaryCall( 2489 getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()), request); 2490 } 2491 2492 /** 2493 * 2494 * 2495 * <pre> 2496 * Lists the tasks in a queue. 2497 * By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] 2498 * view is retrieved due to performance considerations; 2499 * [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] 2500 * controls the subset of information which is returned. 2501 * The tasks may be returned in any order. The ordering may change at any 2502 * time. 2503 * </pre> 2504 */ 2505 public com.google.common.util.concurrent.ListenableFuture< 2506 com.google.cloud.tasks.v2beta2.ListTasksResponse> listTasks(com.google.cloud.tasks.v2beta2.ListTasksRequest request)2507 listTasks(com.google.cloud.tasks.v2beta2.ListTasksRequest request) { 2508 return io.grpc.stub.ClientCalls.futureUnaryCall( 2509 getChannel().newCall(getListTasksMethod(), getCallOptions()), request); 2510 } 2511 2512 /** 2513 * 2514 * 2515 * <pre> 2516 * Gets a task. 2517 * </pre> 2518 */ 2519 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Task> getTask(com.google.cloud.tasks.v2beta2.GetTaskRequest request)2520 getTask(com.google.cloud.tasks.v2beta2.GetTaskRequest request) { 2521 return io.grpc.stub.ClientCalls.futureUnaryCall( 2522 getChannel().newCall(getGetTaskMethod(), getCallOptions()), request); 2523 } 2524 2525 /** 2526 * 2527 * 2528 * <pre> 2529 * Creates a task and adds it to a queue. 2530 * Tasks cannot be updated after creation; there is no UpdateTask command. 2531 * * For [App Engine queues][google.cloud.tasks.v2beta2.AppEngineHttpTarget], 2532 * the maximum task size is 2533 * 100KB. 2534 * * For [pull queues][google.cloud.tasks.v2beta2.PullTarget], the maximum 2535 * task size is 1MB. 2536 * </pre> 2537 */ 2538 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Task> createTask(com.google.cloud.tasks.v2beta2.CreateTaskRequest request)2539 createTask(com.google.cloud.tasks.v2beta2.CreateTaskRequest request) { 2540 return io.grpc.stub.ClientCalls.futureUnaryCall( 2541 getChannel().newCall(getCreateTaskMethod(), getCallOptions()), request); 2542 } 2543 2544 /** 2545 * 2546 * 2547 * <pre> 2548 * Deletes a task. 2549 * A task can be deleted if it is scheduled or dispatched. A task 2550 * cannot be deleted if it has completed successfully or permanently 2551 * failed. 2552 * </pre> 2553 */ deleteTask( com.google.cloud.tasks.v2beta2.DeleteTaskRequest request)2554 public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteTask( 2555 com.google.cloud.tasks.v2beta2.DeleteTaskRequest request) { 2556 return io.grpc.stub.ClientCalls.futureUnaryCall( 2557 getChannel().newCall(getDeleteTaskMethod(), getCallOptions()), request); 2558 } 2559 2560 /** 2561 * 2562 * 2563 * <pre> 2564 * Leases tasks from a pull queue for 2565 * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration]. 2566 * This method is invoked by the worker to obtain a lease. The 2567 * worker must acknowledge the task via 2568 * [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] 2569 * after they have performed the work associated with the task. 2570 * The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended 2571 * to store data that the worker needs to perform the work associated with the 2572 * task. To return the payloads in the 2573 * [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set 2574 * [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] 2575 * to [FULL][google.cloud.tasks.v2beta2.Task.View.FULL]. 2576 * A maximum of 10 qps of 2577 * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] requests are 2578 * allowed per queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED] 2579 * is returned when this limit is 2580 * exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED] 2581 * is also returned when 2582 * [max_tasks_dispatched_per_second][google.cloud.tasks.v2beta2.RateLimits.max_tasks_dispatched_per_second] 2583 * is exceeded. 2584 * </pre> 2585 */ 2586 public com.google.common.util.concurrent.ListenableFuture< 2587 com.google.cloud.tasks.v2beta2.LeaseTasksResponse> leaseTasks(com.google.cloud.tasks.v2beta2.LeaseTasksRequest request)2588 leaseTasks(com.google.cloud.tasks.v2beta2.LeaseTasksRequest request) { 2589 return io.grpc.stub.ClientCalls.futureUnaryCall( 2590 getChannel().newCall(getLeaseTasksMethod(), getCallOptions()), request); 2591 } 2592 2593 /** 2594 * 2595 * 2596 * <pre> 2597 * Acknowledges a pull task. 2598 * The worker, that is, the entity that 2599 * [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must 2600 * call this method to indicate that the work associated with the task has 2601 * finished. 2602 * The worker must acknowledge a task within the 2603 * [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] 2604 * or the lease will expire and the task will become available to be leased 2605 * again. After the task is acknowledged, it will not be returned 2606 * by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks], 2607 * [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or 2608 * [ListTasks][google.cloud.tasks.v2beta2.CloudTasks.ListTasks]. 2609 * </pre> 2610 */ 2611 public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> acknowledgeTask(com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request)2612 acknowledgeTask(com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest request) { 2613 return io.grpc.stub.ClientCalls.futureUnaryCall( 2614 getChannel().newCall(getAcknowledgeTaskMethod(), getCallOptions()), request); 2615 } 2616 2617 /** 2618 * 2619 * 2620 * <pre> 2621 * Renew the current lease of a pull task. 2622 * The worker can use this method to extend the lease by a new 2623 * duration, starting from now. The new task lease will be 2624 * returned in the task's 2625 * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time]. 2626 * </pre> 2627 */ 2628 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Task> renewLease(com.google.cloud.tasks.v2beta2.RenewLeaseRequest request)2629 renewLease(com.google.cloud.tasks.v2beta2.RenewLeaseRequest request) { 2630 return io.grpc.stub.ClientCalls.futureUnaryCall( 2631 getChannel().newCall(getRenewLeaseMethod(), getCallOptions()), request); 2632 } 2633 2634 /** 2635 * 2636 * 2637 * <pre> 2638 * Cancel a pull task's lease. 2639 * The worker can use this method to cancel a task's lease by 2640 * setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] 2641 * to now. This will make the task available to be leased to the next caller 2642 * of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]. 2643 * </pre> 2644 */ 2645 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Task> cancelLease(com.google.cloud.tasks.v2beta2.CancelLeaseRequest request)2646 cancelLease(com.google.cloud.tasks.v2beta2.CancelLeaseRequest request) { 2647 return io.grpc.stub.ClientCalls.futureUnaryCall( 2648 getChannel().newCall(getCancelLeaseMethod(), getCallOptions()), request); 2649 } 2650 2651 /** 2652 * 2653 * 2654 * <pre> 2655 * Forces a task to run now. 2656 * When this method is called, Cloud Tasks will dispatch the task, even if 2657 * the task is already running, the queue has reached its 2658 * [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or is 2659 * [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED]. 2660 * This command is meant to be used for manual debugging. For 2661 * example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be 2662 * used to retry a failed task after a fix has been made or to manually force 2663 * a task to be dispatched now. 2664 * The dispatched task is returned. That is, the task that is returned 2665 * contains the [status][google.cloud.tasks.v2beta2.Task.status] after the 2666 * task is dispatched but before the task is received by its target. 2667 * If Cloud Tasks receives a successful response from the task's 2668 * target, then the task will be deleted; otherwise the task's 2669 * [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be 2670 * reset to the time that 2671 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus 2672 * the retry delay specified in the queue's 2673 * [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig]. 2674 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns 2675 * [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a 2676 * task that has already succeeded or permanently failed. 2677 * [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called 2678 * on a [pull task][google.cloud.tasks.v2beta2.PullMessage]. 2679 * </pre> 2680 */ 2681 public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.tasks.v2beta2.Task> runTask(com.google.cloud.tasks.v2beta2.RunTaskRequest request)2682 runTask(com.google.cloud.tasks.v2beta2.RunTaskRequest request) { 2683 return io.grpc.stub.ClientCalls.futureUnaryCall( 2684 getChannel().newCall(getRunTaskMethod(), getCallOptions()), request); 2685 } 2686 } 2687 2688 private static final int METHODID_LIST_QUEUES = 0; 2689 private static final int METHODID_GET_QUEUE = 1; 2690 private static final int METHODID_CREATE_QUEUE = 2; 2691 private static final int METHODID_UPDATE_QUEUE = 3; 2692 private static final int METHODID_DELETE_QUEUE = 4; 2693 private static final int METHODID_PURGE_QUEUE = 5; 2694 private static final int METHODID_PAUSE_QUEUE = 6; 2695 private static final int METHODID_RESUME_QUEUE = 7; 2696 private static final int METHODID_GET_IAM_POLICY = 8; 2697 private static final int METHODID_SET_IAM_POLICY = 9; 2698 private static final int METHODID_TEST_IAM_PERMISSIONS = 10; 2699 private static final int METHODID_LIST_TASKS = 11; 2700 private static final int METHODID_GET_TASK = 12; 2701 private static final int METHODID_CREATE_TASK = 13; 2702 private static final int METHODID_DELETE_TASK = 14; 2703 private static final int METHODID_LEASE_TASKS = 15; 2704 private static final int METHODID_ACKNOWLEDGE_TASK = 16; 2705 private static final int METHODID_RENEW_LEASE = 17; 2706 private static final int METHODID_CANCEL_LEASE = 18; 2707 private static final int METHODID_RUN_TASK = 19; 2708 2709 private static final class MethodHandlers<Req, Resp> 2710 implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>, 2711 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>, 2712 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>, 2713 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> { 2714 private final AsyncService serviceImpl; 2715 private final int methodId; 2716 MethodHandlers(AsyncService serviceImpl, int methodId)2717 MethodHandlers(AsyncService serviceImpl, int methodId) { 2718 this.serviceImpl = serviceImpl; 2719 this.methodId = methodId; 2720 } 2721 2722 @java.lang.Override 2723 @java.lang.SuppressWarnings("unchecked") invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver)2724 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { 2725 switch (methodId) { 2726 case METHODID_LIST_QUEUES: 2727 serviceImpl.listQueues( 2728 (com.google.cloud.tasks.v2beta2.ListQueuesRequest) request, 2729 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListQueuesResponse>) 2730 responseObserver); 2731 break; 2732 case METHODID_GET_QUEUE: 2733 serviceImpl.getQueue( 2734 (com.google.cloud.tasks.v2beta2.GetQueueRequest) request, 2735 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue>) responseObserver); 2736 break; 2737 case METHODID_CREATE_QUEUE: 2738 serviceImpl.createQueue( 2739 (com.google.cloud.tasks.v2beta2.CreateQueueRequest) request, 2740 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue>) responseObserver); 2741 break; 2742 case METHODID_UPDATE_QUEUE: 2743 serviceImpl.updateQueue( 2744 (com.google.cloud.tasks.v2beta2.UpdateQueueRequest) request, 2745 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue>) responseObserver); 2746 break; 2747 case METHODID_DELETE_QUEUE: 2748 serviceImpl.deleteQueue( 2749 (com.google.cloud.tasks.v2beta2.DeleteQueueRequest) request, 2750 (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver); 2751 break; 2752 case METHODID_PURGE_QUEUE: 2753 serviceImpl.purgeQueue( 2754 (com.google.cloud.tasks.v2beta2.PurgeQueueRequest) request, 2755 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue>) responseObserver); 2756 break; 2757 case METHODID_PAUSE_QUEUE: 2758 serviceImpl.pauseQueue( 2759 (com.google.cloud.tasks.v2beta2.PauseQueueRequest) request, 2760 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue>) responseObserver); 2761 break; 2762 case METHODID_RESUME_QUEUE: 2763 serviceImpl.resumeQueue( 2764 (com.google.cloud.tasks.v2beta2.ResumeQueueRequest) request, 2765 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Queue>) responseObserver); 2766 break; 2767 case METHODID_GET_IAM_POLICY: 2768 serviceImpl.getIamPolicy( 2769 (com.google.iam.v1.GetIamPolicyRequest) request, 2770 (io.grpc.stub.StreamObserver<com.google.iam.v1.Policy>) responseObserver); 2771 break; 2772 case METHODID_SET_IAM_POLICY: 2773 serviceImpl.setIamPolicy( 2774 (com.google.iam.v1.SetIamPolicyRequest) request, 2775 (io.grpc.stub.StreamObserver<com.google.iam.v1.Policy>) responseObserver); 2776 break; 2777 case METHODID_TEST_IAM_PERMISSIONS: 2778 serviceImpl.testIamPermissions( 2779 (com.google.iam.v1.TestIamPermissionsRequest) request, 2780 (io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse>) 2781 responseObserver); 2782 break; 2783 case METHODID_LIST_TASKS: 2784 serviceImpl.listTasks( 2785 (com.google.cloud.tasks.v2beta2.ListTasksRequest) request, 2786 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.ListTasksResponse>) 2787 responseObserver); 2788 break; 2789 case METHODID_GET_TASK: 2790 serviceImpl.getTask( 2791 (com.google.cloud.tasks.v2beta2.GetTaskRequest) request, 2792 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task>) responseObserver); 2793 break; 2794 case METHODID_CREATE_TASK: 2795 serviceImpl.createTask( 2796 (com.google.cloud.tasks.v2beta2.CreateTaskRequest) request, 2797 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task>) responseObserver); 2798 break; 2799 case METHODID_DELETE_TASK: 2800 serviceImpl.deleteTask( 2801 (com.google.cloud.tasks.v2beta2.DeleteTaskRequest) request, 2802 (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver); 2803 break; 2804 case METHODID_LEASE_TASKS: 2805 serviceImpl.leaseTasks( 2806 (com.google.cloud.tasks.v2beta2.LeaseTasksRequest) request, 2807 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.LeaseTasksResponse>) 2808 responseObserver); 2809 break; 2810 case METHODID_ACKNOWLEDGE_TASK: 2811 serviceImpl.acknowledgeTask( 2812 (com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest) request, 2813 (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver); 2814 break; 2815 case METHODID_RENEW_LEASE: 2816 serviceImpl.renewLease( 2817 (com.google.cloud.tasks.v2beta2.RenewLeaseRequest) request, 2818 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task>) responseObserver); 2819 break; 2820 case METHODID_CANCEL_LEASE: 2821 serviceImpl.cancelLease( 2822 (com.google.cloud.tasks.v2beta2.CancelLeaseRequest) request, 2823 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task>) responseObserver); 2824 break; 2825 case METHODID_RUN_TASK: 2826 serviceImpl.runTask( 2827 (com.google.cloud.tasks.v2beta2.RunTaskRequest) request, 2828 (io.grpc.stub.StreamObserver<com.google.cloud.tasks.v2beta2.Task>) responseObserver); 2829 break; 2830 default: 2831 throw new AssertionError(); 2832 } 2833 } 2834 2835 @java.lang.Override 2836 @java.lang.SuppressWarnings("unchecked") invoke( io.grpc.stub.StreamObserver<Resp> responseObserver)2837 public io.grpc.stub.StreamObserver<Req> invoke( 2838 io.grpc.stub.StreamObserver<Resp> responseObserver) { 2839 switch (methodId) { 2840 default: 2841 throw new AssertionError(); 2842 } 2843 } 2844 } 2845 bindService(AsyncService service)2846 public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) { 2847 return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) 2848 .addMethod( 2849 getListQueuesMethod(), 2850 io.grpc.stub.ServerCalls.asyncUnaryCall( 2851 new MethodHandlers< 2852 com.google.cloud.tasks.v2beta2.ListQueuesRequest, 2853 com.google.cloud.tasks.v2beta2.ListQueuesResponse>( 2854 service, METHODID_LIST_QUEUES))) 2855 .addMethod( 2856 getGetQueueMethod(), 2857 io.grpc.stub.ServerCalls.asyncUnaryCall( 2858 new MethodHandlers< 2859 com.google.cloud.tasks.v2beta2.GetQueueRequest, 2860 com.google.cloud.tasks.v2beta2.Queue>(service, METHODID_GET_QUEUE))) 2861 .addMethod( 2862 getCreateQueueMethod(), 2863 io.grpc.stub.ServerCalls.asyncUnaryCall( 2864 new MethodHandlers< 2865 com.google.cloud.tasks.v2beta2.CreateQueueRequest, 2866 com.google.cloud.tasks.v2beta2.Queue>(service, METHODID_CREATE_QUEUE))) 2867 .addMethod( 2868 getUpdateQueueMethod(), 2869 io.grpc.stub.ServerCalls.asyncUnaryCall( 2870 new MethodHandlers< 2871 com.google.cloud.tasks.v2beta2.UpdateQueueRequest, 2872 com.google.cloud.tasks.v2beta2.Queue>(service, METHODID_UPDATE_QUEUE))) 2873 .addMethod( 2874 getDeleteQueueMethod(), 2875 io.grpc.stub.ServerCalls.asyncUnaryCall( 2876 new MethodHandlers< 2877 com.google.cloud.tasks.v2beta2.DeleteQueueRequest, com.google.protobuf.Empty>( 2878 service, METHODID_DELETE_QUEUE))) 2879 .addMethod( 2880 getPurgeQueueMethod(), 2881 io.grpc.stub.ServerCalls.asyncUnaryCall( 2882 new MethodHandlers< 2883 com.google.cloud.tasks.v2beta2.PurgeQueueRequest, 2884 com.google.cloud.tasks.v2beta2.Queue>(service, METHODID_PURGE_QUEUE))) 2885 .addMethod( 2886 getPauseQueueMethod(), 2887 io.grpc.stub.ServerCalls.asyncUnaryCall( 2888 new MethodHandlers< 2889 com.google.cloud.tasks.v2beta2.PauseQueueRequest, 2890 com.google.cloud.tasks.v2beta2.Queue>(service, METHODID_PAUSE_QUEUE))) 2891 .addMethod( 2892 getResumeQueueMethod(), 2893 io.grpc.stub.ServerCalls.asyncUnaryCall( 2894 new MethodHandlers< 2895 com.google.cloud.tasks.v2beta2.ResumeQueueRequest, 2896 com.google.cloud.tasks.v2beta2.Queue>(service, METHODID_RESUME_QUEUE))) 2897 .addMethod( 2898 getGetIamPolicyMethod(), 2899 io.grpc.stub.ServerCalls.asyncUnaryCall( 2900 new MethodHandlers<com.google.iam.v1.GetIamPolicyRequest, com.google.iam.v1.Policy>( 2901 service, METHODID_GET_IAM_POLICY))) 2902 .addMethod( 2903 getSetIamPolicyMethod(), 2904 io.grpc.stub.ServerCalls.asyncUnaryCall( 2905 new MethodHandlers<com.google.iam.v1.SetIamPolicyRequest, com.google.iam.v1.Policy>( 2906 service, METHODID_SET_IAM_POLICY))) 2907 .addMethod( 2908 getTestIamPermissionsMethod(), 2909 io.grpc.stub.ServerCalls.asyncUnaryCall( 2910 new MethodHandlers< 2911 com.google.iam.v1.TestIamPermissionsRequest, 2912 com.google.iam.v1.TestIamPermissionsResponse>( 2913 service, METHODID_TEST_IAM_PERMISSIONS))) 2914 .addMethod( 2915 getListTasksMethod(), 2916 io.grpc.stub.ServerCalls.asyncUnaryCall( 2917 new MethodHandlers< 2918 com.google.cloud.tasks.v2beta2.ListTasksRequest, 2919 com.google.cloud.tasks.v2beta2.ListTasksResponse>( 2920 service, METHODID_LIST_TASKS))) 2921 .addMethod( 2922 getGetTaskMethod(), 2923 io.grpc.stub.ServerCalls.asyncUnaryCall( 2924 new MethodHandlers< 2925 com.google.cloud.tasks.v2beta2.GetTaskRequest, 2926 com.google.cloud.tasks.v2beta2.Task>(service, METHODID_GET_TASK))) 2927 .addMethod( 2928 getCreateTaskMethod(), 2929 io.grpc.stub.ServerCalls.asyncUnaryCall( 2930 new MethodHandlers< 2931 com.google.cloud.tasks.v2beta2.CreateTaskRequest, 2932 com.google.cloud.tasks.v2beta2.Task>(service, METHODID_CREATE_TASK))) 2933 .addMethod( 2934 getDeleteTaskMethod(), 2935 io.grpc.stub.ServerCalls.asyncUnaryCall( 2936 new MethodHandlers< 2937 com.google.cloud.tasks.v2beta2.DeleteTaskRequest, com.google.protobuf.Empty>( 2938 service, METHODID_DELETE_TASK))) 2939 .addMethod( 2940 getLeaseTasksMethod(), 2941 io.grpc.stub.ServerCalls.asyncUnaryCall( 2942 new MethodHandlers< 2943 com.google.cloud.tasks.v2beta2.LeaseTasksRequest, 2944 com.google.cloud.tasks.v2beta2.LeaseTasksResponse>( 2945 service, METHODID_LEASE_TASKS))) 2946 .addMethod( 2947 getAcknowledgeTaskMethod(), 2948 io.grpc.stub.ServerCalls.asyncUnaryCall( 2949 new MethodHandlers< 2950 com.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest, 2951 com.google.protobuf.Empty>(service, METHODID_ACKNOWLEDGE_TASK))) 2952 .addMethod( 2953 getRenewLeaseMethod(), 2954 io.grpc.stub.ServerCalls.asyncUnaryCall( 2955 new MethodHandlers< 2956 com.google.cloud.tasks.v2beta2.RenewLeaseRequest, 2957 com.google.cloud.tasks.v2beta2.Task>(service, METHODID_RENEW_LEASE))) 2958 .addMethod( 2959 getCancelLeaseMethod(), 2960 io.grpc.stub.ServerCalls.asyncUnaryCall( 2961 new MethodHandlers< 2962 com.google.cloud.tasks.v2beta2.CancelLeaseRequest, 2963 com.google.cloud.tasks.v2beta2.Task>(service, METHODID_CANCEL_LEASE))) 2964 .addMethod( 2965 getRunTaskMethod(), 2966 io.grpc.stub.ServerCalls.asyncUnaryCall( 2967 new MethodHandlers< 2968 com.google.cloud.tasks.v2beta2.RunTaskRequest, 2969 com.google.cloud.tasks.v2beta2.Task>(service, METHODID_RUN_TASK))) 2970 .build(); 2971 } 2972 2973 private abstract static class CloudTasksBaseDescriptorSupplier 2974 implements io.grpc.protobuf.ProtoFileDescriptorSupplier, 2975 io.grpc.protobuf.ProtoServiceDescriptorSupplier { CloudTasksBaseDescriptorSupplier()2976 CloudTasksBaseDescriptorSupplier() {} 2977 2978 @java.lang.Override getFileDescriptor()2979 public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { 2980 return com.google.cloud.tasks.v2beta2.CloudTasksProto.getDescriptor(); 2981 } 2982 2983 @java.lang.Override getServiceDescriptor()2984 public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { 2985 return getFileDescriptor().findServiceByName("CloudTasks"); 2986 } 2987 } 2988 2989 private static final class CloudTasksFileDescriptorSupplier 2990 extends CloudTasksBaseDescriptorSupplier { CloudTasksFileDescriptorSupplier()2991 CloudTasksFileDescriptorSupplier() {} 2992 } 2993 2994 private static final class CloudTasksMethodDescriptorSupplier 2995 extends CloudTasksBaseDescriptorSupplier 2996 implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { 2997 private final String methodName; 2998 CloudTasksMethodDescriptorSupplier(String methodName)2999 CloudTasksMethodDescriptorSupplier(String methodName) { 3000 this.methodName = methodName; 3001 } 3002 3003 @java.lang.Override getMethodDescriptor()3004 public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { 3005 return getServiceDescriptor().findMethodByName(methodName); 3006 } 3007 } 3008 3009 private static volatile io.grpc.ServiceDescriptor serviceDescriptor; 3010 getServiceDescriptor()3011 public static io.grpc.ServiceDescriptor getServiceDescriptor() { 3012 io.grpc.ServiceDescriptor result = serviceDescriptor; 3013 if (result == null) { 3014 synchronized (CloudTasksGrpc.class) { 3015 result = serviceDescriptor; 3016 if (result == null) { 3017 serviceDescriptor = 3018 result = 3019 io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) 3020 .setSchemaDescriptor(new CloudTasksFileDescriptorSupplier()) 3021 .addMethod(getListQueuesMethod()) 3022 .addMethod(getGetQueueMethod()) 3023 .addMethod(getCreateQueueMethod()) 3024 .addMethod(getUpdateQueueMethod()) 3025 .addMethod(getDeleteQueueMethod()) 3026 .addMethod(getPurgeQueueMethod()) 3027 .addMethod(getPauseQueueMethod()) 3028 .addMethod(getResumeQueueMethod()) 3029 .addMethod(getGetIamPolicyMethod()) 3030 .addMethod(getSetIamPolicyMethod()) 3031 .addMethod(getTestIamPermissionsMethod()) 3032 .addMethod(getListTasksMethod()) 3033 .addMethod(getGetTaskMethod()) 3034 .addMethod(getCreateTaskMethod()) 3035 .addMethod(getDeleteTaskMethod()) 3036 .addMethod(getLeaseTasksMethod()) 3037 .addMethod(getAcknowledgeTaskMethod()) 3038 .addMethod(getRenewLeaseMethod()) 3039 .addMethod(getCancelLeaseMethod()) 3040 .addMethod(getRunTaskMethod()) 3041 .build(); 3042 } 3043 } 3044 } 3045 return result; 3046 } 3047 } 3048