1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/cloud/tasks/v2beta3/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 empty "github.com/golang/protobuf/ptypes/empty" 13 _ "google.golang.org/genproto/googleapis/api/annotations" 14 v1 "google.golang.org/genproto/googleapis/iam/v1" 15 field_mask "google.golang.org/genproto/protobuf/field_mask" 16 grpc "google.golang.org/grpc" 17 codes "google.golang.org/grpc/codes" 18 status "google.golang.org/grpc/status" 19) 20 21// Reference imports to suppress errors if they are not otherwise used. 22var _ = proto.Marshal 23var _ = fmt.Errorf 24var _ = math.Inf 25 26// This is a compile-time assertion to ensure that this generated file 27// is compatible with the proto package it is being compiled against. 28// A compilation error at this line likely means your copy of the 29// proto package needs to be updated. 30const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 31 32// Request message for [ListQueues][google.cloud.tasks.v2beta3.CloudTasks.ListQueues]. 33type ListQueuesRequest struct { 34 // Required. The location name. 35 // For example: `projects/PROJECT_ID/locations/LOCATION_ID` 36 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 37 // `filter` can be used to specify a subset of queues. Any [Queue][google.cloud.tasks.v2beta3.Queue] 38 // field can be used as a filter and several operators as supported. 39 // For example: `<=, <, >=, >, !=, =, :`. The filter syntax is the same as 40 // described in 41 // [Stackdriver's Advanced Logs 42 // Filters](https://cloud.google.com/logging/docs/view/advanced_filters). 43 // 44 // Sample filter "state: PAUSED". 45 // 46 // Note that using filters might cause fewer queues than the 47 // requested page_size to be returned. 48 Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` 49 // Requested page size. 50 // 51 // The maximum page size is 9800. If unspecified, the page size will 52 // be the maximum. Fewer queues than requested might be returned, 53 // even if more queues exist; use the 54 // [next_page_token][google.cloud.tasks.v2beta3.ListQueuesResponse.next_page_token] in the 55 // response to determine if more queues exist. 56 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 57 // A token identifying the page of results to return. 58 // 59 // To request the first page results, page_token must be empty. To 60 // request the next page of results, page_token must be the value of 61 // [next_page_token][google.cloud.tasks.v2beta3.ListQueuesResponse.next_page_token] returned 62 // from the previous call to [ListQueues][google.cloud.tasks.v2beta3.CloudTasks.ListQueues] 63 // method. It is an error to switch the value of the 64 // [filter][google.cloud.tasks.v2beta3.ListQueuesRequest.filter] while iterating through pages. 65 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 66 XXX_NoUnkeyedLiteral struct{} `json:"-"` 67 XXX_unrecognized []byte `json:"-"` 68 XXX_sizecache int32 `json:"-"` 69} 70 71func (m *ListQueuesRequest) Reset() { *m = ListQueuesRequest{} } 72func (m *ListQueuesRequest) String() string { return proto.CompactTextString(m) } 73func (*ListQueuesRequest) ProtoMessage() {} 74func (*ListQueuesRequest) Descriptor() ([]byte, []int) { 75 return fileDescriptor_774b6c8e7fbe6f6d, []int{0} 76} 77 78func (m *ListQueuesRequest) XXX_Unmarshal(b []byte) error { 79 return xxx_messageInfo_ListQueuesRequest.Unmarshal(m, b) 80} 81func (m *ListQueuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 82 return xxx_messageInfo_ListQueuesRequest.Marshal(b, m, deterministic) 83} 84func (m *ListQueuesRequest) XXX_Merge(src proto.Message) { 85 xxx_messageInfo_ListQueuesRequest.Merge(m, src) 86} 87func (m *ListQueuesRequest) XXX_Size() int { 88 return xxx_messageInfo_ListQueuesRequest.Size(m) 89} 90func (m *ListQueuesRequest) XXX_DiscardUnknown() { 91 xxx_messageInfo_ListQueuesRequest.DiscardUnknown(m) 92} 93 94var xxx_messageInfo_ListQueuesRequest proto.InternalMessageInfo 95 96func (m *ListQueuesRequest) GetParent() string { 97 if m != nil { 98 return m.Parent 99 } 100 return "" 101} 102 103func (m *ListQueuesRequest) GetFilter() string { 104 if m != nil { 105 return m.Filter 106 } 107 return "" 108} 109 110func (m *ListQueuesRequest) GetPageSize() int32 { 111 if m != nil { 112 return m.PageSize 113 } 114 return 0 115} 116 117func (m *ListQueuesRequest) GetPageToken() string { 118 if m != nil { 119 return m.PageToken 120 } 121 return "" 122} 123 124// Response message for [ListQueues][google.cloud.tasks.v2beta3.CloudTasks.ListQueues]. 125type ListQueuesResponse struct { 126 // The list of queues. 127 Queues []*Queue `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"` 128 // A token to retrieve next page of results. 129 // 130 // To return the next page of results, call 131 // [ListQueues][google.cloud.tasks.v2beta3.CloudTasks.ListQueues] with this value as the 132 // [page_token][google.cloud.tasks.v2beta3.ListQueuesRequest.page_token]. 133 // 134 // If the next_page_token is empty, there are no more results. 135 // 136 // The page token is valid for only 2 hours. 137 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 138 XXX_NoUnkeyedLiteral struct{} `json:"-"` 139 XXX_unrecognized []byte `json:"-"` 140 XXX_sizecache int32 `json:"-"` 141} 142 143func (m *ListQueuesResponse) Reset() { *m = ListQueuesResponse{} } 144func (m *ListQueuesResponse) String() string { return proto.CompactTextString(m) } 145func (*ListQueuesResponse) ProtoMessage() {} 146func (*ListQueuesResponse) Descriptor() ([]byte, []int) { 147 return fileDescriptor_774b6c8e7fbe6f6d, []int{1} 148} 149 150func (m *ListQueuesResponse) XXX_Unmarshal(b []byte) error { 151 return xxx_messageInfo_ListQueuesResponse.Unmarshal(m, b) 152} 153func (m *ListQueuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 154 return xxx_messageInfo_ListQueuesResponse.Marshal(b, m, deterministic) 155} 156func (m *ListQueuesResponse) XXX_Merge(src proto.Message) { 157 xxx_messageInfo_ListQueuesResponse.Merge(m, src) 158} 159func (m *ListQueuesResponse) XXX_Size() int { 160 return xxx_messageInfo_ListQueuesResponse.Size(m) 161} 162func (m *ListQueuesResponse) XXX_DiscardUnknown() { 163 xxx_messageInfo_ListQueuesResponse.DiscardUnknown(m) 164} 165 166var xxx_messageInfo_ListQueuesResponse proto.InternalMessageInfo 167 168func (m *ListQueuesResponse) GetQueues() []*Queue { 169 if m != nil { 170 return m.Queues 171 } 172 return nil 173} 174 175func (m *ListQueuesResponse) GetNextPageToken() string { 176 if m != nil { 177 return m.NextPageToken 178 } 179 return "" 180} 181 182// Request message for [GetQueue][google.cloud.tasks.v2beta3.CloudTasks.GetQueue]. 183type GetQueueRequest struct { 184 // Required. The resource name of the queue. For example: 185 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 186 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 187 XXX_NoUnkeyedLiteral struct{} `json:"-"` 188 XXX_unrecognized []byte `json:"-"` 189 XXX_sizecache int32 `json:"-"` 190} 191 192func (m *GetQueueRequest) Reset() { *m = GetQueueRequest{} } 193func (m *GetQueueRequest) String() string { return proto.CompactTextString(m) } 194func (*GetQueueRequest) ProtoMessage() {} 195func (*GetQueueRequest) Descriptor() ([]byte, []int) { 196 return fileDescriptor_774b6c8e7fbe6f6d, []int{2} 197} 198 199func (m *GetQueueRequest) XXX_Unmarshal(b []byte) error { 200 return xxx_messageInfo_GetQueueRequest.Unmarshal(m, b) 201} 202func (m *GetQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 203 return xxx_messageInfo_GetQueueRequest.Marshal(b, m, deterministic) 204} 205func (m *GetQueueRequest) XXX_Merge(src proto.Message) { 206 xxx_messageInfo_GetQueueRequest.Merge(m, src) 207} 208func (m *GetQueueRequest) XXX_Size() int { 209 return xxx_messageInfo_GetQueueRequest.Size(m) 210} 211func (m *GetQueueRequest) XXX_DiscardUnknown() { 212 xxx_messageInfo_GetQueueRequest.DiscardUnknown(m) 213} 214 215var xxx_messageInfo_GetQueueRequest proto.InternalMessageInfo 216 217func (m *GetQueueRequest) GetName() string { 218 if m != nil { 219 return m.Name 220 } 221 return "" 222} 223 224// Request message for [CreateQueue][google.cloud.tasks.v2beta3.CloudTasks.CreateQueue]. 225type CreateQueueRequest struct { 226 // Required. The location name in which the queue will be created. 227 // For example: `projects/PROJECT_ID/locations/LOCATION_ID` 228 // 229 // The list of allowed locations can be obtained by calling Cloud 230 // Tasks' implementation of 231 // [ListLocations][google.cloud.location.Locations.ListLocations]. 232 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 233 // Required. The queue to create. 234 // 235 // [Queue's name][google.cloud.tasks.v2beta3.Queue.name] cannot be the same as an existing queue. 236 Queue *Queue `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` 237 XXX_NoUnkeyedLiteral struct{} `json:"-"` 238 XXX_unrecognized []byte `json:"-"` 239 XXX_sizecache int32 `json:"-"` 240} 241 242func (m *CreateQueueRequest) Reset() { *m = CreateQueueRequest{} } 243func (m *CreateQueueRequest) String() string { return proto.CompactTextString(m) } 244func (*CreateQueueRequest) ProtoMessage() {} 245func (*CreateQueueRequest) Descriptor() ([]byte, []int) { 246 return fileDescriptor_774b6c8e7fbe6f6d, []int{3} 247} 248 249func (m *CreateQueueRequest) XXX_Unmarshal(b []byte) error { 250 return xxx_messageInfo_CreateQueueRequest.Unmarshal(m, b) 251} 252func (m *CreateQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 253 return xxx_messageInfo_CreateQueueRequest.Marshal(b, m, deterministic) 254} 255func (m *CreateQueueRequest) XXX_Merge(src proto.Message) { 256 xxx_messageInfo_CreateQueueRequest.Merge(m, src) 257} 258func (m *CreateQueueRequest) XXX_Size() int { 259 return xxx_messageInfo_CreateQueueRequest.Size(m) 260} 261func (m *CreateQueueRequest) XXX_DiscardUnknown() { 262 xxx_messageInfo_CreateQueueRequest.DiscardUnknown(m) 263} 264 265var xxx_messageInfo_CreateQueueRequest proto.InternalMessageInfo 266 267func (m *CreateQueueRequest) GetParent() string { 268 if m != nil { 269 return m.Parent 270 } 271 return "" 272} 273 274func (m *CreateQueueRequest) GetQueue() *Queue { 275 if m != nil { 276 return m.Queue 277 } 278 return nil 279} 280 281// Request message for [UpdateQueue][google.cloud.tasks.v2beta3.CloudTasks.UpdateQueue]. 282type UpdateQueueRequest struct { 283 // Required. The queue to create or update. 284 // 285 // The queue's [name][google.cloud.tasks.v2beta3.Queue.name] must be specified. 286 // 287 // Output only fields cannot be modified using UpdateQueue. 288 // Any value specified for an output only field will be ignored. 289 // The queue's [name][google.cloud.tasks.v2beta3.Queue.name] cannot be changed. 290 Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"` 291 // A mask used to specify which fields of the queue are being updated. 292 // 293 // If empty, then all fields will be updated. 294 UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 295 XXX_NoUnkeyedLiteral struct{} `json:"-"` 296 XXX_unrecognized []byte `json:"-"` 297 XXX_sizecache int32 `json:"-"` 298} 299 300func (m *UpdateQueueRequest) Reset() { *m = UpdateQueueRequest{} } 301func (m *UpdateQueueRequest) String() string { return proto.CompactTextString(m) } 302func (*UpdateQueueRequest) ProtoMessage() {} 303func (*UpdateQueueRequest) Descriptor() ([]byte, []int) { 304 return fileDescriptor_774b6c8e7fbe6f6d, []int{4} 305} 306 307func (m *UpdateQueueRequest) XXX_Unmarshal(b []byte) error { 308 return xxx_messageInfo_UpdateQueueRequest.Unmarshal(m, b) 309} 310func (m *UpdateQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 311 return xxx_messageInfo_UpdateQueueRequest.Marshal(b, m, deterministic) 312} 313func (m *UpdateQueueRequest) XXX_Merge(src proto.Message) { 314 xxx_messageInfo_UpdateQueueRequest.Merge(m, src) 315} 316func (m *UpdateQueueRequest) XXX_Size() int { 317 return xxx_messageInfo_UpdateQueueRequest.Size(m) 318} 319func (m *UpdateQueueRequest) XXX_DiscardUnknown() { 320 xxx_messageInfo_UpdateQueueRequest.DiscardUnknown(m) 321} 322 323var xxx_messageInfo_UpdateQueueRequest proto.InternalMessageInfo 324 325func (m *UpdateQueueRequest) GetQueue() *Queue { 326 if m != nil { 327 return m.Queue 328 } 329 return nil 330} 331 332func (m *UpdateQueueRequest) GetUpdateMask() *field_mask.FieldMask { 333 if m != nil { 334 return m.UpdateMask 335 } 336 return nil 337} 338 339// Request message for [DeleteQueue][google.cloud.tasks.v2beta3.CloudTasks.DeleteQueue]. 340type DeleteQueueRequest struct { 341 // Required. The queue name. For example: 342 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 343 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 344 XXX_NoUnkeyedLiteral struct{} `json:"-"` 345 XXX_unrecognized []byte `json:"-"` 346 XXX_sizecache int32 `json:"-"` 347} 348 349func (m *DeleteQueueRequest) Reset() { *m = DeleteQueueRequest{} } 350func (m *DeleteQueueRequest) String() string { return proto.CompactTextString(m) } 351func (*DeleteQueueRequest) ProtoMessage() {} 352func (*DeleteQueueRequest) Descriptor() ([]byte, []int) { 353 return fileDescriptor_774b6c8e7fbe6f6d, []int{5} 354} 355 356func (m *DeleteQueueRequest) XXX_Unmarshal(b []byte) error { 357 return xxx_messageInfo_DeleteQueueRequest.Unmarshal(m, b) 358} 359func (m *DeleteQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 360 return xxx_messageInfo_DeleteQueueRequest.Marshal(b, m, deterministic) 361} 362func (m *DeleteQueueRequest) XXX_Merge(src proto.Message) { 363 xxx_messageInfo_DeleteQueueRequest.Merge(m, src) 364} 365func (m *DeleteQueueRequest) XXX_Size() int { 366 return xxx_messageInfo_DeleteQueueRequest.Size(m) 367} 368func (m *DeleteQueueRequest) XXX_DiscardUnknown() { 369 xxx_messageInfo_DeleteQueueRequest.DiscardUnknown(m) 370} 371 372var xxx_messageInfo_DeleteQueueRequest proto.InternalMessageInfo 373 374func (m *DeleteQueueRequest) GetName() string { 375 if m != nil { 376 return m.Name 377 } 378 return "" 379} 380 381// Request message for [PurgeQueue][google.cloud.tasks.v2beta3.CloudTasks.PurgeQueue]. 382type PurgeQueueRequest struct { 383 // Required. The queue name. For example: 384 // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` 385 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 386 XXX_NoUnkeyedLiteral struct{} `json:"-"` 387 XXX_unrecognized []byte `json:"-"` 388 XXX_sizecache int32 `json:"-"` 389} 390 391func (m *PurgeQueueRequest) Reset() { *m = PurgeQueueRequest{} } 392func (m *PurgeQueueRequest) String() string { return proto.CompactTextString(m) } 393func (*PurgeQueueRequest) ProtoMessage() {} 394func (*PurgeQueueRequest) Descriptor() ([]byte, []int) { 395 return fileDescriptor_774b6c8e7fbe6f6d, []int{6} 396} 397 398func (m *PurgeQueueRequest) XXX_Unmarshal(b []byte) error { 399 return xxx_messageInfo_PurgeQueueRequest.Unmarshal(m, b) 400} 401func (m *PurgeQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 402 return xxx_messageInfo_PurgeQueueRequest.Marshal(b, m, deterministic) 403} 404func (m *PurgeQueueRequest) XXX_Merge(src proto.Message) { 405 xxx_messageInfo_PurgeQueueRequest.Merge(m, src) 406} 407func (m *PurgeQueueRequest) XXX_Size() int { 408 return xxx_messageInfo_PurgeQueueRequest.Size(m) 409} 410func (m *PurgeQueueRequest) XXX_DiscardUnknown() { 411 xxx_messageInfo_PurgeQueueRequest.DiscardUnknown(m) 412} 413 414var xxx_messageInfo_PurgeQueueRequest proto.InternalMessageInfo 415 416func (m *PurgeQueueRequest) GetName() string { 417 if m != nil { 418 return m.Name 419 } 420 return "" 421} 422 423// Request message for [PauseQueue][google.cloud.tasks.v2beta3.CloudTasks.PauseQueue]. 424type PauseQueueRequest struct { 425 // Required. The queue name. For example: 426 // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` 427 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 428 XXX_NoUnkeyedLiteral struct{} `json:"-"` 429 XXX_unrecognized []byte `json:"-"` 430 XXX_sizecache int32 `json:"-"` 431} 432 433func (m *PauseQueueRequest) Reset() { *m = PauseQueueRequest{} } 434func (m *PauseQueueRequest) String() string { return proto.CompactTextString(m) } 435func (*PauseQueueRequest) ProtoMessage() {} 436func (*PauseQueueRequest) Descriptor() ([]byte, []int) { 437 return fileDescriptor_774b6c8e7fbe6f6d, []int{7} 438} 439 440func (m *PauseQueueRequest) XXX_Unmarshal(b []byte) error { 441 return xxx_messageInfo_PauseQueueRequest.Unmarshal(m, b) 442} 443func (m *PauseQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 444 return xxx_messageInfo_PauseQueueRequest.Marshal(b, m, deterministic) 445} 446func (m *PauseQueueRequest) XXX_Merge(src proto.Message) { 447 xxx_messageInfo_PauseQueueRequest.Merge(m, src) 448} 449func (m *PauseQueueRequest) XXX_Size() int { 450 return xxx_messageInfo_PauseQueueRequest.Size(m) 451} 452func (m *PauseQueueRequest) XXX_DiscardUnknown() { 453 xxx_messageInfo_PauseQueueRequest.DiscardUnknown(m) 454} 455 456var xxx_messageInfo_PauseQueueRequest proto.InternalMessageInfo 457 458func (m *PauseQueueRequest) GetName() string { 459 if m != nil { 460 return m.Name 461 } 462 return "" 463} 464 465// Request message for [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue]. 466type ResumeQueueRequest struct { 467 // Required. The queue name. For example: 468 // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` 469 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 470 XXX_NoUnkeyedLiteral struct{} `json:"-"` 471 XXX_unrecognized []byte `json:"-"` 472 XXX_sizecache int32 `json:"-"` 473} 474 475func (m *ResumeQueueRequest) Reset() { *m = ResumeQueueRequest{} } 476func (m *ResumeQueueRequest) String() string { return proto.CompactTextString(m) } 477func (*ResumeQueueRequest) ProtoMessage() {} 478func (*ResumeQueueRequest) Descriptor() ([]byte, []int) { 479 return fileDescriptor_774b6c8e7fbe6f6d, []int{8} 480} 481 482func (m *ResumeQueueRequest) XXX_Unmarshal(b []byte) error { 483 return xxx_messageInfo_ResumeQueueRequest.Unmarshal(m, b) 484} 485func (m *ResumeQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 486 return xxx_messageInfo_ResumeQueueRequest.Marshal(b, m, deterministic) 487} 488func (m *ResumeQueueRequest) XXX_Merge(src proto.Message) { 489 xxx_messageInfo_ResumeQueueRequest.Merge(m, src) 490} 491func (m *ResumeQueueRequest) XXX_Size() int { 492 return xxx_messageInfo_ResumeQueueRequest.Size(m) 493} 494func (m *ResumeQueueRequest) XXX_DiscardUnknown() { 495 xxx_messageInfo_ResumeQueueRequest.DiscardUnknown(m) 496} 497 498var xxx_messageInfo_ResumeQueueRequest proto.InternalMessageInfo 499 500func (m *ResumeQueueRequest) GetName() string { 501 if m != nil { 502 return m.Name 503 } 504 return "" 505} 506 507// Request message for listing tasks using [ListTasks][google.cloud.tasks.v2beta3.CloudTasks.ListTasks]. 508type ListTasksRequest struct { 509 // Required. The queue name. For example: 510 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 511 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 512 // The response_view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] will be 513 // returned. 514 // 515 // By default response_view is [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]; not all 516 // information is retrieved by default because some data, such as 517 // payloads, might be desirable to return only when needed because 518 // of its large size or because of the sensitivity of data that it 519 // contains. 520 // 521 // Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires 522 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 523 // permission on the [Task][google.cloud.tasks.v2beta3.Task] resource. 524 ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"response_view,omitempty"` 525 // Maximum page size. 526 // 527 // Fewer tasks than requested might be returned, even if more tasks exist; use 528 // [next_page_token][google.cloud.tasks.v2beta3.ListTasksResponse.next_page_token] in the response to 529 // determine if more tasks exist. 530 // 531 // The maximum page size is 1000. If unspecified, the page size will be the 532 // maximum. 533 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 534 // A token identifying the page of results to return. 535 // 536 // To request the first page results, page_token must be empty. To 537 // request the next page of results, page_token must be the value of 538 // [next_page_token][google.cloud.tasks.v2beta3.ListTasksResponse.next_page_token] returned 539 // from the previous call to [ListTasks][google.cloud.tasks.v2beta3.CloudTasks.ListTasks] 540 // method. 541 // 542 // The page token is valid for only 2 hours. 543 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 544 XXX_NoUnkeyedLiteral struct{} `json:"-"` 545 XXX_unrecognized []byte `json:"-"` 546 XXX_sizecache int32 `json:"-"` 547} 548 549func (m *ListTasksRequest) Reset() { *m = ListTasksRequest{} } 550func (m *ListTasksRequest) String() string { return proto.CompactTextString(m) } 551func (*ListTasksRequest) ProtoMessage() {} 552func (*ListTasksRequest) Descriptor() ([]byte, []int) { 553 return fileDescriptor_774b6c8e7fbe6f6d, []int{9} 554} 555 556func (m *ListTasksRequest) XXX_Unmarshal(b []byte) error { 557 return xxx_messageInfo_ListTasksRequest.Unmarshal(m, b) 558} 559func (m *ListTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 560 return xxx_messageInfo_ListTasksRequest.Marshal(b, m, deterministic) 561} 562func (m *ListTasksRequest) XXX_Merge(src proto.Message) { 563 xxx_messageInfo_ListTasksRequest.Merge(m, src) 564} 565func (m *ListTasksRequest) XXX_Size() int { 566 return xxx_messageInfo_ListTasksRequest.Size(m) 567} 568func (m *ListTasksRequest) XXX_DiscardUnknown() { 569 xxx_messageInfo_ListTasksRequest.DiscardUnknown(m) 570} 571 572var xxx_messageInfo_ListTasksRequest proto.InternalMessageInfo 573 574func (m *ListTasksRequest) GetParent() string { 575 if m != nil { 576 return m.Parent 577 } 578 return "" 579} 580 581func (m *ListTasksRequest) GetResponseView() Task_View { 582 if m != nil { 583 return m.ResponseView 584 } 585 return Task_VIEW_UNSPECIFIED 586} 587 588func (m *ListTasksRequest) GetPageSize() int32 { 589 if m != nil { 590 return m.PageSize 591 } 592 return 0 593} 594 595func (m *ListTasksRequest) GetPageToken() string { 596 if m != nil { 597 return m.PageToken 598 } 599 return "" 600} 601 602// Response message for listing tasks using [ListTasks][google.cloud.tasks.v2beta3.CloudTasks.ListTasks]. 603type ListTasksResponse struct { 604 // The list of tasks. 605 Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` 606 // A token to retrieve next page of results. 607 // 608 // To return the next page of results, call 609 // [ListTasks][google.cloud.tasks.v2beta3.CloudTasks.ListTasks] with this value as the 610 // [page_token][google.cloud.tasks.v2beta3.ListTasksRequest.page_token]. 611 // 612 // If the next_page_token is empty, there are no more results. 613 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 614 XXX_NoUnkeyedLiteral struct{} `json:"-"` 615 XXX_unrecognized []byte `json:"-"` 616 XXX_sizecache int32 `json:"-"` 617} 618 619func (m *ListTasksResponse) Reset() { *m = ListTasksResponse{} } 620func (m *ListTasksResponse) String() string { return proto.CompactTextString(m) } 621func (*ListTasksResponse) ProtoMessage() {} 622func (*ListTasksResponse) Descriptor() ([]byte, []int) { 623 return fileDescriptor_774b6c8e7fbe6f6d, []int{10} 624} 625 626func (m *ListTasksResponse) XXX_Unmarshal(b []byte) error { 627 return xxx_messageInfo_ListTasksResponse.Unmarshal(m, b) 628} 629func (m *ListTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 630 return xxx_messageInfo_ListTasksResponse.Marshal(b, m, deterministic) 631} 632func (m *ListTasksResponse) XXX_Merge(src proto.Message) { 633 xxx_messageInfo_ListTasksResponse.Merge(m, src) 634} 635func (m *ListTasksResponse) XXX_Size() int { 636 return xxx_messageInfo_ListTasksResponse.Size(m) 637} 638func (m *ListTasksResponse) XXX_DiscardUnknown() { 639 xxx_messageInfo_ListTasksResponse.DiscardUnknown(m) 640} 641 642var xxx_messageInfo_ListTasksResponse proto.InternalMessageInfo 643 644func (m *ListTasksResponse) GetTasks() []*Task { 645 if m != nil { 646 return m.Tasks 647 } 648 return nil 649} 650 651func (m *ListTasksResponse) GetNextPageToken() string { 652 if m != nil { 653 return m.NextPageToken 654 } 655 return "" 656} 657 658// Request message for getting a task using [GetTask][google.cloud.tasks.v2beta3.CloudTasks.GetTask]. 659type GetTaskRequest struct { 660 // Required. The task name. For example: 661 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` 662 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 663 // The response_view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] will be 664 // returned. 665 // 666 // By default response_view is [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]; not all 667 // information is retrieved by default because some data, such as 668 // payloads, might be desirable to return only when needed because 669 // of its large size or because of the sensitivity of data that it 670 // contains. 671 // 672 // Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires 673 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 674 // permission on the [Task][google.cloud.tasks.v2beta3.Task] resource. 675 ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"response_view,omitempty"` 676 XXX_NoUnkeyedLiteral struct{} `json:"-"` 677 XXX_unrecognized []byte `json:"-"` 678 XXX_sizecache int32 `json:"-"` 679} 680 681func (m *GetTaskRequest) Reset() { *m = GetTaskRequest{} } 682func (m *GetTaskRequest) String() string { return proto.CompactTextString(m) } 683func (*GetTaskRequest) ProtoMessage() {} 684func (*GetTaskRequest) Descriptor() ([]byte, []int) { 685 return fileDescriptor_774b6c8e7fbe6f6d, []int{11} 686} 687 688func (m *GetTaskRequest) XXX_Unmarshal(b []byte) error { 689 return xxx_messageInfo_GetTaskRequest.Unmarshal(m, b) 690} 691func (m *GetTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 692 return xxx_messageInfo_GetTaskRequest.Marshal(b, m, deterministic) 693} 694func (m *GetTaskRequest) XXX_Merge(src proto.Message) { 695 xxx_messageInfo_GetTaskRequest.Merge(m, src) 696} 697func (m *GetTaskRequest) XXX_Size() int { 698 return xxx_messageInfo_GetTaskRequest.Size(m) 699} 700func (m *GetTaskRequest) XXX_DiscardUnknown() { 701 xxx_messageInfo_GetTaskRequest.DiscardUnknown(m) 702} 703 704var xxx_messageInfo_GetTaskRequest proto.InternalMessageInfo 705 706func (m *GetTaskRequest) GetName() string { 707 if m != nil { 708 return m.Name 709 } 710 return "" 711} 712 713func (m *GetTaskRequest) GetResponseView() Task_View { 714 if m != nil { 715 return m.ResponseView 716 } 717 return Task_VIEW_UNSPECIFIED 718} 719 720// Request message for [CreateTask][google.cloud.tasks.v2beta3.CloudTasks.CreateTask]. 721type CreateTaskRequest struct { 722 // Required. The queue name. For example: 723 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 724 // 725 // The queue must already exist. 726 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 727 // Required. The task to add. 728 // 729 // Task names have the following format: 730 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID`. 731 // The user can optionally specify a task [name][google.cloud.tasks.v2beta3.Task.name]. If a 732 // name is not specified then the system will generate a random 733 // unique task id, which will be set in the task returned in the 734 // [response][google.cloud.tasks.v2beta3.Task.name]. 735 // 736 // If [schedule_time][google.cloud.tasks.v2beta3.Task.schedule_time] is not set or is in the 737 // past then Cloud Tasks will set it to the current time. 738 // 739 // Task De-duplication: 740 // 741 // Explicitly specifying a task ID enables task de-duplication. If 742 // a task's ID is identical to that of an existing task or a task 743 // that was deleted or executed recently then the call will fail 744 // with [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS]. 745 // If the task's queue was created using Cloud Tasks, then another task with 746 // the same name can't be created for ~1hour after the original task was 747 // deleted or executed. If the task's queue was created using queue.yaml or 748 // queue.xml, then another task with the same name can't be created 749 // for ~9days after the original task was deleted or executed. 750 // 751 // Because there is an extra lookup cost to identify duplicate task 752 // names, these [CreateTask][google.cloud.tasks.v2beta3.CloudTasks.CreateTask] calls have significantly 753 // increased latency. Using hashed strings for the task id or for 754 // the prefix of the task id is recommended. Choosing task ids that 755 // are sequential or have sequential prefixes, for example using a 756 // timestamp, causes an increase in latency and error rates in all 757 // task commands. The infrastructure relies on an approximately 758 // uniform distribution of task ids to store and serve tasks 759 // efficiently. 760 Task *Task `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` 761 // The response_view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] will be 762 // returned. 763 // 764 // By default response_view is [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]; not all 765 // information is retrieved by default because some data, such as 766 // payloads, might be desirable to return only when needed because 767 // of its large size or because of the sensitivity of data that it 768 // contains. 769 // 770 // Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires 771 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 772 // permission on the [Task][google.cloud.tasks.v2beta3.Task] resource. 773 ResponseView Task_View `protobuf:"varint,3,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"response_view,omitempty"` 774 XXX_NoUnkeyedLiteral struct{} `json:"-"` 775 XXX_unrecognized []byte `json:"-"` 776 XXX_sizecache int32 `json:"-"` 777} 778 779func (m *CreateTaskRequest) Reset() { *m = CreateTaskRequest{} } 780func (m *CreateTaskRequest) String() string { return proto.CompactTextString(m) } 781func (*CreateTaskRequest) ProtoMessage() {} 782func (*CreateTaskRequest) Descriptor() ([]byte, []int) { 783 return fileDescriptor_774b6c8e7fbe6f6d, []int{12} 784} 785 786func (m *CreateTaskRequest) XXX_Unmarshal(b []byte) error { 787 return xxx_messageInfo_CreateTaskRequest.Unmarshal(m, b) 788} 789func (m *CreateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 790 return xxx_messageInfo_CreateTaskRequest.Marshal(b, m, deterministic) 791} 792func (m *CreateTaskRequest) XXX_Merge(src proto.Message) { 793 xxx_messageInfo_CreateTaskRequest.Merge(m, src) 794} 795func (m *CreateTaskRequest) XXX_Size() int { 796 return xxx_messageInfo_CreateTaskRequest.Size(m) 797} 798func (m *CreateTaskRequest) XXX_DiscardUnknown() { 799 xxx_messageInfo_CreateTaskRequest.DiscardUnknown(m) 800} 801 802var xxx_messageInfo_CreateTaskRequest proto.InternalMessageInfo 803 804func (m *CreateTaskRequest) GetParent() string { 805 if m != nil { 806 return m.Parent 807 } 808 return "" 809} 810 811func (m *CreateTaskRequest) GetTask() *Task { 812 if m != nil { 813 return m.Task 814 } 815 return nil 816} 817 818func (m *CreateTaskRequest) GetResponseView() Task_View { 819 if m != nil { 820 return m.ResponseView 821 } 822 return Task_VIEW_UNSPECIFIED 823} 824 825// Request message for deleting a task using 826// [DeleteTask][google.cloud.tasks.v2beta3.CloudTasks.DeleteTask]. 827type DeleteTaskRequest struct { 828 // Required. The task name. For example: 829 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` 830 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 831 XXX_NoUnkeyedLiteral struct{} `json:"-"` 832 XXX_unrecognized []byte `json:"-"` 833 XXX_sizecache int32 `json:"-"` 834} 835 836func (m *DeleteTaskRequest) Reset() { *m = DeleteTaskRequest{} } 837func (m *DeleteTaskRequest) String() string { return proto.CompactTextString(m) } 838func (*DeleteTaskRequest) ProtoMessage() {} 839func (*DeleteTaskRequest) Descriptor() ([]byte, []int) { 840 return fileDescriptor_774b6c8e7fbe6f6d, []int{13} 841} 842 843func (m *DeleteTaskRequest) XXX_Unmarshal(b []byte) error { 844 return xxx_messageInfo_DeleteTaskRequest.Unmarshal(m, b) 845} 846func (m *DeleteTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 847 return xxx_messageInfo_DeleteTaskRequest.Marshal(b, m, deterministic) 848} 849func (m *DeleteTaskRequest) XXX_Merge(src proto.Message) { 850 xxx_messageInfo_DeleteTaskRequest.Merge(m, src) 851} 852func (m *DeleteTaskRequest) XXX_Size() int { 853 return xxx_messageInfo_DeleteTaskRequest.Size(m) 854} 855func (m *DeleteTaskRequest) XXX_DiscardUnknown() { 856 xxx_messageInfo_DeleteTaskRequest.DiscardUnknown(m) 857} 858 859var xxx_messageInfo_DeleteTaskRequest proto.InternalMessageInfo 860 861func (m *DeleteTaskRequest) GetName() string { 862 if m != nil { 863 return m.Name 864 } 865 return "" 866} 867 868// Request message for forcing a task to run now using 869// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask]. 870type RunTaskRequest struct { 871 // Required. The task name. For example: 872 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` 873 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 874 // The response_view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] will be 875 // returned. 876 // 877 // By default response_view is [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]; not all 878 // information is retrieved by default because some data, such as 879 // payloads, might be desirable to return only when needed because 880 // of its large size or because of the sensitivity of data that it 881 // contains. 882 // 883 // Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires 884 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 885 // permission on the [Task][google.cloud.tasks.v2beta3.Task] resource. 886 ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"response_view,omitempty"` 887 XXX_NoUnkeyedLiteral struct{} `json:"-"` 888 XXX_unrecognized []byte `json:"-"` 889 XXX_sizecache int32 `json:"-"` 890} 891 892func (m *RunTaskRequest) Reset() { *m = RunTaskRequest{} } 893func (m *RunTaskRequest) String() string { return proto.CompactTextString(m) } 894func (*RunTaskRequest) ProtoMessage() {} 895func (*RunTaskRequest) Descriptor() ([]byte, []int) { 896 return fileDescriptor_774b6c8e7fbe6f6d, []int{14} 897} 898 899func (m *RunTaskRequest) XXX_Unmarshal(b []byte) error { 900 return xxx_messageInfo_RunTaskRequest.Unmarshal(m, b) 901} 902func (m *RunTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 903 return xxx_messageInfo_RunTaskRequest.Marshal(b, m, deterministic) 904} 905func (m *RunTaskRequest) XXX_Merge(src proto.Message) { 906 xxx_messageInfo_RunTaskRequest.Merge(m, src) 907} 908func (m *RunTaskRequest) XXX_Size() int { 909 return xxx_messageInfo_RunTaskRequest.Size(m) 910} 911func (m *RunTaskRequest) XXX_DiscardUnknown() { 912 xxx_messageInfo_RunTaskRequest.DiscardUnknown(m) 913} 914 915var xxx_messageInfo_RunTaskRequest proto.InternalMessageInfo 916 917func (m *RunTaskRequest) GetName() string { 918 if m != nil { 919 return m.Name 920 } 921 return "" 922} 923 924func (m *RunTaskRequest) GetResponseView() Task_View { 925 if m != nil { 926 return m.ResponseView 927 } 928 return Task_VIEW_UNSPECIFIED 929} 930 931func init() { 932 proto.RegisterType((*ListQueuesRequest)(nil), "google.cloud.tasks.v2beta3.ListQueuesRequest") 933 proto.RegisterType((*ListQueuesResponse)(nil), "google.cloud.tasks.v2beta3.ListQueuesResponse") 934 proto.RegisterType((*GetQueueRequest)(nil), "google.cloud.tasks.v2beta3.GetQueueRequest") 935 proto.RegisterType((*CreateQueueRequest)(nil), "google.cloud.tasks.v2beta3.CreateQueueRequest") 936 proto.RegisterType((*UpdateQueueRequest)(nil), "google.cloud.tasks.v2beta3.UpdateQueueRequest") 937 proto.RegisterType((*DeleteQueueRequest)(nil), "google.cloud.tasks.v2beta3.DeleteQueueRequest") 938 proto.RegisterType((*PurgeQueueRequest)(nil), "google.cloud.tasks.v2beta3.PurgeQueueRequest") 939 proto.RegisterType((*PauseQueueRequest)(nil), "google.cloud.tasks.v2beta3.PauseQueueRequest") 940 proto.RegisterType((*ResumeQueueRequest)(nil), "google.cloud.tasks.v2beta3.ResumeQueueRequest") 941 proto.RegisterType((*ListTasksRequest)(nil), "google.cloud.tasks.v2beta3.ListTasksRequest") 942 proto.RegisterType((*ListTasksResponse)(nil), "google.cloud.tasks.v2beta3.ListTasksResponse") 943 proto.RegisterType((*GetTaskRequest)(nil), "google.cloud.tasks.v2beta3.GetTaskRequest") 944 proto.RegisterType((*CreateTaskRequest)(nil), "google.cloud.tasks.v2beta3.CreateTaskRequest") 945 proto.RegisterType((*DeleteTaskRequest)(nil), "google.cloud.tasks.v2beta3.DeleteTaskRequest") 946 proto.RegisterType((*RunTaskRequest)(nil), "google.cloud.tasks.v2beta3.RunTaskRequest") 947} 948 949func init() { 950 proto.RegisterFile("google/cloud/tasks/v2beta3/cloudtasks.proto", fileDescriptor_774b6c8e7fbe6f6d) 951} 952 953var fileDescriptor_774b6c8e7fbe6f6d = []byte{ 954 // 1303 bytes of a gzipped FileDescriptorProto 955 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x98, 0x4f, 0x6f, 0xdc, 0xc4, 956 0x1b, 0xc7, 0x35, 0x49, 0x93, 0x26, 0xcf, 0xa6, 0xcd, 0x2f, 0xa3, 0x1f, 0x21, 0xdd, 0x42, 0xba, 957 0xb5, 0xd4, 0x10, 0xb6, 0x89, 0xad, 0xa4, 0x6a, 0x21, 0x9b, 0x92, 0xc6, 0x29, 0x4d, 0x0a, 0x25, 958 0xb0, 0xd9, 0x84, 0x0a, 0x21, 0xa1, 0xc8, 0xd9, 0x4c, 0x36, 0x26, 0xbb, 0xb6, 0x6b, 0x8f, 0xb3, 959 0x50, 0xe8, 0x85, 0x37, 0xc0, 0xa1, 0x42, 0x42, 0x70, 0x40, 0x20, 0x01, 0x15, 0x12, 0x42, 0xe2, 960 0xc8, 0x4b, 0xe0, 0x48, 0x6f, 0x7b, 0xea, 0x81, 0x57, 0xc1, 0x09, 0xcd, 0x1f, 0xaf, 0xbd, 0x36, 961 0xf1, 0x3a, 0x9b, 0x08, 0x71, 0x4a, 0x3c, 0xcf, 0x33, 0xcf, 0xf3, 0x99, 0x67, 0xc6, 0xf3, 0x7c, 962 0xd7, 0x70, 0xb5, 0x66, 0xdb, 0xb5, 0x3a, 0xd1, 0xaa, 0x75, 0xdb, 0xdf, 0xd5, 0xa8, 0xe1, 0x1d, 963 0x78, 0xda, 0xe1, 0xfc, 0x0e, 0xa1, 0xc6, 0x35, 0x31, 0xc6, 0x87, 0x54, 0xc7, 0xb5, 0xa9, 0x8d, 964 0xf3, 0xc2, 0x59, 0xe5, 0x06, 0x55, 0x58, 0xa4, 0x73, 0xfe, 0x05, 0x19, 0xc8, 0x70, 0x4c, 0xcd, 965 0xb0, 0x2c, 0x9b, 0x1a, 0xd4, 0xb4, 0x2d, 0x39, 0x33, 0xff, 0x7c, 0xc4, 0x5a, 0xad, 0x9b, 0xc4, 966 0xa2, 0xd2, 0x70, 0x29, 0x62, 0xd8, 0x33, 0x49, 0x7d, 0x77, 0x7b, 0x87, 0xec, 0x1b, 0x87, 0xa6, 967 0xed, 0x4a, 0x87, 0x0b, 0x11, 0x07, 0x97, 0x78, 0xb6, 0xef, 0x56, 0x89, 0x34, 0x4d, 0xa5, 0xb0, 968 0x3f, 0xf0, 0x89, 0x1f, 0xf8, 0x5d, 0x49, 0xf1, 0x63, 0x4f, 0xd2, 0x6d, 0x52, 0xba, 0x99, 0x46, 969 0x43, 0x3b, 0x9c, 0x63, 0x7f, 0xb6, 0x1d, 0xbb, 0x6e, 0x56, 0x3f, 0x96, 0xf6, 0x7c, 0xa7, 0xbd, 970 0xc3, 0x76, 0x51, 0xda, 0xf8, 0xd3, 0x8e, 0xbf, 0xa7, 0x91, 0x86, 0x43, 0x03, 0x63, 0x21, 0x6e, 971 0x14, 0x0b, 0x6d, 0xb4, 0x53, 0x2b, 0x4f, 0x10, 0x8c, 0xbd, 0x65, 0x7a, 0x74, 0x83, 0x51, 0x7b, 972 0x15, 0xf2, 0xc0, 0x27, 0x1e, 0xc5, 0xb7, 0x60, 0xd0, 0x31, 0x5c, 0x62, 0xd1, 0x09, 0x54, 0x40, 973 0xd3, 0xc3, 0x2b, 0x2f, 0x3d, 0xd3, 0xfb, 0xfe, 0xd2, 0x2f, 0xe3, 0x4b, 0x91, 0x8d, 0x11, 0xa1, 974 0x0d, 0xc7, 0xf4, 0xd4, 0xaa, 0xdd, 0xd0, 0x78, 0x80, 0x8a, 0x9c, 0x86, 0xc7, 0x61, 0x70, 0xcf, 975 0xac, 0x53, 0xe2, 0x4e, 0xf4, 0xb1, 0x00, 0x15, 0xf9, 0x84, 0x2f, 0xc2, 0xb0, 0x63, 0xd4, 0xc8, 976 0xb6, 0x67, 0x3e, 0x24, 0x13, 0xfd, 0x05, 0x34, 0x3d, 0x50, 0x19, 0x62, 0x03, 0x9b, 0xe6, 0x43, 977 0x82, 0x5f, 0x04, 0xe0, 0x46, 0x6a, 0x1f, 0x10, 0x6b, 0xe2, 0x0c, 0x9f, 0xc8, 0xdd, 0xb7, 0xd8, 978 0x80, 0xd2, 0x04, 0x1c, 0x25, 0xf5, 0x1c, 0xdb, 0xf2, 0x08, 0x5e, 0x80, 0x41, 0x5e, 0x71, 0x6f, 979 0x02, 0x15, 0xfa, 0xa7, 0x73, 0xf3, 0x97, 0xd5, 0xa3, 0x8f, 0x8a, 0x2a, 0x21, 0xc5, 0x04, 0x3c, 980 0x05, 0xa3, 0x16, 0xf9, 0x88, 0x6e, 0x47, 0x92, 0x0a, 0xda, 0x73, 0x6c, 0xb8, 0xdc, 0x4e, 0xfc, 981 0x36, 0x8c, 0xae, 0x11, 0x91, 0x37, 0x28, 0xd0, 0x22, 0x9c, 0xb1, 0x8c, 0x06, 0xe9, 0x2c, 0x0f, 982 0x74, 0x2d, 0x0f, 0x9f, 0xa4, 0x3c, 0x46, 0x80, 0x6f, 0xbb, 0xc4, 0xa0, 0xa4, 0x23, 0xe6, 0x89, 983 0x8b, 0x7e, 0x13, 0x06, 0xf8, 0xca, 0xf8, 0x2a, 0xb2, 0x54, 0x62, 0xa5, 0xff, 0x99, 0xde, 0x57, 984 0x11, 0x93, 0x94, 0xcf, 0x11, 0xe0, 0x77, 0x9d, 0xdd, 0x38, 0x55, 0x3b, 0x28, 0xea, 0x21, 0x28, 985 0x5e, 0x84, 0x9c, 0xcf, 0x63, 0xf2, 0x33, 0x27, 0xc1, 0xf2, 0x41, 0x8c, 0xe0, 0x58, 0xaa, 0xab, 986 0xec, 0x58, 0xae, 0x1b, 0xde, 0x41, 0x05, 0x84, 0x3b, 0xfb, 0x5f, 0xd9, 0x00, 0xfc, 0x3a, 0xa9, 987 0x93, 0x18, 0xd0, 0x89, 0x4a, 0x5f, 0x86, 0xb1, 0xb2, 0xef, 0xd6, 0x4e, 0x39, 0xa2, 0xe1, 0x7b, 988 0xa7, 0x18, 0x71, 0x03, 0x70, 0x85, 0x78, 0x7e, 0xe3, 0x14, 0x43, 0xb6, 0x10, 0xfc, 0x8f, 0xbd, 989 0x3b, 0x5b, 0xcc, 0x31, 0x88, 0xb8, 0x14, 0x3b, 0x6f, 0x53, 0x3c, 0x66, 0x01, 0x4f, 0x1e, 0x1d, 990 0x93, 0xcd, 0x6f, 0x1f, 0xb7, 0x37, 0xe1, 0x9c, 0x2b, 0xdf, 0xc2, 0xed, 0x43, 0x93, 0x34, 0xf9, 991 0xee, 0x9e, 0x9f, 0xbf, 0x92, 0x76, 0x42, 0x58, 0x00, 0xf5, 0xbe, 0x49, 0x9a, 0x95, 0x91, 0x60, 992 0x2e, 0x7b, 0x3a, 0xd1, 0xbd, 0xe0, 0x89, 0x1b, 0x4c, 0xae, 0x4d, 0x5e, 0x0b, 0x37, 0x60, 0x80, 993 0x67, 0x96, 0xb7, 0x42, 0xa1, 0x1b, 0x54, 0x45, 0xb8, 0x67, 0xbe, 0x13, 0xbe, 0x44, 0x70, 0x7e, 994 0x8d, 0xf0, 0xa4, 0x41, 0x3d, 0x4b, 0x1d, 0x3b, 0x24, 0xab, 0x09, 0xdd, 0xaa, 0xc9, 0xe7, 0x9c, 995 0x66, 0x2d, 0xd9, 0x66, 0x8f, 0x89, 0xeb, 0x25, 0x4a, 0x77, 0xd2, 0xdd, 0x5e, 0x80, 0x33, 0x34, 996 0x7c, 0x85, 0xbb, 0xd6, 0x53, 0xdc, 0x02, 0x7c, 0x4a, 0x72, 0x71, 0xfd, 0xbd, 0x2f, 0xee, 0x1d, 997 0x18, 0x13, 0x77, 0xc2, 0x29, 0x55, 0x9e, 0x6f, 0x64, 0xc5, 0xb7, 0xfe, 0x83, 0x1b, 0x39, 0xff, 998 0xfd, 0x38, 0xc0, 0x6d, 0xe6, 0xcf, 0x8f, 0x36, 0xfe, 0x19, 0x01, 0x84, 0x0d, 0x10, 0xcf, 0xa6, 999 0x85, 0x4c, 0xb4, 0xf4, 0xbc, 0x9a, 0xd5, 0x5d, 0x00, 0x28, 0xcb, 0x2d, 0x5d, 0x6e, 0xfd, 0x67, 1000 0x4f, 0xff, 0x7c, 0xdc, 0x37, 0x87, 0xb5, 0xb6, 0x72, 0xf9, 0x44, 0x8c, 0xbf, 0xe6, 0xb8, 0xf6, 1001 0x87, 0xa4, 0x4a, 0x3d, 0xad, 0xa8, 0xd5, 0xed, 0xaa, 0x50, 0x5d, 0x5a, 0xf1, 0x91, 0x26, 0xdb, 1002 0xeb, 0x57, 0x08, 0x86, 0x82, 0xbe, 0x89, 0xaf, 0xa6, 0xa5, 0x8f, 0x75, 0xd7, 0x7c, 0xf7, 0x26, 1003 0xa3, 0x2c, 0xb5, 0x74, 0x5e, 0xf0, 0x24, 0x1c, 0x1b, 0x3d, 0x02, 0x4d, 0x92, 0x69, 0xc5, 0x47, 1004 0xf8, 0x17, 0x04, 0xb9, 0x48, 0x0f, 0xc6, 0xa9, 0xe5, 0x49, 0x36, 0xeb, 0x2c, 0x88, 0xeb, 0x2d, 1005 0x7d, 0x44, 0x54, 0x6a, 0x86, 0xe7, 0xe5, 0xa8, 0xaf, 0x2a, 0xc7, 0xad, 0x63, 0x49, 0xb6, 0xd2, 1006 0xdf, 0x10, 0xe4, 0x22, 0xfd, 0x39, 0x9d, 0x38, 0xd9, 0xc8, 0xb3, 0x10, 0xbf, 0xd7, 0xd2, 0xc7, 1007 0x78, 0xb2, 0x99, 0x48, 0xd3, 0xe6, 0xd8, 0x4b, 0xf3, 0xd7, 0x43, 0x6c, 0xa1, 0x70, 0x33, 0xd5, 1008 0x39, 0x80, 0xff, 0x02, 0x41, 0x2e, 0xd2, 0xcb, 0xd3, 0xe1, 0x93, 0x4d, 0x3f, 0x3f, 0x9e, 0x90, 1009 0x0c, 0x77, 0x98, 0xcc, 0x8d, 0x1d, 0x83, 0xe2, 0xb1, 0x8f, 0xc1, 0x8f, 0x08, 0x20, 0x14, 0x04, 1010 0xe9, 0xef, 0x54, 0x42, 0x38, 0x64, 0x29, 0xe9, 0x5a, 0x14, 0xb0, 0xa4, 0x5c, 0x3f, 0x26, 0x60, 1011 0xc9, 0x61, 0x49, 0x4b, 0xa8, 0x28, 0x48, 0xdb, 0x42, 0xa3, 0x0b, 0x69, 0x5c, 0x90, 0xfc, 0x2b, 1012 0xa4, 0x2c, 0x29, 0x23, 0xfd, 0x09, 0x41, 0x2e, 0x22, 0x60, 0xd2, 0xf7, 0x3a, 0xa9, 0x74, 0xb2, 1013 0xb0, 0xde, 0x8d, 0xb2, 0x2e, 0x2a, 0x37, 0x8e, 0xcb, 0xea, 0xf2, 0xac, 0x0c, 0xf6, 0x5b, 0x04, 1014 0x23, 0x6b, 0x84, 0xbe, 0x61, 0x34, 0xca, 0xfc, 0x57, 0x15, 0x56, 0x82, 0xec, 0xa6, 0xd1, 0x50, 1015 0x0f, 0xe7, 0xd4, 0xa8, 0x31, 0x20, 0x7c, 0x2e, 0xe6, 0x23, 0xac, 0xca, 0xfd, 0x96, 0x3e, 0x14, 1016 0xfc, 0x50, 0xe4, 0x64, 0x77, 0x94, 0xe5, 0x90, 0x2c, 0xb0, 0x74, 0xa7, 0xab, 0x45, 0x52, 0x32, 1017 0xc6, 0x27, 0x08, 0x46, 0x36, 0xd3, 0x18, 0x37, 0xb3, 0x33, 0x7e, 0xd0, 0xd2, 0x47, 0x03, 0x92, 1018 0x19, 0xf1, 0x43, 0xf2, 0x24, 0xa8, 0x5e, 0x0c, 0xf5, 0x29, 0x02, 0xbc, 0x45, 0x3c, 0x3e, 0x48, 1019 0xdc, 0x86, 0xe9, 0x79, 0x6c, 0x0a, 0x9e, 0x8e, 0xc1, 0x24, 0x5d, 0x02, 0xec, 0x97, 0x33, 0x78, 1020 0xca, 0x0e, 0xb5, 0xdf, 0xd2, 0xff, 0x1f, 0x2e, 0x25, 0x74, 0xe0, 0xeb, 0xb9, 0xa7, 0xac, 0xf6, 1021 0xb2, 0x1e, 0x9a, 0x48, 0xc7, 0x56, 0xf5, 0x2b, 0x82, 0xe1, 0xb6, 0xc4, 0xc4, 0x33, 0xdd, 0x3a, 1022 0x69, 0x54, 0x65, 0xe7, 0x67, 0x33, 0x7a, 0xcb, 0x45, 0xdd, 0xed, 0x6c, 0xbb, 0x0b, 0xf8, 0x95, 1023 0x8c, 0xed, 0x22, 0x5c, 0x84, 0xf8, 0xce, 0x80, 0xbf, 0x41, 0x70, 0x56, 0x2a, 0x54, 0x5c, 0xec, 1024 0xd2, 0x7d, 0x23, 0xea, 0x27, 0xdf, 0x55, 0xda, 0x29, 0xab, 0xd1, 0xb7, 0xaf, 0x83, 0x30, 0xcb, 1025 0xdb, 0x27, 0x3f, 0x83, 0x88, 0x1e, 0x0c, 0xa1, 0x50, 0x4d, 0xbf, 0xd2, 0x12, 0x82, 0x36, 0x03, 1026 0x67, 0xb9, 0xa5, 0xe7, 0x64, 0x03, 0xa6, 0x41, 0x23, 0xbb, 0xa9, 0xf4, 0x5a, 0x50, 0x76, 0x10, 1027 0xbe, 0x46, 0x00, 0xa1, 0xfc, 0x4c, 0x27, 0x4e, 0xc8, 0xd4, 0x23, 0x9b, 0x58, 0x67, 0x3d, 0x8b, 1028 0x3d, 0xd7, 0xf3, 0x07, 0x04, 0x67, 0xa5, 0x94, 0x4d, 0xdf, 0xf1, 0x4e, 0xbd, 0x9b, 0xa1, 0x92, 1029 0xeb, 0x51, 0xc2, 0x65, 0x65, 0xb1, 0x47, 0xc2, 0x92, 0xeb, 0x5b, 0x25, 0x54, 0xcc, 0xaf, 0xff, 1030 0xae, 0x5f, 0x38, 0x52, 0x4d, 0xff, 0xa1, 0xab, 0xfb, 0x94, 0x3a, 0x5e, 0x49, 0xd3, 0x9a, 0xcd, 1031 0x66, 0x5c, 0x6a, 0x1b, 0x3e, 0xdd, 0x17, 0x9f, 0xd3, 0x66, 0x9d, 0xba, 0x41, 0xf7, 0x6c, 0xb7, 1032 0xb1, 0xf2, 0x29, 0x4c, 0x56, 0xed, 0x46, 0xca, 0x22, 0x56, 0x46, 0x43, 0x19, 0x5d, 0x66, 0xb5, 1033 0x2f, 0xa3, 0xf7, 0x6f, 0x49, 0xf7, 0x9a, 0x5d, 0x37, 0xac, 0x9a, 0x6a, 0xbb, 0x35, 0xad, 0x46, 1034 0x2c, 0xbe, 0x33, 0x5a, 0x98, 0xf3, 0x9f, 0xbe, 0xdc, 0x2d, 0xf2, 0xa7, 0xef, 0xfa, 0x06, 0xb6, 1035 0xf4, 0xcd, 0x7b, 0x9b, 0x3b, 0x83, 0x7c, 0xce, 0xb5, 0xbf, 0x03, 0x00, 0x00, 0xff, 0xff, 0x81, 1036 0x92, 0x43, 0xb2, 0xd0, 0x14, 0x00, 0x00, 1037} 1038 1039// Reference imports to suppress errors if they are not otherwise used. 1040var _ context.Context 1041var _ grpc.ClientConn 1042 1043// This is a compile-time assertion to ensure that this generated file 1044// is compatible with the grpc package it is being compiled against. 1045const _ = grpc.SupportPackageIsVersion4 1046 1047// CloudTasksClient is the client API for CloudTasks service. 1048// 1049// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1050type CloudTasksClient interface { 1051 // Lists queues. 1052 // 1053 // Queues are returned in lexicographical order. 1054 ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error) 1055 // Gets a queue. 1056 GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1057 // Creates a queue. 1058 // 1059 // Queues created with this method allow tasks to live for a maximum of 31 1060 // days. After a task is 31 days old, the task will be deleted regardless of whether 1061 // it was dispatched or not. 1062 // 1063 // WARNING: Using this method may have unintended side effects if you are 1064 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1065 // Read 1066 // [Overview of Queue Management and 1067 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1068 // this method. 1069 CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1070 // Updates a queue. 1071 // 1072 // This method creates the queue if it does not exist and updates 1073 // the queue if it does exist. 1074 // 1075 // Queues created with this method allow tasks to live for a maximum of 31 1076 // days. After a task is 31 days old, the task will be deleted regardless of whether 1077 // it was dispatched or not. 1078 // 1079 // WARNING: Using this method may have unintended side effects if you are 1080 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1081 // Read 1082 // [Overview of Queue Management and 1083 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1084 // this method. 1085 UpdateQueue(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1086 // Deletes a queue. 1087 // 1088 // This command will delete the queue even if it has tasks in it. 1089 // 1090 // Note: If you delete a queue, a queue with the same name can't be created 1091 // for 7 days. 1092 // 1093 // WARNING: Using this method may have unintended side effects if you are 1094 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1095 // Read 1096 // [Overview of Queue Management and 1097 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1098 // this method. 1099 DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1100 // Purges a queue by deleting all of its tasks. 1101 // 1102 // All tasks created before this method is called are permanently deleted. 1103 // 1104 // Purge operations can take up to one minute to take effect. Tasks 1105 // might be dispatched before the purge takes effect. A purge is irreversible. 1106 PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1107 // Pauses the queue. 1108 // 1109 // If a queue is paused then the system will stop dispatching tasks 1110 // until the queue is resumed via 1111 // [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue]. Tasks can still be added 1112 // when the queue is paused. A queue is paused if its 1113 // [state][google.cloud.tasks.v2beta3.Queue.state] is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED]. 1114 PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1115 // Resume a queue. 1116 // 1117 // This method resumes a queue after it has been 1118 // [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED] or 1119 // [DISABLED][google.cloud.tasks.v2beta3.Queue.State.DISABLED]. The state of a queue is stored 1120 // in the queue's [state][google.cloud.tasks.v2beta3.Queue.state]; after calling this method it 1121 // will be set to [RUNNING][google.cloud.tasks.v2beta3.Queue.State.RUNNING]. 1122 // 1123 // WARNING: Resuming many high-QPS queues at the same time can 1124 // lead to target overloading. If you are resuming high-QPS 1125 // queues, follow the 500/50/5 pattern described in 1126 // [Managing Cloud Tasks Scaling 1127 // Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). 1128 ResumeQueue(ctx context.Context, in *ResumeQueueRequest, opts ...grpc.CallOption) (*Queue, error) 1129 // Gets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue]. 1130 // Returns an empty policy if the resource exists and does not have a policy 1131 // set. 1132 // 1133 // Authorization requires the following 1134 // [Google IAM](https://cloud.google.com/iam) permission on the specified 1135 // resource parent: 1136 // 1137 // * `cloudtasks.queues.getIamPolicy` 1138 GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) 1139 // Sets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue]. Replaces any existing 1140 // policy. 1141 // 1142 // Note: The Cloud Console does not check queue-level IAM permissions yet. 1143 // Project-level permissions are required to use the Cloud Console. 1144 // 1145 // Authorization requires the following 1146 // [Google IAM](https://cloud.google.com/iam) permission on the specified 1147 // resource parent: 1148 // 1149 // * `cloudtasks.queues.setIamPolicy` 1150 SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) 1151 // Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta3.Queue]. 1152 // If the resource does not exist, this will return an empty set of 1153 // permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error. 1154 // 1155 // Note: This operation is designed to be used for building permission-aware 1156 // UIs and command-line tools, not for authorization checking. This operation 1157 // may "fail open" without warning. 1158 TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error) 1159 // Lists the tasks in a queue. 1160 // 1161 // By default, only the [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC] view is retrieved 1162 // due to performance considerations; 1163 // [response_view][google.cloud.tasks.v2beta3.ListTasksRequest.response_view] controls the 1164 // subset of information which is returned. 1165 // 1166 // The tasks may be returned in any order. The ordering may change at any 1167 // time. 1168 ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) 1169 // Gets a task. 1170 GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error) 1171 // Creates a task and adds it to a queue. 1172 // 1173 // Tasks cannot be updated after creation; there is no UpdateTask command. 1174 // 1175 // * The maximum task size is 100KB. 1176 CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*Task, error) 1177 // Deletes a task. 1178 // 1179 // A task can be deleted if it is scheduled or dispatched. A task 1180 // cannot be deleted if it has executed successfully or permanently 1181 // failed. 1182 DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1183 // Forces a task to run now. 1184 // 1185 // When this method is called, Cloud Tasks will dispatch the task, even if 1186 // the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta3.RateLimits] or 1187 // is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED]. 1188 // 1189 // This command is meant to be used for manual debugging. For 1190 // example, [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] can be used to retry a failed 1191 // task after a fix has been made or to manually force a task to be 1192 // dispatched now. 1193 // 1194 // The dispatched task is returned. That is, the task that is returned 1195 // contains the [status][Task.status] after the task is dispatched but 1196 // before the task is received by its target. 1197 // 1198 // If Cloud Tasks receives a successful response from the task's 1199 // target, then the task will be deleted; otherwise the task's 1200 // [schedule_time][google.cloud.tasks.v2beta3.Task.schedule_time] will be reset to the time that 1201 // [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] was called plus the retry delay specified 1202 // in the queue's [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig]. 1203 // 1204 // [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] returns 1205 // [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a 1206 // task that has already succeeded or permanently failed. 1207 RunTask(ctx context.Context, in *RunTaskRequest, opts ...grpc.CallOption) (*Task, error) 1208} 1209 1210type cloudTasksClient struct { 1211 cc *grpc.ClientConn 1212} 1213 1214func NewCloudTasksClient(cc *grpc.ClientConn) CloudTasksClient { 1215 return &cloudTasksClient{cc} 1216} 1217 1218func (c *cloudTasksClient) ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error) { 1219 out := new(ListQueuesResponse) 1220 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/ListQueues", in, out, opts...) 1221 if err != nil { 1222 return nil, err 1223 } 1224 return out, nil 1225} 1226 1227func (c *cloudTasksClient) GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1228 out := new(Queue) 1229 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/GetQueue", in, out, opts...) 1230 if err != nil { 1231 return nil, err 1232 } 1233 return out, nil 1234} 1235 1236func (c *cloudTasksClient) CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1237 out := new(Queue) 1238 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/CreateQueue", in, out, opts...) 1239 if err != nil { 1240 return nil, err 1241 } 1242 return out, nil 1243} 1244 1245func (c *cloudTasksClient) UpdateQueue(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1246 out := new(Queue) 1247 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/UpdateQueue", in, out, opts...) 1248 if err != nil { 1249 return nil, err 1250 } 1251 return out, nil 1252} 1253 1254func (c *cloudTasksClient) DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 1255 out := new(empty.Empty) 1256 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/DeleteQueue", in, out, opts...) 1257 if err != nil { 1258 return nil, err 1259 } 1260 return out, nil 1261} 1262 1263func (c *cloudTasksClient) PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1264 out := new(Queue) 1265 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/PurgeQueue", in, out, opts...) 1266 if err != nil { 1267 return nil, err 1268 } 1269 return out, nil 1270} 1271 1272func (c *cloudTasksClient) PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1273 out := new(Queue) 1274 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/PauseQueue", in, out, opts...) 1275 if err != nil { 1276 return nil, err 1277 } 1278 return out, nil 1279} 1280 1281func (c *cloudTasksClient) ResumeQueue(ctx context.Context, in *ResumeQueueRequest, opts ...grpc.CallOption) (*Queue, error) { 1282 out := new(Queue) 1283 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/ResumeQueue", in, out, opts...) 1284 if err != nil { 1285 return nil, err 1286 } 1287 return out, nil 1288} 1289 1290func (c *cloudTasksClient) GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) { 1291 out := new(v1.Policy) 1292 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/GetIamPolicy", in, out, opts...) 1293 if err != nil { 1294 return nil, err 1295 } 1296 return out, nil 1297} 1298 1299func (c *cloudTasksClient) SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) { 1300 out := new(v1.Policy) 1301 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/SetIamPolicy", in, out, opts...) 1302 if err != nil { 1303 return nil, err 1304 } 1305 return out, nil 1306} 1307 1308func (c *cloudTasksClient) TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error) { 1309 out := new(v1.TestIamPermissionsResponse) 1310 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/TestIamPermissions", in, out, opts...) 1311 if err != nil { 1312 return nil, err 1313 } 1314 return out, nil 1315} 1316 1317func (c *cloudTasksClient) ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) { 1318 out := new(ListTasksResponse) 1319 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/ListTasks", in, out, opts...) 1320 if err != nil { 1321 return nil, err 1322 } 1323 return out, nil 1324} 1325 1326func (c *cloudTasksClient) GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error) { 1327 out := new(Task) 1328 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/GetTask", in, out, opts...) 1329 if err != nil { 1330 return nil, err 1331 } 1332 return out, nil 1333} 1334 1335func (c *cloudTasksClient) CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*Task, error) { 1336 out := new(Task) 1337 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/CreateTask", in, out, opts...) 1338 if err != nil { 1339 return nil, err 1340 } 1341 return out, nil 1342} 1343 1344func (c *cloudTasksClient) DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 1345 out := new(empty.Empty) 1346 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/DeleteTask", in, out, opts...) 1347 if err != nil { 1348 return nil, err 1349 } 1350 return out, nil 1351} 1352 1353func (c *cloudTasksClient) RunTask(ctx context.Context, in *RunTaskRequest, opts ...grpc.CallOption) (*Task, error) { 1354 out := new(Task) 1355 err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/RunTask", in, out, opts...) 1356 if err != nil { 1357 return nil, err 1358 } 1359 return out, nil 1360} 1361 1362// CloudTasksServer is the server API for CloudTasks service. 1363type CloudTasksServer interface { 1364 // Lists queues. 1365 // 1366 // Queues are returned in lexicographical order. 1367 ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error) 1368 // Gets a queue. 1369 GetQueue(context.Context, *GetQueueRequest) (*Queue, error) 1370 // Creates a queue. 1371 // 1372 // Queues created with this method allow tasks to live for a maximum of 31 1373 // days. After a task is 31 days old, the task will be deleted regardless of whether 1374 // it was dispatched or not. 1375 // 1376 // WARNING: Using this method may have unintended side effects if you are 1377 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1378 // Read 1379 // [Overview of Queue Management and 1380 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1381 // this method. 1382 CreateQueue(context.Context, *CreateQueueRequest) (*Queue, error) 1383 // Updates a queue. 1384 // 1385 // This method creates the queue if it does not exist and updates 1386 // the queue if it does exist. 1387 // 1388 // Queues created with this method allow tasks to live for a maximum of 31 1389 // days. After a task is 31 days old, the task will be deleted regardless of whether 1390 // it was dispatched or not. 1391 // 1392 // WARNING: Using this method may have unintended side effects if you are 1393 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1394 // Read 1395 // [Overview of Queue Management and 1396 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1397 // this method. 1398 UpdateQueue(context.Context, *UpdateQueueRequest) (*Queue, error) 1399 // Deletes a queue. 1400 // 1401 // This command will delete the queue even if it has tasks in it. 1402 // 1403 // Note: If you delete a queue, a queue with the same name can't be created 1404 // for 7 days. 1405 // 1406 // WARNING: Using this method may have unintended side effects if you are 1407 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. 1408 // Read 1409 // [Overview of Queue Management and 1410 // queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using 1411 // this method. 1412 DeleteQueue(context.Context, *DeleteQueueRequest) (*empty.Empty, error) 1413 // Purges a queue by deleting all of its tasks. 1414 // 1415 // All tasks created before this method is called are permanently deleted. 1416 // 1417 // Purge operations can take up to one minute to take effect. Tasks 1418 // might be dispatched before the purge takes effect. A purge is irreversible. 1419 PurgeQueue(context.Context, *PurgeQueueRequest) (*Queue, error) 1420 // Pauses the queue. 1421 // 1422 // If a queue is paused then the system will stop dispatching tasks 1423 // until the queue is resumed via 1424 // [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue]. Tasks can still be added 1425 // when the queue is paused. A queue is paused if its 1426 // [state][google.cloud.tasks.v2beta3.Queue.state] is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED]. 1427 PauseQueue(context.Context, *PauseQueueRequest) (*Queue, error) 1428 // Resume a queue. 1429 // 1430 // This method resumes a queue after it has been 1431 // [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED] or 1432 // [DISABLED][google.cloud.tasks.v2beta3.Queue.State.DISABLED]. The state of a queue is stored 1433 // in the queue's [state][google.cloud.tasks.v2beta3.Queue.state]; after calling this method it 1434 // will be set to [RUNNING][google.cloud.tasks.v2beta3.Queue.State.RUNNING]. 1435 // 1436 // WARNING: Resuming many high-QPS queues at the same time can 1437 // lead to target overloading. If you are resuming high-QPS 1438 // queues, follow the 500/50/5 pattern described in 1439 // [Managing Cloud Tasks Scaling 1440 // Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). 1441 ResumeQueue(context.Context, *ResumeQueueRequest) (*Queue, error) 1442 // Gets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue]. 1443 // Returns an empty policy if the resource exists and does not have a policy 1444 // set. 1445 // 1446 // Authorization requires the following 1447 // [Google IAM](https://cloud.google.com/iam) permission on the specified 1448 // resource parent: 1449 // 1450 // * `cloudtasks.queues.getIamPolicy` 1451 GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error) 1452 // Sets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue]. Replaces any existing 1453 // policy. 1454 // 1455 // Note: The Cloud Console does not check queue-level IAM permissions yet. 1456 // Project-level permissions are required to use the Cloud Console. 1457 // 1458 // Authorization requires the following 1459 // [Google IAM](https://cloud.google.com/iam) permission on the specified 1460 // resource parent: 1461 // 1462 // * `cloudtasks.queues.setIamPolicy` 1463 SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error) 1464 // Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta3.Queue]. 1465 // If the resource does not exist, this will return an empty set of 1466 // permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error. 1467 // 1468 // Note: This operation is designed to be used for building permission-aware 1469 // UIs and command-line tools, not for authorization checking. This operation 1470 // may "fail open" without warning. 1471 TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error) 1472 // Lists the tasks in a queue. 1473 // 1474 // By default, only the [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC] view is retrieved 1475 // due to performance considerations; 1476 // [response_view][google.cloud.tasks.v2beta3.ListTasksRequest.response_view] controls the 1477 // subset of information which is returned. 1478 // 1479 // The tasks may be returned in any order. The ordering may change at any 1480 // time. 1481 ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) 1482 // Gets a task. 1483 GetTask(context.Context, *GetTaskRequest) (*Task, error) 1484 // Creates a task and adds it to a queue. 1485 // 1486 // Tasks cannot be updated after creation; there is no UpdateTask command. 1487 // 1488 // * The maximum task size is 100KB. 1489 CreateTask(context.Context, *CreateTaskRequest) (*Task, error) 1490 // Deletes a task. 1491 // 1492 // A task can be deleted if it is scheduled or dispatched. A task 1493 // cannot be deleted if it has executed successfully or permanently 1494 // failed. 1495 DeleteTask(context.Context, *DeleteTaskRequest) (*empty.Empty, error) 1496 // Forces a task to run now. 1497 // 1498 // When this method is called, Cloud Tasks will dispatch the task, even if 1499 // the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta3.RateLimits] or 1500 // is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED]. 1501 // 1502 // This command is meant to be used for manual debugging. For 1503 // example, [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] can be used to retry a failed 1504 // task after a fix has been made or to manually force a task to be 1505 // dispatched now. 1506 // 1507 // The dispatched task is returned. That is, the task that is returned 1508 // contains the [status][Task.status] after the task is dispatched but 1509 // before the task is received by its target. 1510 // 1511 // If Cloud Tasks receives a successful response from the task's 1512 // target, then the task will be deleted; otherwise the task's 1513 // [schedule_time][google.cloud.tasks.v2beta3.Task.schedule_time] will be reset to the time that 1514 // [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] was called plus the retry delay specified 1515 // in the queue's [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig]. 1516 // 1517 // [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] returns 1518 // [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a 1519 // task that has already succeeded or permanently failed. 1520 RunTask(context.Context, *RunTaskRequest) (*Task, error) 1521} 1522 1523// UnimplementedCloudTasksServer can be embedded to have forward compatible implementations. 1524type UnimplementedCloudTasksServer struct { 1525} 1526 1527func (*UnimplementedCloudTasksServer) ListQueues(ctx context.Context, req *ListQueuesRequest) (*ListQueuesResponse, error) { 1528 return nil, status.Errorf(codes.Unimplemented, "method ListQueues not implemented") 1529} 1530func (*UnimplementedCloudTasksServer) GetQueue(ctx context.Context, req *GetQueueRequest) (*Queue, error) { 1531 return nil, status.Errorf(codes.Unimplemented, "method GetQueue not implemented") 1532} 1533func (*UnimplementedCloudTasksServer) CreateQueue(ctx context.Context, req *CreateQueueRequest) (*Queue, error) { 1534 return nil, status.Errorf(codes.Unimplemented, "method CreateQueue not implemented") 1535} 1536func (*UnimplementedCloudTasksServer) UpdateQueue(ctx context.Context, req *UpdateQueueRequest) (*Queue, error) { 1537 return nil, status.Errorf(codes.Unimplemented, "method UpdateQueue not implemented") 1538} 1539func (*UnimplementedCloudTasksServer) DeleteQueue(ctx context.Context, req *DeleteQueueRequest) (*empty.Empty, error) { 1540 return nil, status.Errorf(codes.Unimplemented, "method DeleteQueue not implemented") 1541} 1542func (*UnimplementedCloudTasksServer) PurgeQueue(ctx context.Context, req *PurgeQueueRequest) (*Queue, error) { 1543 return nil, status.Errorf(codes.Unimplemented, "method PurgeQueue not implemented") 1544} 1545func (*UnimplementedCloudTasksServer) PauseQueue(ctx context.Context, req *PauseQueueRequest) (*Queue, error) { 1546 return nil, status.Errorf(codes.Unimplemented, "method PauseQueue not implemented") 1547} 1548func (*UnimplementedCloudTasksServer) ResumeQueue(ctx context.Context, req *ResumeQueueRequest) (*Queue, error) { 1549 return nil, status.Errorf(codes.Unimplemented, "method ResumeQueue not implemented") 1550} 1551func (*UnimplementedCloudTasksServer) GetIamPolicy(ctx context.Context, req *v1.GetIamPolicyRequest) (*v1.Policy, error) { 1552 return nil, status.Errorf(codes.Unimplemented, "method GetIamPolicy not implemented") 1553} 1554func (*UnimplementedCloudTasksServer) SetIamPolicy(ctx context.Context, req *v1.SetIamPolicyRequest) (*v1.Policy, error) { 1555 return nil, status.Errorf(codes.Unimplemented, "method SetIamPolicy not implemented") 1556} 1557func (*UnimplementedCloudTasksServer) TestIamPermissions(ctx context.Context, req *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error) { 1558 return nil, status.Errorf(codes.Unimplemented, "method TestIamPermissions not implemented") 1559} 1560func (*UnimplementedCloudTasksServer) ListTasks(ctx context.Context, req *ListTasksRequest) (*ListTasksResponse, error) { 1561 return nil, status.Errorf(codes.Unimplemented, "method ListTasks not implemented") 1562} 1563func (*UnimplementedCloudTasksServer) GetTask(ctx context.Context, req *GetTaskRequest) (*Task, error) { 1564 return nil, status.Errorf(codes.Unimplemented, "method GetTask not implemented") 1565} 1566func (*UnimplementedCloudTasksServer) CreateTask(ctx context.Context, req *CreateTaskRequest) (*Task, error) { 1567 return nil, status.Errorf(codes.Unimplemented, "method CreateTask not implemented") 1568} 1569func (*UnimplementedCloudTasksServer) DeleteTask(ctx context.Context, req *DeleteTaskRequest) (*empty.Empty, error) { 1570 return nil, status.Errorf(codes.Unimplemented, "method DeleteTask not implemented") 1571} 1572func (*UnimplementedCloudTasksServer) RunTask(ctx context.Context, req *RunTaskRequest) (*Task, error) { 1573 return nil, status.Errorf(codes.Unimplemented, "method RunTask not implemented") 1574} 1575 1576func RegisterCloudTasksServer(s *grpc.Server, srv CloudTasksServer) { 1577 s.RegisterService(&_CloudTasks_serviceDesc, srv) 1578} 1579 1580func _CloudTasks_ListQueues_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1581 in := new(ListQueuesRequest) 1582 if err := dec(in); err != nil { 1583 return nil, err 1584 } 1585 if interceptor == nil { 1586 return srv.(CloudTasksServer).ListQueues(ctx, in) 1587 } 1588 info := &grpc.UnaryServerInfo{ 1589 Server: srv, 1590 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/ListQueues", 1591 } 1592 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1593 return srv.(CloudTasksServer).ListQueues(ctx, req.(*ListQueuesRequest)) 1594 } 1595 return interceptor(ctx, in, info, handler) 1596} 1597 1598func _CloudTasks_GetQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1599 in := new(GetQueueRequest) 1600 if err := dec(in); err != nil { 1601 return nil, err 1602 } 1603 if interceptor == nil { 1604 return srv.(CloudTasksServer).GetQueue(ctx, in) 1605 } 1606 info := &grpc.UnaryServerInfo{ 1607 Server: srv, 1608 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/GetQueue", 1609 } 1610 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1611 return srv.(CloudTasksServer).GetQueue(ctx, req.(*GetQueueRequest)) 1612 } 1613 return interceptor(ctx, in, info, handler) 1614} 1615 1616func _CloudTasks_CreateQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1617 in := new(CreateQueueRequest) 1618 if err := dec(in); err != nil { 1619 return nil, err 1620 } 1621 if interceptor == nil { 1622 return srv.(CloudTasksServer).CreateQueue(ctx, in) 1623 } 1624 info := &grpc.UnaryServerInfo{ 1625 Server: srv, 1626 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/CreateQueue", 1627 } 1628 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1629 return srv.(CloudTasksServer).CreateQueue(ctx, req.(*CreateQueueRequest)) 1630 } 1631 return interceptor(ctx, in, info, handler) 1632} 1633 1634func _CloudTasks_UpdateQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1635 in := new(UpdateQueueRequest) 1636 if err := dec(in); err != nil { 1637 return nil, err 1638 } 1639 if interceptor == nil { 1640 return srv.(CloudTasksServer).UpdateQueue(ctx, in) 1641 } 1642 info := &grpc.UnaryServerInfo{ 1643 Server: srv, 1644 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/UpdateQueue", 1645 } 1646 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1647 return srv.(CloudTasksServer).UpdateQueue(ctx, req.(*UpdateQueueRequest)) 1648 } 1649 return interceptor(ctx, in, info, handler) 1650} 1651 1652func _CloudTasks_DeleteQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1653 in := new(DeleteQueueRequest) 1654 if err := dec(in); err != nil { 1655 return nil, err 1656 } 1657 if interceptor == nil { 1658 return srv.(CloudTasksServer).DeleteQueue(ctx, in) 1659 } 1660 info := &grpc.UnaryServerInfo{ 1661 Server: srv, 1662 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/DeleteQueue", 1663 } 1664 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1665 return srv.(CloudTasksServer).DeleteQueue(ctx, req.(*DeleteQueueRequest)) 1666 } 1667 return interceptor(ctx, in, info, handler) 1668} 1669 1670func _CloudTasks_PurgeQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1671 in := new(PurgeQueueRequest) 1672 if err := dec(in); err != nil { 1673 return nil, err 1674 } 1675 if interceptor == nil { 1676 return srv.(CloudTasksServer).PurgeQueue(ctx, in) 1677 } 1678 info := &grpc.UnaryServerInfo{ 1679 Server: srv, 1680 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/PurgeQueue", 1681 } 1682 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1683 return srv.(CloudTasksServer).PurgeQueue(ctx, req.(*PurgeQueueRequest)) 1684 } 1685 return interceptor(ctx, in, info, handler) 1686} 1687 1688func _CloudTasks_PauseQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1689 in := new(PauseQueueRequest) 1690 if err := dec(in); err != nil { 1691 return nil, err 1692 } 1693 if interceptor == nil { 1694 return srv.(CloudTasksServer).PauseQueue(ctx, in) 1695 } 1696 info := &grpc.UnaryServerInfo{ 1697 Server: srv, 1698 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/PauseQueue", 1699 } 1700 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1701 return srv.(CloudTasksServer).PauseQueue(ctx, req.(*PauseQueueRequest)) 1702 } 1703 return interceptor(ctx, in, info, handler) 1704} 1705 1706func _CloudTasks_ResumeQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1707 in := new(ResumeQueueRequest) 1708 if err := dec(in); err != nil { 1709 return nil, err 1710 } 1711 if interceptor == nil { 1712 return srv.(CloudTasksServer).ResumeQueue(ctx, in) 1713 } 1714 info := &grpc.UnaryServerInfo{ 1715 Server: srv, 1716 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/ResumeQueue", 1717 } 1718 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1719 return srv.(CloudTasksServer).ResumeQueue(ctx, req.(*ResumeQueueRequest)) 1720 } 1721 return interceptor(ctx, in, info, handler) 1722} 1723 1724func _CloudTasks_GetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1725 in := new(v1.GetIamPolicyRequest) 1726 if err := dec(in); err != nil { 1727 return nil, err 1728 } 1729 if interceptor == nil { 1730 return srv.(CloudTasksServer).GetIamPolicy(ctx, in) 1731 } 1732 info := &grpc.UnaryServerInfo{ 1733 Server: srv, 1734 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/GetIamPolicy", 1735 } 1736 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1737 return srv.(CloudTasksServer).GetIamPolicy(ctx, req.(*v1.GetIamPolicyRequest)) 1738 } 1739 return interceptor(ctx, in, info, handler) 1740} 1741 1742func _CloudTasks_SetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1743 in := new(v1.SetIamPolicyRequest) 1744 if err := dec(in); err != nil { 1745 return nil, err 1746 } 1747 if interceptor == nil { 1748 return srv.(CloudTasksServer).SetIamPolicy(ctx, in) 1749 } 1750 info := &grpc.UnaryServerInfo{ 1751 Server: srv, 1752 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/SetIamPolicy", 1753 } 1754 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1755 return srv.(CloudTasksServer).SetIamPolicy(ctx, req.(*v1.SetIamPolicyRequest)) 1756 } 1757 return interceptor(ctx, in, info, handler) 1758} 1759 1760func _CloudTasks_TestIamPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1761 in := new(v1.TestIamPermissionsRequest) 1762 if err := dec(in); err != nil { 1763 return nil, err 1764 } 1765 if interceptor == nil { 1766 return srv.(CloudTasksServer).TestIamPermissions(ctx, in) 1767 } 1768 info := &grpc.UnaryServerInfo{ 1769 Server: srv, 1770 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/TestIamPermissions", 1771 } 1772 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1773 return srv.(CloudTasksServer).TestIamPermissions(ctx, req.(*v1.TestIamPermissionsRequest)) 1774 } 1775 return interceptor(ctx, in, info, handler) 1776} 1777 1778func _CloudTasks_ListTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1779 in := new(ListTasksRequest) 1780 if err := dec(in); err != nil { 1781 return nil, err 1782 } 1783 if interceptor == nil { 1784 return srv.(CloudTasksServer).ListTasks(ctx, in) 1785 } 1786 info := &grpc.UnaryServerInfo{ 1787 Server: srv, 1788 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/ListTasks", 1789 } 1790 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1791 return srv.(CloudTasksServer).ListTasks(ctx, req.(*ListTasksRequest)) 1792 } 1793 return interceptor(ctx, in, info, handler) 1794} 1795 1796func _CloudTasks_GetTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1797 in := new(GetTaskRequest) 1798 if err := dec(in); err != nil { 1799 return nil, err 1800 } 1801 if interceptor == nil { 1802 return srv.(CloudTasksServer).GetTask(ctx, in) 1803 } 1804 info := &grpc.UnaryServerInfo{ 1805 Server: srv, 1806 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/GetTask", 1807 } 1808 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1809 return srv.(CloudTasksServer).GetTask(ctx, req.(*GetTaskRequest)) 1810 } 1811 return interceptor(ctx, in, info, handler) 1812} 1813 1814func _CloudTasks_CreateTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1815 in := new(CreateTaskRequest) 1816 if err := dec(in); err != nil { 1817 return nil, err 1818 } 1819 if interceptor == nil { 1820 return srv.(CloudTasksServer).CreateTask(ctx, in) 1821 } 1822 info := &grpc.UnaryServerInfo{ 1823 Server: srv, 1824 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/CreateTask", 1825 } 1826 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1827 return srv.(CloudTasksServer).CreateTask(ctx, req.(*CreateTaskRequest)) 1828 } 1829 return interceptor(ctx, in, info, handler) 1830} 1831 1832func _CloudTasks_DeleteTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1833 in := new(DeleteTaskRequest) 1834 if err := dec(in); err != nil { 1835 return nil, err 1836 } 1837 if interceptor == nil { 1838 return srv.(CloudTasksServer).DeleteTask(ctx, in) 1839 } 1840 info := &grpc.UnaryServerInfo{ 1841 Server: srv, 1842 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/DeleteTask", 1843 } 1844 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1845 return srv.(CloudTasksServer).DeleteTask(ctx, req.(*DeleteTaskRequest)) 1846 } 1847 return interceptor(ctx, in, info, handler) 1848} 1849 1850func _CloudTasks_RunTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1851 in := new(RunTaskRequest) 1852 if err := dec(in); err != nil { 1853 return nil, err 1854 } 1855 if interceptor == nil { 1856 return srv.(CloudTasksServer).RunTask(ctx, in) 1857 } 1858 info := &grpc.UnaryServerInfo{ 1859 Server: srv, 1860 FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/RunTask", 1861 } 1862 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1863 return srv.(CloudTasksServer).RunTask(ctx, req.(*RunTaskRequest)) 1864 } 1865 return interceptor(ctx, in, info, handler) 1866} 1867 1868var _CloudTasks_serviceDesc = grpc.ServiceDesc{ 1869 ServiceName: "google.cloud.tasks.v2beta3.CloudTasks", 1870 HandlerType: (*CloudTasksServer)(nil), 1871 Methods: []grpc.MethodDesc{ 1872 { 1873 MethodName: "ListQueues", 1874 Handler: _CloudTasks_ListQueues_Handler, 1875 }, 1876 { 1877 MethodName: "GetQueue", 1878 Handler: _CloudTasks_GetQueue_Handler, 1879 }, 1880 { 1881 MethodName: "CreateQueue", 1882 Handler: _CloudTasks_CreateQueue_Handler, 1883 }, 1884 { 1885 MethodName: "UpdateQueue", 1886 Handler: _CloudTasks_UpdateQueue_Handler, 1887 }, 1888 { 1889 MethodName: "DeleteQueue", 1890 Handler: _CloudTasks_DeleteQueue_Handler, 1891 }, 1892 { 1893 MethodName: "PurgeQueue", 1894 Handler: _CloudTasks_PurgeQueue_Handler, 1895 }, 1896 { 1897 MethodName: "PauseQueue", 1898 Handler: _CloudTasks_PauseQueue_Handler, 1899 }, 1900 { 1901 MethodName: "ResumeQueue", 1902 Handler: _CloudTasks_ResumeQueue_Handler, 1903 }, 1904 { 1905 MethodName: "GetIamPolicy", 1906 Handler: _CloudTasks_GetIamPolicy_Handler, 1907 }, 1908 { 1909 MethodName: "SetIamPolicy", 1910 Handler: _CloudTasks_SetIamPolicy_Handler, 1911 }, 1912 { 1913 MethodName: "TestIamPermissions", 1914 Handler: _CloudTasks_TestIamPermissions_Handler, 1915 }, 1916 { 1917 MethodName: "ListTasks", 1918 Handler: _CloudTasks_ListTasks_Handler, 1919 }, 1920 { 1921 MethodName: "GetTask", 1922 Handler: _CloudTasks_GetTask_Handler, 1923 }, 1924 { 1925 MethodName: "CreateTask", 1926 Handler: _CloudTasks_CreateTask_Handler, 1927 }, 1928 { 1929 MethodName: "DeleteTask", 1930 Handler: _CloudTasks_DeleteTask_Handler, 1931 }, 1932 { 1933 MethodName: "RunTask", 1934 Handler: _CloudTasks_RunTask_Handler, 1935 }, 1936 }, 1937 Streams: []grpc.StreamDesc{}, 1938 Metadata: "google/cloud/tasks/v2beta3/cloudtasks.proto", 1939} 1940