| // Copyright 2025 Google LLC |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| // Code generated by protoc-gen-go. DO NOT EDIT. |
| // versions: |
| // protoc-gen-go v1.36.11 |
| // protoc v6.33.2 |
| // source: google/cloud/tasks/v2/cloudtasks.proto |
| |
| package cloudtaskspb |
| |
| import ( |
| reflect "reflect" |
| sync "sync" |
| unsafe "unsafe" |
| |
| iampb "cloud.google.com/go/iam/apiv1/iampb" |
| _ "google.golang.org/genproto/googleapis/api/annotations" |
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" |
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" |
| emptypb "google.golang.org/protobuf/types/known/emptypb" |
| fieldmaskpb "google.golang.org/protobuf/types/known/fieldmaskpb" |
| ) |
| |
| const ( |
| // Verify that this generated code is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) |
| // Verify that runtime/protoimpl is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) |
| ) |
| |
| // Request message for |
| // [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues]. |
| type ListQueuesRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The location name. |
| // For example: `projects/PROJECT_ID/locations/LOCATION_ID` |
| Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` |
| // `filter` can be used to specify a subset of queues. Any |
| // [Queue][google.cloud.tasks.v2.Queue] field can be used as a filter and |
| // several operators as supported. For example: `<=, <, >=, >, !=, =, :`. The |
| // filter syntax is the same as described in [Stackdriver's Advanced Logs |
| // Filters](https://cloud.google.com/logging/docs/view/advanced_filters). |
| // |
| // Sample filter "state: PAUSED". |
| // |
| // Note that using filters might cause fewer queues than the |
| // requested page_size to be returned. |
| Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` |
| // Requested page size. |
| // |
| // The maximum page size is 9800. If unspecified, the page size will |
| // be the maximum. Fewer queues than requested might be returned, |
| // even if more queues exist; use the |
| // [next_page_token][google.cloud.tasks.v2.ListQueuesResponse.next_page_token] |
| // in the response to determine if more queues exist. |
| PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` |
| // A token identifying the page of results to return. |
| // |
| // To request the first page results, page_token must be empty. To |
| // request the next page of results, page_token must be the value of |
| // [next_page_token][google.cloud.tasks.v2.ListQueuesResponse.next_page_token] |
| // returned from the previous call to |
| // [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues] method. It is an |
| // error to switch the value of the |
| // [filter][google.cloud.tasks.v2.ListQueuesRequest.filter] while iterating |
| // through pages. |
| PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *ListQueuesRequest) Reset() { |
| *x = ListQueuesRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[0] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *ListQueuesRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ListQueuesRequest) ProtoMessage() {} |
| |
| func (x *ListQueuesRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[0] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ListQueuesRequest.ProtoReflect.Descriptor instead. |
| func (*ListQueuesRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{0} |
| } |
| |
| func (x *ListQueuesRequest) GetParent() string { |
| if x != nil { |
| return x.Parent |
| } |
| return "" |
| } |
| |
| func (x *ListQueuesRequest) GetFilter() string { |
| if x != nil { |
| return x.Filter |
| } |
| return "" |
| } |
| |
| func (x *ListQueuesRequest) GetPageSize() int32 { |
| if x != nil { |
| return x.PageSize |
| } |
| return 0 |
| } |
| |
| func (x *ListQueuesRequest) GetPageToken() string { |
| if x != nil { |
| return x.PageToken |
| } |
| return "" |
| } |
| |
| // Response message for |
| // [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues]. |
| type ListQueuesResponse struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // The list of queues. |
| Queues []*Queue `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"` |
| // A token to retrieve next page of results. |
| // |
| // To return the next page of results, call |
| // [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues] with this value |
| // as the [page_token][google.cloud.tasks.v2.ListQueuesRequest.page_token]. |
| // |
| // If the next_page_token is empty, there are no more results. |
| // |
| // The page token is valid for only 2 hours. |
| NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *ListQueuesResponse) Reset() { |
| *x = ListQueuesResponse{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[1] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *ListQueuesResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ListQueuesResponse) ProtoMessage() {} |
| |
| func (x *ListQueuesResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[1] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ListQueuesResponse.ProtoReflect.Descriptor instead. |
| func (*ListQueuesResponse) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{1} |
| } |
| |
| func (x *ListQueuesResponse) GetQueues() []*Queue { |
| if x != nil { |
| return x.Queues |
| } |
| return nil |
| } |
| |
| func (x *ListQueuesResponse) GetNextPageToken() string { |
| if x != nil { |
| return x.NextPageToken |
| } |
| return "" |
| } |
| |
| // Request message for [GetQueue][google.cloud.tasks.v2.CloudTasks.GetQueue]. |
| type GetQueueRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The resource name of the queue. For example: |
| // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *GetQueueRequest) Reset() { |
| *x = GetQueueRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[2] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *GetQueueRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*GetQueueRequest) ProtoMessage() {} |
| |
| func (x *GetQueueRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[2] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use GetQueueRequest.ProtoReflect.Descriptor instead. |
| func (*GetQueueRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{2} |
| } |
| |
| func (x *GetQueueRequest) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| // Request message for |
| // [CreateQueue][google.cloud.tasks.v2.CloudTasks.CreateQueue]. |
| type CreateQueueRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The location name in which the queue will be created. |
| // For example: `projects/PROJECT_ID/locations/LOCATION_ID` |
| // |
| // The list of allowed locations can be obtained by calling Cloud |
| // Tasks' implementation of |
| // [ListLocations][google.cloud.location.Locations.ListLocations]. |
| Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` |
| // Required. The queue to create. |
| // |
| // [Queue's name][google.cloud.tasks.v2.Queue.name] cannot be the same as an |
| // existing queue. |
| Queue *Queue `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *CreateQueueRequest) Reset() { |
| *x = CreateQueueRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[3] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *CreateQueueRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*CreateQueueRequest) ProtoMessage() {} |
| |
| func (x *CreateQueueRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[3] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use CreateQueueRequest.ProtoReflect.Descriptor instead. |
| func (*CreateQueueRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{3} |
| } |
| |
| func (x *CreateQueueRequest) GetParent() string { |
| if x != nil { |
| return x.Parent |
| } |
| return "" |
| } |
| |
| func (x *CreateQueueRequest) GetQueue() *Queue { |
| if x != nil { |
| return x.Queue |
| } |
| return nil |
| } |
| |
| // Request message for |
| // [UpdateQueue][google.cloud.tasks.v2.CloudTasks.UpdateQueue]. |
| type UpdateQueueRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The queue to create or update. |
| // |
| // The queue's [name][google.cloud.tasks.v2.Queue.name] must be specified. |
| // |
| // Output only fields cannot be modified using UpdateQueue. |
| // Any value specified for an output only field will be ignored. |
| // The queue's [name][google.cloud.tasks.v2.Queue.name] cannot be changed. |
| Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"` |
| // A mask used to specify which fields of the queue are being updated. |
| // |
| // If empty, then all fields will be updated. |
| UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *UpdateQueueRequest) Reset() { |
| *x = UpdateQueueRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[4] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *UpdateQueueRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*UpdateQueueRequest) ProtoMessage() {} |
| |
| func (x *UpdateQueueRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[4] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use UpdateQueueRequest.ProtoReflect.Descriptor instead. |
| func (*UpdateQueueRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{4} |
| } |
| |
| func (x *UpdateQueueRequest) GetQueue() *Queue { |
| if x != nil { |
| return x.Queue |
| } |
| return nil |
| } |
| |
| func (x *UpdateQueueRequest) GetUpdateMask() *fieldmaskpb.FieldMask { |
| if x != nil { |
| return x.UpdateMask |
| } |
| return nil |
| } |
| |
| // Request message for |
| // [DeleteQueue][google.cloud.tasks.v2.CloudTasks.DeleteQueue]. |
| type DeleteQueueRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The queue name. For example: |
| // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *DeleteQueueRequest) Reset() { |
| *x = DeleteQueueRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[5] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *DeleteQueueRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*DeleteQueueRequest) ProtoMessage() {} |
| |
| func (x *DeleteQueueRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[5] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use DeleteQueueRequest.ProtoReflect.Descriptor instead. |
| func (*DeleteQueueRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{5} |
| } |
| |
| func (x *DeleteQueueRequest) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| // Request message for |
| // [PurgeQueue][google.cloud.tasks.v2.CloudTasks.PurgeQueue]. |
| type PurgeQueueRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The queue name. For example: |
| // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *PurgeQueueRequest) Reset() { |
| *x = PurgeQueueRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[6] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *PurgeQueueRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*PurgeQueueRequest) ProtoMessage() {} |
| |
| func (x *PurgeQueueRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[6] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use PurgeQueueRequest.ProtoReflect.Descriptor instead. |
| func (*PurgeQueueRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{6} |
| } |
| |
| func (x *PurgeQueueRequest) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| // Request message for |
| // [PauseQueue][google.cloud.tasks.v2.CloudTasks.PauseQueue]. |
| type PauseQueueRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The queue name. For example: |
| // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *PauseQueueRequest) Reset() { |
| *x = PauseQueueRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[7] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *PauseQueueRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*PauseQueueRequest) ProtoMessage() {} |
| |
| func (x *PauseQueueRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[7] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use PauseQueueRequest.ProtoReflect.Descriptor instead. |
| func (*PauseQueueRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{7} |
| } |
| |
| func (x *PauseQueueRequest) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| // Request message for |
| // [ResumeQueue][google.cloud.tasks.v2.CloudTasks.ResumeQueue]. |
| type ResumeQueueRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The queue name. For example: |
| // `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *ResumeQueueRequest) Reset() { |
| *x = ResumeQueueRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[8] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *ResumeQueueRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ResumeQueueRequest) ProtoMessage() {} |
| |
| func (x *ResumeQueueRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[8] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ResumeQueueRequest.ProtoReflect.Descriptor instead. |
| func (*ResumeQueueRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{8} |
| } |
| |
| func (x *ResumeQueueRequest) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| // Request message for listing tasks using |
| // [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks]. |
| type ListTasksRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The queue name. For example: |
| // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` |
| Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` |
| // The response_view specifies which subset of the |
| // [Task][google.cloud.tasks.v2.Task] will be returned. |
| // |
| // By default response_view is [BASIC][google.cloud.tasks.v2.Task.View.BASIC]; |
| // not all information is retrieved by default because some data, such as |
| // payloads, might be desirable to return only when needed because |
| // of its large size or because of the sensitivity of data that it |
| // contains. |
| // |
| // Authorization for [FULL][google.cloud.tasks.v2.Task.View.FULL] requires |
| // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) |
| // permission on the [Task][google.cloud.tasks.v2.Task] resource. |
| ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2.Task_View" json:"response_view,omitempty"` |
| // Maximum page size. |
| // |
| // Fewer tasks than requested might be returned, even if more tasks exist; use |
| // [next_page_token][google.cloud.tasks.v2.ListTasksResponse.next_page_token] |
| // in the response to determine if more tasks exist. |
| // |
| // The maximum page size is 1000. If unspecified, the page size will be the |
| // maximum. |
| PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` |
| // A token identifying the page of results to return. |
| // |
| // To request the first page results, page_token must be empty. To |
| // request the next page of results, page_token must be the value of |
| // [next_page_token][google.cloud.tasks.v2.ListTasksResponse.next_page_token] |
| // returned from the previous call to |
| // [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks] method. |
| // |
| // The page token is valid for only 2 hours. |
| PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *ListTasksRequest) Reset() { |
| *x = ListTasksRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[9] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *ListTasksRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ListTasksRequest) ProtoMessage() {} |
| |
| func (x *ListTasksRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[9] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead. |
| func (*ListTasksRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{9} |
| } |
| |
| func (x *ListTasksRequest) GetParent() string { |
| if x != nil { |
| return x.Parent |
| } |
| return "" |
| } |
| |
| func (x *ListTasksRequest) GetResponseView() Task_View { |
| if x != nil { |
| return x.ResponseView |
| } |
| return Task_VIEW_UNSPECIFIED |
| } |
| |
| func (x *ListTasksRequest) GetPageSize() int32 { |
| if x != nil { |
| return x.PageSize |
| } |
| return 0 |
| } |
| |
| func (x *ListTasksRequest) GetPageToken() string { |
| if x != nil { |
| return x.PageToken |
| } |
| return "" |
| } |
| |
| // Response message for listing tasks using |
| // [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks]. |
| type ListTasksResponse struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // The list of tasks. |
| Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` |
| // A token to retrieve next page of results. |
| // |
| // To return the next page of results, call |
| // [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks] with this value as |
| // the [page_token][google.cloud.tasks.v2.ListTasksRequest.page_token]. |
| // |
| // If the next_page_token is empty, there are no more results. |
| NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *ListTasksResponse) Reset() { |
| *x = ListTasksResponse{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[10] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *ListTasksResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ListTasksResponse) ProtoMessage() {} |
| |
| func (x *ListTasksResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[10] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead. |
| func (*ListTasksResponse) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{10} |
| } |
| |
| func (x *ListTasksResponse) GetTasks() []*Task { |
| if x != nil { |
| return x.Tasks |
| } |
| return nil |
| } |
| |
| func (x *ListTasksResponse) GetNextPageToken() string { |
| if x != nil { |
| return x.NextPageToken |
| } |
| return "" |
| } |
| |
| // Request message for getting a task using |
| // [GetTask][google.cloud.tasks.v2.CloudTasks.GetTask]. |
| type GetTaskRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The task name. For example: |
| // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| // The response_view specifies which subset of the |
| // [Task][google.cloud.tasks.v2.Task] will be returned. |
| // |
| // By default response_view is [BASIC][google.cloud.tasks.v2.Task.View.BASIC]; |
| // not all information is retrieved by default because some data, such as |
| // payloads, might be desirable to return only when needed because |
| // of its large size or because of the sensitivity of data that it |
| // contains. |
| // |
| // Authorization for [FULL][google.cloud.tasks.v2.Task.View.FULL] requires |
| // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) |
| // permission on the [Task][google.cloud.tasks.v2.Task] resource. |
| ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2.Task_View" json:"response_view,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *GetTaskRequest) Reset() { |
| *x = GetTaskRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[11] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *GetTaskRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*GetTaskRequest) ProtoMessage() {} |
| |
| func (x *GetTaskRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[11] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead. |
| func (*GetTaskRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{11} |
| } |
| |
| func (x *GetTaskRequest) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| func (x *GetTaskRequest) GetResponseView() Task_View { |
| if x != nil { |
| return x.ResponseView |
| } |
| return Task_VIEW_UNSPECIFIED |
| } |
| |
| // Request message for |
| // [CreateTask][google.cloud.tasks.v2.CloudTasks.CreateTask]. |
| type CreateTaskRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The queue name. For example: |
| // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` |
| // |
| // The queue must already exist. |
| Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` |
| // Required. The task to add. |
| // |
| // Task names have the following format: |
| // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID`. |
| // The user can optionally specify a task |
| // [name][google.cloud.tasks.v2.Task.name]. If a name is not specified then |
| // the system will generate a random unique task id, which will be set in the |
| // task returned in the [response][google.cloud.tasks.v2.Task.name]. |
| // |
| // If [schedule_time][google.cloud.tasks.v2.Task.schedule_time] is not set or |
| // is in the past then Cloud Tasks will set it to the current time. |
| // |
| // Task De-duplication: |
| // |
| // Explicitly specifying a task ID enables task de-duplication. If |
| // a task's ID is identical to that of an existing task or a task |
| // that was deleted or executed recently then the call will fail |
| // with [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS]. |
| // If the task's queue was created using Cloud Tasks, then another task with |
| // the same name can't be created for ~1hour after the original task was |
| // deleted or executed. If the task's queue was created using queue.yaml or |
| // queue.xml, then another task with the same name can't be created |
| // for ~9days after the original task was deleted or executed. |
| // |
| // Because there is an extra lookup cost to identify duplicate task |
| // names, these [CreateTask][google.cloud.tasks.v2.CloudTasks.CreateTask] |
| // calls have significantly increased latency. Using hashed strings for the |
| // task id or for the prefix of the task id is recommended. Choosing task ids |
| // that are sequential or have sequential prefixes, for example using a |
| // timestamp, causes an increase in latency and error rates in all |
| // task commands. The infrastructure relies on an approximately |
| // uniform distribution of task ids to store and serve tasks |
| // efficiently. |
| Task *Task `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` |
| // The response_view specifies which subset of the |
| // [Task][google.cloud.tasks.v2.Task] will be returned. |
| // |
| // By default response_view is [BASIC][google.cloud.tasks.v2.Task.View.BASIC]; |
| // not all information is retrieved by default because some data, such as |
| // payloads, might be desirable to return only when needed because |
| // of its large size or because of the sensitivity of data that it |
| // contains. |
| // |
| // Authorization for [FULL][google.cloud.tasks.v2.Task.View.FULL] requires |
| // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) |
| // permission on the [Task][google.cloud.tasks.v2.Task] resource. |
| ResponseView Task_View `protobuf:"varint,3,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2.Task_View" json:"response_view,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *CreateTaskRequest) Reset() { |
| *x = CreateTaskRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[12] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *CreateTaskRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*CreateTaskRequest) ProtoMessage() {} |
| |
| func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[12] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead. |
| func (*CreateTaskRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{12} |
| } |
| |
| func (x *CreateTaskRequest) GetParent() string { |
| if x != nil { |
| return x.Parent |
| } |
| return "" |
| } |
| |
| func (x *CreateTaskRequest) GetTask() *Task { |
| if x != nil { |
| return x.Task |
| } |
| return nil |
| } |
| |
| func (x *CreateTaskRequest) GetResponseView() Task_View { |
| if x != nil { |
| return x.ResponseView |
| } |
| return Task_VIEW_UNSPECIFIED |
| } |
| |
| // Request message for deleting a task using |
| // [DeleteTask][google.cloud.tasks.v2.CloudTasks.DeleteTask]. |
| type DeleteTaskRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The task name. For example: |
| // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *DeleteTaskRequest) Reset() { |
| *x = DeleteTaskRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[13] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *DeleteTaskRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*DeleteTaskRequest) ProtoMessage() {} |
| |
| func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[13] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead. |
| func (*DeleteTaskRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{13} |
| } |
| |
| func (x *DeleteTaskRequest) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| // Request message for forcing a task to run now using |
| // [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask]. |
| type RunTaskRequest struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Required. The task name. For example: |
| // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| // The response_view specifies which subset of the |
| // [Task][google.cloud.tasks.v2.Task] will be returned. |
| // |
| // By default response_view is [BASIC][google.cloud.tasks.v2.Task.View.BASIC]; |
| // not all information is retrieved by default because some data, such as |
| // payloads, might be desirable to return only when needed because |
| // of its large size or because of the sensitivity of data that it |
| // contains. |
| // |
| // Authorization for [FULL][google.cloud.tasks.v2.Task.View.FULL] requires |
| // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) |
| // permission on the [Task][google.cloud.tasks.v2.Task] resource. |
| ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2.Task_View" json:"response_view,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *RunTaskRequest) Reset() { |
| *x = RunTaskRequest{} |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[14] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *RunTaskRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*RunTaskRequest) ProtoMessage() {} |
| |
| func (x *RunTaskRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes[14] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use RunTaskRequest.ProtoReflect.Descriptor instead. |
| func (*RunTaskRequest) Descriptor() ([]byte, []int) { |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP(), []int{14} |
| } |
| |
| func (x *RunTaskRequest) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| func (x *RunTaskRequest) GetResponseView() Task_View { |
| if x != nil { |
| return x.ResponseView |
| } |
| return Task_VIEW_UNSPECIFIED |
| } |
| |
| var File_google_cloud_tasks_v2_cloudtasks_proto protoreflect.FileDescriptor |
| |
| const file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc = "" + |
| "\n" + |
| "&google/cloud/tasks/v2/cloudtasks.proto\x12\x15google.cloud.tasks.v2\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a!google/cloud/tasks/v2/queue.proto\x1a google/cloud/tasks/v2/task.proto\x1a\x1egoogle/iam/v1/iam_policy.proto\x1a\x1agoogle/iam/v1/policy.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a google/protobuf/field_mask.proto\"\xa8\x01\n" + |
| "\x11ListQueuesRequest\x12?\n" + |
| "\x06parent\x18\x01 \x01(\tB'\xe0A\x02\xfaA!\x12\x1fcloudtasks.googleapis.com/QueueR\x06parent\x12\x16\n" + |
| "\x06filter\x18\x02 \x01(\tR\x06filter\x12\x1b\n" + |
| "\tpage_size\x18\x03 \x01(\x05R\bpageSize\x12\x1d\n" + |
| "\n" + |
| "page_token\x18\x04 \x01(\tR\tpageToken\"r\n" + |
| "\x12ListQueuesResponse\x124\n" + |
| "\x06queues\x18\x01 \x03(\v2\x1c.google.cloud.tasks.v2.QueueR\x06queues\x12&\n" + |
| "\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\"N\n" + |
| "\x0fGetQueueRequest\x12;\n" + |
| "\x04name\x18\x01 \x01(\tB'\xe0A\x02\xfaA!\n" + |
| "\x1fcloudtasks.googleapis.com/QueueR\x04name\"\x8e\x01\n" + |
| "\x12CreateQueueRequest\x12?\n" + |
| "\x06parent\x18\x01 \x01(\tB'\xe0A\x02\xfaA!\x12\x1fcloudtasks.googleapis.com/QueueR\x06parent\x127\n" + |
| "\x05queue\x18\x02 \x01(\v2\x1c.google.cloud.tasks.v2.QueueB\x03\xe0A\x02R\x05queue\"\x8a\x01\n" + |
| "\x12UpdateQueueRequest\x127\n" + |
| "\x05queue\x18\x01 \x01(\v2\x1c.google.cloud.tasks.v2.QueueB\x03\xe0A\x02R\x05queue\x12;\n" + |
| "\vupdate_mask\x18\x02 \x01(\v2\x1a.google.protobuf.FieldMaskR\n" + |
| "updateMask\"Q\n" + |
| "\x12DeleteQueueRequest\x12;\n" + |
| "\x04name\x18\x01 \x01(\tB'\xe0A\x02\xfaA!\n" + |
| "\x1fcloudtasks.googleapis.com/QueueR\x04name\"P\n" + |
| "\x11PurgeQueueRequest\x12;\n" + |
| "\x04name\x18\x01 \x01(\tB'\xe0A\x02\xfaA!\n" + |
| "\x1fcloudtasks.googleapis.com/QueueR\x04name\"P\n" + |
| "\x11PauseQueueRequest\x12;\n" + |
| "\x04name\x18\x01 \x01(\tB'\xe0A\x02\xfaA!\n" + |
| "\x1fcloudtasks.googleapis.com/QueueR\x04name\"Q\n" + |
| "\x12ResumeQueueRequest\x12;\n" + |
| "\x04name\x18\x01 \x01(\tB'\xe0A\x02\xfaA!\n" + |
| "\x1fcloudtasks.googleapis.com/QueueR\x04name\"\xd5\x01\n" + |
| "\x10ListTasksRequest\x12>\n" + |
| "\x06parent\x18\x01 \x01(\tB&\xe0A\x02\xfaA \x12\x1ecloudtasks.googleapis.com/TaskR\x06parent\x12E\n" + |
| "\rresponse_view\x18\x02 \x01(\x0e2 .google.cloud.tasks.v2.Task.ViewR\fresponseView\x12\x1b\n" + |
| "\tpage_size\x18\x03 \x01(\x05R\bpageSize\x12\x1d\n" + |
| "\n" + |
| "page_token\x18\x04 \x01(\tR\tpageToken\"n\n" + |
| "\x11ListTasksResponse\x121\n" + |
| "\x05tasks\x18\x01 \x03(\v2\x1b.google.cloud.tasks.v2.TaskR\x05tasks\x12&\n" + |
| "\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\"\x93\x01\n" + |
| "\x0eGetTaskRequest\x12:\n" + |
| "\x04name\x18\x01 \x01(\tB&\xe0A\x02\xfaA \n" + |
| "\x1ecloudtasks.googleapis.com/TaskR\x04name\x12E\n" + |
| "\rresponse_view\x18\x02 \x01(\x0e2 .google.cloud.tasks.v2.Task.ViewR\fresponseView\"\xd0\x01\n" + |
| "\x11CreateTaskRequest\x12>\n" + |
| "\x06parent\x18\x01 \x01(\tB&\xe0A\x02\xfaA \x12\x1ecloudtasks.googleapis.com/TaskR\x06parent\x124\n" + |
| "\x04task\x18\x02 \x01(\v2\x1b.google.cloud.tasks.v2.TaskB\x03\xe0A\x02R\x04task\x12E\n" + |
| "\rresponse_view\x18\x03 \x01(\x0e2 .google.cloud.tasks.v2.Task.ViewR\fresponseView\"O\n" + |
| "\x11DeleteTaskRequest\x12:\n" + |
| "\x04name\x18\x01 \x01(\tB&\xe0A\x02\xfaA \n" + |
| "\x1ecloudtasks.googleapis.com/TaskR\x04name\"\x93\x01\n" + |
| "\x0eRunTaskRequest\x12:\n" + |
| "\x04name\x18\x01 \x01(\tB&\xe0A\x02\xfaA \n" + |
| "\x1ecloudtasks.googleapis.com/TaskR\x04name\x12E\n" + |
| "\rresponse_view\x18\x02 \x01(\x0e2 .google.cloud.tasks.v2.Task.ViewR\fresponseView2\xdd\x14\n" + |
| "\n" + |
| "CloudTasks\x12\x9e\x01\n" + |
| "\n" + |
| "ListQueues\x12(.google.cloud.tasks.v2.ListQueuesRequest\x1a).google.cloud.tasks.v2.ListQueuesResponse\";\xdaA\x06parent\x82\xd3\xe4\x93\x02,\x12*/v2/{parent=projects/*/locations/*}/queues\x12\x8b\x01\n" + |
| "\bGetQueue\x12&.google.cloud.tasks.v2.GetQueueRequest\x1a\x1c.google.cloud.tasks.v2.Queue\"9\xdaA\x04name\x82\xd3\xe4\x93\x02,\x12*/v2/{name=projects/*/locations/*/queues/*}\x12\xa0\x01\n" + |
| "\vCreateQueue\x12).google.cloud.tasks.v2.CreateQueueRequest\x1a\x1c.google.cloud.tasks.v2.Queue\"H\xdaA\fparent,queue\x82\xd3\xe4\x93\x023:\x05queue\"*/v2/{parent=projects/*/locations/*}/queues\x12\xab\x01\n" + |
| "\vUpdateQueue\x12).google.cloud.tasks.v2.UpdateQueueRequest\x1a\x1c.google.cloud.tasks.v2.Queue\"S\xdaA\x11queue,update_mask\x82\xd3\xe4\x93\x029:\x05queue20/v2/{queue.name=projects/*/locations/*/queues/*}\x12\x8b\x01\n" + |
| "\vDeleteQueue\x12).google.cloud.tasks.v2.DeleteQueueRequest\x1a\x16.google.protobuf.Empty\"9\xdaA\x04name\x82\xd3\xe4\x93\x02,**/v2/{name=projects/*/locations/*/queues/*}\x12\x98\x01\n" + |
| "\n" + |
| "PurgeQueue\x12(.google.cloud.tasks.v2.PurgeQueueRequest\x1a\x1c.google.cloud.tasks.v2.Queue\"B\xdaA\x04name\x82\xd3\xe4\x93\x025:\x01*\"0/v2/{name=projects/*/locations/*/queues/*}:purge\x12\x98\x01\n" + |
| "\n" + |
| "PauseQueue\x12(.google.cloud.tasks.v2.PauseQueueRequest\x1a\x1c.google.cloud.tasks.v2.Queue\"B\xdaA\x04name\x82\xd3\xe4\x93\x025:\x01*\"0/v2/{name=projects/*/locations/*/queues/*}:pause\x12\x9b\x01\n" + |
| "\vResumeQueue\x12).google.cloud.tasks.v2.ResumeQueueRequest\x1a\x1c.google.cloud.tasks.v2.Queue\"C\xdaA\x04name\x82\xd3\xe4\x93\x026:\x01*\"1/v2/{name=projects/*/locations/*/queues/*}:resume\x12\x9c\x01\n" + |
| "\fGetIamPolicy\x12\".google.iam.v1.GetIamPolicyRequest\x1a\x15.google.iam.v1.Policy\"Q\xdaA\bresource\x82\xd3\xe4\x93\x02@:\x01*\";/v2/{resource=projects/*/locations/*/queues/*}:getIamPolicy\x12\xa3\x01\n" + |
| "\fSetIamPolicy\x12\".google.iam.v1.SetIamPolicyRequest\x1a\x15.google.iam.v1.Policy\"X\xdaA\x0fresource,policy\x82\xd3\xe4\x93\x02@:\x01*\";/v2/{resource=projects/*/locations/*/queues/*}:setIamPolicy\x12\xce\x01\n" + |
| "\x12TestIamPermissions\x12(.google.iam.v1.TestIamPermissionsRequest\x1a).google.iam.v1.TestIamPermissionsResponse\"c\xdaA\x14resource,permissions\x82\xd3\xe4\x93\x02F:\x01*\"A/v2/{resource=projects/*/locations/*/queues/*}:testIamPermissions\x12\xa3\x01\n" + |
| "\tListTasks\x12'.google.cloud.tasks.v2.ListTasksRequest\x1a(.google.cloud.tasks.v2.ListTasksResponse\"C\xdaA\x06parent\x82\xd3\xe4\x93\x024\x122/v2/{parent=projects/*/locations/*/queues/*}/tasks\x12\x90\x01\n" + |
| "\aGetTask\x12%.google.cloud.tasks.v2.GetTaskRequest\x1a\x1b.google.cloud.tasks.v2.Task\"A\xdaA\x04name\x82\xd3\xe4\x93\x024\x122/v2/{name=projects/*/locations/*/queues/*/tasks/*}\x12\xa0\x01\n" + |
| "\n" + |
| "CreateTask\x12(.google.cloud.tasks.v2.CreateTaskRequest\x1a\x1b.google.cloud.tasks.v2.Task\"K\xdaA\vparent,task\x82\xd3\xe4\x93\x027:\x01*\"2/v2/{parent=projects/*/locations/*/queues/*}/tasks\x12\x91\x01\n" + |
| "\n" + |
| "DeleteTask\x12(.google.cloud.tasks.v2.DeleteTaskRequest\x1a\x16.google.protobuf.Empty\"A\xdaA\x04name\x82\xd3\xe4\x93\x024*2/v2/{name=projects/*/locations/*/queues/*/tasks/*}\x12\x97\x01\n" + |
| "\aRunTask\x12%.google.cloud.tasks.v2.RunTaskRequest\x1a\x1b.google.cloud.tasks.v2.Task\"H\xdaA\x04name\x82\xd3\xe4\x93\x02;:\x01*\"6/v2/{name=projects/*/locations/*/queues/*/tasks/*}:run\x1aM\xcaA\x19cloudtasks.googleapis.com\xd2A.https://www.googleapis.com/auth/cloud-platformBv\n" + |
| "\x19com.google.cloud.tasks.v2B\x0fCloudTasksProtoP\x01Z>cloud.google.com/go/cloudtasks/apiv2/cloudtaskspb;cloudtaskspb\xa2\x02\x05TASKSb\x06proto3" |
| |
| var ( |
| file_google_cloud_tasks_v2_cloudtasks_proto_rawDescOnce sync.Once |
| file_google_cloud_tasks_v2_cloudtasks_proto_rawDescData []byte |
| ) |
| |
| func file_google_cloud_tasks_v2_cloudtasks_proto_rawDescGZIP() []byte { |
| file_google_cloud_tasks_v2_cloudtasks_proto_rawDescOnce.Do(func() { |
| file_google_cloud_tasks_v2_cloudtasks_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc), len(file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc))) |
| }) |
| return file_google_cloud_tasks_v2_cloudtasks_proto_rawDescData |
| } |
| |
| var file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes = make([]protoimpl.MessageInfo, 15) |
| var file_google_cloud_tasks_v2_cloudtasks_proto_goTypes = []any{ |
| (*ListQueuesRequest)(nil), // 0: google.cloud.tasks.v2.ListQueuesRequest |
| (*ListQueuesResponse)(nil), // 1: google.cloud.tasks.v2.ListQueuesResponse |
| (*GetQueueRequest)(nil), // 2: google.cloud.tasks.v2.GetQueueRequest |
| (*CreateQueueRequest)(nil), // 3: google.cloud.tasks.v2.CreateQueueRequest |
| (*UpdateQueueRequest)(nil), // 4: google.cloud.tasks.v2.UpdateQueueRequest |
| (*DeleteQueueRequest)(nil), // 5: google.cloud.tasks.v2.DeleteQueueRequest |
| (*PurgeQueueRequest)(nil), // 6: google.cloud.tasks.v2.PurgeQueueRequest |
| (*PauseQueueRequest)(nil), // 7: google.cloud.tasks.v2.PauseQueueRequest |
| (*ResumeQueueRequest)(nil), // 8: google.cloud.tasks.v2.ResumeQueueRequest |
| (*ListTasksRequest)(nil), // 9: google.cloud.tasks.v2.ListTasksRequest |
| (*ListTasksResponse)(nil), // 10: google.cloud.tasks.v2.ListTasksResponse |
| (*GetTaskRequest)(nil), // 11: google.cloud.tasks.v2.GetTaskRequest |
| (*CreateTaskRequest)(nil), // 12: google.cloud.tasks.v2.CreateTaskRequest |
| (*DeleteTaskRequest)(nil), // 13: google.cloud.tasks.v2.DeleteTaskRequest |
| (*RunTaskRequest)(nil), // 14: google.cloud.tasks.v2.RunTaskRequest |
| (*Queue)(nil), // 15: google.cloud.tasks.v2.Queue |
| (*fieldmaskpb.FieldMask)(nil), // 16: google.protobuf.FieldMask |
| (Task_View)(0), // 17: google.cloud.tasks.v2.Task.View |
| (*Task)(nil), // 18: google.cloud.tasks.v2.Task |
| (*iampb.GetIamPolicyRequest)(nil), // 19: google.iam.v1.GetIamPolicyRequest |
| (*iampb.SetIamPolicyRequest)(nil), // 20: google.iam.v1.SetIamPolicyRequest |
| (*iampb.TestIamPermissionsRequest)(nil), // 21: google.iam.v1.TestIamPermissionsRequest |
| (*emptypb.Empty)(nil), // 22: google.protobuf.Empty |
| (*iampb.Policy)(nil), // 23: google.iam.v1.Policy |
| (*iampb.TestIamPermissionsResponse)(nil), // 24: google.iam.v1.TestIamPermissionsResponse |
| } |
| var file_google_cloud_tasks_v2_cloudtasks_proto_depIdxs = []int32{ |
| 15, // 0: google.cloud.tasks.v2.ListQueuesResponse.queues:type_name -> google.cloud.tasks.v2.Queue |
| 15, // 1: google.cloud.tasks.v2.CreateQueueRequest.queue:type_name -> google.cloud.tasks.v2.Queue |
| 15, // 2: google.cloud.tasks.v2.UpdateQueueRequest.queue:type_name -> google.cloud.tasks.v2.Queue |
| 16, // 3: google.cloud.tasks.v2.UpdateQueueRequest.update_mask:type_name -> google.protobuf.FieldMask |
| 17, // 4: google.cloud.tasks.v2.ListTasksRequest.response_view:type_name -> google.cloud.tasks.v2.Task.View |
| 18, // 5: google.cloud.tasks.v2.ListTasksResponse.tasks:type_name -> google.cloud.tasks.v2.Task |
| 17, // 6: google.cloud.tasks.v2.GetTaskRequest.response_view:type_name -> google.cloud.tasks.v2.Task.View |
| 18, // 7: google.cloud.tasks.v2.CreateTaskRequest.task:type_name -> google.cloud.tasks.v2.Task |
| 17, // 8: google.cloud.tasks.v2.CreateTaskRequest.response_view:type_name -> google.cloud.tasks.v2.Task.View |
| 17, // 9: google.cloud.tasks.v2.RunTaskRequest.response_view:type_name -> google.cloud.tasks.v2.Task.View |
| 0, // 10: google.cloud.tasks.v2.CloudTasks.ListQueues:input_type -> google.cloud.tasks.v2.ListQueuesRequest |
| 2, // 11: google.cloud.tasks.v2.CloudTasks.GetQueue:input_type -> google.cloud.tasks.v2.GetQueueRequest |
| 3, // 12: google.cloud.tasks.v2.CloudTasks.CreateQueue:input_type -> google.cloud.tasks.v2.CreateQueueRequest |
| 4, // 13: google.cloud.tasks.v2.CloudTasks.UpdateQueue:input_type -> google.cloud.tasks.v2.UpdateQueueRequest |
| 5, // 14: google.cloud.tasks.v2.CloudTasks.DeleteQueue:input_type -> google.cloud.tasks.v2.DeleteQueueRequest |
| 6, // 15: google.cloud.tasks.v2.CloudTasks.PurgeQueue:input_type -> google.cloud.tasks.v2.PurgeQueueRequest |
| 7, // 16: google.cloud.tasks.v2.CloudTasks.PauseQueue:input_type -> google.cloud.tasks.v2.PauseQueueRequest |
| 8, // 17: google.cloud.tasks.v2.CloudTasks.ResumeQueue:input_type -> google.cloud.tasks.v2.ResumeQueueRequest |
| 19, // 18: google.cloud.tasks.v2.CloudTasks.GetIamPolicy:input_type -> google.iam.v1.GetIamPolicyRequest |
| 20, // 19: google.cloud.tasks.v2.CloudTasks.SetIamPolicy:input_type -> google.iam.v1.SetIamPolicyRequest |
| 21, // 20: google.cloud.tasks.v2.CloudTasks.TestIamPermissions:input_type -> google.iam.v1.TestIamPermissionsRequest |
| 9, // 21: google.cloud.tasks.v2.CloudTasks.ListTasks:input_type -> google.cloud.tasks.v2.ListTasksRequest |
| 11, // 22: google.cloud.tasks.v2.CloudTasks.GetTask:input_type -> google.cloud.tasks.v2.GetTaskRequest |
| 12, // 23: google.cloud.tasks.v2.CloudTasks.CreateTask:input_type -> google.cloud.tasks.v2.CreateTaskRequest |
| 13, // 24: google.cloud.tasks.v2.CloudTasks.DeleteTask:input_type -> google.cloud.tasks.v2.DeleteTaskRequest |
| 14, // 25: google.cloud.tasks.v2.CloudTasks.RunTask:input_type -> google.cloud.tasks.v2.RunTaskRequest |
| 1, // 26: google.cloud.tasks.v2.CloudTasks.ListQueues:output_type -> google.cloud.tasks.v2.ListQueuesResponse |
| 15, // 27: google.cloud.tasks.v2.CloudTasks.GetQueue:output_type -> google.cloud.tasks.v2.Queue |
| 15, // 28: google.cloud.tasks.v2.CloudTasks.CreateQueue:output_type -> google.cloud.tasks.v2.Queue |
| 15, // 29: google.cloud.tasks.v2.CloudTasks.UpdateQueue:output_type -> google.cloud.tasks.v2.Queue |
| 22, // 30: google.cloud.tasks.v2.CloudTasks.DeleteQueue:output_type -> google.protobuf.Empty |
| 15, // 31: google.cloud.tasks.v2.CloudTasks.PurgeQueue:output_type -> google.cloud.tasks.v2.Queue |
| 15, // 32: google.cloud.tasks.v2.CloudTasks.PauseQueue:output_type -> google.cloud.tasks.v2.Queue |
| 15, // 33: google.cloud.tasks.v2.CloudTasks.ResumeQueue:output_type -> google.cloud.tasks.v2.Queue |
| 23, // 34: google.cloud.tasks.v2.CloudTasks.GetIamPolicy:output_type -> google.iam.v1.Policy |
| 23, // 35: google.cloud.tasks.v2.CloudTasks.SetIamPolicy:output_type -> google.iam.v1.Policy |
| 24, // 36: google.cloud.tasks.v2.CloudTasks.TestIamPermissions:output_type -> google.iam.v1.TestIamPermissionsResponse |
| 10, // 37: google.cloud.tasks.v2.CloudTasks.ListTasks:output_type -> google.cloud.tasks.v2.ListTasksResponse |
| 18, // 38: google.cloud.tasks.v2.CloudTasks.GetTask:output_type -> google.cloud.tasks.v2.Task |
| 18, // 39: google.cloud.tasks.v2.CloudTasks.CreateTask:output_type -> google.cloud.tasks.v2.Task |
| 22, // 40: google.cloud.tasks.v2.CloudTasks.DeleteTask:output_type -> google.protobuf.Empty |
| 18, // 41: google.cloud.tasks.v2.CloudTasks.RunTask:output_type -> google.cloud.tasks.v2.Task |
| 26, // [26:42] is the sub-list for method output_type |
| 10, // [10:26] is the sub-list for method input_type |
| 10, // [10:10] is the sub-list for extension type_name |
| 10, // [10:10] is the sub-list for extension extendee |
| 0, // [0:10] is the sub-list for field type_name |
| } |
| |
| func init() { file_google_cloud_tasks_v2_cloudtasks_proto_init() } |
| func file_google_cloud_tasks_v2_cloudtasks_proto_init() { |
| if File_google_cloud_tasks_v2_cloudtasks_proto != nil { |
| return |
| } |
| file_google_cloud_tasks_v2_queue_proto_init() |
| file_google_cloud_tasks_v2_task_proto_init() |
| type x struct{} |
| out := protoimpl.TypeBuilder{ |
| File: protoimpl.DescBuilder{ |
| GoPackagePath: reflect.TypeOf(x{}).PkgPath(), |
| RawDescriptor: unsafe.Slice(unsafe.StringData(file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc), len(file_google_cloud_tasks_v2_cloudtasks_proto_rawDesc)), |
| NumEnums: 0, |
| NumMessages: 15, |
| NumExtensions: 0, |
| NumServices: 1, |
| }, |
| GoTypes: file_google_cloud_tasks_v2_cloudtasks_proto_goTypes, |
| DependencyIndexes: file_google_cloud_tasks_v2_cloudtasks_proto_depIdxs, |
| MessageInfos: file_google_cloud_tasks_v2_cloudtasks_proto_msgTypes, |
| }.Build() |
| File_google_cloud_tasks_v2_cloudtasks_proto = out.File |
| file_google_cloud_tasks_v2_cloudtasks_proto_goTypes = nil |
| file_google_cloud_tasks_v2_cloudtasks_proto_depIdxs = nil |
| } |
