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