1// Copyright 2020 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.26.0 18// protoc v3.12.2 19// source: google/cloud/tasks/v2beta3/task.proto 20 21package tasks 22 23import ( 24 reflect "reflect" 25 sync "sync" 26 27 _ "google.golang.org/genproto/googleapis/api/annotations" 28 status "google.golang.org/genproto/googleapis/rpc/status" 29 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 30 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 31 durationpb "google.golang.org/protobuf/types/known/durationpb" 32 timestamppb "google.golang.org/protobuf/types/known/timestamppb" 33) 34 35const ( 36 // Verify that this generated code is sufficiently up-to-date. 37 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 38 // Verify that runtime/protoimpl is sufficiently up-to-date. 39 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 40) 41 42// The view specifies a subset of [Task][google.cloud.tasks.v2beta3.Task] data. 43// 44// When a task is returned in a response, not all 45// information is retrieved by default because some data, such as 46// payloads, might be desirable to return only when needed because 47// of its large size or because of the sensitivity of data that it 48// contains. 49type Task_View int32 50 51const ( 52 // Unspecified. Defaults to BASIC. 53 Task_VIEW_UNSPECIFIED Task_View = 0 54 // The basic view omits fields which can be large or can contain 55 // sensitive data. 56 // 57 // This view does not include the 58 // [body in AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest.body]. 59 // Bodies are desirable to return only when needed, because they 60 // can be large and because of the sensitivity of the data that you 61 // choose to store in it. 62 Task_BASIC Task_View = 1 63 // All information is returned. 64 // 65 // Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires 66 // `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/) 67 // permission on the [Queue][google.cloud.tasks.v2beta3.Queue] resource. 68 Task_FULL Task_View = 2 69) 70 71// Enum value maps for Task_View. 72var ( 73 Task_View_name = map[int32]string{ 74 0: "VIEW_UNSPECIFIED", 75 1: "BASIC", 76 2: "FULL", 77 } 78 Task_View_value = map[string]int32{ 79 "VIEW_UNSPECIFIED": 0, 80 "BASIC": 1, 81 "FULL": 2, 82 } 83) 84 85func (x Task_View) Enum() *Task_View { 86 p := new(Task_View) 87 *p = x 88 return p 89} 90 91func (x Task_View) String() string { 92 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 93} 94 95func (Task_View) Descriptor() protoreflect.EnumDescriptor { 96 return file_google_cloud_tasks_v2beta3_task_proto_enumTypes[0].Descriptor() 97} 98 99func (Task_View) Type() protoreflect.EnumType { 100 return &file_google_cloud_tasks_v2beta3_task_proto_enumTypes[0] 101} 102 103func (x Task_View) Number() protoreflect.EnumNumber { 104 return protoreflect.EnumNumber(x) 105} 106 107// Deprecated: Use Task_View.Descriptor instead. 108func (Task_View) EnumDescriptor() ([]byte, []int) { 109 return file_google_cloud_tasks_v2beta3_task_proto_rawDescGZIP(), []int{0, 0} 110} 111 112// A unit of scheduled work. 113type Task struct { 114 state protoimpl.MessageState 115 sizeCache protoimpl.SizeCache 116 unknownFields protoimpl.UnknownFields 117 118 // Optionally caller-specified in [CreateTask][google.cloud.tasks.v2beta3.CloudTasks.CreateTask]. 119 // 120 // The task name. 121 // 122 // The task name must have the following format: 123 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID` 124 // 125 // * `PROJECT_ID` can contain letters ([A-Za-z]), numbers ([0-9]), 126 // hyphens (-), colons (:), or periods (.). 127 // For more information, see 128 // [Identifying 129 // projects](https://cloud.google.com/resource-manager/docs/creating-managing-projects#identifying_projects) 130 // * `LOCATION_ID` is the canonical ID for the task's location. 131 // The list of available locations can be obtained by calling 132 // [ListLocations][google.cloud.location.Locations.ListLocations]. 133 // For more information, see https://cloud.google.com/about/locations/. 134 // * `QUEUE_ID` can contain letters ([A-Za-z]), numbers ([0-9]), or 135 // hyphens (-). The maximum length is 100 characters. 136 // * `TASK_ID` can contain only letters ([A-Za-z]), numbers ([0-9]), 137 // hyphens (-), or underscores (_). The maximum length is 500 characters. 138 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 139 // Required. The message to send to the worker. 140 // 141 // Types that are assignable to PayloadType: 142 // *Task_AppEngineHttpRequest 143 // *Task_HttpRequest 144 // *Task_PullMessage 145 PayloadType isTask_PayloadType `protobuf_oneof:"payload_type"` 146 // The time when the task is scheduled to be attempted. 147 // 148 // For App Engine queues, this is when the task will be attempted or retried. 149 // 150 // `schedule_time` will be truncated to the nearest microsecond. 151 ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"` 152 // Output only. The time that the task was created. 153 // 154 // `create_time` will be truncated to the nearest second. 155 CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` 156 // The deadline for requests sent to the worker. If the worker does not 157 // respond by this deadline then the request is cancelled and the attempt 158 // is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the 159 // task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig]. 160 // 161 // Note that when the request is cancelled, Cloud Tasks will stop listening 162 // for the response, but whether the worker stops processing depends on the 163 // worker. For example, if the worker is stuck, it may not react to cancelled 164 // requests. 165 // 166 // The default and maximum values depend on the type of request: 167 // 168 // * For [HTTP tasks][google.cloud.tasks.v2beta3.HttpRequest], the default is 10 minutes. The deadline 169 // must be in the interval [15 seconds, 30 minutes]. 170 // 171 // * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the 172 // request has the default deadline. The default deadline depends on the 173 // [scaling 174 // type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling) 175 // of the service: 10 minutes for standard apps with automatic scaling, 24 176 // hours for standard apps with manual and basic scaling, and 60 minutes for 177 // flex apps. If the request deadline is set, it must be in the interval [15 178 // seconds, 24 hours 15 seconds]. Regardless of the task's 179 // `dispatch_deadline`, the app handler will not run for longer than than 180 // the service's timeout. We recommend setting the `dispatch_deadline` to 181 // at most a few seconds more than the app handler's timeout. For more 182 // information see 183 // [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts). 184 // 185 // `dispatch_deadline` will be truncated to the nearest millisecond. The 186 // deadline is an approximate deadline. 187 DispatchDeadline *durationpb.Duration `protobuf:"bytes,12,opt,name=dispatch_deadline,json=dispatchDeadline,proto3" json:"dispatch_deadline,omitempty"` 188 // Output only. The number of attempts dispatched. 189 // 190 // This count includes attempts which have been dispatched but haven't 191 // received a response. 192 DispatchCount int32 `protobuf:"varint,6,opt,name=dispatch_count,json=dispatchCount,proto3" json:"dispatch_count,omitempty"` 193 // Output only. The number of attempts which have received a response. 194 ResponseCount int32 `protobuf:"varint,7,opt,name=response_count,json=responseCount,proto3" json:"response_count,omitempty"` 195 // Output only. The status of the task's first attempt. 196 // 197 // Only [dispatch_time][google.cloud.tasks.v2beta3.Attempt.dispatch_time] will be set. 198 // The other [Attempt][google.cloud.tasks.v2beta3.Attempt] information is not retained by Cloud Tasks. 199 FirstAttempt *Attempt `protobuf:"bytes,8,opt,name=first_attempt,json=firstAttempt,proto3" json:"first_attempt,omitempty"` 200 // Output only. The status of the task's last attempt. 201 LastAttempt *Attempt `protobuf:"bytes,9,opt,name=last_attempt,json=lastAttempt,proto3" json:"last_attempt,omitempty"` 202 // Output only. The view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] has 203 // been returned. 204 View Task_View `protobuf:"varint,10,opt,name=view,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"view,omitempty"` 205} 206 207func (x *Task) Reset() { 208 *x = Task{} 209 if protoimpl.UnsafeEnabled { 210 mi := &file_google_cloud_tasks_v2beta3_task_proto_msgTypes[0] 211 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 212 ms.StoreMessageInfo(mi) 213 } 214} 215 216func (x *Task) String() string { 217 return protoimpl.X.MessageStringOf(x) 218} 219 220func (*Task) ProtoMessage() {} 221 222func (x *Task) ProtoReflect() protoreflect.Message { 223 mi := &file_google_cloud_tasks_v2beta3_task_proto_msgTypes[0] 224 if protoimpl.UnsafeEnabled && x != nil { 225 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 226 if ms.LoadMessageInfo() == nil { 227 ms.StoreMessageInfo(mi) 228 } 229 return ms 230 } 231 return mi.MessageOf(x) 232} 233 234// Deprecated: Use Task.ProtoReflect.Descriptor instead. 235func (*Task) Descriptor() ([]byte, []int) { 236 return file_google_cloud_tasks_v2beta3_task_proto_rawDescGZIP(), []int{0} 237} 238 239func (x *Task) GetName() string { 240 if x != nil { 241 return x.Name 242 } 243 return "" 244} 245 246func (m *Task) GetPayloadType() isTask_PayloadType { 247 if m != nil { 248 return m.PayloadType 249 } 250 return nil 251} 252 253func (x *Task) GetAppEngineHttpRequest() *AppEngineHttpRequest { 254 if x, ok := x.GetPayloadType().(*Task_AppEngineHttpRequest); ok { 255 return x.AppEngineHttpRequest 256 } 257 return nil 258} 259 260func (x *Task) GetHttpRequest() *HttpRequest { 261 if x, ok := x.GetPayloadType().(*Task_HttpRequest); ok { 262 return x.HttpRequest 263 } 264 return nil 265} 266 267func (x *Task) GetPullMessage() *PullMessage { 268 if x, ok := x.GetPayloadType().(*Task_PullMessage); ok { 269 return x.PullMessage 270 } 271 return nil 272} 273 274func (x *Task) GetScheduleTime() *timestamppb.Timestamp { 275 if x != nil { 276 return x.ScheduleTime 277 } 278 return nil 279} 280 281func (x *Task) GetCreateTime() *timestamppb.Timestamp { 282 if x != nil { 283 return x.CreateTime 284 } 285 return nil 286} 287 288func (x *Task) GetDispatchDeadline() *durationpb.Duration { 289 if x != nil { 290 return x.DispatchDeadline 291 } 292 return nil 293} 294 295func (x *Task) GetDispatchCount() int32 { 296 if x != nil { 297 return x.DispatchCount 298 } 299 return 0 300} 301 302func (x *Task) GetResponseCount() int32 { 303 if x != nil { 304 return x.ResponseCount 305 } 306 return 0 307} 308 309func (x *Task) GetFirstAttempt() *Attempt { 310 if x != nil { 311 return x.FirstAttempt 312 } 313 return nil 314} 315 316func (x *Task) GetLastAttempt() *Attempt { 317 if x != nil { 318 return x.LastAttempt 319 } 320 return nil 321} 322 323func (x *Task) GetView() Task_View { 324 if x != nil { 325 return x.View 326 } 327 return Task_VIEW_UNSPECIFIED 328} 329 330type isTask_PayloadType interface { 331 isTask_PayloadType() 332} 333 334type Task_AppEngineHttpRequest struct { 335 // HTTP request that is sent to the App Engine app handler. 336 // 337 // An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set. 338 AppEngineHttpRequest *AppEngineHttpRequest `protobuf:"bytes,3,opt,name=app_engine_http_request,json=appEngineHttpRequest,proto3,oneof"` 339} 340 341type Task_HttpRequest struct { 342 // HTTP request that is sent to the task's target. 343 // 344 // An HTTP task is a task that has [HttpRequest][google.cloud.tasks.v2beta3.HttpRequest] set. 345 HttpRequest *HttpRequest `protobuf:"bytes,11,opt,name=http_request,json=httpRequest,proto3,oneof"` 346} 347 348type Task_PullMessage struct { 349 // Pull Message contained in a task in a [PULL][google.cloud.tasks.v2beta3.Queue.type] queue type. This 350 // payload type cannot be explicitly set through Cloud Tasks API. Its 351 // purpose, currently is to provide backward compatibility with App Engine 352 // Task Queue 353 // [pull](https://cloud.google.com/appengine/docs/standard/java/taskqueue/pull/) 354 // queues to provide a way to inspect contents of pull tasks through the 355 // [CloudTasks.GetTask][google.cloud.tasks.v2beta3.CloudTasks.GetTask]. 356 PullMessage *PullMessage `protobuf:"bytes,13,opt,name=pull_message,json=pullMessage,proto3,oneof"` 357} 358 359func (*Task_AppEngineHttpRequest) isTask_PayloadType() {} 360 361func (*Task_HttpRequest) isTask_PayloadType() {} 362 363func (*Task_PullMessage) isTask_PayloadType() {} 364 365// The status of a task attempt. 366type Attempt struct { 367 state protoimpl.MessageState 368 sizeCache protoimpl.SizeCache 369 unknownFields protoimpl.UnknownFields 370 371 // Output only. The time that this attempt was scheduled. 372 // 373 // `schedule_time` will be truncated to the nearest microsecond. 374 ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"` 375 // Output only. The time that this attempt was dispatched. 376 // 377 // `dispatch_time` will be truncated to the nearest microsecond. 378 DispatchTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=dispatch_time,json=dispatchTime,proto3" json:"dispatch_time,omitempty"` 379 // Output only. The time that this attempt response was received. 380 // 381 // `response_time` will be truncated to the nearest microsecond. 382 ResponseTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=response_time,json=responseTime,proto3" json:"response_time,omitempty"` 383 // Output only. The response from the worker for this attempt. 384 // 385 // If `response_time` is unset, then the task has not been attempted or is 386 // currently running and the `response_status` field is meaningless. 387 ResponseStatus *status.Status `protobuf:"bytes,4,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"` 388} 389 390func (x *Attempt) Reset() { 391 *x = Attempt{} 392 if protoimpl.UnsafeEnabled { 393 mi := &file_google_cloud_tasks_v2beta3_task_proto_msgTypes[1] 394 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 395 ms.StoreMessageInfo(mi) 396 } 397} 398 399func (x *Attempt) String() string { 400 return protoimpl.X.MessageStringOf(x) 401} 402 403func (*Attempt) ProtoMessage() {} 404 405func (x *Attempt) ProtoReflect() protoreflect.Message { 406 mi := &file_google_cloud_tasks_v2beta3_task_proto_msgTypes[1] 407 if protoimpl.UnsafeEnabled && x != nil { 408 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 409 if ms.LoadMessageInfo() == nil { 410 ms.StoreMessageInfo(mi) 411 } 412 return ms 413 } 414 return mi.MessageOf(x) 415} 416 417// Deprecated: Use Attempt.ProtoReflect.Descriptor instead. 418func (*Attempt) Descriptor() ([]byte, []int) { 419 return file_google_cloud_tasks_v2beta3_task_proto_rawDescGZIP(), []int{1} 420} 421 422func (x *Attempt) GetScheduleTime() *timestamppb.Timestamp { 423 if x != nil { 424 return x.ScheduleTime 425 } 426 return nil 427} 428 429func (x *Attempt) GetDispatchTime() *timestamppb.Timestamp { 430 if x != nil { 431 return x.DispatchTime 432 } 433 return nil 434} 435 436func (x *Attempt) GetResponseTime() *timestamppb.Timestamp { 437 if x != nil { 438 return x.ResponseTime 439 } 440 return nil 441} 442 443func (x *Attempt) GetResponseStatus() *status.Status { 444 if x != nil { 445 return x.ResponseStatus 446 } 447 return nil 448} 449 450var File_google_cloud_tasks_v2beta3_task_proto protoreflect.FileDescriptor 451 452var file_google_cloud_tasks_v2beta3_task_proto_rawDesc = []byte{ 453 0x0a, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 454 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x74, 0x61, 0x73, 455 0x6b, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 456 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 457 0x74, 0x61, 0x33, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 458 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x27, 459 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 0x61, 0x73, 460 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x74, 0x61, 0x72, 0x67, 0x65, 461 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 462 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 463 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 464 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 465 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 466 0x2f, 0x72, 0x70, 0x63, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 467 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 468 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 469 0xaf, 0x07, 0x0a, 0x04, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 470 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x69, 0x0a, 0x17, 471 0x61, 0x70, 0x70, 0x5f, 0x65, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x5f, 0x68, 0x74, 0x74, 0x70, 0x5f, 472 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 473 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 474 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x70, 0x70, 0x45, 0x6e, 475 0x67, 0x69, 0x6e, 0x65, 0x48, 0x74, 0x74, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 476 0x00, 0x52, 0x14, 0x61, 0x70, 0x70, 0x45, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x48, 0x74, 0x74, 0x70, 477 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4c, 0x0a, 0x0c, 0x68, 0x74, 0x74, 0x70, 0x5f, 478 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 479 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 480 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x52, 481 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52, 0x0b, 0x68, 0x74, 0x74, 0x70, 0x52, 0x65, 482 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4c, 0x0a, 0x0c, 0x70, 0x75, 0x6c, 0x6c, 0x5f, 0x6d, 0x65, 483 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x67, 0x6f, 484 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 485 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x50, 0x75, 0x6c, 0x6c, 0x4d, 0x65, 0x73, 486 0x73, 0x61, 0x67, 0x65, 0x48, 0x00, 0x52, 0x0b, 0x70, 0x75, 0x6c, 0x6c, 0x4d, 0x65, 0x73, 0x73, 487 0x61, 0x67, 0x65, 0x12, 0x3f, 0x0a, 0x0d, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x5f, 488 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 489 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 490 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0c, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 491 0x54, 0x69, 0x6d, 0x65, 0x12, 0x3b, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 492 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 493 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 494 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 495 0x65, 0x12, 0x46, 0x0a, 0x11, 0x64, 0x69, 0x73, 0x70, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x64, 0x65, 496 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 497 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 498 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x10, 0x64, 0x69, 0x73, 0x70, 0x61, 0x74, 0x63, 499 0x68, 0x44, 0x65, 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x64, 0x69, 0x73, 500 0x70, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 501 0x05, 0x52, 0x0d, 0x64, 0x69, 0x73, 0x70, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6f, 0x75, 0x6e, 0x74, 502 0x12, 0x25, 0x0a, 0x0e, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x63, 0x6f, 0x75, 503 0x6e, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 504 0x73, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x48, 0x0a, 0x0d, 0x66, 0x69, 0x72, 0x73, 0x74, 505 0x5f, 0x61, 0x74, 0x74, 0x65, 0x6d, 0x70, 0x74, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 506 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 507 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x74, 0x74, 0x65, 508 0x6d, 0x70, 0x74, 0x52, 0x0c, 0x66, 0x69, 0x72, 0x73, 0x74, 0x41, 0x74, 0x74, 0x65, 0x6d, 0x70, 509 0x74, 0x12, 0x46, 0x0a, 0x0c, 0x6c, 0x61, 0x73, 0x74, 0x5f, 0x61, 0x74, 0x74, 0x65, 0x6d, 0x70, 510 0x74, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 511 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 512 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x74, 0x74, 0x65, 0x6d, 0x70, 0x74, 0x52, 0x0b, 0x6c, 0x61, 513 0x73, 0x74, 0x41, 0x74, 0x74, 0x65, 0x6d, 0x70, 0x74, 0x12, 0x39, 0x0a, 0x04, 0x76, 0x69, 0x65, 514 0x77, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 515 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 516 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x2e, 0x56, 0x69, 0x65, 0x77, 0x52, 0x04, 517 0x76, 0x69, 0x65, 0x77, 0x22, 0x31, 0x0a, 0x04, 0x56, 0x69, 0x65, 0x77, 0x12, 0x14, 0x0a, 0x10, 518 0x56, 0x49, 0x45, 0x57, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 519 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x42, 0x41, 0x53, 0x49, 0x43, 0x10, 0x01, 0x12, 0x08, 0x0a, 520 0x04, 0x46, 0x55, 0x4c, 0x4c, 0x10, 0x02, 0x3a, 0x68, 0xea, 0x41, 0x65, 0x0a, 0x1e, 0x63, 0x6c, 521 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 522 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x43, 0x70, 0x72, 523 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 524 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 525 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x7b, 0x71, 0x75, 526 0x65, 0x75, 0x65, 0x7d, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x7b, 0x74, 0x61, 0x73, 0x6b, 527 0x7d, 0x42, 0x0e, 0x0a, 0x0c, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x5f, 0x74, 0x79, 0x70, 528 0x65, 0x22, 0x89, 0x02, 0x0a, 0x07, 0x41, 0x74, 0x74, 0x65, 0x6d, 0x70, 0x74, 0x12, 0x3f, 0x0a, 529 0x0d, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 530 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 531 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 532 0x52, 0x0c, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x3f, 533 0x0a, 0x0d, 0x64, 0x69, 0x73, 0x70, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 534 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 535 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 536 0x70, 0x52, 0x0c, 0x64, 0x69, 0x73, 0x70, 0x61, 0x74, 0x63, 0x68, 0x54, 0x69, 0x6d, 0x65, 0x12, 537 0x3f, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 538 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 539 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 540 0x6d, 0x70, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x54, 0x69, 0x6d, 0x65, 541 0x12, 0x3b, 0x0a, 0x0f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x73, 0x74, 0x61, 542 0x74, 0x75, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 543 0x6c, 0x65, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x0e, 0x72, 544 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x42, 0x6e, 0x0a, 545 0x1e, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 546 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x42, 547 0x09, 0x54, 0x61, 0x73, 0x6b, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3f, 0x67, 0x6f, 548 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 549 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 550 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 551 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x3b, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x62, 0x06, 0x70, 552 0x72, 0x6f, 0x74, 0x6f, 0x33, 553} 554 555var ( 556 file_google_cloud_tasks_v2beta3_task_proto_rawDescOnce sync.Once 557 file_google_cloud_tasks_v2beta3_task_proto_rawDescData = file_google_cloud_tasks_v2beta3_task_proto_rawDesc 558) 559 560func file_google_cloud_tasks_v2beta3_task_proto_rawDescGZIP() []byte { 561 file_google_cloud_tasks_v2beta3_task_proto_rawDescOnce.Do(func() { 562 file_google_cloud_tasks_v2beta3_task_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_tasks_v2beta3_task_proto_rawDescData) 563 }) 564 return file_google_cloud_tasks_v2beta3_task_proto_rawDescData 565} 566 567var file_google_cloud_tasks_v2beta3_task_proto_enumTypes = make([]protoimpl.EnumInfo, 1) 568var file_google_cloud_tasks_v2beta3_task_proto_msgTypes = make([]protoimpl.MessageInfo, 2) 569var file_google_cloud_tasks_v2beta3_task_proto_goTypes = []interface{}{ 570 (Task_View)(0), // 0: google.cloud.tasks.v2beta3.Task.View 571 (*Task)(nil), // 1: google.cloud.tasks.v2beta3.Task 572 (*Attempt)(nil), // 2: google.cloud.tasks.v2beta3.Attempt 573 (*AppEngineHttpRequest)(nil), // 3: google.cloud.tasks.v2beta3.AppEngineHttpRequest 574 (*HttpRequest)(nil), // 4: google.cloud.tasks.v2beta3.HttpRequest 575 (*PullMessage)(nil), // 5: google.cloud.tasks.v2beta3.PullMessage 576 (*timestamppb.Timestamp)(nil), // 6: google.protobuf.Timestamp 577 (*durationpb.Duration)(nil), // 7: google.protobuf.Duration 578 (*status.Status)(nil), // 8: google.rpc.Status 579} 580var file_google_cloud_tasks_v2beta3_task_proto_depIdxs = []int32{ 581 3, // 0: google.cloud.tasks.v2beta3.Task.app_engine_http_request:type_name -> google.cloud.tasks.v2beta3.AppEngineHttpRequest 582 4, // 1: google.cloud.tasks.v2beta3.Task.http_request:type_name -> google.cloud.tasks.v2beta3.HttpRequest 583 5, // 2: google.cloud.tasks.v2beta3.Task.pull_message:type_name -> google.cloud.tasks.v2beta3.PullMessage 584 6, // 3: google.cloud.tasks.v2beta3.Task.schedule_time:type_name -> google.protobuf.Timestamp 585 6, // 4: google.cloud.tasks.v2beta3.Task.create_time:type_name -> google.protobuf.Timestamp 586 7, // 5: google.cloud.tasks.v2beta3.Task.dispatch_deadline:type_name -> google.protobuf.Duration 587 2, // 6: google.cloud.tasks.v2beta3.Task.first_attempt:type_name -> google.cloud.tasks.v2beta3.Attempt 588 2, // 7: google.cloud.tasks.v2beta3.Task.last_attempt:type_name -> google.cloud.tasks.v2beta3.Attempt 589 0, // 8: google.cloud.tasks.v2beta3.Task.view:type_name -> google.cloud.tasks.v2beta3.Task.View 590 6, // 9: google.cloud.tasks.v2beta3.Attempt.schedule_time:type_name -> google.protobuf.Timestamp 591 6, // 10: google.cloud.tasks.v2beta3.Attempt.dispatch_time:type_name -> google.protobuf.Timestamp 592 6, // 11: google.cloud.tasks.v2beta3.Attempt.response_time:type_name -> google.protobuf.Timestamp 593 8, // 12: google.cloud.tasks.v2beta3.Attempt.response_status:type_name -> google.rpc.Status 594 13, // [13:13] is the sub-list for method output_type 595 13, // [13:13] is the sub-list for method input_type 596 13, // [13:13] is the sub-list for extension type_name 597 13, // [13:13] is the sub-list for extension extendee 598 0, // [0:13] is the sub-list for field type_name 599} 600 601func init() { file_google_cloud_tasks_v2beta3_task_proto_init() } 602func file_google_cloud_tasks_v2beta3_task_proto_init() { 603 if File_google_cloud_tasks_v2beta3_task_proto != nil { 604 return 605 } 606 file_google_cloud_tasks_v2beta3_target_proto_init() 607 if !protoimpl.UnsafeEnabled { 608 file_google_cloud_tasks_v2beta3_task_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 609 switch v := v.(*Task); i { 610 case 0: 611 return &v.state 612 case 1: 613 return &v.sizeCache 614 case 2: 615 return &v.unknownFields 616 default: 617 return nil 618 } 619 } 620 file_google_cloud_tasks_v2beta3_task_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 621 switch v := v.(*Attempt); i { 622 case 0: 623 return &v.state 624 case 1: 625 return &v.sizeCache 626 case 2: 627 return &v.unknownFields 628 default: 629 return nil 630 } 631 } 632 } 633 file_google_cloud_tasks_v2beta3_task_proto_msgTypes[0].OneofWrappers = []interface{}{ 634 (*Task_AppEngineHttpRequest)(nil), 635 (*Task_HttpRequest)(nil), 636 (*Task_PullMessage)(nil), 637 } 638 type x struct{} 639 out := protoimpl.TypeBuilder{ 640 File: protoimpl.DescBuilder{ 641 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 642 RawDescriptor: file_google_cloud_tasks_v2beta3_task_proto_rawDesc, 643 NumEnums: 1, 644 NumMessages: 2, 645 NumExtensions: 0, 646 NumServices: 0, 647 }, 648 GoTypes: file_google_cloud_tasks_v2beta3_task_proto_goTypes, 649 DependencyIndexes: file_google_cloud_tasks_v2beta3_task_proto_depIdxs, 650 EnumInfos: file_google_cloud_tasks_v2beta3_task_proto_enumTypes, 651 MessageInfos: file_google_cloud_tasks_v2beta3_task_proto_msgTypes, 652 }.Build() 653 File_google_cloud_tasks_v2beta3_task_proto = out.File 654 file_google_cloud_tasks_v2beta3_task_proto_rawDesc = nil 655 file_google_cloud_tasks_v2beta3_task_proto_goTypes = nil 656 file_google_cloud_tasks_v2beta3_task_proto_depIdxs = nil 657} 658