1// Copyright 2019 Google LLC. 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14// 15 16// Code generated by protoc-gen-go. DO NOT EDIT. 17// versions: 18// protoc-gen-go v1.25.0 19// protoc v3.13.0 20// source: google/cloud/tasks/v2/cloudtasks.proto 21 22package tasks 23 24import ( 25 context "context" 26 reflect "reflect" 27 sync "sync" 28 29 proto "github.com/golang/protobuf/proto" 30 _ "google.golang.org/genproto/googleapis/api/annotations" 31 v1 "google.golang.org/genproto/googleapis/iam/v1" 32 grpc "google.golang.org/grpc" 33 codes "google.golang.org/grpc/codes" 34 status "google.golang.org/grpc/status" 35 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 36 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 37 emptypb "google.golang.org/protobuf/types/known/emptypb" 38 fieldmaskpb "google.golang.org/protobuf/types/known/fieldmaskpb" 39) 40 41const ( 42 // Verify that this generated code is sufficiently up-to-date. 43 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 44 // Verify that runtime/protoimpl is sufficiently up-to-date. 45 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 46) 47 48// This is a compile-time assertion that a sufficiently up-to-date version 49// of the legacy proto package is being used. 50const _ = proto.ProtoPackageIsVersion4 51 52// Request message for [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues]. 53type ListQueuesRequest struct { 54 state protoimpl.MessageState 55 sizeCache protoimpl.SizeCache 56 unknownFields protoimpl.UnknownFields 57 58 // Required. The location name. 59 // For example: `projects/PROJECT_ID/locations/LOCATION_ID` 60 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 61 // `filter` can be used to specify a subset of queues. Any [Queue][google.cloud.tasks.v2.Queue] 62 // field can be used as a filter and several operators as supported. 63 // For example: `<=, <, >=, >, !=, =, :`. The filter syntax is the same as 64 // described in 65 // [Stackdriver's Advanced Logs 66 // Filters](https://cloud.google.com/logging/docs/view/advanced_filters). 67 // 68 // Sample filter "state: PAUSED". 69 // 70 // Note that using filters might cause fewer queues than the 71 // requested page_size to be returned. 72 Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` 73 // Requested page size. 74 // 75 // The maximum page size is 9800. If unspecified, the page size will 76 // be the maximum. Fewer queues than requested might be returned, 77 // even if more queues exist; use the 78 // [next_page_token][google.cloud.tasks.v2.ListQueuesResponse.next_page_token] in the 79 // response to determine if more queues exist. 80 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 81 // A token identifying the page of results to return. 82 // 83 // To request the first page results, page_token must be empty. To 84 // request the next page of results, page_token must be the value of 85 // [next_page_token][google.cloud.tasks.v2.ListQueuesResponse.next_page_token] returned 86 // from the previous call to [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues] 87 // method. It is an error to switch the value of the 88 // [filter][google.cloud.tasks.v2.ListQueuesRequest.filter] while iterating through pages. 89 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 90} 91 92func (x *ListQueuesRequest) Reset() { 93 *x = ListQueuesRequest{} 94 if protoimpl.UnsafeEnabled { 95 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[0] 96 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 97 ms.StoreMessageInfo(mi) 98 } 99} 100 101func (x *ListQueuesRequest) String() string { 102 return protoimpl.X.MessageStringOf(x) 103} 104 105func (*ListQueuesRequest) ProtoMessage() {} 106 107func (x *ListQueuesRequest) ProtoReflect() protoreflect.Message { 108 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[0] 109 if protoimpl.UnsafeEnabled && x != nil { 110 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 111 if ms.LoadMessageInfo() == nil { 112 ms.StoreMessageInfo(mi) 113 } 114 return ms 115 } 116 return mi.MessageOf(x) 117} 118 119// Deprecated: Use ListQueuesRequest.ProtoReflect.Descriptor instead. 120func (*ListQueuesRequest) Descriptor() ([]byte, []int) { 121 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{0} 122} 123 124func (x *ListQueuesRequest) GetParent() string { 125 if x != nil { 126 return x.Parent 127 } 128 return "" 129} 130 131func (x *ListQueuesRequest) GetFilter() string { 132 if x != nil { 133 return x.Filter 134 } 135 return "" 136} 137 138func (x *ListQueuesRequest) GetPageSize() int32 { 139 if x != nil { 140 return x.PageSize 141 } 142 return 0 143} 144 145func (x *ListQueuesRequest) GetPageToken() string { 146 if x != nil { 147 return x.PageToken 148 } 149 return "" 150} 151 152// Response message for [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues]. 153type ListQueuesResponse struct { 154 state protoimpl.MessageState 155 sizeCache protoimpl.SizeCache 156 unknownFields protoimpl.UnknownFields 157 158 // The list of queues. 159 Queues []*Queue `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"` 160 // A token to retrieve next page of results. 161 // 162 // To return the next page of results, call 163 // [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues] with this value as the 164 // [page_token][google.cloud.tasks.v2.ListQueuesRequest.page_token]. 165 // 166 // If the next_page_token is empty, there are no more results. 167 // 168 // The page token is valid for only 2 hours. 169 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 170} 171 172func (x *ListQueuesResponse) Reset() { 173 *x = ListQueuesResponse{} 174 if protoimpl.UnsafeEnabled { 175 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[1] 176 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 177 ms.StoreMessageInfo(mi) 178 } 179} 180 181func (x *ListQueuesResponse) String() string { 182 return protoimpl.X.MessageStringOf(x) 183} 184 185func (*ListQueuesResponse) ProtoMessage() {} 186 187func (x *ListQueuesResponse) ProtoReflect() protoreflect.Message { 188 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[1] 189 if protoimpl.UnsafeEnabled && x != nil { 190 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 191 if ms.LoadMessageInfo() == nil { 192 ms.StoreMessageInfo(mi) 193 } 194 return ms 195 } 196 return mi.MessageOf(x) 197} 198 199// Deprecated: Use ListQueuesResponse.ProtoReflect.Descriptor instead. 200func (*ListQueuesResponse) Descriptor() ([]byte, []int) { 201 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{1} 202} 203 204func (x *ListQueuesResponse) GetQueues() []*Queue { 205 if x != nil { 206 return x.Queues 207 } 208 return nil 209} 210 211func (x *ListQueuesResponse) GetNextPageToken() string { 212 if x != nil { 213 return x.NextPageToken 214 } 215 return "" 216} 217 218// Request message for [GetQueue][google.cloud.tasks.v2.CloudTasks.GetQueue]. 219type GetQueueRequest struct { 220 state protoimpl.MessageState 221 sizeCache protoimpl.SizeCache 222 unknownFields protoimpl.UnknownFields 223 224 // Required. The resource name of the queue. For example: 225 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 226 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 227} 228 229func (x *GetQueueRequest) Reset() { 230 *x = GetQueueRequest{} 231 if protoimpl.UnsafeEnabled { 232 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[2] 233 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 234 ms.StoreMessageInfo(mi) 235 } 236} 237 238func (x *GetQueueRequest) String() string { 239 return protoimpl.X.MessageStringOf(x) 240} 241 242func (*GetQueueRequest) ProtoMessage() {} 243 244func (x *GetQueueRequest) ProtoReflect() protoreflect.Message { 245 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[2] 246 if protoimpl.UnsafeEnabled && x != nil { 247 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 248 if ms.LoadMessageInfo() == nil { 249 ms.StoreMessageInfo(mi) 250 } 251 return ms 252 } 253 return mi.MessageOf(x) 254} 255 256// Deprecated: Use GetQueueRequest.ProtoReflect.Descriptor instead. 257func (*GetQueueRequest) Descriptor() ([]byte, []int) { 258 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{2} 259} 260 261func (x *GetQueueRequest) GetName() string { 262 if x != nil { 263 return x.Name 264 } 265 return "" 266} 267 268// Request message for [CreateQueue][google.cloud.tasks.v2.CloudTasks.CreateQueue]. 269type CreateQueueRequest struct { 270 state protoimpl.MessageState 271 sizeCache protoimpl.SizeCache 272 unknownFields protoimpl.UnknownFields 273 274 // Required. The location name in which the queue will be created. 275 // For example: `projects/PROJECT_ID/locations/LOCATION_ID` 276 // 277 // The list of allowed locations can be obtained by calling Cloud 278 // Tasks' implementation of 279 // [ListLocations][google.cloud.location.Locations.ListLocations]. 280 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 281 // Required. The queue to create. 282 // 283 // [Queue's name][google.cloud.tasks.v2.Queue.name] cannot be the same as an existing queue. 284 Queue *Queue `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` 285} 286 287func (x *CreateQueueRequest) Reset() { 288 *x = CreateQueueRequest{} 289 if protoimpl.UnsafeEnabled { 290 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[3] 291 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 292 ms.StoreMessageInfo(mi) 293 } 294} 295 296func (x *CreateQueueRequest) String() string { 297 return protoimpl.X.MessageStringOf(x) 298} 299 300func (*CreateQueueRequest) ProtoMessage() {} 301 302func (x *CreateQueueRequest) ProtoReflect() protoreflect.Message { 303 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[3] 304 if protoimpl.UnsafeEnabled && x != nil { 305 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 306 if ms.LoadMessageInfo() == nil { 307 ms.StoreMessageInfo(mi) 308 } 309 return ms 310 } 311 return mi.MessageOf(x) 312} 313 314// Deprecated: Use CreateQueueRequest.ProtoReflect.Descriptor instead. 315func (*CreateQueueRequest) Descriptor() ([]byte, []int) { 316 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{3} 317} 318 319func (x *CreateQueueRequest) GetParent() string { 320 if x != nil { 321 return x.Parent 322 } 323 return "" 324} 325 326func (x *CreateQueueRequest) GetQueue() *Queue { 327 if x != nil { 328 return x.Queue 329 } 330 return nil 331} 332 333// Request message for [UpdateQueue][google.cloud.tasks.v2.CloudTasks.UpdateQueue]. 334type UpdateQueueRequest struct { 335 state protoimpl.MessageState 336 sizeCache protoimpl.SizeCache 337 unknownFields protoimpl.UnknownFields 338 339 // Required. The queue to create or update. 340 // 341 // The queue's [name][google.cloud.tasks.v2.Queue.name] must be specified. 342 // 343 // Output only fields cannot be modified using UpdateQueue. 344 // Any value specified for an output only field will be ignored. 345 // The queue's [name][google.cloud.tasks.v2.Queue.name] cannot be changed. 346 Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"` 347 // A mask used to specify which fields of the queue are being updated. 348 // 349 // If empty, then all fields will be updated. 350 UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 351} 352 353func (x *UpdateQueueRequest) Reset() { 354 *x = UpdateQueueRequest{} 355 if protoimpl.UnsafeEnabled { 356 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[4] 357 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 358 ms.StoreMessageInfo(mi) 359 } 360} 361 362func (x *UpdateQueueRequest) String() string { 363 return protoimpl.X.MessageStringOf(x) 364} 365 366func (*UpdateQueueRequest) ProtoMessage() {} 367 368func (x *UpdateQueueRequest) ProtoReflect() protoreflect.Message { 369 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[4] 370 if protoimpl.UnsafeEnabled && x != nil { 371 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 372 if ms.LoadMessageInfo() == nil { 373 ms.StoreMessageInfo(mi) 374 } 375 return ms 376 } 377 return mi.MessageOf(x) 378} 379 380// Deprecated: Use UpdateQueueRequest.ProtoReflect.Descriptor instead. 381func (*UpdateQueueRequest) Descriptor() ([]byte, []int) { 382 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{4} 383} 384 385func (x *UpdateQueueRequest) GetQueue() *Queue { 386 if x != nil { 387 return x.Queue 388 } 389 return nil 390} 391 392func (x *UpdateQueueRequest) GetUpdateMask() *fieldmaskpb.FieldMask { 393 if x != nil { 394 return x.UpdateMask 395 } 396 return nil 397} 398 399// Request message for [DeleteQueue][google.cloud.tasks.v2.CloudTasks.DeleteQueue]. 400type DeleteQueueRequest struct { 401 state protoimpl.MessageState 402 sizeCache protoimpl.SizeCache 403 unknownFields protoimpl.UnknownFields 404 405 // Required. The queue name. For example: 406 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 407 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 408} 409 410func (x *DeleteQueueRequest) Reset() { 411 *x = DeleteQueueRequest{} 412 if protoimpl.UnsafeEnabled { 413 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[5] 414 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 415 ms.StoreMessageInfo(mi) 416 } 417} 418 419func (x *DeleteQueueRequest) String() string { 420 return protoimpl.X.MessageStringOf(x) 421} 422 423func (*DeleteQueueRequest) ProtoMessage() {} 424 425func (x *DeleteQueueRequest) ProtoReflect() protoreflect.Message { 426 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[5] 427 if protoimpl.UnsafeEnabled && x != nil { 428 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 429 if ms.LoadMessageInfo() == nil { 430 ms.StoreMessageInfo(mi) 431 } 432 return ms 433 } 434 return mi.MessageOf(x) 435} 436 437// Deprecated: Use DeleteQueueRequest.ProtoReflect.Descriptor instead. 438func (*DeleteQueueRequest) Descriptor() ([]byte, []int) { 439 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{5} 440} 441 442func (x *DeleteQueueRequest) GetName() string { 443 if x != nil { 444 return x.Name 445 } 446 return "" 447} 448 449// Request message for [PurgeQueue][google.cloud.tasks.v2.CloudTasks.PurgeQueue]. 450type PurgeQueueRequest struct { 451 state protoimpl.MessageState 452 sizeCache protoimpl.SizeCache 453 unknownFields protoimpl.UnknownFields 454 455 // Required. The queue name. For example: 456 // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` 457 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 458} 459 460func (x *PurgeQueueRequest) Reset() { 461 *x = PurgeQueueRequest{} 462 if protoimpl.UnsafeEnabled { 463 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[6] 464 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 465 ms.StoreMessageInfo(mi) 466 } 467} 468 469func (x *PurgeQueueRequest) String() string { 470 return protoimpl.X.MessageStringOf(x) 471} 472 473func (*PurgeQueueRequest) ProtoMessage() {} 474 475func (x *PurgeQueueRequest) ProtoReflect() protoreflect.Message { 476 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[6] 477 if protoimpl.UnsafeEnabled && x != nil { 478 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 479 if ms.LoadMessageInfo() == nil { 480 ms.StoreMessageInfo(mi) 481 } 482 return ms 483 } 484 return mi.MessageOf(x) 485} 486 487// Deprecated: Use PurgeQueueRequest.ProtoReflect.Descriptor instead. 488func (*PurgeQueueRequest) Descriptor() ([]byte, []int) { 489 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{6} 490} 491 492func (x *PurgeQueueRequest) GetName() string { 493 if x != nil { 494 return x.Name 495 } 496 return "" 497} 498 499// Request message for [PauseQueue][google.cloud.tasks.v2.CloudTasks.PauseQueue]. 500type PauseQueueRequest struct { 501 state protoimpl.MessageState 502 sizeCache protoimpl.SizeCache 503 unknownFields protoimpl.UnknownFields 504 505 // Required. The queue name. For example: 506 // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` 507 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 508} 509 510func (x *PauseQueueRequest) Reset() { 511 *x = PauseQueueRequest{} 512 if protoimpl.UnsafeEnabled { 513 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[7] 514 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 515 ms.StoreMessageInfo(mi) 516 } 517} 518 519func (x *PauseQueueRequest) String() string { 520 return protoimpl.X.MessageStringOf(x) 521} 522 523func (*PauseQueueRequest) ProtoMessage() {} 524 525func (x *PauseQueueRequest) ProtoReflect() protoreflect.Message { 526 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[7] 527 if protoimpl.UnsafeEnabled && x != nil { 528 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 529 if ms.LoadMessageInfo() == nil { 530 ms.StoreMessageInfo(mi) 531 } 532 return ms 533 } 534 return mi.MessageOf(x) 535} 536 537// Deprecated: Use PauseQueueRequest.ProtoReflect.Descriptor instead. 538func (*PauseQueueRequest) Descriptor() ([]byte, []int) { 539 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{7} 540} 541 542func (x *PauseQueueRequest) GetName() string { 543 if x != nil { 544 return x.Name 545 } 546 return "" 547} 548 549// Request message for [ResumeQueue][google.cloud.tasks.v2.CloudTasks.ResumeQueue]. 550type ResumeQueueRequest struct { 551 state protoimpl.MessageState 552 sizeCache protoimpl.SizeCache 553 unknownFields protoimpl.UnknownFields 554 555 // Required. The queue name. For example: 556 // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` 557 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 558} 559 560func (x *ResumeQueueRequest) Reset() { 561 *x = ResumeQueueRequest{} 562 if protoimpl.UnsafeEnabled { 563 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[8] 564 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 565 ms.StoreMessageInfo(mi) 566 } 567} 568 569func (x *ResumeQueueRequest) String() string { 570 return protoimpl.X.MessageStringOf(x) 571} 572 573func (*ResumeQueueRequest) ProtoMessage() {} 574 575func (x *ResumeQueueRequest) ProtoReflect() protoreflect.Message { 576 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[8] 577 if protoimpl.UnsafeEnabled && x != nil { 578 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 579 if ms.LoadMessageInfo() == nil { 580 ms.StoreMessageInfo(mi) 581 } 582 return ms 583 } 584 return mi.MessageOf(x) 585} 586 587// Deprecated: Use ResumeQueueRequest.ProtoReflect.Descriptor instead. 588func (*ResumeQueueRequest) Descriptor() ([]byte, []int) { 589 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{8} 590} 591 592func (x *ResumeQueueRequest) GetName() string { 593 if x != nil { 594 return x.Name 595 } 596 return "" 597} 598 599// Request message for listing tasks using [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks]. 600type ListTasksRequest struct { 601 state protoimpl.MessageState 602 sizeCache protoimpl.SizeCache 603 unknownFields protoimpl.UnknownFields 604 605 // Required. The queue name. For example: 606 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 607 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 608 // The response_view specifies which subset of the [Task][google.cloud.tasks.v2.Task] will be 609 // returned. 610 // 611 // By default response_view is [BASIC][google.cloud.tasks.v2.Task.View.BASIC]; not all 612 // information is retrieved by default because some data, such as 613 // payloads, might be desirable to return only when needed because 614 // of its large size or because of the sensitivity of data that it 615 // contains. 616 // 617 // Authorization for [FULL][google.cloud.tasks.v2.Task.View.FULL] requires 618 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 619 // permission on the [Task][google.cloud.tasks.v2.Task] resource. 620 ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2.Task_View" json:"response_view,omitempty"` 621 // Maximum page size. 622 // 623 // Fewer tasks than requested might be returned, even if more tasks exist; use 624 // [next_page_token][google.cloud.tasks.v2.ListTasksResponse.next_page_token] in the response to 625 // determine if more tasks exist. 626 // 627 // The maximum page size is 1000. If unspecified, the page size will be the 628 // maximum. 629 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 630 // A token identifying the page of results to return. 631 // 632 // To request the first page results, page_token must be empty. To 633 // request the next page of results, page_token must be the value of 634 // [next_page_token][google.cloud.tasks.v2.ListTasksResponse.next_page_token] returned 635 // from the previous call to [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks] 636 // method. 637 // 638 // The page token is valid for only 2 hours. 639 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 640} 641 642func (x *ListTasksRequest) Reset() { 643 *x = ListTasksRequest{} 644 if protoimpl.UnsafeEnabled { 645 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[9] 646 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 647 ms.StoreMessageInfo(mi) 648 } 649} 650 651func (x *ListTasksRequest) String() string { 652 return protoimpl.X.MessageStringOf(x) 653} 654 655func (*ListTasksRequest) ProtoMessage() {} 656 657func (x *ListTasksRequest) ProtoReflect() protoreflect.Message { 658 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[9] 659 if protoimpl.UnsafeEnabled && x != nil { 660 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 661 if ms.LoadMessageInfo() == nil { 662 ms.StoreMessageInfo(mi) 663 } 664 return ms 665 } 666 return mi.MessageOf(x) 667} 668 669// Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead. 670func (*ListTasksRequest) Descriptor() ([]byte, []int) { 671 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{9} 672} 673 674func (x *ListTasksRequest) GetParent() string { 675 if x != nil { 676 return x.Parent 677 } 678 return "" 679} 680 681func (x *ListTasksRequest) GetResponseView() Task_View { 682 if x != nil { 683 return x.ResponseView 684 } 685 return Task_VIEW_UNSPECIFIED 686} 687 688func (x *ListTasksRequest) GetPageSize() int32 { 689 if x != nil { 690 return x.PageSize 691 } 692 return 0 693} 694 695func (x *ListTasksRequest) GetPageToken() string { 696 if x != nil { 697 return x.PageToken 698 } 699 return "" 700} 701 702// Response message for listing tasks using [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks]. 703type ListTasksResponse struct { 704 state protoimpl.MessageState 705 sizeCache protoimpl.SizeCache 706 unknownFields protoimpl.UnknownFields 707 708 // The list of tasks. 709 Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` 710 // A token to retrieve next page of results. 711 // 712 // To return the next page of results, call 713 // [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks] with this value as the 714 // [page_token][google.cloud.tasks.v2.ListTasksRequest.page_token]. 715 // 716 // If the next_page_token is empty, there are no more results. 717 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 718} 719 720func (x *ListTasksResponse) Reset() { 721 *x = ListTasksResponse{} 722 if protoimpl.UnsafeEnabled { 723 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[10] 724 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 725 ms.StoreMessageInfo(mi) 726 } 727} 728 729func (x *ListTasksResponse) String() string { 730 return protoimpl.X.MessageStringOf(x) 731} 732 733func (*ListTasksResponse) ProtoMessage() {} 734 735func (x *ListTasksResponse) ProtoReflect() protoreflect.Message { 736 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[10] 737 if protoimpl.UnsafeEnabled && x != nil { 738 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 739 if ms.LoadMessageInfo() == nil { 740 ms.StoreMessageInfo(mi) 741 } 742 return ms 743 } 744 return mi.MessageOf(x) 745} 746 747// Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead. 748func (*ListTasksResponse) Descriptor() ([]byte, []int) { 749 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{10} 750} 751 752func (x *ListTasksResponse) GetTasks() []*Task { 753 if x != nil { 754 return x.Tasks 755 } 756 return nil 757} 758 759func (x *ListTasksResponse) GetNextPageToken() string { 760 if x != nil { 761 return x.NextPageToken 762 } 763 return "" 764} 765 766// Request message for getting a task using [GetTask][google.cloud.tasks.v2.CloudTasks.GetTask]. 767type GetTaskRequest struct { 768 state protoimpl.MessageState 769 sizeCache protoimpl.SizeCache 770 unknownFields protoimpl.UnknownFields 771 772 // Required. The task name. For example: 773 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` 774 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 775 // The response_view specifies which subset of the [Task][google.cloud.tasks.v2.Task] will be 776 // returned. 777 // 778 // By default response_view is [BASIC][google.cloud.tasks.v2.Task.View.BASIC]; not all 779 // information is retrieved by default because some data, such as 780 // payloads, might be desirable to return only when needed because 781 // of its large size or because of the sensitivity of data that it 782 // contains. 783 // 784 // Authorization for [FULL][google.cloud.tasks.v2.Task.View.FULL] requires 785 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 786 // permission on the [Task][google.cloud.tasks.v2.Task] resource. 787 ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2.Task_View" json:"response_view,omitempty"` 788} 789 790func (x *GetTaskRequest) Reset() { 791 *x = GetTaskRequest{} 792 if protoimpl.UnsafeEnabled { 793 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[11] 794 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 795 ms.StoreMessageInfo(mi) 796 } 797} 798 799func (x *GetTaskRequest) String() string { 800 return protoimpl.X.MessageStringOf(x) 801} 802 803func (*GetTaskRequest) ProtoMessage() {} 804 805func (x *GetTaskRequest) ProtoReflect() protoreflect.Message { 806 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[11] 807 if protoimpl.UnsafeEnabled && x != nil { 808 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 809 if ms.LoadMessageInfo() == nil { 810 ms.StoreMessageInfo(mi) 811 } 812 return ms 813 } 814 return mi.MessageOf(x) 815} 816 817// Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead. 818func (*GetTaskRequest) Descriptor() ([]byte, []int) { 819 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{11} 820} 821 822func (x *GetTaskRequest) GetName() string { 823 if x != nil { 824 return x.Name 825 } 826 return "" 827} 828 829func (x *GetTaskRequest) GetResponseView() Task_View { 830 if x != nil { 831 return x.ResponseView 832 } 833 return Task_VIEW_UNSPECIFIED 834} 835 836// Request message for [CreateTask][google.cloud.tasks.v2.CloudTasks.CreateTask]. 837type CreateTaskRequest struct { 838 state protoimpl.MessageState 839 sizeCache protoimpl.SizeCache 840 unknownFields protoimpl.UnknownFields 841 842 // Required. The queue name. For example: 843 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 844 // 845 // The queue must already exist. 846 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 847 // Required. The task to add. 848 // 849 // Task names have the following format: 850 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID`. 851 // The user can optionally specify a task [name][google.cloud.tasks.v2.Task.name]. If a 852 // name is not specified then the system will generate a random 853 // unique task id, which will be set in the task returned in the 854 // [response][google.cloud.tasks.v2.Task.name]. 855 // 856 // If [schedule_time][google.cloud.tasks.v2.Task.schedule_time] is not set or is in the 857 // past then Cloud Tasks will set it to the current time. 858 // 859 // Task De-duplication: 860 // 861 // Explicitly specifying a task ID enables task de-duplication. If 862 // a task's ID is identical to that of an existing task or a task 863 // that was deleted or executed recently then the call will fail 864 // with [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS]. 865 // If the task's queue was created using Cloud Tasks, then another task with 866 // the same name can't be created for ~1hour after the original task was 867 // deleted or executed. If the task's queue was created using queue.yaml or 868 // queue.xml, then another task with the same name can't be created 869 // for ~9days after the original task was deleted or executed. 870 // 871 // Because there is an extra lookup cost to identify duplicate task 872 // names, these [CreateTask][google.cloud.tasks.v2.CloudTasks.CreateTask] calls have significantly 873 // increased latency. Using hashed strings for the task id or for 874 // the prefix of the task id is recommended. Choosing task ids that 875 // are sequential or have sequential prefixes, for example using a 876 // timestamp, causes an increase in latency and error rates in all 877 // task commands. The infrastructure relies on an approximately 878 // uniform distribution of task ids to store and serve tasks 879 // efficiently. 880 Task *Task `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` 881 // The response_view specifies which subset of the [Task][google.cloud.tasks.v2.Task] will be 882 // returned. 883 // 884 // By default response_view is [BASIC][google.cloud.tasks.v2.Task.View.BASIC]; not all 885 // information is retrieved by default because some data, such as 886 // payloads, might be desirable to return only when needed because 887 // of its large size or because of the sensitivity of data that it 888 // contains. 889 // 890 // Authorization for [FULL][google.cloud.tasks.v2.Task.View.FULL] requires 891 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 892 // permission on the [Task][google.cloud.tasks.v2.Task] resource. 893 ResponseView Task_View `protobuf:"varint,3,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2.Task_View" json:"response_view,omitempty"` 894} 895 896func (x *CreateTaskRequest) Reset() { 897 *x = CreateTaskRequest{} 898 if protoimpl.UnsafeEnabled { 899 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[12] 900 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 901 ms.StoreMessageInfo(mi) 902 } 903} 904 905func (x *CreateTaskRequest) String() string { 906 return protoimpl.X.MessageStringOf(x) 907} 908 909func (*CreateTaskRequest) ProtoMessage() {} 910 911func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message { 912 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[12] 913 if protoimpl.UnsafeEnabled && x != nil { 914 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 915 if ms.LoadMessageInfo() == nil { 916 ms.StoreMessageInfo(mi) 917 } 918 return ms 919 } 920 return mi.MessageOf(x) 921} 922 923// Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead. 924func (*CreateTaskRequest) Descriptor() ([]byte, []int) { 925 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{12} 926} 927 928func (x *CreateTaskRequest) GetParent() string { 929 if x != nil { 930 return x.Parent 931 } 932 return "" 933} 934 935func (x *CreateTaskRequest) GetTask() *Task { 936 if x != nil { 937 return x.Task 938 } 939 return nil 940} 941 942func (x *CreateTaskRequest) GetResponseView() Task_View { 943 if x != nil { 944 return x.ResponseView 945 } 946 return Task_VIEW_UNSPECIFIED 947} 948 949// Request message for deleting a task using 950// [DeleteTask][google.cloud.tasks.v2.CloudTasks.DeleteTask]. 951type DeleteTaskRequest struct { 952 state protoimpl.MessageState 953 sizeCache protoimpl.SizeCache 954 unknownFields protoimpl.UnknownFields 955 956 // Required. The task name. For example: 957 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` 958 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 959} 960 961func (x *DeleteTaskRequest) Reset() { 962 *x = DeleteTaskRequest{} 963 if protoimpl.UnsafeEnabled { 964 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[13] 965 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 966 ms.StoreMessageInfo(mi) 967 } 968} 969 970func (x *DeleteTaskRequest) String() string { 971 return protoimpl.X.MessageStringOf(x) 972} 973 974func (*DeleteTaskRequest) ProtoMessage() {} 975 976func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message { 977 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[13] 978 if protoimpl.UnsafeEnabled && x != nil { 979 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 980 if ms.LoadMessageInfo() == nil { 981 ms.StoreMessageInfo(mi) 982 } 983 return ms 984 } 985 return mi.MessageOf(x) 986} 987 988// Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead. 989func (*DeleteTaskRequest) Descriptor() ([]byte, []int) { 990 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{13} 991} 992 993func (x *DeleteTaskRequest) GetName() string { 994 if x != nil { 995 return x.Name 996 } 997 return "" 998} 999 1000// Request message for forcing a task to run now using 1001// [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask]. 1002type RunTaskRequest struct { 1003 state protoimpl.MessageState 1004 sizeCache protoimpl.SizeCache 1005 unknownFields protoimpl.UnknownFields 1006 1007 // Required. The task name. For example: 1008 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` 1009 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1010 // The response_view specifies which subset of the [Task][google.cloud.tasks.v2.Task] will be 1011 // returned. 1012 // 1013 // By default response_view is [BASIC][google.cloud.tasks.v2.Task.View.BASIC]; not all 1014 // information is retrieved by default because some data, such as 1015 // payloads, might be desirable to return only when needed because 1016 // of its large size or because of the sensitivity of data that it 1017 // contains. 1018 // 1019 // Authorization for [FULL][google.cloud.tasks.v2.Task.View.FULL] requires 1020 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 1021 // permission on the [Task][google.cloud.tasks.v2.Task] resource. 1022 ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2.Task_View" json:"response_view,omitempty"` 1023} 1024 1025func (x *RunTaskRequest) Reset() { 1026 *x = RunTaskRequest{} 1027 if protoimpl.UnsafeEnabled { 1028 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[14] 1029 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1030 ms.StoreMessageInfo(mi) 1031 } 1032} 1033 1034func (x *RunTaskRequest) String() string { 1035 return protoimpl.X.MessageStringOf(x) 1036} 1037 1038func (*RunTaskRequest) ProtoMessage() {} 1039 1040func (x *RunTaskRequest) ProtoReflect() protoreflect.Message { 1041 mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[14] 1042 if protoimpl.UnsafeEnabled && x != nil { 1043 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1044 if ms.LoadMessageInfo() == nil { 1045 ms.StoreMessageInfo(mi) 1046 } 1047 return ms 1048 } 1049 return mi.MessageOf(x) 1050} 1051 1052// Deprecated: Use RunTaskRequest.ProtoReflect.Descriptor instead. 1053func (*RunTaskRequest) Descriptor() ([]byte, []int) { 1054 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{14} 1055} 1056 1057func (x *RunTaskRequest) GetName() string { 1058 if x != nil { 1059 return x.Name 1060 } 1061 return "" 1062} 1063 1064func (x *RunTaskRequest) GetResponseView() Task_View { 1065 if x != nil { 1066 return x.ResponseView 1067 } 1068 return Task_VIEW_UNSPECIFIED 1069} 1070 1071var File_google_cloud_tasks_v2_cloudtasks_proto protoreflect.FileDescriptor 1072 1073var file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc = []byte{ 1074 0x0a, 0x26, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 1075 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 1076 0x6b, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1077 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x1a, 1078 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 1079 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 1080 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 1081 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 1082 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 1083 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 1084 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 1085 0x74, 0x6f, 0x1a, 0x21, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 1086 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x2e, 1087 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 1088 0x6f, 0x75, 0x64, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x2f, 0x74, 0x61, 0x73, 1089 0x6b, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 1090 0x69, 0x61, 0x6d, 0x2f, 0x76, 0x31, 0x2f, 0x69, 0x61, 0x6d, 0x5f, 0x70, 0x6f, 0x6c, 0x69, 0x63, 1091 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1a, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 1092 0x69, 0x61, 0x6d, 0x2f, 0x76, 0x31, 0x2f, 0x70, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x2e, 0x70, 0x72, 1093 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 1094 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 1095 0x1a, 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 1096 0x66, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x2e, 0x70, 0x72, 0x6f, 1097 0x74, 0x6f, 0x22, 0xa8, 0x01, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 1098 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3f, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 1099 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 1100 0x12, 0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 1101 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 1102 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69, 0x6c, 1103 0x74, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 1104 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 1105 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 1106 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 1107 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x72, 0x0a, 1108 0x12, 0x4c, 0x69, 0x73, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 1109 0x6e, 0x73, 0x65, 0x12, 0x34, 0x0a, 0x06, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x18, 0x01, 0x20, 1110 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 1111 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x75, 1112 0x65, 0x52, 0x06, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 1113 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 1114 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 1115 0x6e, 0x22, 0x4e, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 1116 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 1117 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x0a, 0x1f, 0x63, 0x6c, 0x6f, 0x75, 1118 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 1119 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 1120 0x65, 0x22, 0x8e, 0x01, 0x0a, 0x12, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 1121 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3f, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 1122 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 1123 0x12, 0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 1124 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 1125 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x37, 0x0a, 0x05, 0x71, 0x75, 0x65, 1126 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1127 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 1128 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x05, 0x71, 0x75, 0x65, 1129 0x75, 0x65, 0x22, 0x8a, 0x01, 0x0a, 0x12, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x51, 0x75, 0x65, 1130 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x05, 0x71, 0x75, 0x65, 1131 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1132 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 1133 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x05, 0x71, 0x75, 0x65, 1134 0x75, 0x65, 0x12, 0x3b, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 1135 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1136 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 1137 0x61, 0x73, 0x6b, 0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x73, 0x6b, 0x22, 1138 0x51, 0x0a, 0x12, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 1139 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 1140 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x0a, 0x1f, 0x63, 0x6c, 0x6f, 1141 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 1142 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x04, 0x6e, 0x61, 1143 0x6d, 0x65, 0x22, 0x50, 0x0a, 0x11, 0x50, 0x75, 0x72, 0x67, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 1144 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 1145 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x0a, 0x1f, 0x63, 1146 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1147 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x04, 1148 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x50, 0x0a, 0x11, 0x50, 0x61, 0x75, 0x73, 0x65, 0x51, 0x75, 0x65, 1149 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 1150 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x0a, 1151 0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1152 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65, 1153 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x51, 0x0a, 0x12, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 1154 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 1155 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 1156 0x41, 0x21, 0x0a, 0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 1157 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 1158 0x65, 0x75, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xd5, 0x01, 0x0a, 0x10, 0x4c, 0x69, 1159 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3e, 1160 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 1161 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x20, 0x12, 0x1e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 1162 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 1163 0x6d, 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x45, 1164 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18, 1165 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 1166 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x54, 0x61, 1167 0x73, 0x6b, 0x2e, 0x56, 0x69, 0x65, 0x77, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 1168 0x65, 0x56, 0x69, 0x65, 0x77, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 1169 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 1170 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 1171 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 1172 0x6e, 0x22, 0x6e, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 1173 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x31, 0x0a, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 1174 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 1175 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x54, 0x61, 1176 0x73, 0x6b, 0x52, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 1177 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 1178 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 1179 0x6e, 0x22, 0x93, 0x01, 0x0a, 0x0e, 0x47, 0x65, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 1180 0x75, 0x65, 0x73, 0x74, 0x12, 0x3a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 1181 0x28, 0x09, 0x42, 0x26, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x20, 0x0a, 0x1e, 0x63, 0x6c, 0x6f, 0x75, 1182 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 1183 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 1184 0x12, 0x45, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x76, 0x69, 0x65, 1185 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1186 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 1187 0x54, 0x61, 0x73, 0x6b, 0x2e, 0x56, 0x69, 0x65, 0x77, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 1188 0x6e, 0x73, 0x65, 0x56, 0x69, 0x65, 0x77, 0x22, 0xd0, 0x01, 0x0a, 0x11, 0x43, 0x72, 0x65, 0x61, 1189 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3e, 0x0a, 1190 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xe0, 1191 0x41, 0x02, 0xfa, 0x41, 0x20, 0x12, 0x1e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 1192 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 1193 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x34, 0x0a, 1194 0x04, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x6f, 1195 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 1196 0x2e, 0x76, 0x32, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x04, 0x74, 1197 0x61, 0x73, 0x6b, 0x12, 0x45, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 1198 0x76, 0x69, 0x65, 0x77, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 1199 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 1200 0x76, 0x32, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x2e, 0x56, 0x69, 0x65, 0x77, 0x52, 0x0c, 0x72, 0x65, 1201 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x56, 0x69, 0x65, 0x77, 0x22, 0x4f, 0x0a, 0x11, 0x44, 0x65, 1202 0x6c, 0x65, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 1203 0x3a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xe0, 1204 0x41, 0x02, 0xfa, 0x41, 0x20, 0x0a, 0x1e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 1205 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 1206 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x93, 0x01, 0x0a, 0x0e, 1207 0x52, 0x75, 0x6e, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3a, 1208 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xe0, 0x41, 1209 0x02, 0xfa, 0x41, 0x20, 0x0a, 0x1e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 1210 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 1211 0x54, 0x61, 0x73, 0x6b, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x45, 0x0a, 0x0d, 0x72, 0x65, 1212 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 1213 0x0e, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 1214 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x2e, 0x56, 1215 0x69, 0x65, 0x77, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x56, 0x69, 0x65, 1216 0x77, 0x32, 0xdd, 0x14, 0x0a, 0x0a, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x54, 0x61, 0x73, 0x6b, 0x73, 1217 0x12, 0x9e, 0x01, 0x0a, 0x0a, 0x4c, 0x69, 0x73, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x73, 0x12, 1218 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 1219 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x51, 0x75, 0x65, 0x75, 1220 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1221 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 1222 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 1223 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x3b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2c, 0x12, 0x2a, 0x2f, 0x76, 1224 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 1225 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 1226 0x7d, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 1227 0x74, 0x12, 0x8b, 0x01, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x26, 1228 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 1229 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 1230 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1231 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x51, 1232 0x75, 0x65, 0x75, 0x65, 0x22, 0x39, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2c, 0x12, 0x2a, 0x2f, 0x76, 1233 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 1234 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 1235 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 1236 0xa0, 0x01, 0x0a, 0x0b, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 1237 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 1238 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x51, 0x75, 1239 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 1240 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 1241 0x76, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x22, 0x48, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x33, 1242 0x22, 0x2a, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 1243 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 1244 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x3a, 0x05, 0x71, 0x75, 1245 0x65, 0x75, 0x65, 0xda, 0x41, 0x0c, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x71, 0x75, 0x65, 1246 0x75, 0x65, 0x12, 0xab, 0x01, 0x0a, 0x0b, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x51, 0x75, 0x65, 1247 0x75, 0x65, 0x12, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 1248 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 1249 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 1250 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 1251 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x22, 0x53, 0x82, 0xd3, 0xe4, 1252 0x93, 0x02, 0x39, 0x32, 0x30, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x71, 0x75, 0x65, 0x75, 0x65, 0x2e, 1253 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 1254 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 1255 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x05, 0x71, 0x75, 0x65, 0x75, 0x65, 0xda, 0x41, 0x11, 0x71, 1256 0x75, 0x65, 0x75, 0x65, 0x2c, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 1257 0x12, 0x8b, 0x01, 0x0a, 0x0b, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 1258 0x12, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 1259 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x51, 1260 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 1261 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 1262 0x70, 0x74, 0x79, 0x22, 0x39, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2c, 0x2a, 0x2a, 0x2f, 0x76, 0x32, 1263 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 1264 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 1265 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x98, 1266 0x01, 0x0a, 0x0a, 0x50, 0x75, 0x72, 0x67, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x28, 0x2e, 1267 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 1268 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x50, 0x75, 0x72, 0x67, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 1269 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1270 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 1271 0x51, 0x75, 0x65, 0x75, 0x65, 0x22, 0x42, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x35, 0x22, 0x30, 0x2f, 1272 0x76, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 1273 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 1274 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x70, 0x75, 0x72, 0x67, 0x65, 0x3a, 1275 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x98, 0x01, 0x0a, 0x0a, 0x50, 0x61, 1276 0x75, 0x73, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1277 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 1278 0x2e, 0x50, 0x61, 0x75, 0x73, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 1279 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 1280 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 1281 0x22, 0x42, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x35, 0x22, 0x30, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x6e, 1282 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 1283 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 1284 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x70, 0x61, 0x75, 0x73, 0x65, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 1285 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x9b, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x51, 1286 0x75, 0x65, 0x75, 0x65, 0x12, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 1287 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x52, 0x65, 0x73, 1288 0x75, 0x6d, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 1289 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 1290 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x22, 0x43, 0x82, 1291 0xd3, 0xe4, 0x93, 0x02, 0x36, 0x22, 0x31, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 1292 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 1293 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 1294 0x7d, 0x3a, 0x72, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 1295 0x6d, 0x65, 0x12, 0x9c, 0x01, 0x0a, 0x0c, 0x47, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 1296 0x69, 0x63, 0x79, 0x12, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 1297 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 1298 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1299 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x22, 0x51, 1300 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x40, 0x22, 0x3b, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x72, 0x65, 0x73, 1301 0x6f, 0x75, 0x72, 0x63, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 1302 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 1303 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x67, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 1304 0x69, 0x63, 0x79, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x08, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 1305 0x65, 0x12, 0xa3, 0x01, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 1306 0x63, 0x79, 0x12, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 1307 0x76, 0x31, 0x2e, 0x53, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x52, 1308 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1309 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x22, 0x58, 0x82, 1310 0xd3, 0xe4, 0x93, 0x02, 0x40, 0x22, 0x3b, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x72, 0x65, 0x73, 0x6f, 1311 0x75, 0x72, 0x63, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 1312 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 1313 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x73, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 1314 0x63, 0x79, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x0f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 1315 0x2c, 0x70, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x12, 0xce, 0x01, 0x0a, 0x12, 0x54, 0x65, 0x73, 0x74, 1316 0x49, 0x61, 0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x28, 1317 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x54, 1318 0x65, 0x73, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 1319 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1320 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x65, 0x73, 0x74, 0x49, 0x61, 0x6d, 1321 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 1322 0x6e, 0x73, 0x65, 0x22, 0x63, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x46, 0x22, 0x41, 0x2f, 0x76, 0x32, 1323 0x2f, 0x7b, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 1324 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 1325 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x74, 0x65, 0x73, 0x74, 1326 0x49, 0x61, 0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x3a, 0x01, 1327 0x2a, 0xda, 0x41, 0x14, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2c, 0x70, 0x65, 0x72, 1328 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0xa3, 0x01, 0x0a, 0x09, 0x4c, 0x69, 0x73, 1329 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1330 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x4c, 1331 0x69, 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 1332 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 1333 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 1334 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x43, 0x82, 0xd3, 0xe4, 0x93, 0x02, 1335 0x34, 0x12, 0x32, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 1336 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 1337 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 1338 0x74, 0x61, 0x73, 0x6b, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x90, 1339 0x01, 0x0a, 0x07, 0x47, 0x65, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 1340 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 1341 0x76, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 1342 0x74, 0x1a, 0x1b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 1343 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x22, 0x41, 1344 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x12, 0x32, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 1345 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 1346 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 1347 0x2a, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 1348 0x65, 0x12, 0xa0, 0x01, 0x0a, 0x0a, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 1349 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 1350 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 1351 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x67, 0x6f, 0x6f, 1352 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 1353 0x76, 0x32, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x22, 0x4b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x37, 0x22, 1354 0x32, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 1355 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 1356 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x74, 0x61, 1357 0x73, 0x6b, 0x73, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x0b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 1358 0x74, 0x61, 0x73, 0x6b, 0x12, 0x91, 0x01, 0x0a, 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 1359 0x61, 0x73, 0x6b, 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 1360 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x65, 1361 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 1362 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 1363 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x41, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x2a, 0x32, 0x2f, 1364 0x76, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 1365 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 1366 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x2a, 1367 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x97, 0x01, 0x0a, 0x07, 0x52, 0x75, 0x6e, 1368 0x54, 0x61, 0x73, 0x6b, 0x12, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 1369 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x52, 0x75, 0x6e, 1370 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x67, 0x6f, 1371 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 1372 0x2e, 0x76, 0x32, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x22, 0x48, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3b, 1373 0x22, 0x36, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 1374 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 1375 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x73, 0x6b, 1376 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x75, 0x6e, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 1377 0x6d, 0x65, 0x1a, 0x4d, 0xca, 0x41, 0x19, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 1378 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 1379 0xd2, 0x41, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 1380 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 1381 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 1382 0x6d, 0x42, 0x72, 0x0a, 0x19, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1383 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x42, 0x0f, 1384 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 1385 0x01, 0x5a, 0x3a, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 1386 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 1387 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 1388 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x3b, 0x74, 0x61, 0x73, 0x6b, 0x73, 0xa2, 0x02, 0x05, 1389 0x54, 0x41, 0x53, 0x4b, 0x53, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 1390} 1391 1392var ( 1393 file_google_cloud_tasks_v2_cloudtasks_proto_rawDescOnce sync.Once 1394 file_google_cloud_tasks_v2_cloudtasks_proto_rawDescData = file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc 1395) 1396 1397func file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP() []byte { 1398 file_google_cloud_tasks_v2_cloudtasks_proto_rawDescOnce.Do(func() { 1399 file_google_cloud_tasks_v2_cloudtasks_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_tasks_v2_cloudtasks_proto_rawDescData) 1400 }) 1401 return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescData 1402} 1403 1404var file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes = make([]protoimpl.MessageInfo, 15) 1405var file_google_cloud_tasks_v2_cloudtasks_proto_goTypes = []interface{}{ 1406 (*ListQueuesRequest)(nil), // 0: google.cloud.tasks.v2.ListQueuesRequest 1407 (*ListQueuesResponse)(nil), // 1: google.cloud.tasks.v2.ListQueuesResponse 1408 (*GetQueueRequest)(nil), // 2: google.cloud.tasks.v2.GetQueueRequest 1409 (*CreateQueueRequest)(nil), // 3: google.cloud.tasks.v2.CreateQueueRequest 1410 (*UpdateQueueRequest)(nil), // 4: google.cloud.tasks.v2.UpdateQueueRequest 1411 (*DeleteQueueRequest)(nil), // 5: google.cloud.tasks.v2.DeleteQueueRequest 1412 (*PurgeQueueRequest)(nil), // 6: google.cloud.tasks.v2.PurgeQueueRequest 1413 (*PauseQueueRequest)(nil), // 7: google.cloud.tasks.v2.PauseQueueRequest 1414 (*ResumeQueueRequest)(nil), // 8: google.cloud.tasks.v2.ResumeQueueRequest 1415 (*ListTasksRequest)(nil), // 9: google.cloud.tasks.v2.ListTasksRequest 1416 (*ListTasksResponse)(nil), // 10: google.cloud.tasks.v2.ListTasksResponse 1417 (*GetTaskRequest)(nil), // 11: google.cloud.tasks.v2.GetTaskRequest 1418 (*CreateTaskRequest)(nil), // 12: google.cloud.tasks.v2.CreateTaskRequest 1419 (*DeleteTaskRequest)(nil), // 13: google.cloud.tasks.v2.DeleteTaskRequest 1420 (*RunTaskRequest)(nil), // 14: google.cloud.tasks.v2.RunTaskRequest 1421 (*Queue)(nil), // 15: google.cloud.tasks.v2.Queue 1422 (*fieldmaskpb.FieldMask)(nil), // 16: google.protobuf.FieldMask 1423 (Task_View)(0), // 17: google.cloud.tasks.v2.Task.View 1424 (*Task)(nil), // 18: google.cloud.tasks.v2.Task 1425 (*v1.GetIamPolicyRequest)(nil), // 19: google.iam.v1.GetIamPolicyRequest 1426 (*v1.SetIamPolicyRequest)(nil), // 20: google.iam.v1.SetIamPolicyRequest 1427 (*v1.TestIamPermissionsRequest)(nil), // 21: google.iam.v1.TestIamPermissionsRequest 1428 (*emptypb.Empty)(nil), // 22: google.protobuf.Empty 1429 (*v1.Policy)(nil), // 23: google.iam.v1.Policy 1430 (*v1.TestIamPermissionsResponse)(nil), // 24: google.iam.v1.TestIamPermissionsResponse 1431} 1432var file_google_cloud_tasks_v2_cloudtasks_proto_depIdxs = []int32{ 1433 15, // 0: google.cloud.tasks.v2.ListQueuesResponse.queues:type_name -> google.cloud.tasks.v2.Queue 1434 15, // 1: google.cloud.tasks.v2.CreateQueueRequest.queue:type_name -> google.cloud.tasks.v2.Queue 1435 15, // 2: google.cloud.tasks.v2.UpdateQueueRequest.queue:type_name -> google.cloud.tasks.v2.Queue 1436 16, // 3: google.cloud.tasks.v2.UpdateQueueRequest.update_mask:type_name -> google.protobuf.FieldMask 1437 17, // 4: google.cloud.tasks.v2.ListTasksRequest.response_view:type_name -> google.cloud.tasks.v2.Task.View 1438 18, // 5: google.cloud.tasks.v2.ListTasksResponse.tasks:type_name -> google.cloud.tasks.v2.Task 1439 17, // 6: google.cloud.tasks.v2.GetTaskRequest.response_view:type_name -> google.cloud.tasks.v2.Task.View 1440 18, // 7: google.cloud.tasks.v2.CreateTaskRequest.task:type_name -> google.cloud.tasks.v2.Task 1441 17, // 8: google.cloud.tasks.v2.CreateTaskRequest.response_view:type_name -> google.cloud.tasks.v2.Task.View 1442 17, // 9: google.cloud.tasks.v2.RunTaskRequest.response_view:type_name -> google.cloud.tasks.v2.Task.View 1443 0, // 10: google.cloud.tasks.v2.CloudTasks.ListQueues:input_type -> google.cloud.tasks.v2.ListQueuesRequest 1444 2, // 11: google.cloud.tasks.v2.CloudTasks.GetQueue:input_type -> google.cloud.tasks.v2.GetQueueRequest 1445 3, // 12: google.cloud.tasks.v2.CloudTasks.CreateQueue:input_type -> google.cloud.tasks.v2.CreateQueueRequest 1446 4, // 13: google.cloud.tasks.v2.CloudTasks.UpdateQueue:input_type -> google.cloud.tasks.v2.UpdateQueueRequest 1447 5, // 14: google.cloud.tasks.v2.CloudTasks.DeleteQueue:input_type -> google.cloud.tasks.v2.DeleteQueueRequest 1448 6, // 15: google.cloud.tasks.v2.CloudTasks.PurgeQueue:input_type -> google.cloud.tasks.v2.PurgeQueueRequest 1449 7, // 16: google.cloud.tasks.v2.CloudTasks.PauseQueue:input_type -> google.cloud.tasks.v2.PauseQueueRequest 1450 8, // 17: google.cloud.tasks.v2.CloudTasks.ResumeQueue:input_type -> google.cloud.tasks.v2.ResumeQueueRequest 1451 19, // 18: google.cloud.tasks.v2.CloudTasks.GetIamPolicy:input_type -> google.iam.v1.GetIamPolicyRequest 1452 20, // 19: google.cloud.tasks.v2.CloudTasks.SetIamPolicy:input_type -> google.iam.v1.SetIamPolicyRequest 1453 21, // 20: google.cloud.tasks.v2.CloudTasks.TestIamPermissions:input_type -> google.iam.v1.TestIamPermissionsRequest 1454 9, // 21: google.cloud.tasks.v2.CloudTasks.ListTasks:input_type -> google.cloud.tasks.v2.ListTasksRequest 1455 11, // 22: google.cloud.tasks.v2.CloudTasks.GetTask:input_type -> google.cloud.tasks.v2.GetTaskRequest 1456 12, // 23: google.cloud.tasks.v2.CloudTasks.CreateTask:input_type -> google.cloud.tasks.v2.CreateTaskRequest 1457 13, // 24: google.cloud.tasks.v2.CloudTasks.DeleteTask:input_type -> google.cloud.tasks.v2.DeleteTaskRequest 1458 14, // 25: google.cloud.tasks.v2.CloudTasks.RunTask:input_type -> google.cloud.tasks.v2.RunTaskRequest 1459 1, // 26: google.cloud.tasks.v2.CloudTasks.ListQueues:output_type -> google.cloud.tasks.v2.ListQueuesResponse 1460 15, // 27: google.cloud.tasks.v2.CloudTasks.GetQueue:output_type -> google.cloud.tasks.v2.Queue 1461 15, // 28: google.cloud.tasks.v2.CloudTasks.CreateQueue:output_type -> google.cloud.tasks.v2.Queue 1462 15, // 29: google.cloud.tasks.v2.CloudTasks.UpdateQueue:output_type -> google.cloud.tasks.v2.Queue 1463 22, // 30: google.cloud.tasks.v2.CloudTasks.DeleteQueue:output_type -> google.protobuf.Empty 1464 15, // 31: google.cloud.tasks.v2.CloudTasks.PurgeQueue:output_type -> google.cloud.tasks.v2.Queue 1465 15, // 32: google.cloud.tasks.v2.CloudTasks.PauseQueue:output_type -> google.cloud.tasks.v2.Queue 1466 15, // 33: google.cloud.tasks.v2.CloudTasks.ResumeQueue:output_type -> google.cloud.tasks.v2.Queue 1467 23, // 34: google.cloud.tasks.v2.CloudTasks.GetIamPolicy:output_type -> google.iam.v1.Policy 1468 23, // 35: google.cloud.tasks.v2.CloudTasks.SetIamPolicy:output_type -> google.iam.v1.Policy 1469 24, // 36: google.cloud.tasks.v2.CloudTasks.TestIamPermissions:output_type -> google.iam.v1.TestIamPermissionsResponse 1470 10, // 37: google.cloud.tasks.v2.CloudTasks.ListTasks:output_type -> google.cloud.tasks.v2.ListTasksResponse 1471 18, // 38: google.cloud.tasks.v2.CloudTasks.GetTask:output_type -> google.cloud.tasks.v2.Task 1472 18, // 39: google.cloud.tasks.v2.CloudTasks.CreateTask:output_type -> google.cloud.tasks.v2.Task 1473 22, // 40: google.cloud.tasks.v2.CloudTasks.DeleteTask:output_type -> google.protobuf.Empty 1474 18, // 41: google.cloud.tasks.v2.CloudTasks.RunTask:output_type -> google.cloud.tasks.v2.Task 1475 26, // [26:42] is the sub-list for method output_type 1476 10, // [10:26] is the sub-list for method input_type 1477 10, // [10:10] is the sub-list for extension type_name 1478 10, // [10:10] is the sub-list for extension extendee 1479 0, // [0:10] is the sub-list for field type_name 1480} 1481 1482func init() { file_google_cloud_tasks_v2_cloudtasks_proto_init() } 1483func file_google_cloud_tasks_v2_cloudtasks_proto_init() { 1484 if File_google_cloud_tasks_v2_cloudtasks_proto != nil { 1485 return 1486 } 1487 file_google_cloud_tasks_v2_queue_proto_init() 1488 file_google_cloud_tasks_v2_task_proto_init() 1489 if !protoimpl.UnsafeEnabled { 1490 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 1491 switch v := v.(*ListQueuesRequest); i { 1492 case 0: 1493 return &v.state 1494 case 1: 1495 return &v.sizeCache 1496 case 2: 1497 return &v.unknownFields 1498 default: 1499 return nil 1500 } 1501 } 1502 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 1503 switch v := v.(*ListQueuesResponse); i { 1504 case 0: 1505 return &v.state 1506 case 1: 1507 return &v.sizeCache 1508 case 2: 1509 return &v.unknownFields 1510 default: 1511 return nil 1512 } 1513 } 1514 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 1515 switch v := v.(*GetQueueRequest); i { 1516 case 0: 1517 return &v.state 1518 case 1: 1519 return &v.sizeCache 1520 case 2: 1521 return &v.unknownFields 1522 default: 1523 return nil 1524 } 1525 } 1526 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 1527 switch v := v.(*CreateQueueRequest); i { 1528 case 0: 1529 return &v.state 1530 case 1: 1531 return &v.sizeCache 1532 case 2: 1533 return &v.unknownFields 1534 default: 1535 return nil 1536 } 1537 } 1538 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 1539 switch v := v.(*UpdateQueueRequest); i { 1540 case 0: 1541 return &v.state 1542 case 1: 1543 return &v.sizeCache 1544 case 2: 1545 return &v.unknownFields 1546 default: 1547 return nil 1548 } 1549 } 1550 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1551 switch v := v.(*DeleteQueueRequest); i { 1552 case 0: 1553 return &v.state 1554 case 1: 1555 return &v.sizeCache 1556 case 2: 1557 return &v.unknownFields 1558 default: 1559 return nil 1560 } 1561 } 1562 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1563 switch v := v.(*PurgeQueueRequest); i { 1564 case 0: 1565 return &v.state 1566 case 1: 1567 return &v.sizeCache 1568 case 2: 1569 return &v.unknownFields 1570 default: 1571 return nil 1572 } 1573 } 1574 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1575 switch v := v.(*PauseQueueRequest); i { 1576 case 0: 1577 return &v.state 1578 case 1: 1579 return &v.sizeCache 1580 case 2: 1581 return &v.unknownFields 1582 default: 1583 return nil 1584 } 1585 } 1586 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1587 switch v := v.(*ResumeQueueRequest); i { 1588 case 0: 1589 return &v.state 1590 case 1: 1591 return &v.sizeCache 1592 case 2: 1593 return &v.unknownFields 1594 default: 1595 return nil 1596 } 1597 } 1598 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 1599 switch v := v.(*ListTasksRequest); i { 1600 case 0: 1601 return &v.state 1602 case 1: 1603 return &v.sizeCache 1604 case 2: 1605 return &v.unknownFields 1606 default: 1607 return nil 1608 } 1609 } 1610 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { 1611 switch v := v.(*ListTasksResponse); i { 1612 case 0: 1613 return &v.state 1614 case 1: 1615 return &v.sizeCache 1616 case 2: 1617 return &v.unknownFields 1618 default: 1619 return nil 1620 } 1621 } 1622 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { 1623 switch v := v.(*GetTaskRequest); i { 1624 case 0: 1625 return &v.state 1626 case 1: 1627 return &v.sizeCache 1628 case 2: 1629 return &v.unknownFields 1630 default: 1631 return nil 1632 } 1633 } 1634 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { 1635 switch v := v.(*CreateTaskRequest); i { 1636 case 0: 1637 return &v.state 1638 case 1: 1639 return &v.sizeCache 1640 case 2: 1641 return &v.unknownFields 1642 default: 1643 return nil 1644 } 1645 } 1646 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { 1647 switch v := v.(*DeleteTaskRequest); i { 1648 case 0: 1649 return &v.state 1650 case 1: 1651 return &v.sizeCache 1652 case 2: 1653 return &v.unknownFields 1654 default: 1655 return nil 1656 } 1657 } 1658 file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { 1659 switch v := v.(*RunTaskRequest); i { 1660 case 0: 1661 return &v.state 1662 case 1: 1663 return &v.sizeCache 1664 case 2: 1665 return &v.unknownFields 1666 default: 1667 return nil 1668 } 1669 } 1670 } 1671 type x struct{} 1672 out := protoimpl.TypeBuilder{ 1673 File: protoimpl.DescBuilder{ 1674 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1675 RawDescriptor: file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc, 1676 NumEnums: 0, 1677 NumMessages: 15, 1678 NumExtensions: 0, 1679 NumServices: 1, 1680 }, 1681 GoTypes: file_google_cloud_tasks_v2_cloudtasks_proto_goTypes, 1682 DependencyIndexes: file_google_cloud_tasks_v2_cloudtasks_proto_depIdxs, 1683 MessageInfos: file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes, 1684 }.Build() 1685 File_google_cloud_tasks_v2_cloudtasks_proto = out.File 1686 file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc = nil 1687 file_google_cloud_tasks_v2_cloudtasks_proto_goTypes = nil 1688 file_google_cloud_tasks_v2_cloudtasks_proto_depIdxs = nil 1689} 1690 1691// Reference imports to suppress errors if they are not otherwise used. 1692var _ context.Context 1693var _ grpc.ClientConnInterface 1694 1695// This is a compile-time assertion to ensure that this generated file 1696// is compatible with the grpc package it is being compiled against. 1697const _ = grpc.SupportPackageIsVersion6 1698 1699// CloudTasksClient is the client API for CloudTasks service. 1700// 1701// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1702type CloudTasksClient interface { 1703 // Lists queues. 1704 // 1705 // Queues are returned in lexicographical order. 1706 ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error) 1707 // Gets a queue. 1708 GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1709 // Creates a queue. 1710 // 1711 // Queues created with this method allow tasks to live for a maximum of 31 1712 // days. After a task is 31 days old, the task will be deleted regardless of whether 1713 // it was dispatched or not. 1714 // 1715 // WARNING: Using this method may have unintended side effects if you are 1716 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1717 // Read 1718 // [Overview of Queue Management and 1719 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1720 // this method. 1721 CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1722 // Updates a queue. 1723 // 1724 // This method creates the queue if it does not exist and updates 1725 // the queue if it does exist. 1726 // 1727 // Queues created with this method allow tasks to live for a maximum of 31 1728 // days. After a task is 31 days old, the task will be deleted regardless of whether 1729 // it was dispatched or not. 1730 // 1731 // WARNING: Using this method may have unintended side effects if you are 1732 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1733 // Read 1734 // [Overview of Queue Management and 1735 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1736 // this method. 1737 UpdateQueue(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1738 // Deletes a queue. 1739 // 1740 // This command will delete the queue even if it has tasks in it. 1741 // 1742 // Note: If you delete a queue, a queue with the same name can't be created 1743 // for 7 days. 1744 // 1745 // WARNING: Using this method may have unintended side effects if you are 1746 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1747 // Read 1748 // [Overview of Queue Management and 1749 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1750 // this method. 1751 DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1752 // Purges a queue by deleting all of its tasks. 1753 // 1754 // All tasks created before this method is called are permanently deleted. 1755 // 1756 // Purge operations can take up to one minute to take effect. Tasks 1757 // might be dispatched before the purge takes effect. A purge is irreversible. 1758 PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1759 // Pauses the queue. 1760 // 1761 // If a queue is paused then the system will stop dispatching tasks 1762 // until the queue is resumed via 1763 // [ResumeQueue][google.cloud.tasks.v2.CloudTasks.ResumeQueue]. Tasks can still be added 1764 // when the queue is paused. A queue is paused if its 1765 // [state][google.cloud.tasks.v2.Queue.state] is [PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED]. 1766 PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1767 // Resume a queue. 1768 // 1769 // This method resumes a queue after it has been 1770 // [PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED] or 1771 // [DISABLED][google.cloud.tasks.v2.Queue.State.DISABLED]. The state of a queue is stored 1772 // in the queue's [state][google.cloud.tasks.v2.Queue.state]; after calling this method it 1773 // will be set to [RUNNING][google.cloud.tasks.v2.Queue.State.RUNNING]. 1774 // 1775 // WARNING: Resuming many high-QPS queues at the same time can 1776 // lead to target overloading. If you are resuming high-QPS 1777 // queues, follow the 500/50/5 pattern described in 1778 // [Managing Cloud Tasks Scaling 1779 // Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). 1780 ResumeQueue(ctx context.Context, in *ResumeQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1781 // Gets the access control policy for a [Queue][google.cloud.tasks.v2.Queue]. 1782 // Returns an empty policy if the resource exists and does not have a policy 1783 // set. 1784 // 1785 // Authorization requires the following 1786 // [Google IAM](https://cloud.google.com/iam) permission on the specified 1787 // resource parent: 1788 // 1789 // * `cloudtasks.queues.getIamPolicy` 1790 GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) 1791 // Sets the access control policy for a [Queue][google.cloud.tasks.v2.Queue]. Replaces any existing 1792 // policy. 1793 // 1794 // Note: The Cloud Console does not check queue-level IAM permissions yet. 1795 // Project-level permissions are required to use the Cloud Console. 1796 // 1797 // Authorization requires the following 1798 // [Google IAM](https://cloud.google.com/iam) permission on the specified 1799 // resource parent: 1800 // 1801 // * `cloudtasks.queues.setIamPolicy` 1802 SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) 1803 // Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2.Queue]. 1804 // If the resource does not exist, this will return an empty set of 1805 // permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error. 1806 // 1807 // Note: This operation is designed to be used for building permission-aware 1808 // UIs and command-line tools, not for authorization checking. This operation 1809 // may "fail open" without warning. 1810 TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error) 1811 // Lists the tasks in a queue. 1812 // 1813 // By default, only the [BASIC][google.cloud.tasks.v2.Task.View.BASIC] view is retrieved 1814 // due to performance considerations; 1815 // [response_view][google.cloud.tasks.v2.ListTasksRequest.response_view] controls the 1816 // subset of information which is returned. 1817 // 1818 // The tasks may be returned in any order. The ordering may change at any 1819 // time. 1820 ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) 1821 // Gets a task. 1822 GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error) 1823 // Creates a task and adds it to a queue. 1824 // 1825 // Tasks cannot be updated after creation; there is no UpdateTask command. 1826 // 1827 // * The maximum task size is 100KB. 1828 CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*Task, error) 1829 // Deletes a task. 1830 // 1831 // A task can be deleted if it is scheduled or dispatched. A task 1832 // cannot be deleted if it has executed successfully or permanently 1833 // failed. 1834 DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1835 // Forces a task to run now. 1836 // 1837 // When this method is called, Cloud Tasks will dispatch the task, even if 1838 // the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2.RateLimits] or 1839 // is [PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED]. 1840 // 1841 // This command is meant to be used for manual debugging. For 1842 // example, [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask] can be used to retry a failed 1843 // task after a fix has been made or to manually force a task to be 1844 // dispatched now. 1845 // 1846 // The dispatched task is returned. That is, the task that is returned 1847 // contains the [status][Task.status] after the task is dispatched but 1848 // before the task is received by its target. 1849 // 1850 // If Cloud Tasks receives a successful response from the task's 1851 // target, then the task will be deleted; otherwise the task's 1852 // [schedule_time][google.cloud.tasks.v2.Task.schedule_time] will be reset to the time that 1853 // [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask] was called plus the retry delay specified 1854 // in the queue's [RetryConfig][google.cloud.tasks.v2.RetryConfig]. 1855 // 1856 // [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask] returns 1857 // [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a 1858 // task that has already succeeded or permanently failed. 1859 RunTask(ctx context.Context, in *RunTaskRequest, opts ...grpc.CallOption) (*Task, error) 1860} 1861 1862type cloudTasksClient struct { 1863 cc grpc.ClientConnInterface 1864} 1865 1866func NewCloudTasksClient(cc grpc.ClientConnInterface) CloudTasksClient { 1867 return &cloudTasksClient{cc} 1868} 1869 1870func (c *cloudTasksClient) ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error) { 1871 out := new(ListQueuesResponse) 1872 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/ListQueues", in, out, opts...) 1873 if err != nil { 1874 return nil, err 1875 } 1876 return out, nil 1877} 1878 1879func (c *cloudTasksClient) GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1880 out := new(Queue) 1881 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/GetQueue", in, out, opts...) 1882 if err != nil { 1883 return nil, err 1884 } 1885 return out, nil 1886} 1887 1888func (c *cloudTasksClient) CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1889 out := new(Queue) 1890 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/CreateQueue", in, out, opts...) 1891 if err != nil { 1892 return nil, err 1893 } 1894 return out, nil 1895} 1896 1897func (c *cloudTasksClient) UpdateQueue(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1898 out := new(Queue) 1899 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/UpdateQueue", in, out, opts...) 1900 if err != nil { 1901 return nil, err 1902 } 1903 return out, nil 1904} 1905 1906func (c *cloudTasksClient) DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1907 out := new(emptypb.Empty) 1908 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/DeleteQueue", in, out, opts...) 1909 if err != nil { 1910 return nil, err 1911 } 1912 return out, nil 1913} 1914 1915func (c *cloudTasksClient) PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1916 out := new(Queue) 1917 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/PurgeQueue", in, out, opts...) 1918 if err != nil { 1919 return nil, err 1920 } 1921 return out, nil 1922} 1923 1924func (c *cloudTasksClient) PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1925 out := new(Queue) 1926 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/PauseQueue", in, out, opts...) 1927 if err != nil { 1928 return nil, err 1929 } 1930 return out, nil 1931} 1932 1933func (c *cloudTasksClient) ResumeQueue(ctx context.Context, in *ResumeQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1934 out := new(Queue) 1935 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/ResumeQueue", in, out, opts...) 1936 if err != nil { 1937 return nil, err 1938 } 1939 return out, nil 1940} 1941 1942func (c *cloudTasksClient) GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) { 1943 out := new(v1.Policy) 1944 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/GetIamPolicy", in, out, opts...) 1945 if err != nil { 1946 return nil, err 1947 } 1948 return out, nil 1949} 1950 1951func (c *cloudTasksClient) SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) { 1952 out := new(v1.Policy) 1953 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/SetIamPolicy", in, out, opts...) 1954 if err != nil { 1955 return nil, err 1956 } 1957 return out, nil 1958} 1959 1960func (c *cloudTasksClient) TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error) { 1961 out := new(v1.TestIamPermissionsResponse) 1962 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/TestIamPermissions", in, out, opts...) 1963 if err != nil { 1964 return nil, err 1965 } 1966 return out, nil 1967} 1968 1969func (c *cloudTasksClient) ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) { 1970 out := new(ListTasksResponse) 1971 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/ListTasks", in, out, opts...) 1972 if err != nil { 1973 return nil, err 1974 } 1975 return out, nil 1976} 1977 1978func (c *cloudTasksClient) GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error) { 1979 out := new(Task) 1980 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/GetTask", in, out, opts...) 1981 if err != nil { 1982 return nil, err 1983 } 1984 return out, nil 1985} 1986 1987func (c *cloudTasksClient) CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*Task, error) { 1988 out := new(Task) 1989 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/CreateTask", in, out, opts...) 1990 if err != nil { 1991 return nil, err 1992 } 1993 return out, nil 1994} 1995 1996func (c *cloudTasksClient) DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1997 out := new(emptypb.Empty) 1998 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/DeleteTask", in, out, opts...) 1999 if err != nil { 2000 return nil, err 2001 } 2002 return out, nil 2003} 2004 2005func (c *cloudTasksClient) RunTask(ctx context.Context, in *RunTaskRequest, opts ...grpc.CallOption) (*Task, error) { 2006 out := new(Task) 2007 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2.CloudTasks/RunTask", in, out, opts...) 2008 if err != nil { 2009 return nil, err 2010 } 2011 return out, nil 2012} 2013 2014// CloudTasksServer is the server API for CloudTasks service. 2015type CloudTasksServer interface { 2016 // Lists queues. 2017 // 2018 // Queues are returned in lexicographical order. 2019 ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error) 2020 // Gets a queue. 2021 GetQueue(context.Context, *GetQueueRequest) (*Queue, error) 2022 // Creates a queue. 2023 // 2024 // Queues created with this method allow tasks to live for a maximum of 31 2025 // days. After a task is 31 days old, the task will be deleted regardless of whether 2026 // it was dispatched or not. 2027 // 2028 // WARNING: Using this method may have unintended side effects if you are 2029 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 2030 // Read 2031 // [Overview of Queue Management and 2032 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 2033 // this method. 2034 CreateQueue(context.Context, *CreateQueueRequest) (*Queue, error) 2035 // Updates a queue. 2036 // 2037 // This method creates the queue if it does not exist and updates 2038 // the queue if it does exist. 2039 // 2040 // Queues created with this method allow tasks to live for a maximum of 31 2041 // days. After a task is 31 days old, the task will be deleted regardless of whether 2042 // it was dispatched or not. 2043 // 2044 // WARNING: Using this method may have unintended side effects if you are 2045 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 2046 // Read 2047 // [Overview of Queue Management and 2048 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 2049 // this method. 2050 UpdateQueue(context.Context, *UpdateQueueRequest) (*Queue, error) 2051 // Deletes a queue. 2052 // 2053 // This command will delete the queue even if it has tasks in it. 2054 // 2055 // Note: If you delete a queue, a queue with the same name can't be created 2056 // for 7 days. 2057 // 2058 // WARNING: Using this method may have unintended side effects if you are 2059 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 2060 // Read 2061 // [Overview of Queue Management and 2062 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 2063 // this method. 2064 DeleteQueue(context.Context, *DeleteQueueRequest) (*emptypb.Empty, error) 2065 // Purges a queue by deleting all of its tasks. 2066 // 2067 // All tasks created before this method is called are permanently deleted. 2068 // 2069 // Purge operations can take up to one minute to take effect. Tasks 2070 // might be dispatched before the purge takes effect. A purge is irreversible. 2071 PurgeQueue(context.Context, *PurgeQueueRequest) (*Queue, error) 2072 // Pauses the queue. 2073 // 2074 // If a queue is paused then the system will stop dispatching tasks 2075 // until the queue is resumed via 2076 // [ResumeQueue][google.cloud.tasks.v2.CloudTasks.ResumeQueue]. Tasks can still be added 2077 // when the queue is paused. A queue is paused if its 2078 // [state][google.cloud.tasks.v2.Queue.state] is [PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED]. 2079 PauseQueue(context.Context, *PauseQueueRequest) (*Queue, error) 2080 // Resume a queue. 2081 // 2082 // This method resumes a queue after it has been 2083 // [PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED] or 2084 // [DISABLED][google.cloud.tasks.v2.Queue.State.DISABLED]. The state of a queue is stored 2085 // in the queue's [state][google.cloud.tasks.v2.Queue.state]; after calling this method it 2086 // will be set to [RUNNING][google.cloud.tasks.v2.Queue.State.RUNNING]. 2087 // 2088 // WARNING: Resuming many high-QPS queues at the same time can 2089 // lead to target overloading. If you are resuming high-QPS 2090 // queues, follow the 500/50/5 pattern described in 2091 // [Managing Cloud Tasks Scaling 2092 // Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). 2093 ResumeQueue(context.Context, *ResumeQueueRequest) (*Queue, error) 2094 // Gets the access control policy for a [Queue][google.cloud.tasks.v2.Queue]. 2095 // Returns an empty policy if the resource exists and does not have a policy 2096 // set. 2097 // 2098 // Authorization requires the following 2099 // [Google IAM](https://cloud.google.com/iam) permission on the specified 2100 // resource parent: 2101 // 2102 // * `cloudtasks.queues.getIamPolicy` 2103 GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error) 2104 // Sets the access control policy for a [Queue][google.cloud.tasks.v2.Queue]. Replaces any existing 2105 // policy. 2106 // 2107 // Note: The Cloud Console does not check queue-level IAM permissions yet. 2108 // Project-level permissions are required to use the Cloud Console. 2109 // 2110 // Authorization requires the following 2111 // [Google IAM](https://cloud.google.com/iam) permission on the specified 2112 // resource parent: 2113 // 2114 // * `cloudtasks.queues.setIamPolicy` 2115 SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error) 2116 // Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2.Queue]. 2117 // If the resource does not exist, this will return an empty set of 2118 // permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error. 2119 // 2120 // Note: This operation is designed to be used for building permission-aware 2121 // UIs and command-line tools, not for authorization checking. This operation 2122 // may "fail open" without warning. 2123 TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error) 2124 // Lists the tasks in a queue. 2125 // 2126 // By default, only the [BASIC][google.cloud.tasks.v2.Task.View.BASIC] view is retrieved 2127 // due to performance considerations; 2128 // [response_view][google.cloud.tasks.v2.ListTasksRequest.response_view] controls the 2129 // subset of information which is returned. 2130 // 2131 // The tasks may be returned in any order. The ordering may change at any 2132 // time. 2133 ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) 2134 // Gets a task. 2135 GetTask(context.Context, *GetTaskRequest) (*Task, error) 2136 // Creates a task and adds it to a queue. 2137 // 2138 // Tasks cannot be updated after creation; there is no UpdateTask command. 2139 // 2140 // * The maximum task size is 100KB. 2141 CreateTask(context.Context, *CreateTaskRequest) (*Task, error) 2142 // Deletes a task. 2143 // 2144 // A task can be deleted if it is scheduled or dispatched. A task 2145 // cannot be deleted if it has executed successfully or permanently 2146 // failed. 2147 DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error) 2148 // Forces a task to run now. 2149 // 2150 // When this method is called, Cloud Tasks will dispatch the task, even if 2151 // the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2.RateLimits] or 2152 // is [PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED]. 2153 // 2154 // This command is meant to be used for manual debugging. For 2155 // example, [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask] can be used to retry a failed 2156 // task after a fix has been made or to manually force a task to be 2157 // dispatched now. 2158 // 2159 // The dispatched task is returned. That is, the task that is returned 2160 // contains the [status][Task.status] after the task is dispatched but 2161 // before the task is received by its target. 2162 // 2163 // If Cloud Tasks receives a successful response from the task's 2164 // target, then the task will be deleted; otherwise the task's 2165 // [schedule_time][google.cloud.tasks.v2.Task.schedule_time] will be reset to the time that 2166 // [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask] was called plus the retry delay specified 2167 // in the queue's [RetryConfig][google.cloud.tasks.v2.RetryConfig]. 2168 // 2169 // [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask] returns 2170 // [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a 2171 // task that has already succeeded or permanently failed. 2172 RunTask(context.Context, *RunTaskRequest) (*Task, error) 2173} 2174 2175// UnimplementedCloudTasksServer can be embedded to have forward compatible implementations. 2176type UnimplementedCloudTasksServer struct { 2177} 2178 2179func (*UnimplementedCloudTasksServer) ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error) { 2180 return nil, status.Errorf(codes.Unimplemented, "method ListQueues not implemented") 2181} 2182func (*UnimplementedCloudTasksServer) GetQueue(context.Context, *GetQueueRequest) (*Queue, error) { 2183 return nil, status.Errorf(codes.Unimplemented, "method GetQueue not implemented") 2184} 2185func (*UnimplementedCloudTasksServer) CreateQueue(context.Context, *CreateQueueRequest) (*Queue, error) { 2186 return nil, status.Errorf(codes.Unimplemented, "method CreateQueue not implemented") 2187} 2188func (*UnimplementedCloudTasksServer) UpdateQueue(context.Context, *UpdateQueueRequest) (*Queue, error) { 2189 return nil, status.Errorf(codes.Unimplemented, "method UpdateQueue not implemented") 2190} 2191func (*UnimplementedCloudTasksServer) DeleteQueue(context.Context, *DeleteQueueRequest) (*emptypb.Empty, error) { 2192 return nil, status.Errorf(codes.Unimplemented, "method DeleteQueue not implemented") 2193} 2194func (*UnimplementedCloudTasksServer) PurgeQueue(context.Context, *PurgeQueueRequest) (*Queue, error) { 2195 return nil, status.Errorf(codes.Unimplemented, "method PurgeQueue not implemented") 2196} 2197func (*UnimplementedCloudTasksServer) PauseQueue(context.Context, *PauseQueueRequest) (*Queue, error) { 2198 return nil, status.Errorf(codes.Unimplemented, "method PauseQueue not implemented") 2199} 2200func (*UnimplementedCloudTasksServer) ResumeQueue(context.Context, *ResumeQueueRequest) (*Queue, error) { 2201 return nil, status.Errorf(codes.Unimplemented, "method ResumeQueue not implemented") 2202} 2203func (*UnimplementedCloudTasksServer) GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error) { 2204 return nil, status.Errorf(codes.Unimplemented, "method GetIamPolicy not implemented") 2205} 2206func (*UnimplementedCloudTasksServer) SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error) { 2207 return nil, status.Errorf(codes.Unimplemented, "method SetIamPolicy not implemented") 2208} 2209func (*UnimplementedCloudTasksServer) TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error) { 2210 return nil, status.Errorf(codes.Unimplemented, "method TestIamPermissions not implemented") 2211} 2212func (*UnimplementedCloudTasksServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) { 2213 return nil, status.Errorf(codes.Unimplemented, "method ListTasks not implemented") 2214} 2215func (*UnimplementedCloudTasksServer) GetTask(context.Context, *GetTaskRequest) (*Task, error) { 2216 return nil, status.Errorf(codes.Unimplemented, "method GetTask not implemented") 2217} 2218func (*UnimplementedCloudTasksServer) CreateTask(context.Context, *CreateTaskRequest) (*Task, error) { 2219 return nil, status.Errorf(codes.Unimplemented, "method CreateTask not implemented") 2220} 2221func (*UnimplementedCloudTasksServer) DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error) { 2222 return nil, status.Errorf(codes.Unimplemented, "method DeleteTask not implemented") 2223} 2224func (*UnimplementedCloudTasksServer) RunTask(context.Context, *RunTaskRequest) (*Task, error) { 2225 return nil, status.Errorf(codes.Unimplemented, "method RunTask not implemented") 2226} 2227 2228func RegisterCloudTasksServer(s *grpc.Server, srv CloudTasksServer) { 2229 s.RegisterService(&_CloudTasks_serviceDesc, srv) 2230} 2231 2232func _CloudTasks_ListQueues_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2233 in := new(ListQueuesRequest) 2234 if err := dec(in); err != nil { 2235 return nil, err 2236 } 2237 if interceptor == nil { 2238 return srv.(CloudTasksServer).ListQueues(ctx, in) 2239 } 2240 info := &grpc.UnaryServerInfo{ 2241 Server: srv, 2242 FullMethod: "/google.cloud.tasks.v2.CloudTasks/ListQueues", 2243 } 2244 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2245 return srv.(CloudTasksServer).ListQueues(ctx, req.(*ListQueuesRequest)) 2246 } 2247 return interceptor(ctx, in, info, handler) 2248} 2249 2250func _CloudTasks_GetQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2251 in := new(GetQueueRequest) 2252 if err := dec(in); err != nil { 2253 return nil, err 2254 } 2255 if interceptor == nil { 2256 return srv.(CloudTasksServer).GetQueue(ctx, in) 2257 } 2258 info := &grpc.UnaryServerInfo{ 2259 Server: srv, 2260 FullMethod: "/google.cloud.tasks.v2.CloudTasks/GetQueue", 2261 } 2262 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2263 return srv.(CloudTasksServer).GetQueue(ctx, req.(*GetQueueRequest)) 2264 } 2265 return interceptor(ctx, in, info, handler) 2266} 2267 2268func _CloudTasks_CreateQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2269 in := new(CreateQueueRequest) 2270 if err := dec(in); err != nil { 2271 return nil, err 2272 } 2273 if interceptor == nil { 2274 return srv.(CloudTasksServer).CreateQueue(ctx, in) 2275 } 2276 info := &grpc.UnaryServerInfo{ 2277 Server: srv, 2278 FullMethod: "/google.cloud.tasks.v2.CloudTasks/CreateQueue", 2279 } 2280 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2281 return srv.(CloudTasksServer).CreateQueue(ctx, req.(*CreateQueueRequest)) 2282 } 2283 return interceptor(ctx, in, info, handler) 2284} 2285 2286func _CloudTasks_UpdateQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2287 in := new(UpdateQueueRequest) 2288 if err := dec(in); err != nil { 2289 return nil, err 2290 } 2291 if interceptor == nil { 2292 return srv.(CloudTasksServer).UpdateQueue(ctx, in) 2293 } 2294 info := &grpc.UnaryServerInfo{ 2295 Server: srv, 2296 FullMethod: "/google.cloud.tasks.v2.CloudTasks/UpdateQueue", 2297 } 2298 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2299 return srv.(CloudTasksServer).UpdateQueue(ctx, req.(*UpdateQueueRequest)) 2300 } 2301 return interceptor(ctx, in, info, handler) 2302} 2303 2304func _CloudTasks_DeleteQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2305 in := new(DeleteQueueRequest) 2306 if err := dec(in); err != nil { 2307 return nil, err 2308 } 2309 if interceptor == nil { 2310 return srv.(CloudTasksServer).DeleteQueue(ctx, in) 2311 } 2312 info := &grpc.UnaryServerInfo{ 2313 Server: srv, 2314 FullMethod: "/google.cloud.tasks.v2.CloudTasks/DeleteQueue", 2315 } 2316 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2317 return srv.(CloudTasksServer).DeleteQueue(ctx, req.(*DeleteQueueRequest)) 2318 } 2319 return interceptor(ctx, in, info, handler) 2320} 2321 2322func _CloudTasks_PurgeQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2323 in := new(PurgeQueueRequest) 2324 if err := dec(in); err != nil { 2325 return nil, err 2326 } 2327 if interceptor == nil { 2328 return srv.(CloudTasksServer).PurgeQueue(ctx, in) 2329 } 2330 info := &grpc.UnaryServerInfo{ 2331 Server: srv, 2332 FullMethod: "/google.cloud.tasks.v2.CloudTasks/PurgeQueue", 2333 } 2334 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2335 return srv.(CloudTasksServer).PurgeQueue(ctx, req.(*PurgeQueueRequest)) 2336 } 2337 return interceptor(ctx, in, info, handler) 2338} 2339 2340func _CloudTasks_PauseQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2341 in := new(PauseQueueRequest) 2342 if err := dec(in); err != nil { 2343 return nil, err 2344 } 2345 if interceptor == nil { 2346 return srv.(CloudTasksServer).PauseQueue(ctx, in) 2347 } 2348 info := &grpc.UnaryServerInfo{ 2349 Server: srv, 2350 FullMethod: "/google.cloud.tasks.v2.CloudTasks/PauseQueue", 2351 } 2352 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2353 return srv.(CloudTasksServer).PauseQueue(ctx, req.(*PauseQueueRequest)) 2354 } 2355 return interceptor(ctx, in, info, handler) 2356} 2357 2358func _CloudTasks_ResumeQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2359 in := new(ResumeQueueRequest) 2360 if err := dec(in); err != nil { 2361 return nil, err 2362 } 2363 if interceptor == nil { 2364 return srv.(CloudTasksServer).ResumeQueue(ctx, in) 2365 } 2366 info := &grpc.UnaryServerInfo{ 2367 Server: srv, 2368 FullMethod: "/google.cloud.tasks.v2.CloudTasks/ResumeQueue", 2369 } 2370 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2371 return srv.(CloudTasksServer).ResumeQueue(ctx, req.(*ResumeQueueRequest)) 2372 } 2373 return interceptor(ctx, in, info, handler) 2374} 2375 2376func _CloudTasks_GetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2377 in := new(v1.GetIamPolicyRequest) 2378 if err := dec(in); err != nil { 2379 return nil, err 2380 } 2381 if interceptor == nil { 2382 return srv.(CloudTasksServer).GetIamPolicy(ctx, in) 2383 } 2384 info := &grpc.UnaryServerInfo{ 2385 Server: srv, 2386 FullMethod: "/google.cloud.tasks.v2.CloudTasks/GetIamPolicy", 2387 } 2388 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2389 return srv.(CloudTasksServer).GetIamPolicy(ctx, req.(*v1.GetIamPolicyRequest)) 2390 } 2391 return interceptor(ctx, in, info, handler) 2392} 2393 2394func _CloudTasks_SetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2395 in := new(v1.SetIamPolicyRequest) 2396 if err := dec(in); err != nil { 2397 return nil, err 2398 } 2399 if interceptor == nil { 2400 return srv.(CloudTasksServer).SetIamPolicy(ctx, in) 2401 } 2402 info := &grpc.UnaryServerInfo{ 2403 Server: srv, 2404 FullMethod: "/google.cloud.tasks.v2.CloudTasks/SetIamPolicy", 2405 } 2406 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2407 return srv.(CloudTasksServer).SetIamPolicy(ctx, req.(*v1.SetIamPolicyRequest)) 2408 } 2409 return interceptor(ctx, in, info, handler) 2410} 2411 2412func _CloudTasks_TestIamPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2413 in := new(v1.TestIamPermissionsRequest) 2414 if err := dec(in); err != nil { 2415 return nil, err 2416 } 2417 if interceptor == nil { 2418 return srv.(CloudTasksServer).TestIamPermissions(ctx, in) 2419 } 2420 info := &grpc.UnaryServerInfo{ 2421 Server: srv, 2422 FullMethod: "/google.cloud.tasks.v2.CloudTasks/TestIamPermissions", 2423 } 2424 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2425 return srv.(CloudTasksServer).TestIamPermissions(ctx, req.(*v1.TestIamPermissionsRequest)) 2426 } 2427 return interceptor(ctx, in, info, handler) 2428} 2429 2430func _CloudTasks_ListTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2431 in := new(ListTasksRequest) 2432 if err := dec(in); err != nil { 2433 return nil, err 2434 } 2435 if interceptor == nil { 2436 return srv.(CloudTasksServer).ListTasks(ctx, in) 2437 } 2438 info := &grpc.UnaryServerInfo{ 2439 Server: srv, 2440 FullMethod: "/google.cloud.tasks.v2.CloudTasks/ListTasks", 2441 } 2442 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2443 return srv.(CloudTasksServer).ListTasks(ctx, req.(*ListTasksRequest)) 2444 } 2445 return interceptor(ctx, in, info, handler) 2446} 2447 2448func _CloudTasks_GetTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2449 in := new(GetTaskRequest) 2450 if err := dec(in); err != nil { 2451 return nil, err 2452 } 2453 if interceptor == nil { 2454 return srv.(CloudTasksServer).GetTask(ctx, in) 2455 } 2456 info := &grpc.UnaryServerInfo{ 2457 Server: srv, 2458 FullMethod: "/google.cloud.tasks.v2.CloudTasks/GetTask", 2459 } 2460 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2461 return srv.(CloudTasksServer).GetTask(ctx, req.(*GetTaskRequest)) 2462 } 2463 return interceptor(ctx, in, info, handler) 2464} 2465 2466func _CloudTasks_CreateTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2467 in := new(CreateTaskRequest) 2468 if err := dec(in); err != nil { 2469 return nil, err 2470 } 2471 if interceptor == nil { 2472 return srv.(CloudTasksServer).CreateTask(ctx, in) 2473 } 2474 info := &grpc.UnaryServerInfo{ 2475 Server: srv, 2476 FullMethod: "/google.cloud.tasks.v2.CloudTasks/CreateTask", 2477 } 2478 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2479 return srv.(CloudTasksServer).CreateTask(ctx, req.(*CreateTaskRequest)) 2480 } 2481 return interceptor(ctx, in, info, handler) 2482} 2483 2484func _CloudTasks_DeleteTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2485 in := new(DeleteTaskRequest) 2486 if err := dec(in); err != nil { 2487 return nil, err 2488 } 2489 if interceptor == nil { 2490 return srv.(CloudTasksServer).DeleteTask(ctx, in) 2491 } 2492 info := &grpc.UnaryServerInfo{ 2493 Server: srv, 2494 FullMethod: "/google.cloud.tasks.v2.CloudTasks/DeleteTask", 2495 } 2496 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2497 return srv.(CloudTasksServer).DeleteTask(ctx, req.(*DeleteTaskRequest)) 2498 } 2499 return interceptor(ctx, in, info, handler) 2500} 2501 2502func _CloudTasks_RunTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2503 in := new(RunTaskRequest) 2504 if err := dec(in); err != nil { 2505 return nil, err 2506 } 2507 if interceptor == nil { 2508 return srv.(CloudTasksServer).RunTask(ctx, in) 2509 } 2510 info := &grpc.UnaryServerInfo{ 2511 Server: srv, 2512 FullMethod: "/google.cloud.tasks.v2.CloudTasks/RunTask", 2513 } 2514 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2515 return srv.(CloudTasksServer).RunTask(ctx, req.(*RunTaskRequest)) 2516 } 2517 return interceptor(ctx, in, info, handler) 2518} 2519 2520var _CloudTasks_serviceDesc = grpc.ServiceDesc{ 2521 ServiceName: "google.cloud.tasks.v2.CloudTasks", 2522 HandlerType: (*CloudTasksServer)(nil), 2523 Methods: []grpc.MethodDesc{ 2524 { 2525 MethodName: "ListQueues", 2526 Handler: _CloudTasks_ListQueues_Handler, 2527 }, 2528 { 2529 MethodName: "GetQueue", 2530 Handler: _CloudTasks_GetQueue_Handler, 2531 }, 2532 { 2533 MethodName: "CreateQueue", 2534 Handler: _CloudTasks_CreateQueue_Handler, 2535 }, 2536 { 2537 MethodName: "UpdateQueue", 2538 Handler: _CloudTasks_UpdateQueue_Handler, 2539 }, 2540 { 2541 MethodName: "DeleteQueue", 2542 Handler: _CloudTasks_DeleteQueue_Handler, 2543 }, 2544 { 2545 MethodName: "PurgeQueue", 2546 Handler: _CloudTasks_PurgeQueue_Handler, 2547 }, 2548 { 2549 MethodName: "PauseQueue", 2550 Handler: _CloudTasks_PauseQueue_Handler, 2551 }, 2552 { 2553 MethodName: "ResumeQueue", 2554 Handler: _CloudTasks_ResumeQueue_Handler, 2555 }, 2556 { 2557 MethodName: "GetIamPolicy", 2558 Handler: _CloudTasks_GetIamPolicy_Handler, 2559 }, 2560 { 2561 MethodName: "SetIamPolicy", 2562 Handler: _CloudTasks_SetIamPolicy_Handler, 2563 }, 2564 { 2565 MethodName: "TestIamPermissions", 2566 Handler: _CloudTasks_TestIamPermissions_Handler, 2567 }, 2568 { 2569 MethodName: "ListTasks", 2570 Handler: _CloudTasks_ListTasks_Handler, 2571 }, 2572 { 2573 MethodName: "GetTask", 2574 Handler: _CloudTasks_GetTask_Handler, 2575 }, 2576 { 2577 MethodName: "CreateTask", 2578 Handler: _CloudTasks_CreateTask_Handler, 2579 }, 2580 { 2581 MethodName: "DeleteTask", 2582 Handler: _CloudTasks_DeleteTask_Handler, 2583 }, 2584 { 2585 MethodName: "RunTask", 2586 Handler: _CloudTasks_RunTask_Handler, 2587 }, 2588 }, 2589 Streams: []grpc.StreamDesc{}, 2590 Metadata: "google/cloud/tasks/v2/cloudtasks.proto", 2591} 2592