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.25.0 18// protoc v3.13.0 19// source: google/cloud/tasks/v2beta3/queue.proto 20 21package tasks 22 23import ( 24 reflect "reflect" 25 sync "sync" 26 27 proto "github.com/golang/protobuf/proto" 28 _ "google.golang.org/genproto/googleapis/api/annotations" 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// This is a compile-time assertion that a sufficiently up-to-date version 43// of the legacy proto package is being used. 44const _ = proto.ProtoPackageIsVersion4 45 46// State of the queue. 47type Queue_State int32 48 49const ( 50 // Unspecified state. 51 Queue_STATE_UNSPECIFIED Queue_State = 0 52 // The queue is running. Tasks can be dispatched. 53 // 54 // If the queue was created using Cloud Tasks and the queue has 55 // had no activity (method calls or task dispatches) for 30 days, 56 // the queue may take a few minutes to re-activate. Some method 57 // calls may return [NOT_FOUND][google.rpc.Code.NOT_FOUND] and 58 // tasks may not be dispatched for a few minutes until the queue 59 // has been re-activated. 60 Queue_RUNNING Queue_State = 1 61 // Tasks are paused by the user. If the queue is paused then Cloud 62 // Tasks will stop delivering tasks from it, but more tasks can 63 // still be added to it by the user. 64 Queue_PAUSED Queue_State = 2 65 // The queue is disabled. 66 // 67 // A queue becomes `DISABLED` when 68 // [queue.yaml](https://cloud.google.com/appengine/docs/python/config/queueref) 69 // or 70 // [queue.xml](https://cloud.google.com/appengine/docs/standard/java/config/queueref) 71 // is uploaded which does not contain the queue. You cannot directly disable 72 // a queue. 73 // 74 // When a queue is disabled, tasks can still be added to a queue 75 // but the tasks are not dispatched. 76 // 77 // To permanently delete this queue and all of its tasks, call 78 // [DeleteQueue][google.cloud.tasks.v2beta3.CloudTasks.DeleteQueue]. 79 Queue_DISABLED Queue_State = 3 80) 81 82// Enum value maps for Queue_State. 83var ( 84 Queue_State_name = map[int32]string{ 85 0: "STATE_UNSPECIFIED", 86 1: "RUNNING", 87 2: "PAUSED", 88 3: "DISABLED", 89 } 90 Queue_State_value = map[string]int32{ 91 "STATE_UNSPECIFIED": 0, 92 "RUNNING": 1, 93 "PAUSED": 2, 94 "DISABLED": 3, 95 } 96) 97 98func (x Queue_State) Enum() *Queue_State { 99 p := new(Queue_State) 100 *p = x 101 return p 102} 103 104func (x Queue_State) String() string { 105 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 106} 107 108func (Queue_State) Descriptor() protoreflect.EnumDescriptor { 109 return file_google_cloud_tasks_v2beta3_queue_proto_enumTypes[0].Descriptor() 110} 111 112func (Queue_State) Type() protoreflect.EnumType { 113 return &file_google_cloud_tasks_v2beta3_queue_proto_enumTypes[0] 114} 115 116func (x Queue_State) Number() protoreflect.EnumNumber { 117 return protoreflect.EnumNumber(x) 118} 119 120// Deprecated: Use Queue_State.Descriptor instead. 121func (Queue_State) EnumDescriptor() ([]byte, []int) { 122 return file_google_cloud_tasks_v2beta3_queue_proto_rawDescGZIP(), []int{0, 0} 123} 124 125// The type of the queue. 126type Queue_Type int32 127 128const ( 129 // Default value. 130 Queue_TYPE_UNSPECIFIED Queue_Type = 0 131 // A pull queue. 132 Queue_PULL Queue_Type = 1 133 // A push queue. 134 Queue_PUSH Queue_Type = 2 135) 136 137// Enum value maps for Queue_Type. 138var ( 139 Queue_Type_name = map[int32]string{ 140 0: "TYPE_UNSPECIFIED", 141 1: "PULL", 142 2: "PUSH", 143 } 144 Queue_Type_value = map[string]int32{ 145 "TYPE_UNSPECIFIED": 0, 146 "PULL": 1, 147 "PUSH": 2, 148 } 149) 150 151func (x Queue_Type) Enum() *Queue_Type { 152 p := new(Queue_Type) 153 *p = x 154 return p 155} 156 157func (x Queue_Type) String() string { 158 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 159} 160 161func (Queue_Type) Descriptor() protoreflect.EnumDescriptor { 162 return file_google_cloud_tasks_v2beta3_queue_proto_enumTypes[1].Descriptor() 163} 164 165func (Queue_Type) Type() protoreflect.EnumType { 166 return &file_google_cloud_tasks_v2beta3_queue_proto_enumTypes[1] 167} 168 169func (x Queue_Type) Number() protoreflect.EnumNumber { 170 return protoreflect.EnumNumber(x) 171} 172 173// Deprecated: Use Queue_Type.Descriptor instead. 174func (Queue_Type) EnumDescriptor() ([]byte, []int) { 175 return file_google_cloud_tasks_v2beta3_queue_proto_rawDescGZIP(), []int{0, 1} 176} 177 178// A queue is a container of related tasks. Queues are configured to manage 179// how those tasks are dispatched. Configurable properties include rate limits, 180// retry options, queue types, and others. 181type Queue struct { 182 state protoimpl.MessageState 183 sizeCache protoimpl.SizeCache 184 unknownFields protoimpl.UnknownFields 185 186 // Caller-specified and required in [CreateQueue][google.cloud.tasks.v2beta3.CloudTasks.CreateQueue], 187 // after which it becomes output only. 188 // 189 // The queue name. 190 // 191 // The queue name must have the following format: 192 // `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` 193 // 194 // * `PROJECT_ID` can contain letters ([A-Za-z]), numbers ([0-9]), 195 // hyphens (-), colons (:), or periods (.). 196 // For more information, see 197 // [Identifying 198 // projects](https://cloud.google.com/resource-manager/docs/creating-managing-projects#identifying_projects) 199 // * `LOCATION_ID` is the canonical ID for the queue's location. 200 // The list of available locations can be obtained by calling 201 // [ListLocations][google.cloud.location.Locations.ListLocations]. 202 // For more information, see https://cloud.google.com/about/locations/. 203 // * `QUEUE_ID` can contain letters ([A-Za-z]), numbers ([0-9]), or 204 // hyphens (-). The maximum length is 100 characters. 205 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 206 // Types that are assignable to QueueType: 207 // *Queue_AppEngineHttpQueue 208 QueueType isQueue_QueueType `protobuf_oneof:"queue_type"` 209 // Rate limits for task dispatches. 210 // 211 // [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are 212 // related because they both control task attempts. However they control task 213 // attempts in different ways: 214 // 215 // * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of 216 // dispatches from a queue (i.e. all traffic dispatched from the 217 // queue, regardless of whether the dispatch is from a first 218 // attempt or a retry). 219 // * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls what happens to 220 // particular a task after its first attempt fails. That is, 221 // [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the 222 // second attempt, third attempt, etc). 223 // 224 // The queue's actual dispatch rate is the result of: 225 // 226 // * Number of tasks in the queue 227 // * User-specified throttling: [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits], 228 // [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config], and the 229 // [queue's state][google.cloud.tasks.v2beta3.Queue.state]. 230 // * System throttling due to `429` (Too Many Requests) or `503` (Service 231 // Unavailable) responses from the worker, high error rates, or to smooth 232 // sudden large traffic spikes. 233 RateLimits *RateLimits `protobuf:"bytes,4,opt,name=rate_limits,json=rateLimits,proto3" json:"rate_limits,omitempty"` 234 // Settings that determine the retry behavior. 235 // 236 // * For tasks created using Cloud Tasks: the queue-level retry settings 237 // apply to all tasks in the queue that were created using Cloud Tasks. 238 // Retry settings cannot be set on individual tasks. 239 // * For tasks created using the App Engine SDK: the queue-level retry 240 // settings apply to all tasks in the queue which do not have retry settings 241 // explicitly set on the task and were created by the App Engine SDK. See 242 // [App Engine 243 // documentation](https://cloud.google.com/appengine/docs/standard/python/taskqueue/push/retrying-tasks). 244 RetryConfig *RetryConfig `protobuf:"bytes,5,opt,name=retry_config,json=retryConfig,proto3" json:"retry_config,omitempty"` 245 // Output only. The state of the queue. 246 // 247 // `state` can only be changed by called 248 // [PauseQueue][google.cloud.tasks.v2beta3.CloudTasks.PauseQueue], 249 // [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue], or uploading 250 // [queue.yaml/xml](https://cloud.google.com/appengine/docs/python/config/queueref). 251 // [UpdateQueue][google.cloud.tasks.v2beta3.CloudTasks.UpdateQueue] cannot be used to change `state`. 252 State Queue_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.tasks.v2beta3.Queue_State" json:"state,omitempty"` 253 // Output only. The last time this queue was purged. 254 // 255 // All tasks that were [created][google.cloud.tasks.v2beta3.Task.create_time] before this time 256 // were purged. 257 // 258 // A queue can be purged using [PurgeQueue][google.cloud.tasks.v2beta3.CloudTasks.PurgeQueue], the 259 // [App Engine Task Queue SDK, or the Cloud 260 // Console](https://cloud.google.com/appengine/docs/standard/python/taskqueue/push/deleting-tasks-and-queues#purging_all_tasks_from_a_queue). 261 // 262 // Purge time will be truncated to the nearest microsecond. Purge 263 // time will be unset if the queue has never been purged. 264 PurgeTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=purge_time,json=purgeTime,proto3" json:"purge_time,omitempty"` 265 // Configuration options for writing logs to 266 // [Stackdriver Logging](https://cloud.google.com/logging/docs/). If this 267 // field is unset, then no logs are written. 268 StackdriverLoggingConfig *StackdriverLoggingConfig `protobuf:"bytes,10,opt,name=stackdriver_logging_config,json=stackdriverLoggingConfig,proto3" json:"stackdriver_logging_config,omitempty"` 269 // Immutable. The type of a queue (push or pull). 270 // 271 // `Queue.type` is an immutable property of the queue that is set at the queue 272 // creation time. When left unspecified, the default value of `PUSH` is 273 // selected. 274 Type Queue_Type `protobuf:"varint,11,opt,name=type,proto3,enum=google.cloud.tasks.v2beta3.Queue_Type" json:"type,omitempty"` 275} 276 277func (x *Queue) Reset() { 278 *x = Queue{} 279 if protoimpl.UnsafeEnabled { 280 mi := &file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[0] 281 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 282 ms.StoreMessageInfo(mi) 283 } 284} 285 286func (x *Queue) String() string { 287 return protoimpl.X.MessageStringOf(x) 288} 289 290func (*Queue) ProtoMessage() {} 291 292func (x *Queue) ProtoReflect() protoreflect.Message { 293 mi := &file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[0] 294 if protoimpl.UnsafeEnabled && x != nil { 295 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 296 if ms.LoadMessageInfo() == nil { 297 ms.StoreMessageInfo(mi) 298 } 299 return ms 300 } 301 return mi.MessageOf(x) 302} 303 304// Deprecated: Use Queue.ProtoReflect.Descriptor instead. 305func (*Queue) Descriptor() ([]byte, []int) { 306 return file_google_cloud_tasks_v2beta3_queue_proto_rawDescGZIP(), []int{0} 307} 308 309func (x *Queue) GetName() string { 310 if x != nil { 311 return x.Name 312 } 313 return "" 314} 315 316func (m *Queue) GetQueueType() isQueue_QueueType { 317 if m != nil { 318 return m.QueueType 319 } 320 return nil 321} 322 323func (x *Queue) GetAppEngineHttpQueue() *AppEngineHttpQueue { 324 if x, ok := x.GetQueueType().(*Queue_AppEngineHttpQueue); ok { 325 return x.AppEngineHttpQueue 326 } 327 return nil 328} 329 330func (x *Queue) GetRateLimits() *RateLimits { 331 if x != nil { 332 return x.RateLimits 333 } 334 return nil 335} 336 337func (x *Queue) GetRetryConfig() *RetryConfig { 338 if x != nil { 339 return x.RetryConfig 340 } 341 return nil 342} 343 344func (x *Queue) GetState() Queue_State { 345 if x != nil { 346 return x.State 347 } 348 return Queue_STATE_UNSPECIFIED 349} 350 351func (x *Queue) GetPurgeTime() *timestamppb.Timestamp { 352 if x != nil { 353 return x.PurgeTime 354 } 355 return nil 356} 357 358func (x *Queue) GetStackdriverLoggingConfig() *StackdriverLoggingConfig { 359 if x != nil { 360 return x.StackdriverLoggingConfig 361 } 362 return nil 363} 364 365func (x *Queue) GetType() Queue_Type { 366 if x != nil { 367 return x.Type 368 } 369 return Queue_TYPE_UNSPECIFIED 370} 371 372type isQueue_QueueType interface { 373 isQueue_QueueType() 374} 375 376type Queue_AppEngineHttpQueue struct { 377 // [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to 378 // [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue. 379 // [Http tasks][google.cloud.tasks.v2beta3.HttpRequest] are not affected by this proto. 380 AppEngineHttpQueue *AppEngineHttpQueue `protobuf:"bytes,3,opt,name=app_engine_http_queue,json=appEngineHttpQueue,proto3,oneof"` 381} 382 383func (*Queue_AppEngineHttpQueue) isQueue_QueueType() {} 384 385// Rate limits. 386// 387// This message determines the maximum rate that tasks can be dispatched by a 388// queue, regardless of whether the dispatch is a first task attempt or a retry. 389// 390// Note: The debugging command, [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask], will run a task 391// even if the queue has reached its [RateLimits][google.cloud.tasks.v2beta3.RateLimits]. 392type RateLimits struct { 393 state protoimpl.MessageState 394 sizeCache protoimpl.SizeCache 395 unknownFields protoimpl.UnknownFields 396 397 // The maximum rate at which tasks are dispatched from this queue. 398 // 399 // If unspecified when the queue is created, Cloud Tasks will pick the 400 // default. 401 // 402 // * For [App Engine queues][google.cloud.tasks.v2beta3.AppEngineHttpQueue], the maximum allowed value 403 // is 500. 404 // 405 // 406 // This field has the same meaning as 407 // [rate in 408 // queue.yaml/xml](https://cloud.google.com/appengine/docs/standard/python/config/queueref#rate). 409 MaxDispatchesPerSecond float64 `protobuf:"fixed64,1,opt,name=max_dispatches_per_second,json=maxDispatchesPerSecond,proto3" json:"max_dispatches_per_second,omitempty"` 410 // Output only. The max burst size. 411 // 412 // Max burst size limits how fast tasks in queue are processed when 413 // many tasks are in the queue and the rate is high. This field 414 // allows the queue to have a high rate so processing starts shortly 415 // after a task is enqueued, but still limits resource usage when 416 // many tasks are enqueued in a short period of time. 417 // 418 // The [token bucket](https://wikipedia.org/wiki/Token_Bucket) 419 // algorithm is used to control the rate of task dispatches. Each 420 // queue has a token bucket that holds tokens, up to the maximum 421 // specified by `max_burst_size`. Each time a task is dispatched, a 422 // token is removed from the bucket. Tasks will be dispatched until 423 // the queue's bucket runs out of tokens. The bucket will be 424 // continuously refilled with new tokens based on 425 // [max_dispatches_per_second][google.cloud.tasks.v2beta3.RateLimits.max_dispatches_per_second]. 426 // 427 // Cloud Tasks will pick the value of `max_burst_size` based on the 428 // value of 429 // [max_dispatches_per_second][google.cloud.tasks.v2beta3.RateLimits.max_dispatches_per_second]. 430 // 431 // For App Engine queues that were created or updated using 432 // `queue.yaml/xml`, `max_burst_size` is equal to 433 // [bucket_size](https://cloud.google.com/appengine/docs/standard/python/config/queueref#bucket_size). 434 // Since `max_burst_size` is output only, if 435 // [UpdateQueue][google.cloud.tasks.v2beta3.CloudTasks.UpdateQueue] is called on a queue 436 // created by `queue.yaml/xml`, `max_burst_size` will be reset based 437 // on the value of 438 // [max_dispatches_per_second][google.cloud.tasks.v2beta3.RateLimits.max_dispatches_per_second], 439 // regardless of whether 440 // [max_dispatches_per_second][google.cloud.tasks.v2beta3.RateLimits.max_dispatches_per_second] 441 // is updated. 442 // 443 MaxBurstSize int32 `protobuf:"varint,2,opt,name=max_burst_size,json=maxBurstSize,proto3" json:"max_burst_size,omitempty"` 444 // The maximum number of concurrent tasks that Cloud Tasks allows 445 // to be dispatched for this queue. After this threshold has been 446 // reached, Cloud Tasks stops dispatching tasks until the number of 447 // concurrent requests decreases. 448 // 449 // If unspecified when the queue is created, Cloud Tasks will pick the 450 // default. 451 // 452 // 453 // The maximum allowed value is 5,000. 454 // 455 // 456 // This field has the same meaning as 457 // [max_concurrent_requests in 458 // queue.yaml/xml](https://cloud.google.com/appengine/docs/standard/python/config/queueref#max_concurrent_requests). 459 MaxConcurrentDispatches int32 `protobuf:"varint,3,opt,name=max_concurrent_dispatches,json=maxConcurrentDispatches,proto3" json:"max_concurrent_dispatches,omitempty"` 460} 461 462func (x *RateLimits) Reset() { 463 *x = RateLimits{} 464 if protoimpl.UnsafeEnabled { 465 mi := &file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[1] 466 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 467 ms.StoreMessageInfo(mi) 468 } 469} 470 471func (x *RateLimits) String() string { 472 return protoimpl.X.MessageStringOf(x) 473} 474 475func (*RateLimits) ProtoMessage() {} 476 477func (x *RateLimits) ProtoReflect() protoreflect.Message { 478 mi := &file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[1] 479 if protoimpl.UnsafeEnabled && x != nil { 480 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 481 if ms.LoadMessageInfo() == nil { 482 ms.StoreMessageInfo(mi) 483 } 484 return ms 485 } 486 return mi.MessageOf(x) 487} 488 489// Deprecated: Use RateLimits.ProtoReflect.Descriptor instead. 490func (*RateLimits) Descriptor() ([]byte, []int) { 491 return file_google_cloud_tasks_v2beta3_queue_proto_rawDescGZIP(), []int{1} 492} 493 494func (x *RateLimits) GetMaxDispatchesPerSecond() float64 { 495 if x != nil { 496 return x.MaxDispatchesPerSecond 497 } 498 return 0 499} 500 501func (x *RateLimits) GetMaxBurstSize() int32 { 502 if x != nil { 503 return x.MaxBurstSize 504 } 505 return 0 506} 507 508func (x *RateLimits) GetMaxConcurrentDispatches() int32 { 509 if x != nil { 510 return x.MaxConcurrentDispatches 511 } 512 return 0 513} 514 515// Retry config. 516// 517// These settings determine when a failed task attempt is retried. 518type RetryConfig struct { 519 state protoimpl.MessageState 520 sizeCache protoimpl.SizeCache 521 unknownFields protoimpl.UnknownFields 522 523 // Number of attempts per task. 524 // 525 // Cloud Tasks will attempt the task `max_attempts` times (that is, if the 526 // first attempt fails, then there will be `max_attempts - 1` retries). Must 527 // be >= -1. 528 // 529 // If unspecified when the queue is created, Cloud Tasks will pick the 530 // default. 531 // 532 // -1 indicates unlimited attempts. 533 // 534 // This field has the same meaning as 535 // [task_retry_limit in 536 // queue.yaml/xml](https://cloud.google.com/appengine/docs/standard/python/config/queueref#retry_parameters). 537 MaxAttempts int32 `protobuf:"varint,1,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"` 538 // If positive, `max_retry_duration` specifies the time limit for 539 // retrying a failed task, measured from when the task was first 540 // attempted. Once `max_retry_duration` time has passed *and* the 541 // task has been attempted [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] 542 // times, no further attempts will be made and the task will be 543 // deleted. 544 // 545 // If zero, then the task age is unlimited. 546 // 547 // If unspecified when the queue is created, Cloud Tasks will pick the 548 // default. 549 // 550 // 551 // `max_retry_duration` will be truncated to the nearest second. 552 // 553 // This field has the same meaning as 554 // [task_age_limit in 555 // queue.yaml/xml](https://cloud.google.com/appengine/docs/standard/python/config/queueref#retry_parameters). 556 MaxRetryDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=max_retry_duration,json=maxRetryDuration,proto3" json:"max_retry_duration,omitempty"` 557 // A task will be [scheduled][google.cloud.tasks.v2beta3.Task.schedule_time] for retry between 558 // [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff] and 559 // [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] duration after it fails, 560 // if the queue's [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig] specifies that the task should be 561 // retried. 562 // 563 // If unspecified when the queue is created, Cloud Tasks will pick the 564 // default. 565 // 566 // 567 // `min_backoff` will be truncated to the nearest second. 568 // 569 // This field has the same meaning as 570 // [min_backoff_seconds in 571 // queue.yaml/xml](https://cloud.google.com/appengine/docs/standard/python/config/queueref#retry_parameters). 572 MinBackoff *durationpb.Duration `protobuf:"bytes,3,opt,name=min_backoff,json=minBackoff,proto3" json:"min_backoff,omitempty"` 573 // A task will be [scheduled][google.cloud.tasks.v2beta3.Task.schedule_time] for retry between 574 // [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff] and 575 // [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] duration after it fails, 576 // if the queue's [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig] specifies that the task should be 577 // retried. 578 // 579 // If unspecified when the queue is created, Cloud Tasks will pick the 580 // default. 581 // 582 // 583 // `max_backoff` will be truncated to the nearest second. 584 // 585 // This field has the same meaning as 586 // [max_backoff_seconds in 587 // queue.yaml/xml](https://cloud.google.com/appengine/docs/standard/python/config/queueref#retry_parameters). 588 MaxBackoff *durationpb.Duration `protobuf:"bytes,4,opt,name=max_backoff,json=maxBackoff,proto3" json:"max_backoff,omitempty"` 589 // The time between retries will double `max_doublings` times. 590 // 591 // A task's retry interval starts at 592 // [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff], then doubles 593 // `max_doublings` times, then increases linearly, and finally 594 // retries at intervals of 595 // [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] up to 596 // [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] times. 597 // 598 // For example, if [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff] is 10s, 599 // [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] is 300s, and 600 // `max_doublings` is 3, then the a task will first be retried in 601 // 10s. The retry interval will double three times, and then 602 // increase linearly by 2^3 * 10s. Finally, the task will retry at 603 // intervals of [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] until the 604 // task has been attempted [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] 605 // times. Thus, the requests will retry at 10s, 20s, 40s, 80s, 160s, 606 // 240s, 300s, 300s, .... 607 // 608 // If unspecified when the queue is created, Cloud Tasks will pick the 609 // default. 610 // 611 // 612 // This field has the same meaning as 613 // [max_doublings in 614 // queue.yaml/xml](https://cloud.google.com/appengine/docs/standard/python/config/queueref#retry_parameters). 615 MaxDoublings int32 `protobuf:"varint,5,opt,name=max_doublings,json=maxDoublings,proto3" json:"max_doublings,omitempty"` 616} 617 618func (x *RetryConfig) Reset() { 619 *x = RetryConfig{} 620 if protoimpl.UnsafeEnabled { 621 mi := &file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[2] 622 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 623 ms.StoreMessageInfo(mi) 624 } 625} 626 627func (x *RetryConfig) String() string { 628 return protoimpl.X.MessageStringOf(x) 629} 630 631func (*RetryConfig) ProtoMessage() {} 632 633func (x *RetryConfig) ProtoReflect() protoreflect.Message { 634 mi := &file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[2] 635 if protoimpl.UnsafeEnabled && x != nil { 636 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 637 if ms.LoadMessageInfo() == nil { 638 ms.StoreMessageInfo(mi) 639 } 640 return ms 641 } 642 return mi.MessageOf(x) 643} 644 645// Deprecated: Use RetryConfig.ProtoReflect.Descriptor instead. 646func (*RetryConfig) Descriptor() ([]byte, []int) { 647 return file_google_cloud_tasks_v2beta3_queue_proto_rawDescGZIP(), []int{2} 648} 649 650func (x *RetryConfig) GetMaxAttempts() int32 { 651 if x != nil { 652 return x.MaxAttempts 653 } 654 return 0 655} 656 657func (x *RetryConfig) GetMaxRetryDuration() *durationpb.Duration { 658 if x != nil { 659 return x.MaxRetryDuration 660 } 661 return nil 662} 663 664func (x *RetryConfig) GetMinBackoff() *durationpb.Duration { 665 if x != nil { 666 return x.MinBackoff 667 } 668 return nil 669} 670 671func (x *RetryConfig) GetMaxBackoff() *durationpb.Duration { 672 if x != nil { 673 return x.MaxBackoff 674 } 675 return nil 676} 677 678func (x *RetryConfig) GetMaxDoublings() int32 { 679 if x != nil { 680 return x.MaxDoublings 681 } 682 return 0 683} 684 685// Configuration options for writing logs to 686// [Stackdriver Logging](https://cloud.google.com/logging/docs/). 687type StackdriverLoggingConfig struct { 688 state protoimpl.MessageState 689 sizeCache protoimpl.SizeCache 690 unknownFields protoimpl.UnknownFields 691 692 // Specifies the fraction of operations to write to 693 // [Stackdriver Logging](https://cloud.google.com/logging/docs/). 694 // This field may contain any value between 0.0 and 1.0, inclusive. 695 // 0.0 is the default and means that no operations are logged. 696 SamplingRatio float64 `protobuf:"fixed64,1,opt,name=sampling_ratio,json=samplingRatio,proto3" json:"sampling_ratio,omitempty"` 697} 698 699func (x *StackdriverLoggingConfig) Reset() { 700 *x = StackdriverLoggingConfig{} 701 if protoimpl.UnsafeEnabled { 702 mi := &file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[3] 703 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 704 ms.StoreMessageInfo(mi) 705 } 706} 707 708func (x *StackdriverLoggingConfig) String() string { 709 return protoimpl.X.MessageStringOf(x) 710} 711 712func (*StackdriverLoggingConfig) ProtoMessage() {} 713 714func (x *StackdriverLoggingConfig) ProtoReflect() protoreflect.Message { 715 mi := &file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[3] 716 if protoimpl.UnsafeEnabled && x != nil { 717 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 718 if ms.LoadMessageInfo() == nil { 719 ms.StoreMessageInfo(mi) 720 } 721 return ms 722 } 723 return mi.MessageOf(x) 724} 725 726// Deprecated: Use StackdriverLoggingConfig.ProtoReflect.Descriptor instead. 727func (*StackdriverLoggingConfig) Descriptor() ([]byte, []int) { 728 return file_google_cloud_tasks_v2beta3_queue_proto_rawDescGZIP(), []int{3} 729} 730 731func (x *StackdriverLoggingConfig) GetSamplingRatio() float64 { 732 if x != nil { 733 return x.SamplingRatio 734 } 735 return 0 736} 737 738var File_google_cloud_tasks_v2beta3_queue_proto protoreflect.FileDescriptor 739 740var file_google_cloud_tasks_v2beta3_queue_proto_rawDesc = []byte{ 741 0x0a, 0x26, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 742 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x71, 0x75, 0x65, 743 0x75, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 744 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 745 0x65, 0x74, 0x61, 0x33, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 746 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 747 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 748 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 749 0x1a, 0x27, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 750 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x74, 0x61, 0x72, 751 0x67, 0x65, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 752 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 753 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 754 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 755 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 756 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 757 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xa9, 0x06, 0x0a, 0x05, 0x51, 0x75, 0x65, 758 0x75, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 759 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x63, 0x0a, 0x15, 0x61, 0x70, 0x70, 0x5f, 0x65, 0x6e, 760 0x67, 0x69, 0x6e, 0x65, 0x5f, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x18, 761 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 762 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 763 0x61, 0x33, 0x2e, 0x41, 0x70, 0x70, 0x45, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x48, 0x74, 0x74, 0x70, 764 0x51, 0x75, 0x65, 0x75, 0x65, 0x48, 0x00, 0x52, 0x12, 0x61, 0x70, 0x70, 0x45, 0x6e, 0x67, 0x69, 765 0x6e, 0x65, 0x48, 0x74, 0x74, 0x70, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x47, 0x0a, 0x0b, 0x72, 766 0x61, 0x74, 0x65, 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 767 0x32, 0x26, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 768 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x61, 769 0x74, 0x65, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x73, 0x52, 0x0a, 0x72, 0x61, 0x74, 0x65, 0x4c, 0x69, 770 0x6d, 0x69, 0x74, 0x73, 0x12, 0x4a, 0x0a, 0x0c, 0x72, 0x65, 0x74, 0x72, 0x79, 0x5f, 0x63, 0x6f, 771 0x6e, 0x66, 0x69, 0x67, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 772 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 773 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x65, 0x74, 0x72, 0x79, 0x43, 0x6f, 0x6e, 774 0x66, 0x69, 0x67, 0x52, 0x0b, 0x72, 0x65, 0x74, 0x72, 0x79, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 775 0x12, 0x3d, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0e, 0x32, 776 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 777 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 778 0x75, 0x65, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x12, 779 0x39, 0x0a, 0x0a, 0x70, 0x75, 0x72, 0x67, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x07, 0x20, 780 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 781 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 782 0x09, 0x70, 0x75, 0x72, 0x67, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x72, 0x0a, 0x1a, 0x73, 0x74, 783 0x61, 0x63, 0x6b, 0x64, 0x72, 0x69, 0x76, 0x65, 0x72, 0x5f, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 784 0x67, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x34, 785 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 786 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x53, 0x74, 0x61, 0x63, 787 0x6b, 0x64, 0x72, 0x69, 0x76, 0x65, 0x72, 0x4c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x43, 0x6f, 788 0x6e, 0x66, 0x69, 0x67, 0x52, 0x18, 0x73, 0x74, 0x61, 0x63, 0x6b, 0x64, 0x72, 0x69, 0x76, 0x65, 789 0x72, 0x4c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x3f, 790 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x26, 0x2e, 0x67, 791 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 792 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x2e, 793 0x54, 0x79, 0x70, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x05, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x22, 794 0x45, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x15, 0x0a, 0x11, 0x53, 0x54, 0x41, 0x54, 795 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 796 0x0b, 0x0a, 0x07, 0x52, 0x55, 0x4e, 0x4e, 0x49, 0x4e, 0x47, 0x10, 0x01, 0x12, 0x0a, 0x0a, 0x06, 797 0x50, 0x41, 0x55, 0x53, 0x45, 0x44, 0x10, 0x02, 0x12, 0x0c, 0x0a, 0x08, 0x44, 0x49, 0x53, 0x41, 798 0x42, 0x4c, 0x45, 0x44, 0x10, 0x03, 0x22, 0x30, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 799 0x0a, 0x10, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 800 0x45, 0x44, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x50, 0x55, 0x4c, 0x4c, 0x10, 0x01, 0x12, 0x08, 801 0x0a, 0x04, 0x50, 0x55, 0x53, 0x48, 0x10, 0x02, 0x3a, 0x5c, 0xea, 0x41, 0x59, 0x0a, 0x1f, 0x63, 802 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 803 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x36, 804 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 805 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 806 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x7b, 807 0x71, 0x75, 0x65, 0x75, 0x65, 0x7d, 0x42, 0x0c, 0x0a, 0x0a, 0x71, 0x75, 0x65, 0x75, 0x65, 0x5f, 808 0x74, 0x79, 0x70, 0x65, 0x22, 0xa9, 0x01, 0x0a, 0x0a, 0x52, 0x61, 0x74, 0x65, 0x4c, 0x69, 0x6d, 809 0x69, 0x74, 0x73, 0x12, 0x39, 0x0a, 0x19, 0x6d, 0x61, 0x78, 0x5f, 0x64, 0x69, 0x73, 0x70, 0x61, 810 0x74, 0x63, 0x68, 0x65, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 811 0x18, 0x01, 0x20, 0x01, 0x28, 0x01, 0x52, 0x16, 0x6d, 0x61, 0x78, 0x44, 0x69, 0x73, 0x70, 0x61, 812 0x74, 0x63, 0x68, 0x65, 0x73, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x12, 0x24, 813 0x0a, 0x0e, 0x6d, 0x61, 0x78, 0x5f, 0x62, 0x75, 0x72, 0x73, 0x74, 0x5f, 0x73, 0x69, 0x7a, 0x65, 814 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0c, 0x6d, 0x61, 0x78, 0x42, 0x75, 0x72, 0x73, 0x74, 815 0x53, 0x69, 0x7a, 0x65, 0x12, 0x3a, 0x0a, 0x19, 0x6d, 0x61, 0x78, 0x5f, 0x63, 0x6f, 0x6e, 0x63, 816 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x5f, 0x64, 0x69, 0x73, 0x70, 0x61, 0x74, 0x63, 0x68, 0x65, 817 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x17, 0x6d, 0x61, 0x78, 0x43, 0x6f, 0x6e, 0x63, 818 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x44, 0x69, 0x73, 0x70, 0x61, 0x74, 0x63, 0x68, 0x65, 0x73, 819 0x22, 0x96, 0x02, 0x0a, 0x0b, 0x52, 0x65, 0x74, 0x72, 0x79, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 820 0x12, 0x21, 0x0a, 0x0c, 0x6d, 0x61, 0x78, 0x5f, 0x61, 0x74, 0x74, 0x65, 0x6d, 0x70, 0x74, 0x73, 821 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x6d, 0x61, 0x78, 0x41, 0x74, 0x74, 0x65, 0x6d, 822 0x70, 0x74, 0x73, 0x12, 0x47, 0x0a, 0x12, 0x6d, 0x61, 0x78, 0x5f, 0x72, 0x65, 0x74, 0x72, 0x79, 823 0x5f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 824 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 825 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x10, 0x6d, 0x61, 0x78, 0x52, 826 0x65, 0x74, 0x72, 0x79, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3a, 0x0a, 0x0b, 827 0x6d, 0x69, 0x6e, 0x5f, 0x62, 0x61, 0x63, 0x6b, 0x6f, 0x66, 0x66, 0x18, 0x03, 0x20, 0x01, 0x28, 828 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 829 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x6d, 0x69, 830 0x6e, 0x42, 0x61, 0x63, 0x6b, 0x6f, 0x66, 0x66, 0x12, 0x3a, 0x0a, 0x0b, 0x6d, 0x61, 0x78, 0x5f, 831 0x62, 0x61, 0x63, 0x6b, 0x6f, 0x66, 0x66, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 832 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 833 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x6d, 0x61, 0x78, 0x42, 0x61, 0x63, 834 0x6b, 0x6f, 0x66, 0x66, 0x12, 0x23, 0x0a, 0x0d, 0x6d, 0x61, 0x78, 0x5f, 0x64, 0x6f, 0x75, 0x62, 835 0x6c, 0x69, 0x6e, 0x67, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0c, 0x6d, 0x61, 0x78, 836 0x44, 0x6f, 0x75, 0x62, 0x6c, 0x69, 0x6e, 0x67, 0x73, 0x22, 0x41, 0x0a, 0x18, 0x53, 0x74, 0x61, 837 0x63, 0x6b, 0x64, 0x72, 0x69, 0x76, 0x65, 0x72, 0x4c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x43, 838 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x69, 0x6e, 839 0x67, 0x5f, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x01, 0x52, 0x0d, 0x73, 840 0x61, 0x6d, 0x70, 0x6c, 0x69, 0x6e, 0x67, 0x52, 0x61, 0x74, 0x69, 0x6f, 0x42, 0x6f, 0x0a, 0x1e, 841 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 842 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x42, 0x0a, 843 0x51, 0x75, 0x65, 0x75, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3f, 0x67, 0x6f, 844 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 845 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 846 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 847 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x3b, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x62, 0x06, 0x70, 848 0x72, 0x6f, 0x74, 0x6f, 0x33, 849} 850 851var ( 852 file_google_cloud_tasks_v2beta3_queue_proto_rawDescOnce sync.Once 853 file_google_cloud_tasks_v2beta3_queue_proto_rawDescData = file_google_cloud_tasks_v2beta3_queue_proto_rawDesc 854) 855 856func file_google_cloud_tasks_v2beta3_queue_proto_rawDescGZIP() []byte { 857 file_google_cloud_tasks_v2beta3_queue_proto_rawDescOnce.Do(func() { 858 file_google_cloud_tasks_v2beta3_queue_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_tasks_v2beta3_queue_proto_rawDescData) 859 }) 860 return file_google_cloud_tasks_v2beta3_queue_proto_rawDescData 861} 862 863var file_google_cloud_tasks_v2beta3_queue_proto_enumTypes = make([]protoimpl.EnumInfo, 2) 864var file_google_cloud_tasks_v2beta3_queue_proto_msgTypes = make([]protoimpl.MessageInfo, 4) 865var file_google_cloud_tasks_v2beta3_queue_proto_goTypes = []interface{}{ 866 (Queue_State)(0), // 0: google.cloud.tasks.v2beta3.Queue.State 867 (Queue_Type)(0), // 1: google.cloud.tasks.v2beta3.Queue.Type 868 (*Queue)(nil), // 2: google.cloud.tasks.v2beta3.Queue 869 (*RateLimits)(nil), // 3: google.cloud.tasks.v2beta3.RateLimits 870 (*RetryConfig)(nil), // 4: google.cloud.tasks.v2beta3.RetryConfig 871 (*StackdriverLoggingConfig)(nil), // 5: google.cloud.tasks.v2beta3.StackdriverLoggingConfig 872 (*AppEngineHttpQueue)(nil), // 6: google.cloud.tasks.v2beta3.AppEngineHttpQueue 873 (*timestamppb.Timestamp)(nil), // 7: google.protobuf.Timestamp 874 (*durationpb.Duration)(nil), // 8: google.protobuf.Duration 875} 876var file_google_cloud_tasks_v2beta3_queue_proto_depIdxs = []int32{ 877 6, // 0: google.cloud.tasks.v2beta3.Queue.app_engine_http_queue:type_name -> google.cloud.tasks.v2beta3.AppEngineHttpQueue 878 3, // 1: google.cloud.tasks.v2beta3.Queue.rate_limits:type_name -> google.cloud.tasks.v2beta3.RateLimits 879 4, // 2: google.cloud.tasks.v2beta3.Queue.retry_config:type_name -> google.cloud.tasks.v2beta3.RetryConfig 880 0, // 3: google.cloud.tasks.v2beta3.Queue.state:type_name -> google.cloud.tasks.v2beta3.Queue.State 881 7, // 4: google.cloud.tasks.v2beta3.Queue.purge_time:type_name -> google.protobuf.Timestamp 882 5, // 5: google.cloud.tasks.v2beta3.Queue.stackdriver_logging_config:type_name -> google.cloud.tasks.v2beta3.StackdriverLoggingConfig 883 1, // 6: google.cloud.tasks.v2beta3.Queue.type:type_name -> google.cloud.tasks.v2beta3.Queue.Type 884 8, // 7: google.cloud.tasks.v2beta3.RetryConfig.max_retry_duration:type_name -> google.protobuf.Duration 885 8, // 8: google.cloud.tasks.v2beta3.RetryConfig.min_backoff:type_name -> google.protobuf.Duration 886 8, // 9: google.cloud.tasks.v2beta3.RetryConfig.max_backoff:type_name -> google.protobuf.Duration 887 10, // [10:10] is the sub-list for method output_type 888 10, // [10:10] is the sub-list for method input_type 889 10, // [10:10] is the sub-list for extension type_name 890 10, // [10:10] is the sub-list for extension extendee 891 0, // [0:10] is the sub-list for field type_name 892} 893 894func init() { file_google_cloud_tasks_v2beta3_queue_proto_init() } 895func file_google_cloud_tasks_v2beta3_queue_proto_init() { 896 if File_google_cloud_tasks_v2beta3_queue_proto != nil { 897 return 898 } 899 file_google_cloud_tasks_v2beta3_target_proto_init() 900 if !protoimpl.UnsafeEnabled { 901 file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 902 switch v := v.(*Queue); i { 903 case 0: 904 return &v.state 905 case 1: 906 return &v.sizeCache 907 case 2: 908 return &v.unknownFields 909 default: 910 return nil 911 } 912 } 913 file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 914 switch v := v.(*RateLimits); i { 915 case 0: 916 return &v.state 917 case 1: 918 return &v.sizeCache 919 case 2: 920 return &v.unknownFields 921 default: 922 return nil 923 } 924 } 925 file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 926 switch v := v.(*RetryConfig); i { 927 case 0: 928 return &v.state 929 case 1: 930 return &v.sizeCache 931 case 2: 932 return &v.unknownFields 933 default: 934 return nil 935 } 936 } 937 file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 938 switch v := v.(*StackdriverLoggingConfig); i { 939 case 0: 940 return &v.state 941 case 1: 942 return &v.sizeCache 943 case 2: 944 return &v.unknownFields 945 default: 946 return nil 947 } 948 } 949 } 950 file_google_cloud_tasks_v2beta3_queue_proto_msgTypes[0].OneofWrappers = []interface{}{ 951 (*Queue_AppEngineHttpQueue)(nil), 952 } 953 type x struct{} 954 out := protoimpl.TypeBuilder{ 955 File: protoimpl.DescBuilder{ 956 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 957 RawDescriptor: file_google_cloud_tasks_v2beta3_queue_proto_rawDesc, 958 NumEnums: 2, 959 NumMessages: 4, 960 NumExtensions: 0, 961 NumServices: 0, 962 }, 963 GoTypes: file_google_cloud_tasks_v2beta3_queue_proto_goTypes, 964 DependencyIndexes: file_google_cloud_tasks_v2beta3_queue_proto_depIdxs, 965 EnumInfos: file_google_cloud_tasks_v2beta3_queue_proto_enumTypes, 966 MessageInfos: file_google_cloud_tasks_v2beta3_queue_proto_msgTypes, 967 }.Build() 968 File_google_cloud_tasks_v2beta3_queue_proto = out.File 969 file_google_cloud_tasks_v2beta3_queue_proto_rawDesc = nil 970 file_google_cloud_tasks_v2beta3_queue_proto_goTypes = nil 971 file_google_cloud_tasks_v2beta3_queue_proto_depIdxs = nil 972} 973