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