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