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