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