1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google.golang.org/appengine/internal/taskqueue/taskqueue_service.proto 3 4package taskqueue 5 6import proto "github.com/golang/protobuf/proto" 7import fmt "fmt" 8import math "math" 9import datastore "google.golang.org/appengine/internal/datastore" 10 11// Reference imports to suppress errors if they are not otherwise used. 12var _ = proto.Marshal 13var _ = fmt.Errorf 14var _ = math.Inf 15 16// This is a compile-time assertion to ensure that this generated file 17// is compatible with the proto package it is being compiled against. 18// A compilation error at this line likely means your copy of the 19// proto package needs to be updated. 20const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package 21 22type TaskQueueServiceError_ErrorCode int32 23 24const ( 25 TaskQueueServiceError_OK TaskQueueServiceError_ErrorCode = 0 26 TaskQueueServiceError_UNKNOWN_QUEUE TaskQueueServiceError_ErrorCode = 1 27 TaskQueueServiceError_TRANSIENT_ERROR TaskQueueServiceError_ErrorCode = 2 28 TaskQueueServiceError_INTERNAL_ERROR TaskQueueServiceError_ErrorCode = 3 29 TaskQueueServiceError_TASK_TOO_LARGE TaskQueueServiceError_ErrorCode = 4 30 TaskQueueServiceError_INVALID_TASK_NAME TaskQueueServiceError_ErrorCode = 5 31 TaskQueueServiceError_INVALID_QUEUE_NAME TaskQueueServiceError_ErrorCode = 6 32 TaskQueueServiceError_INVALID_URL TaskQueueServiceError_ErrorCode = 7 33 TaskQueueServiceError_INVALID_QUEUE_RATE TaskQueueServiceError_ErrorCode = 8 34 TaskQueueServiceError_PERMISSION_DENIED TaskQueueServiceError_ErrorCode = 9 35 TaskQueueServiceError_TASK_ALREADY_EXISTS TaskQueueServiceError_ErrorCode = 10 36 TaskQueueServiceError_TOMBSTONED_TASK TaskQueueServiceError_ErrorCode = 11 37 TaskQueueServiceError_INVALID_ETA TaskQueueServiceError_ErrorCode = 12 38 TaskQueueServiceError_INVALID_REQUEST TaskQueueServiceError_ErrorCode = 13 39 TaskQueueServiceError_UNKNOWN_TASK TaskQueueServiceError_ErrorCode = 14 40 TaskQueueServiceError_TOMBSTONED_QUEUE TaskQueueServiceError_ErrorCode = 15 41 TaskQueueServiceError_DUPLICATE_TASK_NAME TaskQueueServiceError_ErrorCode = 16 42 TaskQueueServiceError_SKIPPED TaskQueueServiceError_ErrorCode = 17 43 TaskQueueServiceError_TOO_MANY_TASKS TaskQueueServiceError_ErrorCode = 18 44 TaskQueueServiceError_INVALID_PAYLOAD TaskQueueServiceError_ErrorCode = 19 45 TaskQueueServiceError_INVALID_RETRY_PARAMETERS TaskQueueServiceError_ErrorCode = 20 46 TaskQueueServiceError_INVALID_QUEUE_MODE TaskQueueServiceError_ErrorCode = 21 47 TaskQueueServiceError_ACL_LOOKUP_ERROR TaskQueueServiceError_ErrorCode = 22 48 TaskQueueServiceError_TRANSACTIONAL_REQUEST_TOO_LARGE TaskQueueServiceError_ErrorCode = 23 49 TaskQueueServiceError_INCORRECT_CREATOR_NAME TaskQueueServiceError_ErrorCode = 24 50 TaskQueueServiceError_TASK_LEASE_EXPIRED TaskQueueServiceError_ErrorCode = 25 51 TaskQueueServiceError_QUEUE_PAUSED TaskQueueServiceError_ErrorCode = 26 52 TaskQueueServiceError_INVALID_TAG TaskQueueServiceError_ErrorCode = 27 53 // Reserved range for the Datastore error codes. 54 // Original Datastore error code is shifted by DATASTORE_ERROR offset. 55 TaskQueueServiceError_DATASTORE_ERROR TaskQueueServiceError_ErrorCode = 10000 56) 57 58var TaskQueueServiceError_ErrorCode_name = map[int32]string{ 59 0: "OK", 60 1: "UNKNOWN_QUEUE", 61 2: "TRANSIENT_ERROR", 62 3: "INTERNAL_ERROR", 63 4: "TASK_TOO_LARGE", 64 5: "INVALID_TASK_NAME", 65 6: "INVALID_QUEUE_NAME", 66 7: "INVALID_URL", 67 8: "INVALID_QUEUE_RATE", 68 9: "PERMISSION_DENIED", 69 10: "TASK_ALREADY_EXISTS", 70 11: "TOMBSTONED_TASK", 71 12: "INVALID_ETA", 72 13: "INVALID_REQUEST", 73 14: "UNKNOWN_TASK", 74 15: "TOMBSTONED_QUEUE", 75 16: "DUPLICATE_TASK_NAME", 76 17: "SKIPPED", 77 18: "TOO_MANY_TASKS", 78 19: "INVALID_PAYLOAD", 79 20: "INVALID_RETRY_PARAMETERS", 80 21: "INVALID_QUEUE_MODE", 81 22: "ACL_LOOKUP_ERROR", 82 23: "TRANSACTIONAL_REQUEST_TOO_LARGE", 83 24: "INCORRECT_CREATOR_NAME", 84 25: "TASK_LEASE_EXPIRED", 85 26: "QUEUE_PAUSED", 86 27: "INVALID_TAG", 87 10000: "DATASTORE_ERROR", 88} 89var TaskQueueServiceError_ErrorCode_value = map[string]int32{ 90 "OK": 0, 91 "UNKNOWN_QUEUE": 1, 92 "TRANSIENT_ERROR": 2, 93 "INTERNAL_ERROR": 3, 94 "TASK_TOO_LARGE": 4, 95 "INVALID_TASK_NAME": 5, 96 "INVALID_QUEUE_NAME": 6, 97 "INVALID_URL": 7, 98 "INVALID_QUEUE_RATE": 8, 99 "PERMISSION_DENIED": 9, 100 "TASK_ALREADY_EXISTS": 10, 101 "TOMBSTONED_TASK": 11, 102 "INVALID_ETA": 12, 103 "INVALID_REQUEST": 13, 104 "UNKNOWN_TASK": 14, 105 "TOMBSTONED_QUEUE": 15, 106 "DUPLICATE_TASK_NAME": 16, 107 "SKIPPED": 17, 108 "TOO_MANY_TASKS": 18, 109 "INVALID_PAYLOAD": 19, 110 "INVALID_RETRY_PARAMETERS": 20, 111 "INVALID_QUEUE_MODE": 21, 112 "ACL_LOOKUP_ERROR": 22, 113 "TRANSACTIONAL_REQUEST_TOO_LARGE": 23, 114 "INCORRECT_CREATOR_NAME": 24, 115 "TASK_LEASE_EXPIRED": 25, 116 "QUEUE_PAUSED": 26, 117 "INVALID_TAG": 27, 118 "DATASTORE_ERROR": 10000, 119} 120 121func (x TaskQueueServiceError_ErrorCode) Enum() *TaskQueueServiceError_ErrorCode { 122 p := new(TaskQueueServiceError_ErrorCode) 123 *p = x 124 return p 125} 126func (x TaskQueueServiceError_ErrorCode) String() string { 127 return proto.EnumName(TaskQueueServiceError_ErrorCode_name, int32(x)) 128} 129func (x *TaskQueueServiceError_ErrorCode) UnmarshalJSON(data []byte) error { 130 value, err := proto.UnmarshalJSONEnum(TaskQueueServiceError_ErrorCode_value, data, "TaskQueueServiceError_ErrorCode") 131 if err != nil { 132 return err 133 } 134 *x = TaskQueueServiceError_ErrorCode(value) 135 return nil 136} 137func (TaskQueueServiceError_ErrorCode) EnumDescriptor() ([]byte, []int) { 138 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{0, 0} 139} 140 141type TaskQueueMode_Mode int32 142 143const ( 144 TaskQueueMode_PUSH TaskQueueMode_Mode = 0 145 TaskQueueMode_PULL TaskQueueMode_Mode = 1 146) 147 148var TaskQueueMode_Mode_name = map[int32]string{ 149 0: "PUSH", 150 1: "PULL", 151} 152var TaskQueueMode_Mode_value = map[string]int32{ 153 "PUSH": 0, 154 "PULL": 1, 155} 156 157func (x TaskQueueMode_Mode) Enum() *TaskQueueMode_Mode { 158 p := new(TaskQueueMode_Mode) 159 *p = x 160 return p 161} 162func (x TaskQueueMode_Mode) String() string { 163 return proto.EnumName(TaskQueueMode_Mode_name, int32(x)) 164} 165func (x *TaskQueueMode_Mode) UnmarshalJSON(data []byte) error { 166 value, err := proto.UnmarshalJSONEnum(TaskQueueMode_Mode_value, data, "TaskQueueMode_Mode") 167 if err != nil { 168 return err 169 } 170 *x = TaskQueueMode_Mode(value) 171 return nil 172} 173func (TaskQueueMode_Mode) EnumDescriptor() ([]byte, []int) { 174 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{5, 0} 175} 176 177type TaskQueueAddRequest_RequestMethod int32 178 179const ( 180 TaskQueueAddRequest_GET TaskQueueAddRequest_RequestMethod = 1 181 TaskQueueAddRequest_POST TaskQueueAddRequest_RequestMethod = 2 182 TaskQueueAddRequest_HEAD TaskQueueAddRequest_RequestMethod = 3 183 TaskQueueAddRequest_PUT TaskQueueAddRequest_RequestMethod = 4 184 TaskQueueAddRequest_DELETE TaskQueueAddRequest_RequestMethod = 5 185) 186 187var TaskQueueAddRequest_RequestMethod_name = map[int32]string{ 188 1: "GET", 189 2: "POST", 190 3: "HEAD", 191 4: "PUT", 192 5: "DELETE", 193} 194var TaskQueueAddRequest_RequestMethod_value = map[string]int32{ 195 "GET": 1, 196 "POST": 2, 197 "HEAD": 3, 198 "PUT": 4, 199 "DELETE": 5, 200} 201 202func (x TaskQueueAddRequest_RequestMethod) Enum() *TaskQueueAddRequest_RequestMethod { 203 p := new(TaskQueueAddRequest_RequestMethod) 204 *p = x 205 return p 206} 207func (x TaskQueueAddRequest_RequestMethod) String() string { 208 return proto.EnumName(TaskQueueAddRequest_RequestMethod_name, int32(x)) 209} 210func (x *TaskQueueAddRequest_RequestMethod) UnmarshalJSON(data []byte) error { 211 value, err := proto.UnmarshalJSONEnum(TaskQueueAddRequest_RequestMethod_value, data, "TaskQueueAddRequest_RequestMethod") 212 if err != nil { 213 return err 214 } 215 *x = TaskQueueAddRequest_RequestMethod(value) 216 return nil 217} 218func (TaskQueueAddRequest_RequestMethod) EnumDescriptor() ([]byte, []int) { 219 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{6, 0} 220} 221 222type TaskQueueQueryTasksResponse_Task_RequestMethod int32 223 224const ( 225 TaskQueueQueryTasksResponse_Task_GET TaskQueueQueryTasksResponse_Task_RequestMethod = 1 226 TaskQueueQueryTasksResponse_Task_POST TaskQueueQueryTasksResponse_Task_RequestMethod = 2 227 TaskQueueQueryTasksResponse_Task_HEAD TaskQueueQueryTasksResponse_Task_RequestMethod = 3 228 TaskQueueQueryTasksResponse_Task_PUT TaskQueueQueryTasksResponse_Task_RequestMethod = 4 229 TaskQueueQueryTasksResponse_Task_DELETE TaskQueueQueryTasksResponse_Task_RequestMethod = 5 230) 231 232var TaskQueueQueryTasksResponse_Task_RequestMethod_name = map[int32]string{ 233 1: "GET", 234 2: "POST", 235 3: "HEAD", 236 4: "PUT", 237 5: "DELETE", 238} 239var TaskQueueQueryTasksResponse_Task_RequestMethod_value = map[string]int32{ 240 "GET": 1, 241 "POST": 2, 242 "HEAD": 3, 243 "PUT": 4, 244 "DELETE": 5, 245} 246 247func (x TaskQueueQueryTasksResponse_Task_RequestMethod) Enum() *TaskQueueQueryTasksResponse_Task_RequestMethod { 248 p := new(TaskQueueQueryTasksResponse_Task_RequestMethod) 249 *p = x 250 return p 251} 252func (x TaskQueueQueryTasksResponse_Task_RequestMethod) String() string { 253 return proto.EnumName(TaskQueueQueryTasksResponse_Task_RequestMethod_name, int32(x)) 254} 255func (x *TaskQueueQueryTasksResponse_Task_RequestMethod) UnmarshalJSON(data []byte) error { 256 value, err := proto.UnmarshalJSONEnum(TaskQueueQueryTasksResponse_Task_RequestMethod_value, data, "TaskQueueQueryTasksResponse_Task_RequestMethod") 257 if err != nil { 258 return err 259 } 260 *x = TaskQueueQueryTasksResponse_Task_RequestMethod(value) 261 return nil 262} 263func (TaskQueueQueryTasksResponse_Task_RequestMethod) EnumDescriptor() ([]byte, []int) { 264 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{30, 0, 0} 265} 266 267type TaskQueueServiceError struct { 268 XXX_NoUnkeyedLiteral struct{} `json:"-"` 269 XXX_unrecognized []byte `json:"-"` 270 XXX_sizecache int32 `json:"-"` 271} 272 273func (m *TaskQueueServiceError) Reset() { *m = TaskQueueServiceError{} } 274func (m *TaskQueueServiceError) String() string { return proto.CompactTextString(m) } 275func (*TaskQueueServiceError) ProtoMessage() {} 276func (*TaskQueueServiceError) Descriptor() ([]byte, []int) { 277 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{0} 278} 279func (m *TaskQueueServiceError) XXX_Unmarshal(b []byte) error { 280 return xxx_messageInfo_TaskQueueServiceError.Unmarshal(m, b) 281} 282func (m *TaskQueueServiceError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 283 return xxx_messageInfo_TaskQueueServiceError.Marshal(b, m, deterministic) 284} 285func (dst *TaskQueueServiceError) XXX_Merge(src proto.Message) { 286 xxx_messageInfo_TaskQueueServiceError.Merge(dst, src) 287} 288func (m *TaskQueueServiceError) XXX_Size() int { 289 return xxx_messageInfo_TaskQueueServiceError.Size(m) 290} 291func (m *TaskQueueServiceError) XXX_DiscardUnknown() { 292 xxx_messageInfo_TaskQueueServiceError.DiscardUnknown(m) 293} 294 295var xxx_messageInfo_TaskQueueServiceError proto.InternalMessageInfo 296 297type TaskPayload struct { 298 XXX_NoUnkeyedLiteral struct{} `json:"-"` 299 proto.XXX_InternalExtensions `protobuf_messageset:"1" json:"-"` 300 XXX_unrecognized []byte `json:"-"` 301 XXX_sizecache int32 `json:"-"` 302} 303 304func (m *TaskPayload) Reset() { *m = TaskPayload{} } 305func (m *TaskPayload) String() string { return proto.CompactTextString(m) } 306func (*TaskPayload) ProtoMessage() {} 307func (*TaskPayload) Descriptor() ([]byte, []int) { 308 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{1} 309} 310 311func (m *TaskPayload) MarshalJSON() ([]byte, error) { 312 return proto.MarshalMessageSetJSON(&m.XXX_InternalExtensions) 313} 314func (m *TaskPayload) UnmarshalJSON(buf []byte) error { 315 return proto.UnmarshalMessageSetJSON(buf, &m.XXX_InternalExtensions) 316} 317 318var extRange_TaskPayload = []proto.ExtensionRange{ 319 {Start: 10, End: 2147483646}, 320} 321 322func (*TaskPayload) ExtensionRangeArray() []proto.ExtensionRange { 323 return extRange_TaskPayload 324} 325func (m *TaskPayload) XXX_Unmarshal(b []byte) error { 326 return xxx_messageInfo_TaskPayload.Unmarshal(m, b) 327} 328func (m *TaskPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 329 return xxx_messageInfo_TaskPayload.Marshal(b, m, deterministic) 330} 331func (dst *TaskPayload) XXX_Merge(src proto.Message) { 332 xxx_messageInfo_TaskPayload.Merge(dst, src) 333} 334func (m *TaskPayload) XXX_Size() int { 335 return xxx_messageInfo_TaskPayload.Size(m) 336} 337func (m *TaskPayload) XXX_DiscardUnknown() { 338 xxx_messageInfo_TaskPayload.DiscardUnknown(m) 339} 340 341var xxx_messageInfo_TaskPayload proto.InternalMessageInfo 342 343type TaskQueueRetryParameters struct { 344 RetryLimit *int32 `protobuf:"varint,1,opt,name=retry_limit,json=retryLimit" json:"retry_limit,omitempty"` 345 AgeLimitSec *int64 `protobuf:"varint,2,opt,name=age_limit_sec,json=ageLimitSec" json:"age_limit_sec,omitempty"` 346 MinBackoffSec *float64 `protobuf:"fixed64,3,opt,name=min_backoff_sec,json=minBackoffSec,def=0.1" json:"min_backoff_sec,omitempty"` 347 MaxBackoffSec *float64 `protobuf:"fixed64,4,opt,name=max_backoff_sec,json=maxBackoffSec,def=3600" json:"max_backoff_sec,omitempty"` 348 MaxDoublings *int32 `protobuf:"varint,5,opt,name=max_doublings,json=maxDoublings,def=16" json:"max_doublings,omitempty"` 349 XXX_NoUnkeyedLiteral struct{} `json:"-"` 350 XXX_unrecognized []byte `json:"-"` 351 XXX_sizecache int32 `json:"-"` 352} 353 354func (m *TaskQueueRetryParameters) Reset() { *m = TaskQueueRetryParameters{} } 355func (m *TaskQueueRetryParameters) String() string { return proto.CompactTextString(m) } 356func (*TaskQueueRetryParameters) ProtoMessage() {} 357func (*TaskQueueRetryParameters) Descriptor() ([]byte, []int) { 358 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{2} 359} 360func (m *TaskQueueRetryParameters) XXX_Unmarshal(b []byte) error { 361 return xxx_messageInfo_TaskQueueRetryParameters.Unmarshal(m, b) 362} 363func (m *TaskQueueRetryParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 364 return xxx_messageInfo_TaskQueueRetryParameters.Marshal(b, m, deterministic) 365} 366func (dst *TaskQueueRetryParameters) XXX_Merge(src proto.Message) { 367 xxx_messageInfo_TaskQueueRetryParameters.Merge(dst, src) 368} 369func (m *TaskQueueRetryParameters) XXX_Size() int { 370 return xxx_messageInfo_TaskQueueRetryParameters.Size(m) 371} 372func (m *TaskQueueRetryParameters) XXX_DiscardUnknown() { 373 xxx_messageInfo_TaskQueueRetryParameters.DiscardUnknown(m) 374} 375 376var xxx_messageInfo_TaskQueueRetryParameters proto.InternalMessageInfo 377 378const Default_TaskQueueRetryParameters_MinBackoffSec float64 = 0.1 379const Default_TaskQueueRetryParameters_MaxBackoffSec float64 = 3600 380const Default_TaskQueueRetryParameters_MaxDoublings int32 = 16 381 382func (m *TaskQueueRetryParameters) GetRetryLimit() int32 { 383 if m != nil && m.RetryLimit != nil { 384 return *m.RetryLimit 385 } 386 return 0 387} 388 389func (m *TaskQueueRetryParameters) GetAgeLimitSec() int64 { 390 if m != nil && m.AgeLimitSec != nil { 391 return *m.AgeLimitSec 392 } 393 return 0 394} 395 396func (m *TaskQueueRetryParameters) GetMinBackoffSec() float64 { 397 if m != nil && m.MinBackoffSec != nil { 398 return *m.MinBackoffSec 399 } 400 return Default_TaskQueueRetryParameters_MinBackoffSec 401} 402 403func (m *TaskQueueRetryParameters) GetMaxBackoffSec() float64 { 404 if m != nil && m.MaxBackoffSec != nil { 405 return *m.MaxBackoffSec 406 } 407 return Default_TaskQueueRetryParameters_MaxBackoffSec 408} 409 410func (m *TaskQueueRetryParameters) GetMaxDoublings() int32 { 411 if m != nil && m.MaxDoublings != nil { 412 return *m.MaxDoublings 413 } 414 return Default_TaskQueueRetryParameters_MaxDoublings 415} 416 417type TaskQueueAcl struct { 418 UserEmail [][]byte `protobuf:"bytes,1,rep,name=user_email,json=userEmail" json:"user_email,omitempty"` 419 WriterEmail [][]byte `protobuf:"bytes,2,rep,name=writer_email,json=writerEmail" json:"writer_email,omitempty"` 420 XXX_NoUnkeyedLiteral struct{} `json:"-"` 421 XXX_unrecognized []byte `json:"-"` 422 XXX_sizecache int32 `json:"-"` 423} 424 425func (m *TaskQueueAcl) Reset() { *m = TaskQueueAcl{} } 426func (m *TaskQueueAcl) String() string { return proto.CompactTextString(m) } 427func (*TaskQueueAcl) ProtoMessage() {} 428func (*TaskQueueAcl) Descriptor() ([]byte, []int) { 429 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{3} 430} 431func (m *TaskQueueAcl) XXX_Unmarshal(b []byte) error { 432 return xxx_messageInfo_TaskQueueAcl.Unmarshal(m, b) 433} 434func (m *TaskQueueAcl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 435 return xxx_messageInfo_TaskQueueAcl.Marshal(b, m, deterministic) 436} 437func (dst *TaskQueueAcl) XXX_Merge(src proto.Message) { 438 xxx_messageInfo_TaskQueueAcl.Merge(dst, src) 439} 440func (m *TaskQueueAcl) XXX_Size() int { 441 return xxx_messageInfo_TaskQueueAcl.Size(m) 442} 443func (m *TaskQueueAcl) XXX_DiscardUnknown() { 444 xxx_messageInfo_TaskQueueAcl.DiscardUnknown(m) 445} 446 447var xxx_messageInfo_TaskQueueAcl proto.InternalMessageInfo 448 449func (m *TaskQueueAcl) GetUserEmail() [][]byte { 450 if m != nil { 451 return m.UserEmail 452 } 453 return nil 454} 455 456func (m *TaskQueueAcl) GetWriterEmail() [][]byte { 457 if m != nil { 458 return m.WriterEmail 459 } 460 return nil 461} 462 463type TaskQueueHttpHeader struct { 464 Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` 465 Value []byte `protobuf:"bytes,2,req,name=value" json:"value,omitempty"` 466 XXX_NoUnkeyedLiteral struct{} `json:"-"` 467 XXX_unrecognized []byte `json:"-"` 468 XXX_sizecache int32 `json:"-"` 469} 470 471func (m *TaskQueueHttpHeader) Reset() { *m = TaskQueueHttpHeader{} } 472func (m *TaskQueueHttpHeader) String() string { return proto.CompactTextString(m) } 473func (*TaskQueueHttpHeader) ProtoMessage() {} 474func (*TaskQueueHttpHeader) Descriptor() ([]byte, []int) { 475 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{4} 476} 477func (m *TaskQueueHttpHeader) XXX_Unmarshal(b []byte) error { 478 return xxx_messageInfo_TaskQueueHttpHeader.Unmarshal(m, b) 479} 480func (m *TaskQueueHttpHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 481 return xxx_messageInfo_TaskQueueHttpHeader.Marshal(b, m, deterministic) 482} 483func (dst *TaskQueueHttpHeader) XXX_Merge(src proto.Message) { 484 xxx_messageInfo_TaskQueueHttpHeader.Merge(dst, src) 485} 486func (m *TaskQueueHttpHeader) XXX_Size() int { 487 return xxx_messageInfo_TaskQueueHttpHeader.Size(m) 488} 489func (m *TaskQueueHttpHeader) XXX_DiscardUnknown() { 490 xxx_messageInfo_TaskQueueHttpHeader.DiscardUnknown(m) 491} 492 493var xxx_messageInfo_TaskQueueHttpHeader proto.InternalMessageInfo 494 495func (m *TaskQueueHttpHeader) GetKey() []byte { 496 if m != nil { 497 return m.Key 498 } 499 return nil 500} 501 502func (m *TaskQueueHttpHeader) GetValue() []byte { 503 if m != nil { 504 return m.Value 505 } 506 return nil 507} 508 509type TaskQueueMode struct { 510 XXX_NoUnkeyedLiteral struct{} `json:"-"` 511 XXX_unrecognized []byte `json:"-"` 512 XXX_sizecache int32 `json:"-"` 513} 514 515func (m *TaskQueueMode) Reset() { *m = TaskQueueMode{} } 516func (m *TaskQueueMode) String() string { return proto.CompactTextString(m) } 517func (*TaskQueueMode) ProtoMessage() {} 518func (*TaskQueueMode) Descriptor() ([]byte, []int) { 519 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{5} 520} 521func (m *TaskQueueMode) XXX_Unmarshal(b []byte) error { 522 return xxx_messageInfo_TaskQueueMode.Unmarshal(m, b) 523} 524func (m *TaskQueueMode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 525 return xxx_messageInfo_TaskQueueMode.Marshal(b, m, deterministic) 526} 527func (dst *TaskQueueMode) XXX_Merge(src proto.Message) { 528 xxx_messageInfo_TaskQueueMode.Merge(dst, src) 529} 530func (m *TaskQueueMode) XXX_Size() int { 531 return xxx_messageInfo_TaskQueueMode.Size(m) 532} 533func (m *TaskQueueMode) XXX_DiscardUnknown() { 534 xxx_messageInfo_TaskQueueMode.DiscardUnknown(m) 535} 536 537var xxx_messageInfo_TaskQueueMode proto.InternalMessageInfo 538 539type TaskQueueAddRequest struct { 540 QueueName []byte `protobuf:"bytes,1,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 541 TaskName []byte `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"` 542 EtaUsec *int64 `protobuf:"varint,3,req,name=eta_usec,json=etaUsec" json:"eta_usec,omitempty"` 543 Method *TaskQueueAddRequest_RequestMethod `protobuf:"varint,5,opt,name=method,enum=appengine.TaskQueueAddRequest_RequestMethod,def=2" json:"method,omitempty"` 544 Url []byte `protobuf:"bytes,4,opt,name=url" json:"url,omitempty"` 545 Header []*TaskQueueAddRequest_Header `protobuf:"group,6,rep,name=Header,json=header" json:"header,omitempty"` 546 Body []byte `protobuf:"bytes,9,opt,name=body" json:"body,omitempty"` 547 Transaction *datastore.Transaction `protobuf:"bytes,10,opt,name=transaction" json:"transaction,omitempty"` 548 AppId []byte `protobuf:"bytes,11,opt,name=app_id,json=appId" json:"app_id,omitempty"` 549 Crontimetable *TaskQueueAddRequest_CronTimetable `protobuf:"group,12,opt,name=CronTimetable,json=crontimetable" json:"crontimetable,omitempty"` 550 Description []byte `protobuf:"bytes,15,opt,name=description" json:"description,omitempty"` 551 Payload *TaskPayload `protobuf:"bytes,16,opt,name=payload" json:"payload,omitempty"` 552 RetryParameters *TaskQueueRetryParameters `protobuf:"bytes,17,opt,name=retry_parameters,json=retryParameters" json:"retry_parameters,omitempty"` 553 Mode *TaskQueueMode_Mode `protobuf:"varint,18,opt,name=mode,enum=appengine.TaskQueueMode_Mode,def=0" json:"mode,omitempty"` 554 Tag []byte `protobuf:"bytes,19,opt,name=tag" json:"tag,omitempty"` 555 XXX_NoUnkeyedLiteral struct{} `json:"-"` 556 XXX_unrecognized []byte `json:"-"` 557 XXX_sizecache int32 `json:"-"` 558} 559 560func (m *TaskQueueAddRequest) Reset() { *m = TaskQueueAddRequest{} } 561func (m *TaskQueueAddRequest) String() string { return proto.CompactTextString(m) } 562func (*TaskQueueAddRequest) ProtoMessage() {} 563func (*TaskQueueAddRequest) Descriptor() ([]byte, []int) { 564 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{6} 565} 566func (m *TaskQueueAddRequest) XXX_Unmarshal(b []byte) error { 567 return xxx_messageInfo_TaskQueueAddRequest.Unmarshal(m, b) 568} 569func (m *TaskQueueAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 570 return xxx_messageInfo_TaskQueueAddRequest.Marshal(b, m, deterministic) 571} 572func (dst *TaskQueueAddRequest) XXX_Merge(src proto.Message) { 573 xxx_messageInfo_TaskQueueAddRequest.Merge(dst, src) 574} 575func (m *TaskQueueAddRequest) XXX_Size() int { 576 return xxx_messageInfo_TaskQueueAddRequest.Size(m) 577} 578func (m *TaskQueueAddRequest) XXX_DiscardUnknown() { 579 xxx_messageInfo_TaskQueueAddRequest.DiscardUnknown(m) 580} 581 582var xxx_messageInfo_TaskQueueAddRequest proto.InternalMessageInfo 583 584const Default_TaskQueueAddRequest_Method TaskQueueAddRequest_RequestMethod = TaskQueueAddRequest_POST 585const Default_TaskQueueAddRequest_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH 586 587func (m *TaskQueueAddRequest) GetQueueName() []byte { 588 if m != nil { 589 return m.QueueName 590 } 591 return nil 592} 593 594func (m *TaskQueueAddRequest) GetTaskName() []byte { 595 if m != nil { 596 return m.TaskName 597 } 598 return nil 599} 600 601func (m *TaskQueueAddRequest) GetEtaUsec() int64 { 602 if m != nil && m.EtaUsec != nil { 603 return *m.EtaUsec 604 } 605 return 0 606} 607 608func (m *TaskQueueAddRequest) GetMethod() TaskQueueAddRequest_RequestMethod { 609 if m != nil && m.Method != nil { 610 return *m.Method 611 } 612 return Default_TaskQueueAddRequest_Method 613} 614 615func (m *TaskQueueAddRequest) GetUrl() []byte { 616 if m != nil { 617 return m.Url 618 } 619 return nil 620} 621 622func (m *TaskQueueAddRequest) GetHeader() []*TaskQueueAddRequest_Header { 623 if m != nil { 624 return m.Header 625 } 626 return nil 627} 628 629func (m *TaskQueueAddRequest) GetBody() []byte { 630 if m != nil { 631 return m.Body 632 } 633 return nil 634} 635 636func (m *TaskQueueAddRequest) GetTransaction() *datastore.Transaction { 637 if m != nil { 638 return m.Transaction 639 } 640 return nil 641} 642 643func (m *TaskQueueAddRequest) GetAppId() []byte { 644 if m != nil { 645 return m.AppId 646 } 647 return nil 648} 649 650func (m *TaskQueueAddRequest) GetCrontimetable() *TaskQueueAddRequest_CronTimetable { 651 if m != nil { 652 return m.Crontimetable 653 } 654 return nil 655} 656 657func (m *TaskQueueAddRequest) GetDescription() []byte { 658 if m != nil { 659 return m.Description 660 } 661 return nil 662} 663 664func (m *TaskQueueAddRequest) GetPayload() *TaskPayload { 665 if m != nil { 666 return m.Payload 667 } 668 return nil 669} 670 671func (m *TaskQueueAddRequest) GetRetryParameters() *TaskQueueRetryParameters { 672 if m != nil { 673 return m.RetryParameters 674 } 675 return nil 676} 677 678func (m *TaskQueueAddRequest) GetMode() TaskQueueMode_Mode { 679 if m != nil && m.Mode != nil { 680 return *m.Mode 681 } 682 return Default_TaskQueueAddRequest_Mode 683} 684 685func (m *TaskQueueAddRequest) GetTag() []byte { 686 if m != nil { 687 return m.Tag 688 } 689 return nil 690} 691 692type TaskQueueAddRequest_Header struct { 693 Key []byte `protobuf:"bytes,7,req,name=key" json:"key,omitempty"` 694 Value []byte `protobuf:"bytes,8,req,name=value" json:"value,omitempty"` 695 XXX_NoUnkeyedLiteral struct{} `json:"-"` 696 XXX_unrecognized []byte `json:"-"` 697 XXX_sizecache int32 `json:"-"` 698} 699 700func (m *TaskQueueAddRequest_Header) Reset() { *m = TaskQueueAddRequest_Header{} } 701func (m *TaskQueueAddRequest_Header) String() string { return proto.CompactTextString(m) } 702func (*TaskQueueAddRequest_Header) ProtoMessage() {} 703func (*TaskQueueAddRequest_Header) Descriptor() ([]byte, []int) { 704 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{6, 0} 705} 706func (m *TaskQueueAddRequest_Header) XXX_Unmarshal(b []byte) error { 707 return xxx_messageInfo_TaskQueueAddRequest_Header.Unmarshal(m, b) 708} 709func (m *TaskQueueAddRequest_Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 710 return xxx_messageInfo_TaskQueueAddRequest_Header.Marshal(b, m, deterministic) 711} 712func (dst *TaskQueueAddRequest_Header) XXX_Merge(src proto.Message) { 713 xxx_messageInfo_TaskQueueAddRequest_Header.Merge(dst, src) 714} 715func (m *TaskQueueAddRequest_Header) XXX_Size() int { 716 return xxx_messageInfo_TaskQueueAddRequest_Header.Size(m) 717} 718func (m *TaskQueueAddRequest_Header) XXX_DiscardUnknown() { 719 xxx_messageInfo_TaskQueueAddRequest_Header.DiscardUnknown(m) 720} 721 722var xxx_messageInfo_TaskQueueAddRequest_Header proto.InternalMessageInfo 723 724func (m *TaskQueueAddRequest_Header) GetKey() []byte { 725 if m != nil { 726 return m.Key 727 } 728 return nil 729} 730 731func (m *TaskQueueAddRequest_Header) GetValue() []byte { 732 if m != nil { 733 return m.Value 734 } 735 return nil 736} 737 738type TaskQueueAddRequest_CronTimetable struct { 739 Schedule []byte `protobuf:"bytes,13,req,name=schedule" json:"schedule,omitempty"` 740 Timezone []byte `protobuf:"bytes,14,req,name=timezone" json:"timezone,omitempty"` 741 XXX_NoUnkeyedLiteral struct{} `json:"-"` 742 XXX_unrecognized []byte `json:"-"` 743 XXX_sizecache int32 `json:"-"` 744} 745 746func (m *TaskQueueAddRequest_CronTimetable) Reset() { *m = TaskQueueAddRequest_CronTimetable{} } 747func (m *TaskQueueAddRequest_CronTimetable) String() string { return proto.CompactTextString(m) } 748func (*TaskQueueAddRequest_CronTimetable) ProtoMessage() {} 749func (*TaskQueueAddRequest_CronTimetable) Descriptor() ([]byte, []int) { 750 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{6, 1} 751} 752func (m *TaskQueueAddRequest_CronTimetable) XXX_Unmarshal(b []byte) error { 753 return xxx_messageInfo_TaskQueueAddRequest_CronTimetable.Unmarshal(m, b) 754} 755func (m *TaskQueueAddRequest_CronTimetable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 756 return xxx_messageInfo_TaskQueueAddRequest_CronTimetable.Marshal(b, m, deterministic) 757} 758func (dst *TaskQueueAddRequest_CronTimetable) XXX_Merge(src proto.Message) { 759 xxx_messageInfo_TaskQueueAddRequest_CronTimetable.Merge(dst, src) 760} 761func (m *TaskQueueAddRequest_CronTimetable) XXX_Size() int { 762 return xxx_messageInfo_TaskQueueAddRequest_CronTimetable.Size(m) 763} 764func (m *TaskQueueAddRequest_CronTimetable) XXX_DiscardUnknown() { 765 xxx_messageInfo_TaskQueueAddRequest_CronTimetable.DiscardUnknown(m) 766} 767 768var xxx_messageInfo_TaskQueueAddRequest_CronTimetable proto.InternalMessageInfo 769 770func (m *TaskQueueAddRequest_CronTimetable) GetSchedule() []byte { 771 if m != nil { 772 return m.Schedule 773 } 774 return nil 775} 776 777func (m *TaskQueueAddRequest_CronTimetable) GetTimezone() []byte { 778 if m != nil { 779 return m.Timezone 780 } 781 return nil 782} 783 784type TaskQueueAddResponse struct { 785 ChosenTaskName []byte `protobuf:"bytes,1,opt,name=chosen_task_name,json=chosenTaskName" json:"chosen_task_name,omitempty"` 786 XXX_NoUnkeyedLiteral struct{} `json:"-"` 787 XXX_unrecognized []byte `json:"-"` 788 XXX_sizecache int32 `json:"-"` 789} 790 791func (m *TaskQueueAddResponse) Reset() { *m = TaskQueueAddResponse{} } 792func (m *TaskQueueAddResponse) String() string { return proto.CompactTextString(m) } 793func (*TaskQueueAddResponse) ProtoMessage() {} 794func (*TaskQueueAddResponse) Descriptor() ([]byte, []int) { 795 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{7} 796} 797func (m *TaskQueueAddResponse) XXX_Unmarshal(b []byte) error { 798 return xxx_messageInfo_TaskQueueAddResponse.Unmarshal(m, b) 799} 800func (m *TaskQueueAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 801 return xxx_messageInfo_TaskQueueAddResponse.Marshal(b, m, deterministic) 802} 803func (dst *TaskQueueAddResponse) XXX_Merge(src proto.Message) { 804 xxx_messageInfo_TaskQueueAddResponse.Merge(dst, src) 805} 806func (m *TaskQueueAddResponse) XXX_Size() int { 807 return xxx_messageInfo_TaskQueueAddResponse.Size(m) 808} 809func (m *TaskQueueAddResponse) XXX_DiscardUnknown() { 810 xxx_messageInfo_TaskQueueAddResponse.DiscardUnknown(m) 811} 812 813var xxx_messageInfo_TaskQueueAddResponse proto.InternalMessageInfo 814 815func (m *TaskQueueAddResponse) GetChosenTaskName() []byte { 816 if m != nil { 817 return m.ChosenTaskName 818 } 819 return nil 820} 821 822type TaskQueueBulkAddRequest struct { 823 AddRequest []*TaskQueueAddRequest `protobuf:"bytes,1,rep,name=add_request,json=addRequest" json:"add_request,omitempty"` 824 XXX_NoUnkeyedLiteral struct{} `json:"-"` 825 XXX_unrecognized []byte `json:"-"` 826 XXX_sizecache int32 `json:"-"` 827} 828 829func (m *TaskQueueBulkAddRequest) Reset() { *m = TaskQueueBulkAddRequest{} } 830func (m *TaskQueueBulkAddRequest) String() string { return proto.CompactTextString(m) } 831func (*TaskQueueBulkAddRequest) ProtoMessage() {} 832func (*TaskQueueBulkAddRequest) Descriptor() ([]byte, []int) { 833 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{8} 834} 835func (m *TaskQueueBulkAddRequest) XXX_Unmarshal(b []byte) error { 836 return xxx_messageInfo_TaskQueueBulkAddRequest.Unmarshal(m, b) 837} 838func (m *TaskQueueBulkAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 839 return xxx_messageInfo_TaskQueueBulkAddRequest.Marshal(b, m, deterministic) 840} 841func (dst *TaskQueueBulkAddRequest) XXX_Merge(src proto.Message) { 842 xxx_messageInfo_TaskQueueBulkAddRequest.Merge(dst, src) 843} 844func (m *TaskQueueBulkAddRequest) XXX_Size() int { 845 return xxx_messageInfo_TaskQueueBulkAddRequest.Size(m) 846} 847func (m *TaskQueueBulkAddRequest) XXX_DiscardUnknown() { 848 xxx_messageInfo_TaskQueueBulkAddRequest.DiscardUnknown(m) 849} 850 851var xxx_messageInfo_TaskQueueBulkAddRequest proto.InternalMessageInfo 852 853func (m *TaskQueueBulkAddRequest) GetAddRequest() []*TaskQueueAddRequest { 854 if m != nil { 855 return m.AddRequest 856 } 857 return nil 858} 859 860type TaskQueueBulkAddResponse struct { 861 Taskresult []*TaskQueueBulkAddResponse_TaskResult `protobuf:"group,1,rep,name=TaskResult,json=taskresult" json:"taskresult,omitempty"` 862 XXX_NoUnkeyedLiteral struct{} `json:"-"` 863 XXX_unrecognized []byte `json:"-"` 864 XXX_sizecache int32 `json:"-"` 865} 866 867func (m *TaskQueueBulkAddResponse) Reset() { *m = TaskQueueBulkAddResponse{} } 868func (m *TaskQueueBulkAddResponse) String() string { return proto.CompactTextString(m) } 869func (*TaskQueueBulkAddResponse) ProtoMessage() {} 870func (*TaskQueueBulkAddResponse) Descriptor() ([]byte, []int) { 871 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{9} 872} 873func (m *TaskQueueBulkAddResponse) XXX_Unmarshal(b []byte) error { 874 return xxx_messageInfo_TaskQueueBulkAddResponse.Unmarshal(m, b) 875} 876func (m *TaskQueueBulkAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 877 return xxx_messageInfo_TaskQueueBulkAddResponse.Marshal(b, m, deterministic) 878} 879func (dst *TaskQueueBulkAddResponse) XXX_Merge(src proto.Message) { 880 xxx_messageInfo_TaskQueueBulkAddResponse.Merge(dst, src) 881} 882func (m *TaskQueueBulkAddResponse) XXX_Size() int { 883 return xxx_messageInfo_TaskQueueBulkAddResponse.Size(m) 884} 885func (m *TaskQueueBulkAddResponse) XXX_DiscardUnknown() { 886 xxx_messageInfo_TaskQueueBulkAddResponse.DiscardUnknown(m) 887} 888 889var xxx_messageInfo_TaskQueueBulkAddResponse proto.InternalMessageInfo 890 891func (m *TaskQueueBulkAddResponse) GetTaskresult() []*TaskQueueBulkAddResponse_TaskResult { 892 if m != nil { 893 return m.Taskresult 894 } 895 return nil 896} 897 898type TaskQueueBulkAddResponse_TaskResult struct { 899 Result *TaskQueueServiceError_ErrorCode `protobuf:"varint,2,req,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"` 900 ChosenTaskName []byte `protobuf:"bytes,3,opt,name=chosen_task_name,json=chosenTaskName" json:"chosen_task_name,omitempty"` 901 XXX_NoUnkeyedLiteral struct{} `json:"-"` 902 XXX_unrecognized []byte `json:"-"` 903 XXX_sizecache int32 `json:"-"` 904} 905 906func (m *TaskQueueBulkAddResponse_TaskResult) Reset() { *m = TaskQueueBulkAddResponse_TaskResult{} } 907func (m *TaskQueueBulkAddResponse_TaskResult) String() string { return proto.CompactTextString(m) } 908func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage() {} 909func (*TaskQueueBulkAddResponse_TaskResult) Descriptor() ([]byte, []int) { 910 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{9, 0} 911} 912func (m *TaskQueueBulkAddResponse_TaskResult) XXX_Unmarshal(b []byte) error { 913 return xxx_messageInfo_TaskQueueBulkAddResponse_TaskResult.Unmarshal(m, b) 914} 915func (m *TaskQueueBulkAddResponse_TaskResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 916 return xxx_messageInfo_TaskQueueBulkAddResponse_TaskResult.Marshal(b, m, deterministic) 917} 918func (dst *TaskQueueBulkAddResponse_TaskResult) XXX_Merge(src proto.Message) { 919 xxx_messageInfo_TaskQueueBulkAddResponse_TaskResult.Merge(dst, src) 920} 921func (m *TaskQueueBulkAddResponse_TaskResult) XXX_Size() int { 922 return xxx_messageInfo_TaskQueueBulkAddResponse_TaskResult.Size(m) 923} 924func (m *TaskQueueBulkAddResponse_TaskResult) XXX_DiscardUnknown() { 925 xxx_messageInfo_TaskQueueBulkAddResponse_TaskResult.DiscardUnknown(m) 926} 927 928var xxx_messageInfo_TaskQueueBulkAddResponse_TaskResult proto.InternalMessageInfo 929 930func (m *TaskQueueBulkAddResponse_TaskResult) GetResult() TaskQueueServiceError_ErrorCode { 931 if m != nil && m.Result != nil { 932 return *m.Result 933 } 934 return TaskQueueServiceError_OK 935} 936 937func (m *TaskQueueBulkAddResponse_TaskResult) GetChosenTaskName() []byte { 938 if m != nil { 939 return m.ChosenTaskName 940 } 941 return nil 942} 943 944type TaskQueueDeleteRequest struct { 945 QueueName []byte `protobuf:"bytes,1,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 946 TaskName [][]byte `protobuf:"bytes,2,rep,name=task_name,json=taskName" json:"task_name,omitempty"` 947 AppId []byte `protobuf:"bytes,3,opt,name=app_id,json=appId" json:"app_id,omitempty"` 948 XXX_NoUnkeyedLiteral struct{} `json:"-"` 949 XXX_unrecognized []byte `json:"-"` 950 XXX_sizecache int32 `json:"-"` 951} 952 953func (m *TaskQueueDeleteRequest) Reset() { *m = TaskQueueDeleteRequest{} } 954func (m *TaskQueueDeleteRequest) String() string { return proto.CompactTextString(m) } 955func (*TaskQueueDeleteRequest) ProtoMessage() {} 956func (*TaskQueueDeleteRequest) Descriptor() ([]byte, []int) { 957 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{10} 958} 959func (m *TaskQueueDeleteRequest) XXX_Unmarshal(b []byte) error { 960 return xxx_messageInfo_TaskQueueDeleteRequest.Unmarshal(m, b) 961} 962func (m *TaskQueueDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 963 return xxx_messageInfo_TaskQueueDeleteRequest.Marshal(b, m, deterministic) 964} 965func (dst *TaskQueueDeleteRequest) XXX_Merge(src proto.Message) { 966 xxx_messageInfo_TaskQueueDeleteRequest.Merge(dst, src) 967} 968func (m *TaskQueueDeleteRequest) XXX_Size() int { 969 return xxx_messageInfo_TaskQueueDeleteRequest.Size(m) 970} 971func (m *TaskQueueDeleteRequest) XXX_DiscardUnknown() { 972 xxx_messageInfo_TaskQueueDeleteRequest.DiscardUnknown(m) 973} 974 975var xxx_messageInfo_TaskQueueDeleteRequest proto.InternalMessageInfo 976 977func (m *TaskQueueDeleteRequest) GetQueueName() []byte { 978 if m != nil { 979 return m.QueueName 980 } 981 return nil 982} 983 984func (m *TaskQueueDeleteRequest) GetTaskName() [][]byte { 985 if m != nil { 986 return m.TaskName 987 } 988 return nil 989} 990 991func (m *TaskQueueDeleteRequest) GetAppId() []byte { 992 if m != nil { 993 return m.AppId 994 } 995 return nil 996} 997 998type TaskQueueDeleteResponse struct { 999 Result []TaskQueueServiceError_ErrorCode `protobuf:"varint,3,rep,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"` 1000 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1001 XXX_unrecognized []byte `json:"-"` 1002 XXX_sizecache int32 `json:"-"` 1003} 1004 1005func (m *TaskQueueDeleteResponse) Reset() { *m = TaskQueueDeleteResponse{} } 1006func (m *TaskQueueDeleteResponse) String() string { return proto.CompactTextString(m) } 1007func (*TaskQueueDeleteResponse) ProtoMessage() {} 1008func (*TaskQueueDeleteResponse) Descriptor() ([]byte, []int) { 1009 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{11} 1010} 1011func (m *TaskQueueDeleteResponse) XXX_Unmarshal(b []byte) error { 1012 return xxx_messageInfo_TaskQueueDeleteResponse.Unmarshal(m, b) 1013} 1014func (m *TaskQueueDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1015 return xxx_messageInfo_TaskQueueDeleteResponse.Marshal(b, m, deterministic) 1016} 1017func (dst *TaskQueueDeleteResponse) XXX_Merge(src proto.Message) { 1018 xxx_messageInfo_TaskQueueDeleteResponse.Merge(dst, src) 1019} 1020func (m *TaskQueueDeleteResponse) XXX_Size() int { 1021 return xxx_messageInfo_TaskQueueDeleteResponse.Size(m) 1022} 1023func (m *TaskQueueDeleteResponse) XXX_DiscardUnknown() { 1024 xxx_messageInfo_TaskQueueDeleteResponse.DiscardUnknown(m) 1025} 1026 1027var xxx_messageInfo_TaskQueueDeleteResponse proto.InternalMessageInfo 1028 1029func (m *TaskQueueDeleteResponse) GetResult() []TaskQueueServiceError_ErrorCode { 1030 if m != nil { 1031 return m.Result 1032 } 1033 return nil 1034} 1035 1036type TaskQueueForceRunRequest struct { 1037 AppId []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"` 1038 QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 1039 TaskName []byte `protobuf:"bytes,3,req,name=task_name,json=taskName" json:"task_name,omitempty"` 1040 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1041 XXX_unrecognized []byte `json:"-"` 1042 XXX_sizecache int32 `json:"-"` 1043} 1044 1045func (m *TaskQueueForceRunRequest) Reset() { *m = TaskQueueForceRunRequest{} } 1046func (m *TaskQueueForceRunRequest) String() string { return proto.CompactTextString(m) } 1047func (*TaskQueueForceRunRequest) ProtoMessage() {} 1048func (*TaskQueueForceRunRequest) Descriptor() ([]byte, []int) { 1049 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{12} 1050} 1051func (m *TaskQueueForceRunRequest) XXX_Unmarshal(b []byte) error { 1052 return xxx_messageInfo_TaskQueueForceRunRequest.Unmarshal(m, b) 1053} 1054func (m *TaskQueueForceRunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1055 return xxx_messageInfo_TaskQueueForceRunRequest.Marshal(b, m, deterministic) 1056} 1057func (dst *TaskQueueForceRunRequest) XXX_Merge(src proto.Message) { 1058 xxx_messageInfo_TaskQueueForceRunRequest.Merge(dst, src) 1059} 1060func (m *TaskQueueForceRunRequest) XXX_Size() int { 1061 return xxx_messageInfo_TaskQueueForceRunRequest.Size(m) 1062} 1063func (m *TaskQueueForceRunRequest) XXX_DiscardUnknown() { 1064 xxx_messageInfo_TaskQueueForceRunRequest.DiscardUnknown(m) 1065} 1066 1067var xxx_messageInfo_TaskQueueForceRunRequest proto.InternalMessageInfo 1068 1069func (m *TaskQueueForceRunRequest) GetAppId() []byte { 1070 if m != nil { 1071 return m.AppId 1072 } 1073 return nil 1074} 1075 1076func (m *TaskQueueForceRunRequest) GetQueueName() []byte { 1077 if m != nil { 1078 return m.QueueName 1079 } 1080 return nil 1081} 1082 1083func (m *TaskQueueForceRunRequest) GetTaskName() []byte { 1084 if m != nil { 1085 return m.TaskName 1086 } 1087 return nil 1088} 1089 1090type TaskQueueForceRunResponse struct { 1091 Result *TaskQueueServiceError_ErrorCode `protobuf:"varint,3,req,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"` 1092 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1093 XXX_unrecognized []byte `json:"-"` 1094 XXX_sizecache int32 `json:"-"` 1095} 1096 1097func (m *TaskQueueForceRunResponse) Reset() { *m = TaskQueueForceRunResponse{} } 1098func (m *TaskQueueForceRunResponse) String() string { return proto.CompactTextString(m) } 1099func (*TaskQueueForceRunResponse) ProtoMessage() {} 1100func (*TaskQueueForceRunResponse) Descriptor() ([]byte, []int) { 1101 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{13} 1102} 1103func (m *TaskQueueForceRunResponse) XXX_Unmarshal(b []byte) error { 1104 return xxx_messageInfo_TaskQueueForceRunResponse.Unmarshal(m, b) 1105} 1106func (m *TaskQueueForceRunResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1107 return xxx_messageInfo_TaskQueueForceRunResponse.Marshal(b, m, deterministic) 1108} 1109func (dst *TaskQueueForceRunResponse) XXX_Merge(src proto.Message) { 1110 xxx_messageInfo_TaskQueueForceRunResponse.Merge(dst, src) 1111} 1112func (m *TaskQueueForceRunResponse) XXX_Size() int { 1113 return xxx_messageInfo_TaskQueueForceRunResponse.Size(m) 1114} 1115func (m *TaskQueueForceRunResponse) XXX_DiscardUnknown() { 1116 xxx_messageInfo_TaskQueueForceRunResponse.DiscardUnknown(m) 1117} 1118 1119var xxx_messageInfo_TaskQueueForceRunResponse proto.InternalMessageInfo 1120 1121func (m *TaskQueueForceRunResponse) GetResult() TaskQueueServiceError_ErrorCode { 1122 if m != nil && m.Result != nil { 1123 return *m.Result 1124 } 1125 return TaskQueueServiceError_OK 1126} 1127 1128type TaskQueueUpdateQueueRequest struct { 1129 AppId []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"` 1130 QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 1131 BucketRefillPerSecond *float64 `protobuf:"fixed64,3,req,name=bucket_refill_per_second,json=bucketRefillPerSecond" json:"bucket_refill_per_second,omitempty"` 1132 BucketCapacity *int32 `protobuf:"varint,4,req,name=bucket_capacity,json=bucketCapacity" json:"bucket_capacity,omitempty"` 1133 UserSpecifiedRate *string `protobuf:"bytes,5,opt,name=user_specified_rate,json=userSpecifiedRate" json:"user_specified_rate,omitempty"` 1134 RetryParameters *TaskQueueRetryParameters `protobuf:"bytes,6,opt,name=retry_parameters,json=retryParameters" json:"retry_parameters,omitempty"` 1135 MaxConcurrentRequests *int32 `protobuf:"varint,7,opt,name=max_concurrent_requests,json=maxConcurrentRequests" json:"max_concurrent_requests,omitempty"` 1136 Mode *TaskQueueMode_Mode `protobuf:"varint,8,opt,name=mode,enum=appengine.TaskQueueMode_Mode,def=0" json:"mode,omitempty"` 1137 Acl *TaskQueueAcl `protobuf:"bytes,9,opt,name=acl" json:"acl,omitempty"` 1138 HeaderOverride []*TaskQueueHttpHeader `protobuf:"bytes,10,rep,name=header_override,json=headerOverride" json:"header_override,omitempty"` 1139 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1140 XXX_unrecognized []byte `json:"-"` 1141 XXX_sizecache int32 `json:"-"` 1142} 1143 1144func (m *TaskQueueUpdateQueueRequest) Reset() { *m = TaskQueueUpdateQueueRequest{} } 1145func (m *TaskQueueUpdateQueueRequest) String() string { return proto.CompactTextString(m) } 1146func (*TaskQueueUpdateQueueRequest) ProtoMessage() {} 1147func (*TaskQueueUpdateQueueRequest) Descriptor() ([]byte, []int) { 1148 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{14} 1149} 1150func (m *TaskQueueUpdateQueueRequest) XXX_Unmarshal(b []byte) error { 1151 return xxx_messageInfo_TaskQueueUpdateQueueRequest.Unmarshal(m, b) 1152} 1153func (m *TaskQueueUpdateQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1154 return xxx_messageInfo_TaskQueueUpdateQueueRequest.Marshal(b, m, deterministic) 1155} 1156func (dst *TaskQueueUpdateQueueRequest) XXX_Merge(src proto.Message) { 1157 xxx_messageInfo_TaskQueueUpdateQueueRequest.Merge(dst, src) 1158} 1159func (m *TaskQueueUpdateQueueRequest) XXX_Size() int { 1160 return xxx_messageInfo_TaskQueueUpdateQueueRequest.Size(m) 1161} 1162func (m *TaskQueueUpdateQueueRequest) XXX_DiscardUnknown() { 1163 xxx_messageInfo_TaskQueueUpdateQueueRequest.DiscardUnknown(m) 1164} 1165 1166var xxx_messageInfo_TaskQueueUpdateQueueRequest proto.InternalMessageInfo 1167 1168const Default_TaskQueueUpdateQueueRequest_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH 1169 1170func (m *TaskQueueUpdateQueueRequest) GetAppId() []byte { 1171 if m != nil { 1172 return m.AppId 1173 } 1174 return nil 1175} 1176 1177func (m *TaskQueueUpdateQueueRequest) GetQueueName() []byte { 1178 if m != nil { 1179 return m.QueueName 1180 } 1181 return nil 1182} 1183 1184func (m *TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond() float64 { 1185 if m != nil && m.BucketRefillPerSecond != nil { 1186 return *m.BucketRefillPerSecond 1187 } 1188 return 0 1189} 1190 1191func (m *TaskQueueUpdateQueueRequest) GetBucketCapacity() int32 { 1192 if m != nil && m.BucketCapacity != nil { 1193 return *m.BucketCapacity 1194 } 1195 return 0 1196} 1197 1198func (m *TaskQueueUpdateQueueRequest) GetUserSpecifiedRate() string { 1199 if m != nil && m.UserSpecifiedRate != nil { 1200 return *m.UserSpecifiedRate 1201 } 1202 return "" 1203} 1204 1205func (m *TaskQueueUpdateQueueRequest) GetRetryParameters() *TaskQueueRetryParameters { 1206 if m != nil { 1207 return m.RetryParameters 1208 } 1209 return nil 1210} 1211 1212func (m *TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests() int32 { 1213 if m != nil && m.MaxConcurrentRequests != nil { 1214 return *m.MaxConcurrentRequests 1215 } 1216 return 0 1217} 1218 1219func (m *TaskQueueUpdateQueueRequest) GetMode() TaskQueueMode_Mode { 1220 if m != nil && m.Mode != nil { 1221 return *m.Mode 1222 } 1223 return Default_TaskQueueUpdateQueueRequest_Mode 1224} 1225 1226func (m *TaskQueueUpdateQueueRequest) GetAcl() *TaskQueueAcl { 1227 if m != nil { 1228 return m.Acl 1229 } 1230 return nil 1231} 1232 1233func (m *TaskQueueUpdateQueueRequest) GetHeaderOverride() []*TaskQueueHttpHeader { 1234 if m != nil { 1235 return m.HeaderOverride 1236 } 1237 return nil 1238} 1239 1240type TaskQueueUpdateQueueResponse struct { 1241 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1242 XXX_unrecognized []byte `json:"-"` 1243 XXX_sizecache int32 `json:"-"` 1244} 1245 1246func (m *TaskQueueUpdateQueueResponse) Reset() { *m = TaskQueueUpdateQueueResponse{} } 1247func (m *TaskQueueUpdateQueueResponse) String() string { return proto.CompactTextString(m) } 1248func (*TaskQueueUpdateQueueResponse) ProtoMessage() {} 1249func (*TaskQueueUpdateQueueResponse) Descriptor() ([]byte, []int) { 1250 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{15} 1251} 1252func (m *TaskQueueUpdateQueueResponse) XXX_Unmarshal(b []byte) error { 1253 return xxx_messageInfo_TaskQueueUpdateQueueResponse.Unmarshal(m, b) 1254} 1255func (m *TaskQueueUpdateQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1256 return xxx_messageInfo_TaskQueueUpdateQueueResponse.Marshal(b, m, deterministic) 1257} 1258func (dst *TaskQueueUpdateQueueResponse) XXX_Merge(src proto.Message) { 1259 xxx_messageInfo_TaskQueueUpdateQueueResponse.Merge(dst, src) 1260} 1261func (m *TaskQueueUpdateQueueResponse) XXX_Size() int { 1262 return xxx_messageInfo_TaskQueueUpdateQueueResponse.Size(m) 1263} 1264func (m *TaskQueueUpdateQueueResponse) XXX_DiscardUnknown() { 1265 xxx_messageInfo_TaskQueueUpdateQueueResponse.DiscardUnknown(m) 1266} 1267 1268var xxx_messageInfo_TaskQueueUpdateQueueResponse proto.InternalMessageInfo 1269 1270type TaskQueueFetchQueuesRequest struct { 1271 AppId []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"` 1272 MaxRows *int32 `protobuf:"varint,2,req,name=max_rows,json=maxRows" json:"max_rows,omitempty"` 1273 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1274 XXX_unrecognized []byte `json:"-"` 1275 XXX_sizecache int32 `json:"-"` 1276} 1277 1278func (m *TaskQueueFetchQueuesRequest) Reset() { *m = TaskQueueFetchQueuesRequest{} } 1279func (m *TaskQueueFetchQueuesRequest) String() string { return proto.CompactTextString(m) } 1280func (*TaskQueueFetchQueuesRequest) ProtoMessage() {} 1281func (*TaskQueueFetchQueuesRequest) Descriptor() ([]byte, []int) { 1282 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{16} 1283} 1284func (m *TaskQueueFetchQueuesRequest) XXX_Unmarshal(b []byte) error { 1285 return xxx_messageInfo_TaskQueueFetchQueuesRequest.Unmarshal(m, b) 1286} 1287func (m *TaskQueueFetchQueuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1288 return xxx_messageInfo_TaskQueueFetchQueuesRequest.Marshal(b, m, deterministic) 1289} 1290func (dst *TaskQueueFetchQueuesRequest) XXX_Merge(src proto.Message) { 1291 xxx_messageInfo_TaskQueueFetchQueuesRequest.Merge(dst, src) 1292} 1293func (m *TaskQueueFetchQueuesRequest) XXX_Size() int { 1294 return xxx_messageInfo_TaskQueueFetchQueuesRequest.Size(m) 1295} 1296func (m *TaskQueueFetchQueuesRequest) XXX_DiscardUnknown() { 1297 xxx_messageInfo_TaskQueueFetchQueuesRequest.DiscardUnknown(m) 1298} 1299 1300var xxx_messageInfo_TaskQueueFetchQueuesRequest proto.InternalMessageInfo 1301 1302func (m *TaskQueueFetchQueuesRequest) GetAppId() []byte { 1303 if m != nil { 1304 return m.AppId 1305 } 1306 return nil 1307} 1308 1309func (m *TaskQueueFetchQueuesRequest) GetMaxRows() int32 { 1310 if m != nil && m.MaxRows != nil { 1311 return *m.MaxRows 1312 } 1313 return 0 1314} 1315 1316type TaskQueueFetchQueuesResponse struct { 1317 Queue []*TaskQueueFetchQueuesResponse_Queue `protobuf:"group,1,rep,name=Queue,json=queue" json:"queue,omitempty"` 1318 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1319 XXX_unrecognized []byte `json:"-"` 1320 XXX_sizecache int32 `json:"-"` 1321} 1322 1323func (m *TaskQueueFetchQueuesResponse) Reset() { *m = TaskQueueFetchQueuesResponse{} } 1324func (m *TaskQueueFetchQueuesResponse) String() string { return proto.CompactTextString(m) } 1325func (*TaskQueueFetchQueuesResponse) ProtoMessage() {} 1326func (*TaskQueueFetchQueuesResponse) Descriptor() ([]byte, []int) { 1327 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{17} 1328} 1329func (m *TaskQueueFetchQueuesResponse) XXX_Unmarshal(b []byte) error { 1330 return xxx_messageInfo_TaskQueueFetchQueuesResponse.Unmarshal(m, b) 1331} 1332func (m *TaskQueueFetchQueuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1333 return xxx_messageInfo_TaskQueueFetchQueuesResponse.Marshal(b, m, deterministic) 1334} 1335func (dst *TaskQueueFetchQueuesResponse) XXX_Merge(src proto.Message) { 1336 xxx_messageInfo_TaskQueueFetchQueuesResponse.Merge(dst, src) 1337} 1338func (m *TaskQueueFetchQueuesResponse) XXX_Size() int { 1339 return xxx_messageInfo_TaskQueueFetchQueuesResponse.Size(m) 1340} 1341func (m *TaskQueueFetchQueuesResponse) XXX_DiscardUnknown() { 1342 xxx_messageInfo_TaskQueueFetchQueuesResponse.DiscardUnknown(m) 1343} 1344 1345var xxx_messageInfo_TaskQueueFetchQueuesResponse proto.InternalMessageInfo 1346 1347func (m *TaskQueueFetchQueuesResponse) GetQueue() []*TaskQueueFetchQueuesResponse_Queue { 1348 if m != nil { 1349 return m.Queue 1350 } 1351 return nil 1352} 1353 1354type TaskQueueFetchQueuesResponse_Queue struct { 1355 QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 1356 BucketRefillPerSecond *float64 `protobuf:"fixed64,3,req,name=bucket_refill_per_second,json=bucketRefillPerSecond" json:"bucket_refill_per_second,omitempty"` 1357 BucketCapacity *float64 `protobuf:"fixed64,4,req,name=bucket_capacity,json=bucketCapacity" json:"bucket_capacity,omitempty"` 1358 UserSpecifiedRate *string `protobuf:"bytes,5,opt,name=user_specified_rate,json=userSpecifiedRate" json:"user_specified_rate,omitempty"` 1359 Paused *bool `protobuf:"varint,6,req,name=paused,def=0" json:"paused,omitempty"` 1360 RetryParameters *TaskQueueRetryParameters `protobuf:"bytes,7,opt,name=retry_parameters,json=retryParameters" json:"retry_parameters,omitempty"` 1361 MaxConcurrentRequests *int32 `protobuf:"varint,8,opt,name=max_concurrent_requests,json=maxConcurrentRequests" json:"max_concurrent_requests,omitempty"` 1362 Mode *TaskQueueMode_Mode `protobuf:"varint,9,opt,name=mode,enum=appengine.TaskQueueMode_Mode,def=0" json:"mode,omitempty"` 1363 Acl *TaskQueueAcl `protobuf:"bytes,10,opt,name=acl" json:"acl,omitempty"` 1364 HeaderOverride []*TaskQueueHttpHeader `protobuf:"bytes,11,rep,name=header_override,json=headerOverride" json:"header_override,omitempty"` 1365 CreatorName *string `protobuf:"bytes,12,opt,name=creator_name,json=creatorName,def=apphosting" json:"creator_name,omitempty"` 1366 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1367 XXX_unrecognized []byte `json:"-"` 1368 XXX_sizecache int32 `json:"-"` 1369} 1370 1371func (m *TaskQueueFetchQueuesResponse_Queue) Reset() { *m = TaskQueueFetchQueuesResponse_Queue{} } 1372func (m *TaskQueueFetchQueuesResponse_Queue) String() string { return proto.CompactTextString(m) } 1373func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage() {} 1374func (*TaskQueueFetchQueuesResponse_Queue) Descriptor() ([]byte, []int) { 1375 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{17, 0} 1376} 1377func (m *TaskQueueFetchQueuesResponse_Queue) XXX_Unmarshal(b []byte) error { 1378 return xxx_messageInfo_TaskQueueFetchQueuesResponse_Queue.Unmarshal(m, b) 1379} 1380func (m *TaskQueueFetchQueuesResponse_Queue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1381 return xxx_messageInfo_TaskQueueFetchQueuesResponse_Queue.Marshal(b, m, deterministic) 1382} 1383func (dst *TaskQueueFetchQueuesResponse_Queue) XXX_Merge(src proto.Message) { 1384 xxx_messageInfo_TaskQueueFetchQueuesResponse_Queue.Merge(dst, src) 1385} 1386func (m *TaskQueueFetchQueuesResponse_Queue) XXX_Size() int { 1387 return xxx_messageInfo_TaskQueueFetchQueuesResponse_Queue.Size(m) 1388} 1389func (m *TaskQueueFetchQueuesResponse_Queue) XXX_DiscardUnknown() { 1390 xxx_messageInfo_TaskQueueFetchQueuesResponse_Queue.DiscardUnknown(m) 1391} 1392 1393var xxx_messageInfo_TaskQueueFetchQueuesResponse_Queue proto.InternalMessageInfo 1394 1395const Default_TaskQueueFetchQueuesResponse_Queue_Paused bool = false 1396const Default_TaskQueueFetchQueuesResponse_Queue_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH 1397const Default_TaskQueueFetchQueuesResponse_Queue_CreatorName string = "apphosting" 1398 1399func (m *TaskQueueFetchQueuesResponse_Queue) GetQueueName() []byte { 1400 if m != nil { 1401 return m.QueueName 1402 } 1403 return nil 1404} 1405 1406func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond() float64 { 1407 if m != nil && m.BucketRefillPerSecond != nil { 1408 return *m.BucketRefillPerSecond 1409 } 1410 return 0 1411} 1412 1413func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity() float64 { 1414 if m != nil && m.BucketCapacity != nil { 1415 return *m.BucketCapacity 1416 } 1417 return 0 1418} 1419 1420func (m *TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate() string { 1421 if m != nil && m.UserSpecifiedRate != nil { 1422 return *m.UserSpecifiedRate 1423 } 1424 return "" 1425} 1426 1427func (m *TaskQueueFetchQueuesResponse_Queue) GetPaused() bool { 1428 if m != nil && m.Paused != nil { 1429 return *m.Paused 1430 } 1431 return Default_TaskQueueFetchQueuesResponse_Queue_Paused 1432} 1433 1434func (m *TaskQueueFetchQueuesResponse_Queue) GetRetryParameters() *TaskQueueRetryParameters { 1435 if m != nil { 1436 return m.RetryParameters 1437 } 1438 return nil 1439} 1440 1441func (m *TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests() int32 { 1442 if m != nil && m.MaxConcurrentRequests != nil { 1443 return *m.MaxConcurrentRequests 1444 } 1445 return 0 1446} 1447 1448func (m *TaskQueueFetchQueuesResponse_Queue) GetMode() TaskQueueMode_Mode { 1449 if m != nil && m.Mode != nil { 1450 return *m.Mode 1451 } 1452 return Default_TaskQueueFetchQueuesResponse_Queue_Mode 1453} 1454 1455func (m *TaskQueueFetchQueuesResponse_Queue) GetAcl() *TaskQueueAcl { 1456 if m != nil { 1457 return m.Acl 1458 } 1459 return nil 1460} 1461 1462func (m *TaskQueueFetchQueuesResponse_Queue) GetHeaderOverride() []*TaskQueueHttpHeader { 1463 if m != nil { 1464 return m.HeaderOverride 1465 } 1466 return nil 1467} 1468 1469func (m *TaskQueueFetchQueuesResponse_Queue) GetCreatorName() string { 1470 if m != nil && m.CreatorName != nil { 1471 return *m.CreatorName 1472 } 1473 return Default_TaskQueueFetchQueuesResponse_Queue_CreatorName 1474} 1475 1476type TaskQueueFetchQueueStatsRequest struct { 1477 AppId []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"` 1478 QueueName [][]byte `protobuf:"bytes,2,rep,name=queue_name,json=queueName" json:"queue_name,omitempty"` 1479 MaxNumTasks *int32 `protobuf:"varint,3,opt,name=max_num_tasks,json=maxNumTasks,def=0" json:"max_num_tasks,omitempty"` 1480 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1481 XXX_unrecognized []byte `json:"-"` 1482 XXX_sizecache int32 `json:"-"` 1483} 1484 1485func (m *TaskQueueFetchQueueStatsRequest) Reset() { *m = TaskQueueFetchQueueStatsRequest{} } 1486func (m *TaskQueueFetchQueueStatsRequest) String() string { return proto.CompactTextString(m) } 1487func (*TaskQueueFetchQueueStatsRequest) ProtoMessage() {} 1488func (*TaskQueueFetchQueueStatsRequest) Descriptor() ([]byte, []int) { 1489 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{18} 1490} 1491func (m *TaskQueueFetchQueueStatsRequest) XXX_Unmarshal(b []byte) error { 1492 return xxx_messageInfo_TaskQueueFetchQueueStatsRequest.Unmarshal(m, b) 1493} 1494func (m *TaskQueueFetchQueueStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1495 return xxx_messageInfo_TaskQueueFetchQueueStatsRequest.Marshal(b, m, deterministic) 1496} 1497func (dst *TaskQueueFetchQueueStatsRequest) XXX_Merge(src proto.Message) { 1498 xxx_messageInfo_TaskQueueFetchQueueStatsRequest.Merge(dst, src) 1499} 1500func (m *TaskQueueFetchQueueStatsRequest) XXX_Size() int { 1501 return xxx_messageInfo_TaskQueueFetchQueueStatsRequest.Size(m) 1502} 1503func (m *TaskQueueFetchQueueStatsRequest) XXX_DiscardUnknown() { 1504 xxx_messageInfo_TaskQueueFetchQueueStatsRequest.DiscardUnknown(m) 1505} 1506 1507var xxx_messageInfo_TaskQueueFetchQueueStatsRequest proto.InternalMessageInfo 1508 1509const Default_TaskQueueFetchQueueStatsRequest_MaxNumTasks int32 = 0 1510 1511func (m *TaskQueueFetchQueueStatsRequest) GetAppId() []byte { 1512 if m != nil { 1513 return m.AppId 1514 } 1515 return nil 1516} 1517 1518func (m *TaskQueueFetchQueueStatsRequest) GetQueueName() [][]byte { 1519 if m != nil { 1520 return m.QueueName 1521 } 1522 return nil 1523} 1524 1525func (m *TaskQueueFetchQueueStatsRequest) GetMaxNumTasks() int32 { 1526 if m != nil && m.MaxNumTasks != nil { 1527 return *m.MaxNumTasks 1528 } 1529 return Default_TaskQueueFetchQueueStatsRequest_MaxNumTasks 1530} 1531 1532type TaskQueueScannerQueueInfo struct { 1533 ExecutedLastMinute *int64 `protobuf:"varint,1,req,name=executed_last_minute,json=executedLastMinute" json:"executed_last_minute,omitempty"` 1534 ExecutedLastHour *int64 `protobuf:"varint,2,req,name=executed_last_hour,json=executedLastHour" json:"executed_last_hour,omitempty"` 1535 SamplingDurationSeconds *float64 `protobuf:"fixed64,3,req,name=sampling_duration_seconds,json=samplingDurationSeconds" json:"sampling_duration_seconds,omitempty"` 1536 RequestsInFlight *int32 `protobuf:"varint,4,opt,name=requests_in_flight,json=requestsInFlight" json:"requests_in_flight,omitempty"` 1537 EnforcedRate *float64 `protobuf:"fixed64,5,opt,name=enforced_rate,json=enforcedRate" json:"enforced_rate,omitempty"` 1538 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1539 XXX_unrecognized []byte `json:"-"` 1540 XXX_sizecache int32 `json:"-"` 1541} 1542 1543func (m *TaskQueueScannerQueueInfo) Reset() { *m = TaskQueueScannerQueueInfo{} } 1544func (m *TaskQueueScannerQueueInfo) String() string { return proto.CompactTextString(m) } 1545func (*TaskQueueScannerQueueInfo) ProtoMessage() {} 1546func (*TaskQueueScannerQueueInfo) Descriptor() ([]byte, []int) { 1547 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{19} 1548} 1549func (m *TaskQueueScannerQueueInfo) XXX_Unmarshal(b []byte) error { 1550 return xxx_messageInfo_TaskQueueScannerQueueInfo.Unmarshal(m, b) 1551} 1552func (m *TaskQueueScannerQueueInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1553 return xxx_messageInfo_TaskQueueScannerQueueInfo.Marshal(b, m, deterministic) 1554} 1555func (dst *TaskQueueScannerQueueInfo) XXX_Merge(src proto.Message) { 1556 xxx_messageInfo_TaskQueueScannerQueueInfo.Merge(dst, src) 1557} 1558func (m *TaskQueueScannerQueueInfo) XXX_Size() int { 1559 return xxx_messageInfo_TaskQueueScannerQueueInfo.Size(m) 1560} 1561func (m *TaskQueueScannerQueueInfo) XXX_DiscardUnknown() { 1562 xxx_messageInfo_TaskQueueScannerQueueInfo.DiscardUnknown(m) 1563} 1564 1565var xxx_messageInfo_TaskQueueScannerQueueInfo proto.InternalMessageInfo 1566 1567func (m *TaskQueueScannerQueueInfo) GetExecutedLastMinute() int64 { 1568 if m != nil && m.ExecutedLastMinute != nil { 1569 return *m.ExecutedLastMinute 1570 } 1571 return 0 1572} 1573 1574func (m *TaskQueueScannerQueueInfo) GetExecutedLastHour() int64 { 1575 if m != nil && m.ExecutedLastHour != nil { 1576 return *m.ExecutedLastHour 1577 } 1578 return 0 1579} 1580 1581func (m *TaskQueueScannerQueueInfo) GetSamplingDurationSeconds() float64 { 1582 if m != nil && m.SamplingDurationSeconds != nil { 1583 return *m.SamplingDurationSeconds 1584 } 1585 return 0 1586} 1587 1588func (m *TaskQueueScannerQueueInfo) GetRequestsInFlight() int32 { 1589 if m != nil && m.RequestsInFlight != nil { 1590 return *m.RequestsInFlight 1591 } 1592 return 0 1593} 1594 1595func (m *TaskQueueScannerQueueInfo) GetEnforcedRate() float64 { 1596 if m != nil && m.EnforcedRate != nil { 1597 return *m.EnforcedRate 1598 } 1599 return 0 1600} 1601 1602type TaskQueueFetchQueueStatsResponse struct { 1603 Queuestats []*TaskQueueFetchQueueStatsResponse_QueueStats `protobuf:"group,1,rep,name=QueueStats,json=queuestats" json:"queuestats,omitempty"` 1604 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1605 XXX_unrecognized []byte `json:"-"` 1606 XXX_sizecache int32 `json:"-"` 1607} 1608 1609func (m *TaskQueueFetchQueueStatsResponse) Reset() { *m = TaskQueueFetchQueueStatsResponse{} } 1610func (m *TaskQueueFetchQueueStatsResponse) String() string { return proto.CompactTextString(m) } 1611func (*TaskQueueFetchQueueStatsResponse) ProtoMessage() {} 1612func (*TaskQueueFetchQueueStatsResponse) Descriptor() ([]byte, []int) { 1613 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{20} 1614} 1615func (m *TaskQueueFetchQueueStatsResponse) XXX_Unmarshal(b []byte) error { 1616 return xxx_messageInfo_TaskQueueFetchQueueStatsResponse.Unmarshal(m, b) 1617} 1618func (m *TaskQueueFetchQueueStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1619 return xxx_messageInfo_TaskQueueFetchQueueStatsResponse.Marshal(b, m, deterministic) 1620} 1621func (dst *TaskQueueFetchQueueStatsResponse) XXX_Merge(src proto.Message) { 1622 xxx_messageInfo_TaskQueueFetchQueueStatsResponse.Merge(dst, src) 1623} 1624func (m *TaskQueueFetchQueueStatsResponse) XXX_Size() int { 1625 return xxx_messageInfo_TaskQueueFetchQueueStatsResponse.Size(m) 1626} 1627func (m *TaskQueueFetchQueueStatsResponse) XXX_DiscardUnknown() { 1628 xxx_messageInfo_TaskQueueFetchQueueStatsResponse.DiscardUnknown(m) 1629} 1630 1631var xxx_messageInfo_TaskQueueFetchQueueStatsResponse proto.InternalMessageInfo 1632 1633func (m *TaskQueueFetchQueueStatsResponse) GetQueuestats() []*TaskQueueFetchQueueStatsResponse_QueueStats { 1634 if m != nil { 1635 return m.Queuestats 1636 } 1637 return nil 1638} 1639 1640type TaskQueueFetchQueueStatsResponse_QueueStats struct { 1641 NumTasks *int32 `protobuf:"varint,2,req,name=num_tasks,json=numTasks" json:"num_tasks,omitempty"` 1642 OldestEtaUsec *int64 `protobuf:"varint,3,req,name=oldest_eta_usec,json=oldestEtaUsec" json:"oldest_eta_usec,omitempty"` 1643 ScannerInfo *TaskQueueScannerQueueInfo `protobuf:"bytes,4,opt,name=scanner_info,json=scannerInfo" json:"scanner_info,omitempty"` 1644 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1645 XXX_unrecognized []byte `json:"-"` 1646 XXX_sizecache int32 `json:"-"` 1647} 1648 1649func (m *TaskQueueFetchQueueStatsResponse_QueueStats) Reset() { 1650 *m = TaskQueueFetchQueueStatsResponse_QueueStats{} 1651} 1652func (m *TaskQueueFetchQueueStatsResponse_QueueStats) String() string { 1653 return proto.CompactTextString(m) 1654} 1655func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage() {} 1656func (*TaskQueueFetchQueueStatsResponse_QueueStats) Descriptor() ([]byte, []int) { 1657 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{20, 0} 1658} 1659func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Unmarshal(b []byte) error { 1660 return xxx_messageInfo_TaskQueueFetchQueueStatsResponse_QueueStats.Unmarshal(m, b) 1661} 1662func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1663 return xxx_messageInfo_TaskQueueFetchQueueStatsResponse_QueueStats.Marshal(b, m, deterministic) 1664} 1665func (dst *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Merge(src proto.Message) { 1666 xxx_messageInfo_TaskQueueFetchQueueStatsResponse_QueueStats.Merge(dst, src) 1667} 1668func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Size() int { 1669 return xxx_messageInfo_TaskQueueFetchQueueStatsResponse_QueueStats.Size(m) 1670} 1671func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_DiscardUnknown() { 1672 xxx_messageInfo_TaskQueueFetchQueueStatsResponse_QueueStats.DiscardUnknown(m) 1673} 1674 1675var xxx_messageInfo_TaskQueueFetchQueueStatsResponse_QueueStats proto.InternalMessageInfo 1676 1677func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks() int32 { 1678 if m != nil && m.NumTasks != nil { 1679 return *m.NumTasks 1680 } 1681 return 0 1682} 1683 1684func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec() int64 { 1685 if m != nil && m.OldestEtaUsec != nil { 1686 return *m.OldestEtaUsec 1687 } 1688 return 0 1689} 1690 1691func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo() *TaskQueueScannerQueueInfo { 1692 if m != nil { 1693 return m.ScannerInfo 1694 } 1695 return nil 1696} 1697 1698type TaskQueuePauseQueueRequest struct { 1699 AppId []byte `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"` 1700 QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 1701 Pause *bool `protobuf:"varint,3,req,name=pause" json:"pause,omitempty"` 1702 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1703 XXX_unrecognized []byte `json:"-"` 1704 XXX_sizecache int32 `json:"-"` 1705} 1706 1707func (m *TaskQueuePauseQueueRequest) Reset() { *m = TaskQueuePauseQueueRequest{} } 1708func (m *TaskQueuePauseQueueRequest) String() string { return proto.CompactTextString(m) } 1709func (*TaskQueuePauseQueueRequest) ProtoMessage() {} 1710func (*TaskQueuePauseQueueRequest) Descriptor() ([]byte, []int) { 1711 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{21} 1712} 1713func (m *TaskQueuePauseQueueRequest) XXX_Unmarshal(b []byte) error { 1714 return xxx_messageInfo_TaskQueuePauseQueueRequest.Unmarshal(m, b) 1715} 1716func (m *TaskQueuePauseQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1717 return xxx_messageInfo_TaskQueuePauseQueueRequest.Marshal(b, m, deterministic) 1718} 1719func (dst *TaskQueuePauseQueueRequest) XXX_Merge(src proto.Message) { 1720 xxx_messageInfo_TaskQueuePauseQueueRequest.Merge(dst, src) 1721} 1722func (m *TaskQueuePauseQueueRequest) XXX_Size() int { 1723 return xxx_messageInfo_TaskQueuePauseQueueRequest.Size(m) 1724} 1725func (m *TaskQueuePauseQueueRequest) XXX_DiscardUnknown() { 1726 xxx_messageInfo_TaskQueuePauseQueueRequest.DiscardUnknown(m) 1727} 1728 1729var xxx_messageInfo_TaskQueuePauseQueueRequest proto.InternalMessageInfo 1730 1731func (m *TaskQueuePauseQueueRequest) GetAppId() []byte { 1732 if m != nil { 1733 return m.AppId 1734 } 1735 return nil 1736} 1737 1738func (m *TaskQueuePauseQueueRequest) GetQueueName() []byte { 1739 if m != nil { 1740 return m.QueueName 1741 } 1742 return nil 1743} 1744 1745func (m *TaskQueuePauseQueueRequest) GetPause() bool { 1746 if m != nil && m.Pause != nil { 1747 return *m.Pause 1748 } 1749 return false 1750} 1751 1752type TaskQueuePauseQueueResponse struct { 1753 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1754 XXX_unrecognized []byte `json:"-"` 1755 XXX_sizecache int32 `json:"-"` 1756} 1757 1758func (m *TaskQueuePauseQueueResponse) Reset() { *m = TaskQueuePauseQueueResponse{} } 1759func (m *TaskQueuePauseQueueResponse) String() string { return proto.CompactTextString(m) } 1760func (*TaskQueuePauseQueueResponse) ProtoMessage() {} 1761func (*TaskQueuePauseQueueResponse) Descriptor() ([]byte, []int) { 1762 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{22} 1763} 1764func (m *TaskQueuePauseQueueResponse) XXX_Unmarshal(b []byte) error { 1765 return xxx_messageInfo_TaskQueuePauseQueueResponse.Unmarshal(m, b) 1766} 1767func (m *TaskQueuePauseQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1768 return xxx_messageInfo_TaskQueuePauseQueueResponse.Marshal(b, m, deterministic) 1769} 1770func (dst *TaskQueuePauseQueueResponse) XXX_Merge(src proto.Message) { 1771 xxx_messageInfo_TaskQueuePauseQueueResponse.Merge(dst, src) 1772} 1773func (m *TaskQueuePauseQueueResponse) XXX_Size() int { 1774 return xxx_messageInfo_TaskQueuePauseQueueResponse.Size(m) 1775} 1776func (m *TaskQueuePauseQueueResponse) XXX_DiscardUnknown() { 1777 xxx_messageInfo_TaskQueuePauseQueueResponse.DiscardUnknown(m) 1778} 1779 1780var xxx_messageInfo_TaskQueuePauseQueueResponse proto.InternalMessageInfo 1781 1782type TaskQueuePurgeQueueRequest struct { 1783 AppId []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"` 1784 QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 1785 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1786 XXX_unrecognized []byte `json:"-"` 1787 XXX_sizecache int32 `json:"-"` 1788} 1789 1790func (m *TaskQueuePurgeQueueRequest) Reset() { *m = TaskQueuePurgeQueueRequest{} } 1791func (m *TaskQueuePurgeQueueRequest) String() string { return proto.CompactTextString(m) } 1792func (*TaskQueuePurgeQueueRequest) ProtoMessage() {} 1793func (*TaskQueuePurgeQueueRequest) Descriptor() ([]byte, []int) { 1794 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{23} 1795} 1796func (m *TaskQueuePurgeQueueRequest) XXX_Unmarshal(b []byte) error { 1797 return xxx_messageInfo_TaskQueuePurgeQueueRequest.Unmarshal(m, b) 1798} 1799func (m *TaskQueuePurgeQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1800 return xxx_messageInfo_TaskQueuePurgeQueueRequest.Marshal(b, m, deterministic) 1801} 1802func (dst *TaskQueuePurgeQueueRequest) XXX_Merge(src proto.Message) { 1803 xxx_messageInfo_TaskQueuePurgeQueueRequest.Merge(dst, src) 1804} 1805func (m *TaskQueuePurgeQueueRequest) XXX_Size() int { 1806 return xxx_messageInfo_TaskQueuePurgeQueueRequest.Size(m) 1807} 1808func (m *TaskQueuePurgeQueueRequest) XXX_DiscardUnknown() { 1809 xxx_messageInfo_TaskQueuePurgeQueueRequest.DiscardUnknown(m) 1810} 1811 1812var xxx_messageInfo_TaskQueuePurgeQueueRequest proto.InternalMessageInfo 1813 1814func (m *TaskQueuePurgeQueueRequest) GetAppId() []byte { 1815 if m != nil { 1816 return m.AppId 1817 } 1818 return nil 1819} 1820 1821func (m *TaskQueuePurgeQueueRequest) GetQueueName() []byte { 1822 if m != nil { 1823 return m.QueueName 1824 } 1825 return nil 1826} 1827 1828type TaskQueuePurgeQueueResponse struct { 1829 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1830 XXX_unrecognized []byte `json:"-"` 1831 XXX_sizecache int32 `json:"-"` 1832} 1833 1834func (m *TaskQueuePurgeQueueResponse) Reset() { *m = TaskQueuePurgeQueueResponse{} } 1835func (m *TaskQueuePurgeQueueResponse) String() string { return proto.CompactTextString(m) } 1836func (*TaskQueuePurgeQueueResponse) ProtoMessage() {} 1837func (*TaskQueuePurgeQueueResponse) Descriptor() ([]byte, []int) { 1838 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{24} 1839} 1840func (m *TaskQueuePurgeQueueResponse) XXX_Unmarshal(b []byte) error { 1841 return xxx_messageInfo_TaskQueuePurgeQueueResponse.Unmarshal(m, b) 1842} 1843func (m *TaskQueuePurgeQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1844 return xxx_messageInfo_TaskQueuePurgeQueueResponse.Marshal(b, m, deterministic) 1845} 1846func (dst *TaskQueuePurgeQueueResponse) XXX_Merge(src proto.Message) { 1847 xxx_messageInfo_TaskQueuePurgeQueueResponse.Merge(dst, src) 1848} 1849func (m *TaskQueuePurgeQueueResponse) XXX_Size() int { 1850 return xxx_messageInfo_TaskQueuePurgeQueueResponse.Size(m) 1851} 1852func (m *TaskQueuePurgeQueueResponse) XXX_DiscardUnknown() { 1853 xxx_messageInfo_TaskQueuePurgeQueueResponse.DiscardUnknown(m) 1854} 1855 1856var xxx_messageInfo_TaskQueuePurgeQueueResponse proto.InternalMessageInfo 1857 1858type TaskQueueDeleteQueueRequest struct { 1859 AppId []byte `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"` 1860 QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 1861 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1862 XXX_unrecognized []byte `json:"-"` 1863 XXX_sizecache int32 `json:"-"` 1864} 1865 1866func (m *TaskQueueDeleteQueueRequest) Reset() { *m = TaskQueueDeleteQueueRequest{} } 1867func (m *TaskQueueDeleteQueueRequest) String() string { return proto.CompactTextString(m) } 1868func (*TaskQueueDeleteQueueRequest) ProtoMessage() {} 1869func (*TaskQueueDeleteQueueRequest) Descriptor() ([]byte, []int) { 1870 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{25} 1871} 1872func (m *TaskQueueDeleteQueueRequest) XXX_Unmarshal(b []byte) error { 1873 return xxx_messageInfo_TaskQueueDeleteQueueRequest.Unmarshal(m, b) 1874} 1875func (m *TaskQueueDeleteQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1876 return xxx_messageInfo_TaskQueueDeleteQueueRequest.Marshal(b, m, deterministic) 1877} 1878func (dst *TaskQueueDeleteQueueRequest) XXX_Merge(src proto.Message) { 1879 xxx_messageInfo_TaskQueueDeleteQueueRequest.Merge(dst, src) 1880} 1881func (m *TaskQueueDeleteQueueRequest) XXX_Size() int { 1882 return xxx_messageInfo_TaskQueueDeleteQueueRequest.Size(m) 1883} 1884func (m *TaskQueueDeleteQueueRequest) XXX_DiscardUnknown() { 1885 xxx_messageInfo_TaskQueueDeleteQueueRequest.DiscardUnknown(m) 1886} 1887 1888var xxx_messageInfo_TaskQueueDeleteQueueRequest proto.InternalMessageInfo 1889 1890func (m *TaskQueueDeleteQueueRequest) GetAppId() []byte { 1891 if m != nil { 1892 return m.AppId 1893 } 1894 return nil 1895} 1896 1897func (m *TaskQueueDeleteQueueRequest) GetQueueName() []byte { 1898 if m != nil { 1899 return m.QueueName 1900 } 1901 return nil 1902} 1903 1904type TaskQueueDeleteQueueResponse struct { 1905 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1906 XXX_unrecognized []byte `json:"-"` 1907 XXX_sizecache int32 `json:"-"` 1908} 1909 1910func (m *TaskQueueDeleteQueueResponse) Reset() { *m = TaskQueueDeleteQueueResponse{} } 1911func (m *TaskQueueDeleteQueueResponse) String() string { return proto.CompactTextString(m) } 1912func (*TaskQueueDeleteQueueResponse) ProtoMessage() {} 1913func (*TaskQueueDeleteQueueResponse) Descriptor() ([]byte, []int) { 1914 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{26} 1915} 1916func (m *TaskQueueDeleteQueueResponse) XXX_Unmarshal(b []byte) error { 1917 return xxx_messageInfo_TaskQueueDeleteQueueResponse.Unmarshal(m, b) 1918} 1919func (m *TaskQueueDeleteQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1920 return xxx_messageInfo_TaskQueueDeleteQueueResponse.Marshal(b, m, deterministic) 1921} 1922func (dst *TaskQueueDeleteQueueResponse) XXX_Merge(src proto.Message) { 1923 xxx_messageInfo_TaskQueueDeleteQueueResponse.Merge(dst, src) 1924} 1925func (m *TaskQueueDeleteQueueResponse) XXX_Size() int { 1926 return xxx_messageInfo_TaskQueueDeleteQueueResponse.Size(m) 1927} 1928func (m *TaskQueueDeleteQueueResponse) XXX_DiscardUnknown() { 1929 xxx_messageInfo_TaskQueueDeleteQueueResponse.DiscardUnknown(m) 1930} 1931 1932var xxx_messageInfo_TaskQueueDeleteQueueResponse proto.InternalMessageInfo 1933 1934type TaskQueueDeleteGroupRequest struct { 1935 AppId []byte `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"` 1936 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1937 XXX_unrecognized []byte `json:"-"` 1938 XXX_sizecache int32 `json:"-"` 1939} 1940 1941func (m *TaskQueueDeleteGroupRequest) Reset() { *m = TaskQueueDeleteGroupRequest{} } 1942func (m *TaskQueueDeleteGroupRequest) String() string { return proto.CompactTextString(m) } 1943func (*TaskQueueDeleteGroupRequest) ProtoMessage() {} 1944func (*TaskQueueDeleteGroupRequest) Descriptor() ([]byte, []int) { 1945 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{27} 1946} 1947func (m *TaskQueueDeleteGroupRequest) XXX_Unmarshal(b []byte) error { 1948 return xxx_messageInfo_TaskQueueDeleteGroupRequest.Unmarshal(m, b) 1949} 1950func (m *TaskQueueDeleteGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1951 return xxx_messageInfo_TaskQueueDeleteGroupRequest.Marshal(b, m, deterministic) 1952} 1953func (dst *TaskQueueDeleteGroupRequest) XXX_Merge(src proto.Message) { 1954 xxx_messageInfo_TaskQueueDeleteGroupRequest.Merge(dst, src) 1955} 1956func (m *TaskQueueDeleteGroupRequest) XXX_Size() int { 1957 return xxx_messageInfo_TaskQueueDeleteGroupRequest.Size(m) 1958} 1959func (m *TaskQueueDeleteGroupRequest) XXX_DiscardUnknown() { 1960 xxx_messageInfo_TaskQueueDeleteGroupRequest.DiscardUnknown(m) 1961} 1962 1963var xxx_messageInfo_TaskQueueDeleteGroupRequest proto.InternalMessageInfo 1964 1965func (m *TaskQueueDeleteGroupRequest) GetAppId() []byte { 1966 if m != nil { 1967 return m.AppId 1968 } 1969 return nil 1970} 1971 1972type TaskQueueDeleteGroupResponse struct { 1973 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1974 XXX_unrecognized []byte `json:"-"` 1975 XXX_sizecache int32 `json:"-"` 1976} 1977 1978func (m *TaskQueueDeleteGroupResponse) Reset() { *m = TaskQueueDeleteGroupResponse{} } 1979func (m *TaskQueueDeleteGroupResponse) String() string { return proto.CompactTextString(m) } 1980func (*TaskQueueDeleteGroupResponse) ProtoMessage() {} 1981func (*TaskQueueDeleteGroupResponse) Descriptor() ([]byte, []int) { 1982 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{28} 1983} 1984func (m *TaskQueueDeleteGroupResponse) XXX_Unmarshal(b []byte) error { 1985 return xxx_messageInfo_TaskQueueDeleteGroupResponse.Unmarshal(m, b) 1986} 1987func (m *TaskQueueDeleteGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1988 return xxx_messageInfo_TaskQueueDeleteGroupResponse.Marshal(b, m, deterministic) 1989} 1990func (dst *TaskQueueDeleteGroupResponse) XXX_Merge(src proto.Message) { 1991 xxx_messageInfo_TaskQueueDeleteGroupResponse.Merge(dst, src) 1992} 1993func (m *TaskQueueDeleteGroupResponse) XXX_Size() int { 1994 return xxx_messageInfo_TaskQueueDeleteGroupResponse.Size(m) 1995} 1996func (m *TaskQueueDeleteGroupResponse) XXX_DiscardUnknown() { 1997 xxx_messageInfo_TaskQueueDeleteGroupResponse.DiscardUnknown(m) 1998} 1999 2000var xxx_messageInfo_TaskQueueDeleteGroupResponse proto.InternalMessageInfo 2001 2002type TaskQueueQueryTasksRequest struct { 2003 AppId []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"` 2004 QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 2005 StartTaskName []byte `protobuf:"bytes,3,opt,name=start_task_name,json=startTaskName" json:"start_task_name,omitempty"` 2006 StartEtaUsec *int64 `protobuf:"varint,4,opt,name=start_eta_usec,json=startEtaUsec" json:"start_eta_usec,omitempty"` 2007 StartTag []byte `protobuf:"bytes,6,opt,name=start_tag,json=startTag" json:"start_tag,omitempty"` 2008 MaxRows *int32 `protobuf:"varint,5,opt,name=max_rows,json=maxRows,def=1" json:"max_rows,omitempty"` 2009 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2010 XXX_unrecognized []byte `json:"-"` 2011 XXX_sizecache int32 `json:"-"` 2012} 2013 2014func (m *TaskQueueQueryTasksRequest) Reset() { *m = TaskQueueQueryTasksRequest{} } 2015func (m *TaskQueueQueryTasksRequest) String() string { return proto.CompactTextString(m) } 2016func (*TaskQueueQueryTasksRequest) ProtoMessage() {} 2017func (*TaskQueueQueryTasksRequest) Descriptor() ([]byte, []int) { 2018 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{29} 2019} 2020func (m *TaskQueueQueryTasksRequest) XXX_Unmarshal(b []byte) error { 2021 return xxx_messageInfo_TaskQueueQueryTasksRequest.Unmarshal(m, b) 2022} 2023func (m *TaskQueueQueryTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2024 return xxx_messageInfo_TaskQueueQueryTasksRequest.Marshal(b, m, deterministic) 2025} 2026func (dst *TaskQueueQueryTasksRequest) XXX_Merge(src proto.Message) { 2027 xxx_messageInfo_TaskQueueQueryTasksRequest.Merge(dst, src) 2028} 2029func (m *TaskQueueQueryTasksRequest) XXX_Size() int { 2030 return xxx_messageInfo_TaskQueueQueryTasksRequest.Size(m) 2031} 2032func (m *TaskQueueQueryTasksRequest) XXX_DiscardUnknown() { 2033 xxx_messageInfo_TaskQueueQueryTasksRequest.DiscardUnknown(m) 2034} 2035 2036var xxx_messageInfo_TaskQueueQueryTasksRequest proto.InternalMessageInfo 2037 2038const Default_TaskQueueQueryTasksRequest_MaxRows int32 = 1 2039 2040func (m *TaskQueueQueryTasksRequest) GetAppId() []byte { 2041 if m != nil { 2042 return m.AppId 2043 } 2044 return nil 2045} 2046 2047func (m *TaskQueueQueryTasksRequest) GetQueueName() []byte { 2048 if m != nil { 2049 return m.QueueName 2050 } 2051 return nil 2052} 2053 2054func (m *TaskQueueQueryTasksRequest) GetStartTaskName() []byte { 2055 if m != nil { 2056 return m.StartTaskName 2057 } 2058 return nil 2059} 2060 2061func (m *TaskQueueQueryTasksRequest) GetStartEtaUsec() int64 { 2062 if m != nil && m.StartEtaUsec != nil { 2063 return *m.StartEtaUsec 2064 } 2065 return 0 2066} 2067 2068func (m *TaskQueueQueryTasksRequest) GetStartTag() []byte { 2069 if m != nil { 2070 return m.StartTag 2071 } 2072 return nil 2073} 2074 2075func (m *TaskQueueQueryTasksRequest) GetMaxRows() int32 { 2076 if m != nil && m.MaxRows != nil { 2077 return *m.MaxRows 2078 } 2079 return Default_TaskQueueQueryTasksRequest_MaxRows 2080} 2081 2082type TaskQueueQueryTasksResponse struct { 2083 Task []*TaskQueueQueryTasksResponse_Task `protobuf:"group,1,rep,name=Task,json=task" json:"task,omitempty"` 2084 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2085 XXX_unrecognized []byte `json:"-"` 2086 XXX_sizecache int32 `json:"-"` 2087} 2088 2089func (m *TaskQueueQueryTasksResponse) Reset() { *m = TaskQueueQueryTasksResponse{} } 2090func (m *TaskQueueQueryTasksResponse) String() string { return proto.CompactTextString(m) } 2091func (*TaskQueueQueryTasksResponse) ProtoMessage() {} 2092func (*TaskQueueQueryTasksResponse) Descriptor() ([]byte, []int) { 2093 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{30} 2094} 2095func (m *TaskQueueQueryTasksResponse) XXX_Unmarshal(b []byte) error { 2096 return xxx_messageInfo_TaskQueueQueryTasksResponse.Unmarshal(m, b) 2097} 2098func (m *TaskQueueQueryTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2099 return xxx_messageInfo_TaskQueueQueryTasksResponse.Marshal(b, m, deterministic) 2100} 2101func (dst *TaskQueueQueryTasksResponse) XXX_Merge(src proto.Message) { 2102 xxx_messageInfo_TaskQueueQueryTasksResponse.Merge(dst, src) 2103} 2104func (m *TaskQueueQueryTasksResponse) XXX_Size() int { 2105 return xxx_messageInfo_TaskQueueQueryTasksResponse.Size(m) 2106} 2107func (m *TaskQueueQueryTasksResponse) XXX_DiscardUnknown() { 2108 xxx_messageInfo_TaskQueueQueryTasksResponse.DiscardUnknown(m) 2109} 2110 2111var xxx_messageInfo_TaskQueueQueryTasksResponse proto.InternalMessageInfo 2112 2113func (m *TaskQueueQueryTasksResponse) GetTask() []*TaskQueueQueryTasksResponse_Task { 2114 if m != nil { 2115 return m.Task 2116 } 2117 return nil 2118} 2119 2120type TaskQueueQueryTasksResponse_Task struct { 2121 TaskName []byte `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"` 2122 EtaUsec *int64 `protobuf:"varint,3,req,name=eta_usec,json=etaUsec" json:"eta_usec,omitempty"` 2123 Url []byte `protobuf:"bytes,4,opt,name=url" json:"url,omitempty"` 2124 Method *TaskQueueQueryTasksResponse_Task_RequestMethod `protobuf:"varint,5,opt,name=method,enum=appengine.TaskQueueQueryTasksResponse_Task_RequestMethod" json:"method,omitempty"` 2125 RetryCount *int32 `protobuf:"varint,6,opt,name=retry_count,json=retryCount,def=0" json:"retry_count,omitempty"` 2126 Header []*TaskQueueQueryTasksResponse_Task_Header `protobuf:"group,7,rep,name=Header,json=header" json:"header,omitempty"` 2127 BodySize *int32 `protobuf:"varint,10,opt,name=body_size,json=bodySize" json:"body_size,omitempty"` 2128 Body []byte `protobuf:"bytes,11,opt,name=body" json:"body,omitempty"` 2129 CreationTimeUsec *int64 `protobuf:"varint,12,req,name=creation_time_usec,json=creationTimeUsec" json:"creation_time_usec,omitempty"` 2130 Crontimetable *TaskQueueQueryTasksResponse_Task_CronTimetable `protobuf:"group,13,opt,name=CronTimetable,json=crontimetable" json:"crontimetable,omitempty"` 2131 Runlog *TaskQueueQueryTasksResponse_Task_RunLog `protobuf:"group,16,opt,name=RunLog,json=runlog" json:"runlog,omitempty"` 2132 Description []byte `protobuf:"bytes,21,opt,name=description" json:"description,omitempty"` 2133 Payload *TaskPayload `protobuf:"bytes,22,opt,name=payload" json:"payload,omitempty"` 2134 RetryParameters *TaskQueueRetryParameters `protobuf:"bytes,23,opt,name=retry_parameters,json=retryParameters" json:"retry_parameters,omitempty"` 2135 FirstTryUsec *int64 `protobuf:"varint,24,opt,name=first_try_usec,json=firstTryUsec" json:"first_try_usec,omitempty"` 2136 Tag []byte `protobuf:"bytes,25,opt,name=tag" json:"tag,omitempty"` 2137 ExecutionCount *int32 `protobuf:"varint,26,opt,name=execution_count,json=executionCount,def=0" json:"execution_count,omitempty"` 2138 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2139 XXX_unrecognized []byte `json:"-"` 2140 XXX_sizecache int32 `json:"-"` 2141} 2142 2143func (m *TaskQueueQueryTasksResponse_Task) Reset() { *m = TaskQueueQueryTasksResponse_Task{} } 2144func (m *TaskQueueQueryTasksResponse_Task) String() string { return proto.CompactTextString(m) } 2145func (*TaskQueueQueryTasksResponse_Task) ProtoMessage() {} 2146func (*TaskQueueQueryTasksResponse_Task) Descriptor() ([]byte, []int) { 2147 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{30, 0} 2148} 2149func (m *TaskQueueQueryTasksResponse_Task) XXX_Unmarshal(b []byte) error { 2150 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task.Unmarshal(m, b) 2151} 2152func (m *TaskQueueQueryTasksResponse_Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2153 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task.Marshal(b, m, deterministic) 2154} 2155func (dst *TaskQueueQueryTasksResponse_Task) XXX_Merge(src proto.Message) { 2156 xxx_messageInfo_TaskQueueQueryTasksResponse_Task.Merge(dst, src) 2157} 2158func (m *TaskQueueQueryTasksResponse_Task) XXX_Size() int { 2159 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task.Size(m) 2160} 2161func (m *TaskQueueQueryTasksResponse_Task) XXX_DiscardUnknown() { 2162 xxx_messageInfo_TaskQueueQueryTasksResponse_Task.DiscardUnknown(m) 2163} 2164 2165var xxx_messageInfo_TaskQueueQueryTasksResponse_Task proto.InternalMessageInfo 2166 2167const Default_TaskQueueQueryTasksResponse_Task_RetryCount int32 = 0 2168const Default_TaskQueueQueryTasksResponse_Task_ExecutionCount int32 = 0 2169 2170func (m *TaskQueueQueryTasksResponse_Task) GetTaskName() []byte { 2171 if m != nil { 2172 return m.TaskName 2173 } 2174 return nil 2175} 2176 2177func (m *TaskQueueQueryTasksResponse_Task) GetEtaUsec() int64 { 2178 if m != nil && m.EtaUsec != nil { 2179 return *m.EtaUsec 2180 } 2181 return 0 2182} 2183 2184func (m *TaskQueueQueryTasksResponse_Task) GetUrl() []byte { 2185 if m != nil { 2186 return m.Url 2187 } 2188 return nil 2189} 2190 2191func (m *TaskQueueQueryTasksResponse_Task) GetMethod() TaskQueueQueryTasksResponse_Task_RequestMethod { 2192 if m != nil && m.Method != nil { 2193 return *m.Method 2194 } 2195 return TaskQueueQueryTasksResponse_Task_GET 2196} 2197 2198func (m *TaskQueueQueryTasksResponse_Task) GetRetryCount() int32 { 2199 if m != nil && m.RetryCount != nil { 2200 return *m.RetryCount 2201 } 2202 return Default_TaskQueueQueryTasksResponse_Task_RetryCount 2203} 2204 2205func (m *TaskQueueQueryTasksResponse_Task) GetHeader() []*TaskQueueQueryTasksResponse_Task_Header { 2206 if m != nil { 2207 return m.Header 2208 } 2209 return nil 2210} 2211 2212func (m *TaskQueueQueryTasksResponse_Task) GetBodySize() int32 { 2213 if m != nil && m.BodySize != nil { 2214 return *m.BodySize 2215 } 2216 return 0 2217} 2218 2219func (m *TaskQueueQueryTasksResponse_Task) GetBody() []byte { 2220 if m != nil { 2221 return m.Body 2222 } 2223 return nil 2224} 2225 2226func (m *TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec() int64 { 2227 if m != nil && m.CreationTimeUsec != nil { 2228 return *m.CreationTimeUsec 2229 } 2230 return 0 2231} 2232 2233func (m *TaskQueueQueryTasksResponse_Task) GetCrontimetable() *TaskQueueQueryTasksResponse_Task_CronTimetable { 2234 if m != nil { 2235 return m.Crontimetable 2236 } 2237 return nil 2238} 2239 2240func (m *TaskQueueQueryTasksResponse_Task) GetRunlog() *TaskQueueQueryTasksResponse_Task_RunLog { 2241 if m != nil { 2242 return m.Runlog 2243 } 2244 return nil 2245} 2246 2247func (m *TaskQueueQueryTasksResponse_Task) GetDescription() []byte { 2248 if m != nil { 2249 return m.Description 2250 } 2251 return nil 2252} 2253 2254func (m *TaskQueueQueryTasksResponse_Task) GetPayload() *TaskPayload { 2255 if m != nil { 2256 return m.Payload 2257 } 2258 return nil 2259} 2260 2261func (m *TaskQueueQueryTasksResponse_Task) GetRetryParameters() *TaskQueueRetryParameters { 2262 if m != nil { 2263 return m.RetryParameters 2264 } 2265 return nil 2266} 2267 2268func (m *TaskQueueQueryTasksResponse_Task) GetFirstTryUsec() int64 { 2269 if m != nil && m.FirstTryUsec != nil { 2270 return *m.FirstTryUsec 2271 } 2272 return 0 2273} 2274 2275func (m *TaskQueueQueryTasksResponse_Task) GetTag() []byte { 2276 if m != nil { 2277 return m.Tag 2278 } 2279 return nil 2280} 2281 2282func (m *TaskQueueQueryTasksResponse_Task) GetExecutionCount() int32 { 2283 if m != nil && m.ExecutionCount != nil { 2284 return *m.ExecutionCount 2285 } 2286 return Default_TaskQueueQueryTasksResponse_Task_ExecutionCount 2287} 2288 2289type TaskQueueQueryTasksResponse_Task_Header struct { 2290 Key []byte `protobuf:"bytes,8,req,name=key" json:"key,omitempty"` 2291 Value []byte `protobuf:"bytes,9,req,name=value" json:"value,omitempty"` 2292 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2293 XXX_unrecognized []byte `json:"-"` 2294 XXX_sizecache int32 `json:"-"` 2295} 2296 2297func (m *TaskQueueQueryTasksResponse_Task_Header) Reset() { 2298 *m = TaskQueueQueryTasksResponse_Task_Header{} 2299} 2300func (m *TaskQueueQueryTasksResponse_Task_Header) String() string { return proto.CompactTextString(m) } 2301func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage() {} 2302func (*TaskQueueQueryTasksResponse_Task_Header) Descriptor() ([]byte, []int) { 2303 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{30, 0, 0} 2304} 2305func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_Unmarshal(b []byte) error { 2306 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_Header.Unmarshal(m, b) 2307} 2308func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2309 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_Header.Marshal(b, m, deterministic) 2310} 2311func (dst *TaskQueueQueryTasksResponse_Task_Header) XXX_Merge(src proto.Message) { 2312 xxx_messageInfo_TaskQueueQueryTasksResponse_Task_Header.Merge(dst, src) 2313} 2314func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_Size() int { 2315 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_Header.Size(m) 2316} 2317func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_DiscardUnknown() { 2318 xxx_messageInfo_TaskQueueQueryTasksResponse_Task_Header.DiscardUnknown(m) 2319} 2320 2321var xxx_messageInfo_TaskQueueQueryTasksResponse_Task_Header proto.InternalMessageInfo 2322 2323func (m *TaskQueueQueryTasksResponse_Task_Header) GetKey() []byte { 2324 if m != nil { 2325 return m.Key 2326 } 2327 return nil 2328} 2329 2330func (m *TaskQueueQueryTasksResponse_Task_Header) GetValue() []byte { 2331 if m != nil { 2332 return m.Value 2333 } 2334 return nil 2335} 2336 2337type TaskQueueQueryTasksResponse_Task_CronTimetable struct { 2338 Schedule []byte `protobuf:"bytes,14,req,name=schedule" json:"schedule,omitempty"` 2339 Timezone []byte `protobuf:"bytes,15,req,name=timezone" json:"timezone,omitempty"` 2340 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2341 XXX_unrecognized []byte `json:"-"` 2342 XXX_sizecache int32 `json:"-"` 2343} 2344 2345func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) Reset() { 2346 *m = TaskQueueQueryTasksResponse_Task_CronTimetable{} 2347} 2348func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) String() string { 2349 return proto.CompactTextString(m) 2350} 2351func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage() {} 2352func (*TaskQueueQueryTasksResponse_Task_CronTimetable) Descriptor() ([]byte, []int) { 2353 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{30, 0, 1} 2354} 2355func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Unmarshal(b []byte) error { 2356 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_CronTimetable.Unmarshal(m, b) 2357} 2358func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2359 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_CronTimetable.Marshal(b, m, deterministic) 2360} 2361func (dst *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Merge(src proto.Message) { 2362 xxx_messageInfo_TaskQueueQueryTasksResponse_Task_CronTimetable.Merge(dst, src) 2363} 2364func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Size() int { 2365 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_CronTimetable.Size(m) 2366} 2367func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_DiscardUnknown() { 2368 xxx_messageInfo_TaskQueueQueryTasksResponse_Task_CronTimetable.DiscardUnknown(m) 2369} 2370 2371var xxx_messageInfo_TaskQueueQueryTasksResponse_Task_CronTimetable proto.InternalMessageInfo 2372 2373func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) GetSchedule() []byte { 2374 if m != nil { 2375 return m.Schedule 2376 } 2377 return nil 2378} 2379 2380func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) GetTimezone() []byte { 2381 if m != nil { 2382 return m.Timezone 2383 } 2384 return nil 2385} 2386 2387type TaskQueueQueryTasksResponse_Task_RunLog struct { 2388 DispatchedUsec *int64 `protobuf:"varint,17,req,name=dispatched_usec,json=dispatchedUsec" json:"dispatched_usec,omitempty"` 2389 LagUsec *int64 `protobuf:"varint,18,req,name=lag_usec,json=lagUsec" json:"lag_usec,omitempty"` 2390 ElapsedUsec *int64 `protobuf:"varint,19,req,name=elapsed_usec,json=elapsedUsec" json:"elapsed_usec,omitempty"` 2391 ResponseCode *int64 `protobuf:"varint,20,opt,name=response_code,json=responseCode" json:"response_code,omitempty"` 2392 RetryReason *string `protobuf:"bytes,27,opt,name=retry_reason,json=retryReason" json:"retry_reason,omitempty"` 2393 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2394 XXX_unrecognized []byte `json:"-"` 2395 XXX_sizecache int32 `json:"-"` 2396} 2397 2398func (m *TaskQueueQueryTasksResponse_Task_RunLog) Reset() { 2399 *m = TaskQueueQueryTasksResponse_Task_RunLog{} 2400} 2401func (m *TaskQueueQueryTasksResponse_Task_RunLog) String() string { return proto.CompactTextString(m) } 2402func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage() {} 2403func (*TaskQueueQueryTasksResponse_Task_RunLog) Descriptor() ([]byte, []int) { 2404 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{30, 0, 2} 2405} 2406func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Unmarshal(b []byte) error { 2407 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_RunLog.Unmarshal(m, b) 2408} 2409func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2410 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_RunLog.Marshal(b, m, deterministic) 2411} 2412func (dst *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Merge(src proto.Message) { 2413 xxx_messageInfo_TaskQueueQueryTasksResponse_Task_RunLog.Merge(dst, src) 2414} 2415func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Size() int { 2416 return xxx_messageInfo_TaskQueueQueryTasksResponse_Task_RunLog.Size(m) 2417} 2418func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_DiscardUnknown() { 2419 xxx_messageInfo_TaskQueueQueryTasksResponse_Task_RunLog.DiscardUnknown(m) 2420} 2421 2422var xxx_messageInfo_TaskQueueQueryTasksResponse_Task_RunLog proto.InternalMessageInfo 2423 2424func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec() int64 { 2425 if m != nil && m.DispatchedUsec != nil { 2426 return *m.DispatchedUsec 2427 } 2428 return 0 2429} 2430 2431func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec() int64 { 2432 if m != nil && m.LagUsec != nil { 2433 return *m.LagUsec 2434 } 2435 return 0 2436} 2437 2438func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec() int64 { 2439 if m != nil && m.ElapsedUsec != nil { 2440 return *m.ElapsedUsec 2441 } 2442 return 0 2443} 2444 2445func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode() int64 { 2446 if m != nil && m.ResponseCode != nil { 2447 return *m.ResponseCode 2448 } 2449 return 0 2450} 2451 2452func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason() string { 2453 if m != nil && m.RetryReason != nil { 2454 return *m.RetryReason 2455 } 2456 return "" 2457} 2458 2459type TaskQueueFetchTaskRequest struct { 2460 AppId []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"` 2461 QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 2462 TaskName []byte `protobuf:"bytes,3,req,name=task_name,json=taskName" json:"task_name,omitempty"` 2463 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2464 XXX_unrecognized []byte `json:"-"` 2465 XXX_sizecache int32 `json:"-"` 2466} 2467 2468func (m *TaskQueueFetchTaskRequest) Reset() { *m = TaskQueueFetchTaskRequest{} } 2469func (m *TaskQueueFetchTaskRequest) String() string { return proto.CompactTextString(m) } 2470func (*TaskQueueFetchTaskRequest) ProtoMessage() {} 2471func (*TaskQueueFetchTaskRequest) Descriptor() ([]byte, []int) { 2472 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{31} 2473} 2474func (m *TaskQueueFetchTaskRequest) XXX_Unmarshal(b []byte) error { 2475 return xxx_messageInfo_TaskQueueFetchTaskRequest.Unmarshal(m, b) 2476} 2477func (m *TaskQueueFetchTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2478 return xxx_messageInfo_TaskQueueFetchTaskRequest.Marshal(b, m, deterministic) 2479} 2480func (dst *TaskQueueFetchTaskRequest) XXX_Merge(src proto.Message) { 2481 xxx_messageInfo_TaskQueueFetchTaskRequest.Merge(dst, src) 2482} 2483func (m *TaskQueueFetchTaskRequest) XXX_Size() int { 2484 return xxx_messageInfo_TaskQueueFetchTaskRequest.Size(m) 2485} 2486func (m *TaskQueueFetchTaskRequest) XXX_DiscardUnknown() { 2487 xxx_messageInfo_TaskQueueFetchTaskRequest.DiscardUnknown(m) 2488} 2489 2490var xxx_messageInfo_TaskQueueFetchTaskRequest proto.InternalMessageInfo 2491 2492func (m *TaskQueueFetchTaskRequest) GetAppId() []byte { 2493 if m != nil { 2494 return m.AppId 2495 } 2496 return nil 2497} 2498 2499func (m *TaskQueueFetchTaskRequest) GetQueueName() []byte { 2500 if m != nil { 2501 return m.QueueName 2502 } 2503 return nil 2504} 2505 2506func (m *TaskQueueFetchTaskRequest) GetTaskName() []byte { 2507 if m != nil { 2508 return m.TaskName 2509 } 2510 return nil 2511} 2512 2513type TaskQueueFetchTaskResponse struct { 2514 Task *TaskQueueQueryTasksResponse `protobuf:"bytes,1,req,name=task" json:"task,omitempty"` 2515 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2516 XXX_unrecognized []byte `json:"-"` 2517 XXX_sizecache int32 `json:"-"` 2518} 2519 2520func (m *TaskQueueFetchTaskResponse) Reset() { *m = TaskQueueFetchTaskResponse{} } 2521func (m *TaskQueueFetchTaskResponse) String() string { return proto.CompactTextString(m) } 2522func (*TaskQueueFetchTaskResponse) ProtoMessage() {} 2523func (*TaskQueueFetchTaskResponse) Descriptor() ([]byte, []int) { 2524 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{32} 2525} 2526func (m *TaskQueueFetchTaskResponse) XXX_Unmarshal(b []byte) error { 2527 return xxx_messageInfo_TaskQueueFetchTaskResponse.Unmarshal(m, b) 2528} 2529func (m *TaskQueueFetchTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2530 return xxx_messageInfo_TaskQueueFetchTaskResponse.Marshal(b, m, deterministic) 2531} 2532func (dst *TaskQueueFetchTaskResponse) XXX_Merge(src proto.Message) { 2533 xxx_messageInfo_TaskQueueFetchTaskResponse.Merge(dst, src) 2534} 2535func (m *TaskQueueFetchTaskResponse) XXX_Size() int { 2536 return xxx_messageInfo_TaskQueueFetchTaskResponse.Size(m) 2537} 2538func (m *TaskQueueFetchTaskResponse) XXX_DiscardUnknown() { 2539 xxx_messageInfo_TaskQueueFetchTaskResponse.DiscardUnknown(m) 2540} 2541 2542var xxx_messageInfo_TaskQueueFetchTaskResponse proto.InternalMessageInfo 2543 2544func (m *TaskQueueFetchTaskResponse) GetTask() *TaskQueueQueryTasksResponse { 2545 if m != nil { 2546 return m.Task 2547 } 2548 return nil 2549} 2550 2551type TaskQueueUpdateStorageLimitRequest struct { 2552 AppId []byte `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"` 2553 Limit *int64 `protobuf:"varint,2,req,name=limit" json:"limit,omitempty"` 2554 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2555 XXX_unrecognized []byte `json:"-"` 2556 XXX_sizecache int32 `json:"-"` 2557} 2558 2559func (m *TaskQueueUpdateStorageLimitRequest) Reset() { *m = TaskQueueUpdateStorageLimitRequest{} } 2560func (m *TaskQueueUpdateStorageLimitRequest) String() string { return proto.CompactTextString(m) } 2561func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage() {} 2562func (*TaskQueueUpdateStorageLimitRequest) Descriptor() ([]byte, []int) { 2563 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{33} 2564} 2565func (m *TaskQueueUpdateStorageLimitRequest) XXX_Unmarshal(b []byte) error { 2566 return xxx_messageInfo_TaskQueueUpdateStorageLimitRequest.Unmarshal(m, b) 2567} 2568func (m *TaskQueueUpdateStorageLimitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2569 return xxx_messageInfo_TaskQueueUpdateStorageLimitRequest.Marshal(b, m, deterministic) 2570} 2571func (dst *TaskQueueUpdateStorageLimitRequest) XXX_Merge(src proto.Message) { 2572 xxx_messageInfo_TaskQueueUpdateStorageLimitRequest.Merge(dst, src) 2573} 2574func (m *TaskQueueUpdateStorageLimitRequest) XXX_Size() int { 2575 return xxx_messageInfo_TaskQueueUpdateStorageLimitRequest.Size(m) 2576} 2577func (m *TaskQueueUpdateStorageLimitRequest) XXX_DiscardUnknown() { 2578 xxx_messageInfo_TaskQueueUpdateStorageLimitRequest.DiscardUnknown(m) 2579} 2580 2581var xxx_messageInfo_TaskQueueUpdateStorageLimitRequest proto.InternalMessageInfo 2582 2583func (m *TaskQueueUpdateStorageLimitRequest) GetAppId() []byte { 2584 if m != nil { 2585 return m.AppId 2586 } 2587 return nil 2588} 2589 2590func (m *TaskQueueUpdateStorageLimitRequest) GetLimit() int64 { 2591 if m != nil && m.Limit != nil { 2592 return *m.Limit 2593 } 2594 return 0 2595} 2596 2597type TaskQueueUpdateStorageLimitResponse struct { 2598 NewLimit *int64 `protobuf:"varint,1,req,name=new_limit,json=newLimit" json:"new_limit,omitempty"` 2599 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2600 XXX_unrecognized []byte `json:"-"` 2601 XXX_sizecache int32 `json:"-"` 2602} 2603 2604func (m *TaskQueueUpdateStorageLimitResponse) Reset() { *m = TaskQueueUpdateStorageLimitResponse{} } 2605func (m *TaskQueueUpdateStorageLimitResponse) String() string { return proto.CompactTextString(m) } 2606func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage() {} 2607func (*TaskQueueUpdateStorageLimitResponse) Descriptor() ([]byte, []int) { 2608 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{34} 2609} 2610func (m *TaskQueueUpdateStorageLimitResponse) XXX_Unmarshal(b []byte) error { 2611 return xxx_messageInfo_TaskQueueUpdateStorageLimitResponse.Unmarshal(m, b) 2612} 2613func (m *TaskQueueUpdateStorageLimitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2614 return xxx_messageInfo_TaskQueueUpdateStorageLimitResponse.Marshal(b, m, deterministic) 2615} 2616func (dst *TaskQueueUpdateStorageLimitResponse) XXX_Merge(src proto.Message) { 2617 xxx_messageInfo_TaskQueueUpdateStorageLimitResponse.Merge(dst, src) 2618} 2619func (m *TaskQueueUpdateStorageLimitResponse) XXX_Size() int { 2620 return xxx_messageInfo_TaskQueueUpdateStorageLimitResponse.Size(m) 2621} 2622func (m *TaskQueueUpdateStorageLimitResponse) XXX_DiscardUnknown() { 2623 xxx_messageInfo_TaskQueueUpdateStorageLimitResponse.DiscardUnknown(m) 2624} 2625 2626var xxx_messageInfo_TaskQueueUpdateStorageLimitResponse proto.InternalMessageInfo 2627 2628func (m *TaskQueueUpdateStorageLimitResponse) GetNewLimit() int64 { 2629 if m != nil && m.NewLimit != nil { 2630 return *m.NewLimit 2631 } 2632 return 0 2633} 2634 2635type TaskQueueQueryAndOwnTasksRequest struct { 2636 QueueName []byte `protobuf:"bytes,1,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 2637 LeaseSeconds *float64 `protobuf:"fixed64,2,req,name=lease_seconds,json=leaseSeconds" json:"lease_seconds,omitempty"` 2638 MaxTasks *int64 `protobuf:"varint,3,req,name=max_tasks,json=maxTasks" json:"max_tasks,omitempty"` 2639 GroupByTag *bool `protobuf:"varint,4,opt,name=group_by_tag,json=groupByTag,def=0" json:"group_by_tag,omitempty"` 2640 Tag []byte `protobuf:"bytes,5,opt,name=tag" json:"tag,omitempty"` 2641 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2642 XXX_unrecognized []byte `json:"-"` 2643 XXX_sizecache int32 `json:"-"` 2644} 2645 2646func (m *TaskQueueQueryAndOwnTasksRequest) Reset() { *m = TaskQueueQueryAndOwnTasksRequest{} } 2647func (m *TaskQueueQueryAndOwnTasksRequest) String() string { return proto.CompactTextString(m) } 2648func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage() {} 2649func (*TaskQueueQueryAndOwnTasksRequest) Descriptor() ([]byte, []int) { 2650 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{35} 2651} 2652func (m *TaskQueueQueryAndOwnTasksRequest) XXX_Unmarshal(b []byte) error { 2653 return xxx_messageInfo_TaskQueueQueryAndOwnTasksRequest.Unmarshal(m, b) 2654} 2655func (m *TaskQueueQueryAndOwnTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2656 return xxx_messageInfo_TaskQueueQueryAndOwnTasksRequest.Marshal(b, m, deterministic) 2657} 2658func (dst *TaskQueueQueryAndOwnTasksRequest) XXX_Merge(src proto.Message) { 2659 xxx_messageInfo_TaskQueueQueryAndOwnTasksRequest.Merge(dst, src) 2660} 2661func (m *TaskQueueQueryAndOwnTasksRequest) XXX_Size() int { 2662 return xxx_messageInfo_TaskQueueQueryAndOwnTasksRequest.Size(m) 2663} 2664func (m *TaskQueueQueryAndOwnTasksRequest) XXX_DiscardUnknown() { 2665 xxx_messageInfo_TaskQueueQueryAndOwnTasksRequest.DiscardUnknown(m) 2666} 2667 2668var xxx_messageInfo_TaskQueueQueryAndOwnTasksRequest proto.InternalMessageInfo 2669 2670const Default_TaskQueueQueryAndOwnTasksRequest_GroupByTag bool = false 2671 2672func (m *TaskQueueQueryAndOwnTasksRequest) GetQueueName() []byte { 2673 if m != nil { 2674 return m.QueueName 2675 } 2676 return nil 2677} 2678 2679func (m *TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds() float64 { 2680 if m != nil && m.LeaseSeconds != nil { 2681 return *m.LeaseSeconds 2682 } 2683 return 0 2684} 2685 2686func (m *TaskQueueQueryAndOwnTasksRequest) GetMaxTasks() int64 { 2687 if m != nil && m.MaxTasks != nil { 2688 return *m.MaxTasks 2689 } 2690 return 0 2691} 2692 2693func (m *TaskQueueQueryAndOwnTasksRequest) GetGroupByTag() bool { 2694 if m != nil && m.GroupByTag != nil { 2695 return *m.GroupByTag 2696 } 2697 return Default_TaskQueueQueryAndOwnTasksRequest_GroupByTag 2698} 2699 2700func (m *TaskQueueQueryAndOwnTasksRequest) GetTag() []byte { 2701 if m != nil { 2702 return m.Tag 2703 } 2704 return nil 2705} 2706 2707type TaskQueueQueryAndOwnTasksResponse struct { 2708 Task []*TaskQueueQueryAndOwnTasksResponse_Task `protobuf:"group,1,rep,name=Task,json=task" json:"task,omitempty"` 2709 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2710 XXX_unrecognized []byte `json:"-"` 2711 XXX_sizecache int32 `json:"-"` 2712} 2713 2714func (m *TaskQueueQueryAndOwnTasksResponse) Reset() { *m = TaskQueueQueryAndOwnTasksResponse{} } 2715func (m *TaskQueueQueryAndOwnTasksResponse) String() string { return proto.CompactTextString(m) } 2716func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage() {} 2717func (*TaskQueueQueryAndOwnTasksResponse) Descriptor() ([]byte, []int) { 2718 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{36} 2719} 2720func (m *TaskQueueQueryAndOwnTasksResponse) XXX_Unmarshal(b []byte) error { 2721 return xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse.Unmarshal(m, b) 2722} 2723func (m *TaskQueueQueryAndOwnTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2724 return xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse.Marshal(b, m, deterministic) 2725} 2726func (dst *TaskQueueQueryAndOwnTasksResponse) XXX_Merge(src proto.Message) { 2727 xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse.Merge(dst, src) 2728} 2729func (m *TaskQueueQueryAndOwnTasksResponse) XXX_Size() int { 2730 return xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse.Size(m) 2731} 2732func (m *TaskQueueQueryAndOwnTasksResponse) XXX_DiscardUnknown() { 2733 xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse.DiscardUnknown(m) 2734} 2735 2736var xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse proto.InternalMessageInfo 2737 2738func (m *TaskQueueQueryAndOwnTasksResponse) GetTask() []*TaskQueueQueryAndOwnTasksResponse_Task { 2739 if m != nil { 2740 return m.Task 2741 } 2742 return nil 2743} 2744 2745type TaskQueueQueryAndOwnTasksResponse_Task struct { 2746 TaskName []byte `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"` 2747 EtaUsec *int64 `protobuf:"varint,3,req,name=eta_usec,json=etaUsec" json:"eta_usec,omitempty"` 2748 RetryCount *int32 `protobuf:"varint,4,opt,name=retry_count,json=retryCount,def=0" json:"retry_count,omitempty"` 2749 Body []byte `protobuf:"bytes,5,opt,name=body" json:"body,omitempty"` 2750 Tag []byte `protobuf:"bytes,6,opt,name=tag" json:"tag,omitempty"` 2751 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2752 XXX_unrecognized []byte `json:"-"` 2753 XXX_sizecache int32 `json:"-"` 2754} 2755 2756func (m *TaskQueueQueryAndOwnTasksResponse_Task) Reset() { 2757 *m = TaskQueueQueryAndOwnTasksResponse_Task{} 2758} 2759func (m *TaskQueueQueryAndOwnTasksResponse_Task) String() string { return proto.CompactTextString(m) } 2760func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage() {} 2761func (*TaskQueueQueryAndOwnTasksResponse_Task) Descriptor() ([]byte, []int) { 2762 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{36, 0} 2763} 2764func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Unmarshal(b []byte) error { 2765 return xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse_Task.Unmarshal(m, b) 2766} 2767func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2768 return xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse_Task.Marshal(b, m, deterministic) 2769} 2770func (dst *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Merge(src proto.Message) { 2771 xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse_Task.Merge(dst, src) 2772} 2773func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Size() int { 2774 return xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse_Task.Size(m) 2775} 2776func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_DiscardUnknown() { 2777 xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse_Task.DiscardUnknown(m) 2778} 2779 2780var xxx_messageInfo_TaskQueueQueryAndOwnTasksResponse_Task proto.InternalMessageInfo 2781 2782const Default_TaskQueueQueryAndOwnTasksResponse_Task_RetryCount int32 = 0 2783 2784func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetTaskName() []byte { 2785 if m != nil { 2786 return m.TaskName 2787 } 2788 return nil 2789} 2790 2791func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec() int64 { 2792 if m != nil && m.EtaUsec != nil { 2793 return *m.EtaUsec 2794 } 2795 return 0 2796} 2797 2798func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount() int32 { 2799 if m != nil && m.RetryCount != nil { 2800 return *m.RetryCount 2801 } 2802 return Default_TaskQueueQueryAndOwnTasksResponse_Task_RetryCount 2803} 2804 2805func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetBody() []byte { 2806 if m != nil { 2807 return m.Body 2808 } 2809 return nil 2810} 2811 2812func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetTag() []byte { 2813 if m != nil { 2814 return m.Tag 2815 } 2816 return nil 2817} 2818 2819type TaskQueueModifyTaskLeaseRequest struct { 2820 QueueName []byte `protobuf:"bytes,1,req,name=queue_name,json=queueName" json:"queue_name,omitempty"` 2821 TaskName []byte `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"` 2822 EtaUsec *int64 `protobuf:"varint,3,req,name=eta_usec,json=etaUsec" json:"eta_usec,omitempty"` 2823 LeaseSeconds *float64 `protobuf:"fixed64,4,req,name=lease_seconds,json=leaseSeconds" json:"lease_seconds,omitempty"` 2824 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2825 XXX_unrecognized []byte `json:"-"` 2826 XXX_sizecache int32 `json:"-"` 2827} 2828 2829func (m *TaskQueueModifyTaskLeaseRequest) Reset() { *m = TaskQueueModifyTaskLeaseRequest{} } 2830func (m *TaskQueueModifyTaskLeaseRequest) String() string { return proto.CompactTextString(m) } 2831func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage() {} 2832func (*TaskQueueModifyTaskLeaseRequest) Descriptor() ([]byte, []int) { 2833 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{37} 2834} 2835func (m *TaskQueueModifyTaskLeaseRequest) XXX_Unmarshal(b []byte) error { 2836 return xxx_messageInfo_TaskQueueModifyTaskLeaseRequest.Unmarshal(m, b) 2837} 2838func (m *TaskQueueModifyTaskLeaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2839 return xxx_messageInfo_TaskQueueModifyTaskLeaseRequest.Marshal(b, m, deterministic) 2840} 2841func (dst *TaskQueueModifyTaskLeaseRequest) XXX_Merge(src proto.Message) { 2842 xxx_messageInfo_TaskQueueModifyTaskLeaseRequest.Merge(dst, src) 2843} 2844func (m *TaskQueueModifyTaskLeaseRequest) XXX_Size() int { 2845 return xxx_messageInfo_TaskQueueModifyTaskLeaseRequest.Size(m) 2846} 2847func (m *TaskQueueModifyTaskLeaseRequest) XXX_DiscardUnknown() { 2848 xxx_messageInfo_TaskQueueModifyTaskLeaseRequest.DiscardUnknown(m) 2849} 2850 2851var xxx_messageInfo_TaskQueueModifyTaskLeaseRequest proto.InternalMessageInfo 2852 2853func (m *TaskQueueModifyTaskLeaseRequest) GetQueueName() []byte { 2854 if m != nil { 2855 return m.QueueName 2856 } 2857 return nil 2858} 2859 2860func (m *TaskQueueModifyTaskLeaseRequest) GetTaskName() []byte { 2861 if m != nil { 2862 return m.TaskName 2863 } 2864 return nil 2865} 2866 2867func (m *TaskQueueModifyTaskLeaseRequest) GetEtaUsec() int64 { 2868 if m != nil && m.EtaUsec != nil { 2869 return *m.EtaUsec 2870 } 2871 return 0 2872} 2873 2874func (m *TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds() float64 { 2875 if m != nil && m.LeaseSeconds != nil { 2876 return *m.LeaseSeconds 2877 } 2878 return 0 2879} 2880 2881type TaskQueueModifyTaskLeaseResponse struct { 2882 UpdatedEtaUsec *int64 `protobuf:"varint,1,req,name=updated_eta_usec,json=updatedEtaUsec" json:"updated_eta_usec,omitempty"` 2883 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2884 XXX_unrecognized []byte `json:"-"` 2885 XXX_sizecache int32 `json:"-"` 2886} 2887 2888func (m *TaskQueueModifyTaskLeaseResponse) Reset() { *m = TaskQueueModifyTaskLeaseResponse{} } 2889func (m *TaskQueueModifyTaskLeaseResponse) String() string { return proto.CompactTextString(m) } 2890func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage() {} 2891func (*TaskQueueModifyTaskLeaseResponse) Descriptor() ([]byte, []int) { 2892 return fileDescriptor_taskqueue_service_05300f6f4e69f490, []int{38} 2893} 2894func (m *TaskQueueModifyTaskLeaseResponse) XXX_Unmarshal(b []byte) error { 2895 return xxx_messageInfo_TaskQueueModifyTaskLeaseResponse.Unmarshal(m, b) 2896} 2897func (m *TaskQueueModifyTaskLeaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2898 return xxx_messageInfo_TaskQueueModifyTaskLeaseResponse.Marshal(b, m, deterministic) 2899} 2900func (dst *TaskQueueModifyTaskLeaseResponse) XXX_Merge(src proto.Message) { 2901 xxx_messageInfo_TaskQueueModifyTaskLeaseResponse.Merge(dst, src) 2902} 2903func (m *TaskQueueModifyTaskLeaseResponse) XXX_Size() int { 2904 return xxx_messageInfo_TaskQueueModifyTaskLeaseResponse.Size(m) 2905} 2906func (m *TaskQueueModifyTaskLeaseResponse) XXX_DiscardUnknown() { 2907 xxx_messageInfo_TaskQueueModifyTaskLeaseResponse.DiscardUnknown(m) 2908} 2909 2910var xxx_messageInfo_TaskQueueModifyTaskLeaseResponse proto.InternalMessageInfo 2911 2912func (m *TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec() int64 { 2913 if m != nil && m.UpdatedEtaUsec != nil { 2914 return *m.UpdatedEtaUsec 2915 } 2916 return 0 2917} 2918 2919func init() { 2920 proto.RegisterType((*TaskQueueServiceError)(nil), "appengine.TaskQueueServiceError") 2921 proto.RegisterType((*TaskPayload)(nil), "appengine.TaskPayload") 2922 proto.RegisterType((*TaskQueueRetryParameters)(nil), "appengine.TaskQueueRetryParameters") 2923 proto.RegisterType((*TaskQueueAcl)(nil), "appengine.TaskQueueAcl") 2924 proto.RegisterType((*TaskQueueHttpHeader)(nil), "appengine.TaskQueueHttpHeader") 2925 proto.RegisterType((*TaskQueueMode)(nil), "appengine.TaskQueueMode") 2926 proto.RegisterType((*TaskQueueAddRequest)(nil), "appengine.TaskQueueAddRequest") 2927 proto.RegisterType((*TaskQueueAddRequest_Header)(nil), "appengine.TaskQueueAddRequest.Header") 2928 proto.RegisterType((*TaskQueueAddRequest_CronTimetable)(nil), "appengine.TaskQueueAddRequest.CronTimetable") 2929 proto.RegisterType((*TaskQueueAddResponse)(nil), "appengine.TaskQueueAddResponse") 2930 proto.RegisterType((*TaskQueueBulkAddRequest)(nil), "appengine.TaskQueueBulkAddRequest") 2931 proto.RegisterType((*TaskQueueBulkAddResponse)(nil), "appengine.TaskQueueBulkAddResponse") 2932 proto.RegisterType((*TaskQueueBulkAddResponse_TaskResult)(nil), "appengine.TaskQueueBulkAddResponse.TaskResult") 2933 proto.RegisterType((*TaskQueueDeleteRequest)(nil), "appengine.TaskQueueDeleteRequest") 2934 proto.RegisterType((*TaskQueueDeleteResponse)(nil), "appengine.TaskQueueDeleteResponse") 2935 proto.RegisterType((*TaskQueueForceRunRequest)(nil), "appengine.TaskQueueForceRunRequest") 2936 proto.RegisterType((*TaskQueueForceRunResponse)(nil), "appengine.TaskQueueForceRunResponse") 2937 proto.RegisterType((*TaskQueueUpdateQueueRequest)(nil), "appengine.TaskQueueUpdateQueueRequest") 2938 proto.RegisterType((*TaskQueueUpdateQueueResponse)(nil), "appengine.TaskQueueUpdateQueueResponse") 2939 proto.RegisterType((*TaskQueueFetchQueuesRequest)(nil), "appengine.TaskQueueFetchQueuesRequest") 2940 proto.RegisterType((*TaskQueueFetchQueuesResponse)(nil), "appengine.TaskQueueFetchQueuesResponse") 2941 proto.RegisterType((*TaskQueueFetchQueuesResponse_Queue)(nil), "appengine.TaskQueueFetchQueuesResponse.Queue") 2942 proto.RegisterType((*TaskQueueFetchQueueStatsRequest)(nil), "appengine.TaskQueueFetchQueueStatsRequest") 2943 proto.RegisterType((*TaskQueueScannerQueueInfo)(nil), "appengine.TaskQueueScannerQueueInfo") 2944 proto.RegisterType((*TaskQueueFetchQueueStatsResponse)(nil), "appengine.TaskQueueFetchQueueStatsResponse") 2945 proto.RegisterType((*TaskQueueFetchQueueStatsResponse_QueueStats)(nil), "appengine.TaskQueueFetchQueueStatsResponse.QueueStats") 2946 proto.RegisterType((*TaskQueuePauseQueueRequest)(nil), "appengine.TaskQueuePauseQueueRequest") 2947 proto.RegisterType((*TaskQueuePauseQueueResponse)(nil), "appengine.TaskQueuePauseQueueResponse") 2948 proto.RegisterType((*TaskQueuePurgeQueueRequest)(nil), "appengine.TaskQueuePurgeQueueRequest") 2949 proto.RegisterType((*TaskQueuePurgeQueueResponse)(nil), "appengine.TaskQueuePurgeQueueResponse") 2950 proto.RegisterType((*TaskQueueDeleteQueueRequest)(nil), "appengine.TaskQueueDeleteQueueRequest") 2951 proto.RegisterType((*TaskQueueDeleteQueueResponse)(nil), "appengine.TaskQueueDeleteQueueResponse") 2952 proto.RegisterType((*TaskQueueDeleteGroupRequest)(nil), "appengine.TaskQueueDeleteGroupRequest") 2953 proto.RegisterType((*TaskQueueDeleteGroupResponse)(nil), "appengine.TaskQueueDeleteGroupResponse") 2954 proto.RegisterType((*TaskQueueQueryTasksRequest)(nil), "appengine.TaskQueueQueryTasksRequest") 2955 proto.RegisterType((*TaskQueueQueryTasksResponse)(nil), "appengine.TaskQueueQueryTasksResponse") 2956 proto.RegisterType((*TaskQueueQueryTasksResponse_Task)(nil), "appengine.TaskQueueQueryTasksResponse.Task") 2957 proto.RegisterType((*TaskQueueQueryTasksResponse_Task_Header)(nil), "appengine.TaskQueueQueryTasksResponse.Task.Header") 2958 proto.RegisterType((*TaskQueueQueryTasksResponse_Task_CronTimetable)(nil), "appengine.TaskQueueQueryTasksResponse.Task.CronTimetable") 2959 proto.RegisterType((*TaskQueueQueryTasksResponse_Task_RunLog)(nil), "appengine.TaskQueueQueryTasksResponse.Task.RunLog") 2960 proto.RegisterType((*TaskQueueFetchTaskRequest)(nil), "appengine.TaskQueueFetchTaskRequest") 2961 proto.RegisterType((*TaskQueueFetchTaskResponse)(nil), "appengine.TaskQueueFetchTaskResponse") 2962 proto.RegisterType((*TaskQueueUpdateStorageLimitRequest)(nil), "appengine.TaskQueueUpdateStorageLimitRequest") 2963 proto.RegisterType((*TaskQueueUpdateStorageLimitResponse)(nil), "appengine.TaskQueueUpdateStorageLimitResponse") 2964 proto.RegisterType((*TaskQueueQueryAndOwnTasksRequest)(nil), "appengine.TaskQueueQueryAndOwnTasksRequest") 2965 proto.RegisterType((*TaskQueueQueryAndOwnTasksResponse)(nil), "appengine.TaskQueueQueryAndOwnTasksResponse") 2966 proto.RegisterType((*TaskQueueQueryAndOwnTasksResponse_Task)(nil), "appengine.TaskQueueQueryAndOwnTasksResponse.Task") 2967 proto.RegisterType((*TaskQueueModifyTaskLeaseRequest)(nil), "appengine.TaskQueueModifyTaskLeaseRequest") 2968 proto.RegisterType((*TaskQueueModifyTaskLeaseResponse)(nil), "appengine.TaskQueueModifyTaskLeaseResponse") 2969} 2970 2971func init() { 2972 proto.RegisterFile("google.golang.org/appengine/internal/taskqueue/taskqueue_service.proto", fileDescriptor_taskqueue_service_05300f6f4e69f490) 2973} 2974 2975var fileDescriptor_taskqueue_service_05300f6f4e69f490 = []byte{ 2976 // 2747 bytes of a gzipped FileDescriptorProto 2977 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x39, 0x4d, 0x73, 0xdb, 0xd6, 2978 0xb5, 0x01, 0xbf, 0x44, 0x1e, 0x7e, 0xc1, 0xd7, 0xb2, 0x44, 0x51, 0x71, 0x22, 0xc3, 0xf9, 0xd0, 2979 0x4b, 0xfc, 0x14, 0x59, 0x79, 0xe3, 0xbc, 0xa7, 0x99, 0x4c, 0x1e, 0x24, 0xc2, 0x32, 0x63, 0x8a, 2980 0xa4, 0x2f, 0xa1, 0x34, 0xce, 0x4c, 0x07, 0x73, 0x45, 0x5c, 0x51, 0x18, 0x81, 0x00, 0x83, 0x0f, 2981 0x5b, 0xf2, 0xa2, 0xab, 0xae, 0x3a, 0x5d, 0x74, 0xd3, 0xe9, 0x4c, 0x66, 0xba, 0xea, 0xf4, 0x37, 2982 0x74, 0xd7, 0xfe, 0x90, 0x2e, 0x3b, 0xd3, 0x3f, 0xd0, 0x55, 0xa7, 0x0b, 0x77, 0xee, 0xbd, 0x00, 2983 0x08, 0x4a, 0xb4, 0x6c, 0x4b, 0x49, 0x37, 0x12, 0x70, 0xce, 0xb9, 0xe7, 0xdc, 0xf3, 0x7d, 0x70, 2984 0x08, 0x0f, 0x47, 0xae, 0x3b, 0xb2, 0xe9, 0xc6, 0xc8, 0xb5, 0x89, 0x33, 0xda, 0x70, 0xbd, 0xd1, 2985 0x67, 0x64, 0x32, 0xa1, 0xce, 0xc8, 0x72, 0xe8, 0x67, 0x96, 0x13, 0x50, 0xcf, 0x21, 0xf6, 0x67, 2986 0x01, 0xf1, 0x4f, 0xbe, 0x0f, 0x69, 0x48, 0xa7, 0x4f, 0x86, 0x4f, 0xbd, 0x67, 0xd6, 0x90, 0x6e, 2987 0x4c, 0x3c, 0x37, 0x70, 0x51, 0x29, 0x39, 0xd5, 0x54, 0xdf, 0x88, 0xa5, 0x49, 0x02, 0xe2, 0x07, 2988 0xae, 0x47, 0xa7, 0x4f, 0xc6, 0xb3, 0xcf, 0x05, 0x37, 0xe5, 0xb7, 0x79, 0xb8, 0xa5, 0x13, 0xff, 2989 0xe4, 0x09, 0x93, 0x34, 0x10, 0x82, 0x34, 0xcf, 0x73, 0x3d, 0xe5, 0x5f, 0x39, 0x28, 0xf1, 0xa7, 2990 0x5d, 0xd7, 0xa4, 0xa8, 0x00, 0x99, 0xde, 0x63, 0xf9, 0x1d, 0x74, 0x03, 0xaa, 0x07, 0xdd, 0xc7, 2991 0xdd, 0xde, 0xcf, 0xba, 0xc6, 0x93, 0x03, 0xed, 0x40, 0x93, 0x25, 0x74, 0x13, 0xea, 0x3a, 0x56, 2992 0xbb, 0x83, 0xb6, 0xd6, 0xd5, 0x0d, 0x0d, 0xe3, 0x1e, 0x96, 0x33, 0x08, 0x41, 0xad, 0xdd, 0xd5, 2993 0x35, 0xdc, 0x55, 0x3b, 0x11, 0x2c, 0xcb, 0x60, 0xba, 0x3a, 0x78, 0x6c, 0xe8, 0xbd, 0x9e, 0xd1, 2994 0x51, 0xf1, 0x9e, 0x26, 0xe7, 0xd0, 0x2d, 0xb8, 0xd1, 0xee, 0x7e, 0xa3, 0x76, 0xda, 0x2d, 0x83, 2995 0xe3, 0xba, 0xea, 0xbe, 0x26, 0xe7, 0xd1, 0x12, 0xa0, 0x18, 0xcc, 0xc5, 0x08, 0x78, 0x01, 0xd5, 2996 0xa1, 0x1c, 0xc3, 0x0f, 0x70, 0x47, 0x5e, 0xb8, 0x48, 0x88, 0x55, 0x5d, 0x93, 0x8b, 0x8c, 0x6f, 2997 0x5f, 0xc3, 0xfb, 0xed, 0xc1, 0xa0, 0xdd, 0xeb, 0x1a, 0x2d, 0xad, 0xdb, 0xd6, 0x5a, 0x72, 0x09, 2998 0x2d, 0xc3, 0x4d, 0x2e, 0x46, 0xed, 0x60, 0x4d, 0x6d, 0x3d, 0x35, 0xb4, 0x6f, 0xdb, 0x03, 0x7d, 2999 0x20, 0x03, 0x57, 0xa2, 0xb7, 0xbf, 0x33, 0xd0, 0x7b, 0x5d, 0x4d, 0x5c, 0x45, 0x2e, 0xa7, 0xa5, 3000 0x69, 0xba, 0x2a, 0x57, 0x18, 0x55, 0x0c, 0xc0, 0xda, 0x93, 0x03, 0x6d, 0xa0, 0xcb, 0x55, 0x24, 3001 0x43, 0x25, 0x36, 0x09, 0x3f, 0x57, 0x43, 0x8b, 0x20, 0xa7, 0x98, 0x09, 0x3b, 0xd5, 0x99, 0xec, 3002 0xd6, 0x41, 0xbf, 0xd3, 0xde, 0x55, 0x75, 0x2d, 0xa5, 0xac, 0x8c, 0xca, 0xb0, 0x30, 0x78, 0xdc, 3003 0xee, 0xf7, 0xb5, 0x96, 0x7c, 0x83, 0x1b, 0xa9, 0xd7, 0x33, 0xf6, 0xd5, 0xee, 0x53, 0x4e, 0x34, 3004 0x90, 0x51, 0x5a, 0x6c, 0x5f, 0x7d, 0xda, 0xe9, 0xa9, 0x2d, 0xf9, 0x26, 0x7a, 0x17, 0x1a, 0xd3, 3005 0xbb, 0xe8, 0xf8, 0xa9, 0xd1, 0x57, 0xb1, 0xba, 0xaf, 0xe9, 0x1a, 0x1e, 0xc8, 0x8b, 0x17, 0xed, 3006 0xb2, 0xdf, 0x6b, 0x69, 0xf2, 0x2d, 0x76, 0x35, 0x75, 0xb7, 0x63, 0x74, 0x7a, 0xbd, 0xc7, 0x07, 3007 0xfd, 0xc8, 0x33, 0x4b, 0xe8, 0x2e, 0xbc, 0xcf, 0x5d, 0xa8, 0xee, 0xea, 0xed, 0x1e, 0x73, 0x59, 3008 0xa4, 0x5d, 0xca, 0x55, 0xcb, 0xa8, 0x09, 0x4b, 0xed, 0xee, 0x6e, 0x0f, 0x63, 0x6d, 0x57, 0x37, 3009 0x76, 0xb1, 0xa6, 0xea, 0x3d, 0x2c, 0x54, 0x68, 0x30, 0x71, 0x5c, 0xa3, 0x8e, 0xa6, 0x0e, 0x34, 3010 0x43, 0xfb, 0xb6, 0xdf, 0xc6, 0x5a, 0x4b, 0x5e, 0x61, 0xb6, 0x11, 0xe2, 0xfb, 0xea, 0xc1, 0x40, 3011 0x6b, 0xc9, 0xcd, 0xb4, 0x4d, 0x75, 0x75, 0x4f, 0x5e, 0x45, 0x8b, 0x50, 0x6f, 0xa9, 0xba, 0x3a, 3012 0xd0, 0x7b, 0x58, 0x8b, 0x2e, 0xf4, 0x9b, 0xae, 0xb2, 0x0a, 0x65, 0x16, 0x96, 0x7d, 0x72, 0x66, 3013 0xbb, 0xc4, 0xfc, 0xa4, 0x58, 0x04, 0xf9, 0xe5, 0xcb, 0x97, 0x2f, 0x17, 0xb6, 0x33, 0x45, 0x49, 3014 0xf9, 0x9b, 0x04, 0x8d, 0x24, 0x68, 0x31, 0x0d, 0xbc, 0xb3, 0x3e, 0xf1, 0xc8, 0x98, 0x06, 0xd4, 3015 0xf3, 0xd1, 0xfb, 0x50, 0xf6, 0x18, 0xc8, 0xb0, 0xad, 0xb1, 0x15, 0x34, 0xa4, 0x35, 0x69, 0x3d, 3016 0x8f, 0x81, 0x83, 0x3a, 0x0c, 0x82, 0x14, 0xa8, 0x92, 0x11, 0x15, 0x68, 0xc3, 0xa7, 0xc3, 0x46, 3017 0x66, 0x4d, 0x5a, 0xcf, 0xe2, 0x32, 0x19, 0x51, 0x4e, 0x30, 0xa0, 0x43, 0xf4, 0x29, 0xd4, 0xc7, 3018 0x96, 0x63, 0x1c, 0x92, 0xe1, 0x89, 0x7b, 0x74, 0xc4, 0xa9, 0xb2, 0x6b, 0xd2, 0xba, 0xb4, 0x9d, 3019 0xdd, 0xdc, 0xb8, 0x8f, 0xab, 0x63, 0xcb, 0xd9, 0x11, 0x28, 0x46, 0x7c, 0x0f, 0xea, 0x63, 0x72, 3020 0x3a, 0x43, 0x9c, 0xe3, 0xc4, 0xb9, 0xcf, 0x1f, 0x6c, 0x6e, 0xe2, 0xea, 0x98, 0x9c, 0xa6, 0xa8, 3021 0x3f, 0x06, 0x06, 0x30, 0x4c, 0x37, 0x3c, 0xb4, 0x2d, 0x67, 0xe4, 0x37, 0xf2, 0xec, 0x86, 0xdb, 3022 0x99, 0xfb, 0x0f, 0x70, 0x65, 0x4c, 0x4e, 0x5b, 0x31, 0x5c, 0xe9, 0x43, 0x25, 0x51, 0x52, 0x1d, 3023 0xda, 0xe8, 0x36, 0x40, 0xe8, 0x53, 0xcf, 0xa0, 0x63, 0x62, 0xd9, 0x0d, 0x69, 0x2d, 0xbb, 0x5e, 3024 0xc1, 0x25, 0x06, 0xd1, 0x18, 0x00, 0xdd, 0x81, 0xca, 0x73, 0xcf, 0x0a, 0x12, 0x82, 0x0c, 0x27, 3025 0x28, 0x0b, 0x18, 0x27, 0x51, 0xbe, 0x84, 0x9b, 0x09, 0xc7, 0x47, 0x41, 0x30, 0x79, 0x44, 0x89, 3026 0x49, 0x3d, 0x24, 0x43, 0xf6, 0x84, 0x9e, 0x35, 0xa4, 0xb5, 0xcc, 0x7a, 0x05, 0xb3, 0x47, 0xb4, 3027 0x08, 0xf9, 0x67, 0xc4, 0x0e, 0x69, 0x23, 0xc3, 0x61, 0xe2, 0x45, 0xf9, 0x14, 0xaa, 0xc9, 0xf1, 3028 0x7d, 0xd7, 0xa4, 0x4a, 0x13, 0x72, 0xec, 0x3f, 0x2a, 0x42, 0xae, 0x7f, 0x30, 0x78, 0x24, 0xbf, 3029 0x23, 0x9e, 0x3a, 0x1d, 0x59, 0x52, 0xfe, 0x51, 0x48, 0x09, 0x53, 0x4d, 0x13, 0xd3, 0xef, 0x43, 3030 0xea, 0x07, 0x4c, 0x0b, 0x51, 0xd5, 0x1c, 0x32, 0xa6, 0x91, 0xcc, 0x12, 0x87, 0x74, 0xc9, 0x98, 3031 0xa2, 0x55, 0x28, 0xb1, 0xc2, 0x27, 0xb0, 0x42, 0x7a, 0x91, 0x01, 0x38, 0x72, 0x05, 0x8a, 0x34, 3032 0x20, 0x46, 0x28, 0xdc, 0x91, 0x59, 0xcf, 0xe2, 0x05, 0x1a, 0x90, 0x03, 0x9f, 0x0e, 0xd1, 0xd7, 3033 0x50, 0x18, 0xd3, 0xe0, 0xd8, 0x35, 0xb9, 0x39, 0x6b, 0x5b, 0xf7, 0x36, 0x92, 0x4a, 0xb8, 0x31, 3034 0xe7, 0x1a, 0x1b, 0xd1, 0xff, 0x7d, 0x7e, 0x66, 0x3b, 0xd7, 0xef, 0x0d, 0x74, 0x1c, 0x71, 0x60, 3035 0xf6, 0x08, 0x3d, 0x9b, 0xfb, 0xb0, 0x82, 0xd9, 0x23, 0xfa, 0x12, 0x0a, 0xc7, 0xdc, 0x56, 0x8d, 3036 0xc2, 0x5a, 0x76, 0x1d, 0xb6, 0x3e, 0x7c, 0x0d, 0x77, 0x61, 0x58, 0x1c, 0x1d, 0x42, 0x4b, 0x90, 3037 0x3b, 0x74, 0xcd, 0xb3, 0x46, 0x89, 0x71, 0xdc, 0xc9, 0x14, 0x25, 0xcc, 0xdf, 0xd1, 0xff, 0x42, 3038 0x39, 0xf0, 0x88, 0xe3, 0x93, 0x61, 0x60, 0xb9, 0x4e, 0x03, 0xd6, 0xa4, 0xf5, 0xf2, 0xd6, 0x52, 3039 0x9a, 0xf7, 0x14, 0x8b, 0xd3, 0xa4, 0xe8, 0x16, 0x14, 0xc8, 0x64, 0x62, 0x58, 0x66, 0xa3, 0xcc, 3040 0x6f, 0x99, 0x27, 0x93, 0x49, 0xdb, 0x44, 0x18, 0xaa, 0x43, 0xcf, 0x75, 0x02, 0x6b, 0x4c, 0x03, 3041 0x72, 0x68, 0xd3, 0x46, 0x65, 0x4d, 0x5a, 0x87, 0xd7, 0x1a, 0x63, 0xd7, 0x73, 0x1d, 0x3d, 0x3e, 3042 0x83, 0x67, 0x59, 0xa0, 0x35, 0x28, 0x9b, 0xd4, 0x1f, 0x7a, 0xd6, 0x84, 0x5f, 0xb2, 0xce, 0xe5, 3043 0xa5, 0x41, 0x68, 0x13, 0x16, 0x26, 0x22, 0x4f, 0x1b, 0xf2, 0x45, 0x15, 0xa6, 0x59, 0x8c, 0x63, 3044 0x32, 0xd4, 0x05, 0x59, 0xe4, 0xe8, 0x24, 0xc9, 0xdb, 0xc6, 0x0d, 0x7e, 0xf4, 0xee, 0xbc, 0xab, 3045 0x9e, 0x4b, 0x71, 0x5c, 0xf7, 0xce, 0xe5, 0xfc, 0x17, 0x90, 0x1b, 0xbb, 0x26, 0x6d, 0x20, 0xee, 3046 0xfb, 0xdb, 0xf3, 0x78, 0xb0, 0x40, 0xdd, 0x60, 0x7f, 0xb6, 0x79, 0xac, 0x62, 0x7e, 0x80, 0xb9, 3047 0x3a, 0x20, 0xa3, 0xc6, 0x4d, 0xe1, 0xea, 0x80, 0x8c, 0x9a, 0x9b, 0x50, 0x98, 0x4d, 0x8b, 0x85, 3048 0x39, 0x69, 0x51, 0x4c, 0xa5, 0x45, 0x73, 0x0f, 0xaa, 0x33, 0x06, 0x44, 0x4d, 0x28, 0xfa, 0xc3, 3049 0x63, 0x6a, 0x86, 0x36, 0x6d, 0x54, 0x45, 0x08, 0xc7, 0xef, 0x0c, 0xc7, 0x4c, 0xfb, 0xc2, 0x75, 3050 0x68, 0xa3, 0x16, 0x85, 0x77, 0xf4, 0xae, 0xa8, 0x50, 0x9d, 0x09, 0x4b, 0xb4, 0x00, 0xd9, 0x3d, 3051 0x4d, 0x97, 0x25, 0x9e, 0x56, 0xbd, 0x81, 0x2e, 0x67, 0xd8, 0xd3, 0x23, 0x4d, 0x6d, 0xc9, 0x59, 3052 0x86, 0xec, 0x1f, 0xe8, 0x72, 0x0e, 0x01, 0x14, 0x5a, 0x5a, 0x47, 0xd3, 0x35, 0x39, 0xaf, 0xfc, 3053 0x3f, 0x2c, 0xce, 0x3a, 0xd8, 0x9f, 0xb8, 0x8e, 0x4f, 0xd1, 0x3a, 0xc8, 0xc3, 0x63, 0xd7, 0xa7, 3054 0x8e, 0x31, 0xcd, 0x2e, 0x89, 0x2b, 0x5d, 0x13, 0x70, 0x3d, 0xca, 0x31, 0xe5, 0x3b, 0x58, 0x4e, 3055 0x38, 0xec, 0x84, 0xf6, 0x49, 0x2a, 0x75, 0xbf, 0x82, 0x32, 0x31, 0x4d, 0xc3, 0x13, 0xaf, 0xbc, 3056 0x02, 0x95, 0xb7, 0xde, 0xbb, 0x3c, 0xb6, 0x30, 0x90, 0xe4, 0x59, 0xf9, 0x7b, 0xba, 0x6e, 0x27, 3057 0xcc, 0xa3, 0x2b, 0x76, 0x01, 0xd8, 0xdd, 0x3c, 0xea, 0x87, 0xb6, 0x60, 0x0e, 0x5b, 0x1b, 0xf3, 3058 0x98, 0x9f, 0x3b, 0xc8, 0x11, 0x98, 0x9f, 0xc2, 0x29, 0x0e, 0xcd, 0x17, 0x00, 0x53, 0x0c, 0xda, 3059 0x81, 0x42, 0xc4, 0x99, 0x15, 0x95, 0xda, 0xd6, 0x27, 0xf3, 0x38, 0xa7, 0xe7, 0x9f, 0x8d, 0x64, 3060 0xf6, 0xc1, 0xd1, 0xc9, 0xb9, 0x46, 0xcc, 0xce, 0x35, 0xe2, 0x09, 0x2c, 0x25, 0x4c, 0x5b, 0xd4, 3061 0xa6, 0x01, 0xbd, 0x5a, 0xf9, 0xcb, 0xce, 0x94, 0xbf, 0x69, 0xd2, 0x67, 0x53, 0x49, 0xaf, 0xfc, 3062 0x3c, 0xe5, 0xb1, 0x58, 0x58, 0x64, 0xd3, 0xa9, 0xd6, 0xd9, 0xb5, 0xec, 0xd5, 0xb4, 0x56, 0xc6, 3063 0x29, 0x9f, 0x3d, 0x74, 0xbd, 0x21, 0xc5, 0xa1, 0x13, 0x6b, 0x33, 0xbd, 0x91, 0x94, 0x2e, 0x43, 3064 0xb3, 0x4a, 0x66, 0x2e, 0x55, 0x32, 0x3b, 0x5b, 0xe3, 0x15, 0x03, 0x56, 0xe6, 0x88, 0x9b, 0xa3, 3065 0xcf, 0x15, 0xbd, 0xa8, 0xfc, 0x90, 0x83, 0xd5, 0x84, 0xf6, 0x60, 0x62, 0x92, 0x80, 0x46, 0x45, 3066 0xe6, 0x3a, 0x3a, 0x7d, 0x01, 0x8d, 0xc3, 0x70, 0x78, 0x42, 0x03, 0xc3, 0xa3, 0x47, 0x96, 0x6d, 3067 0x1b, 0x13, 0xea, 0xb1, 0x49, 0xc0, 0x75, 0x4c, 0x7e, 0x57, 0x09, 0xdf, 0x12, 0x78, 0xcc, 0xd1, 3068 0x7d, 0xea, 0x0d, 0x38, 0x12, 0x7d, 0x0c, 0xf5, 0xe8, 0xe0, 0x90, 0x4c, 0xc8, 0xd0, 0x0a, 0xce, 3069 0x1a, 0xb9, 0xb5, 0xcc, 0x7a, 0x1e, 0xd7, 0x04, 0x78, 0x37, 0x82, 0xa2, 0x0d, 0xb8, 0xc9, 0xdb, 3070 0xbf, 0x3f, 0xa1, 0x43, 0xeb, 0xc8, 0xa2, 0xa6, 0xe1, 0x91, 0x80, 0xf2, 0x76, 0x57, 0xc2, 0x37, 3071 0x18, 0x6a, 0x10, 0x63, 0x30, 0x09, 0xe8, 0xdc, 0x1a, 0x5b, 0xb8, 0x46, 0x8d, 0x7d, 0x00, 0xcb, 3072 0x6c, 0x6e, 0x19, 0xba, 0xce, 0x30, 0xf4, 0x3c, 0xea, 0x04, 0x71, 0x21, 0xf0, 0x1b, 0x0b, 0x7c, 3073 0xc6, 0xba, 0x35, 0x26, 0xa7, 0xbb, 0x09, 0x36, 0x32, 0xe7, 0xb4, 0x36, 0x17, 0xdf, 0xb6, 0x36, 3074 0xff, 0x17, 0x64, 0xc9, 0xd0, 0xe6, 0x4d, 0xb3, 0xbc, 0xb5, 0x3c, 0xb7, 0xcc, 0x0c, 0x6d, 0xcc, 3075 0x68, 0xd0, 0x1e, 0xd4, 0x45, 0xab, 0x35, 0xdc, 0x67, 0xd4, 0xf3, 0x2c, 0x93, 0x36, 0xe0, 0xd5, 3076 0xd5, 0x69, 0x3a, 0xfa, 0xe0, 0x9a, 0x38, 0xd6, 0x8b, 0x4e, 0x29, 0xef, 0xc1, 0xbb, 0xf3, 0x63, 3077 0x43, 0x04, 0xa0, 0xd2, 0x4b, 0xc5, 0xce, 0x43, 0x1a, 0x0c, 0x8f, 0xf9, 0x93, 0xff, 0x9a, 0xd8, 3078 0x59, 0x81, 0x22, 0x33, 0x9d, 0xe7, 0x3e, 0xf7, 0x79, 0xe4, 0xe4, 0xf1, 0xc2, 0x98, 0x9c, 0x62, 3079 0xf7, 0xb9, 0xaf, 0xfc, 0x31, 0x9f, 0x92, 0x38, 0xc3, 0x31, 0x0a, 0xf9, 0x5d, 0xc8, 0xf3, 0x28, 3080 0x8b, 0x2a, 0xe2, 0x7f, 0xcf, 0x53, 0x68, 0xce, 0xb9, 0x0d, 0x71, 0x6f, 0x71, 0xb6, 0xf9, 0x97, 3081 0x1c, 0xe4, 0x39, 0xe0, 0x3f, 0x1d, 0xc6, 0xd2, 0xb5, 0xc3, 0xf8, 0x36, 0x14, 0x26, 0x24, 0xf4, 3082 0xa9, 0xd9, 0x28, 0xac, 0x65, 0xd6, 0x8b, 0xdb, 0xf9, 0x23, 0x62, 0xfb, 0x14, 0x47, 0xc0, 0xb9, 3083 0x51, 0xbe, 0xf0, 0xd3, 0x44, 0x79, 0xf1, 0x4d, 0xa2, 0xbc, 0x74, 0xc5, 0x28, 0x87, 0xab, 0x45, 3084 0x79, 0xf9, 0x2a, 0x51, 0x8e, 0xee, 0x43, 0x65, 0xe8, 0x51, 0x12, 0xb8, 0x9e, 0x08, 0x03, 0x36, 3085 0x25, 0x96, 0xb6, 0x81, 0x4c, 0x26, 0xc7, 0xae, 0x1f, 0x58, 0xce, 0x88, 0xcf, 0xa8, 0xe5, 0x88, 3086 0x86, 0x97, 0xe5, 0x5f, 0xc0, 0xfb, 0x73, 0xc2, 0x6d, 0x10, 0x90, 0xc0, 0x7f, 0xcb, 0xc2, 0x99, 3087 0x9d, 0x8d, 0xb8, 0x0f, 0xc5, 0xe7, 0x90, 0x13, 0x8e, 0x79, 0x57, 0xf5, 0x79, 0x6f, 0xcb, 0x6f, 3088 0x4b, 0x9b, 0xb8, 0x3c, 0x26, 0xa7, 0xdd, 0x70, 0xcc, 0xc4, 0xfa, 0xca, 0xaf, 0x32, 0xa9, 0xbe, 3089 0x30, 0x18, 0x12, 0xc7, 0xa1, 0x1e, 0x7f, 0x6e, 0x3b, 0x47, 0x2e, 0xda, 0x84, 0x45, 0x7a, 0x4a, 3090 0x87, 0x61, 0x40, 0x4d, 0xc3, 0x26, 0x7e, 0x60, 0x8c, 0x2d, 0x27, 0x0c, 0x44, 0x7f, 0xcd, 0x62, 3091 0x14, 0xe3, 0x3a, 0xc4, 0x0f, 0xf6, 0x39, 0x06, 0xdd, 0x03, 0x34, 0x7b, 0xe2, 0xd8, 0x0d, 0x3d, 3092 0x9e, 0x0f, 0x59, 0x2c, 0xa7, 0xe9, 0x1f, 0xb9, 0xa1, 0x87, 0xb6, 0x61, 0xc5, 0x27, 0xe3, 0x09, 3093 0xfb, 0x2e, 0x33, 0xcc, 0xd0, 0x23, 0x6c, 0xec, 0x8d, 0xd2, 0xc2, 0x8f, 0xf2, 0x62, 0x39, 0x26, 3094 0x68, 0x45, 0x78, 0x91, 0x18, 0x3e, 0x93, 0x14, 0x87, 0x90, 0x61, 0x39, 0xc6, 0x91, 0x6d, 0x8d, 3095 0x8e, 0x03, 0xfe, 0x71, 0x91, 0xc7, 0x72, 0x8c, 0x69, 0x3b, 0x0f, 0x39, 0x1c, 0xdd, 0x85, 0x2a, 3096 0x75, 0x8e, 0x58, 0xdf, 0x4b, 0x25, 0x86, 0x84, 0x2b, 0x31, 0x90, 0xe5, 0x84, 0xf2, 0xbb, 0x0c, 3097 0xac, 0xbd, 0xda, 0x1b, 0x51, 0xe1, 0xf8, 0x26, 0xb2, 0xbb, 0xcf, 0xa0, 0x51, 0xf5, 0x78, 0x70, 3098 0x79, 0xf5, 0x98, 0x61, 0xb0, 0x91, 0x02, 0xa5, 0x38, 0x35, 0x7f, 0x90, 0x00, 0xa6, 0x28, 0xd6, 3099 0xcc, 0xa7, 0xbe, 0x13, 0xc5, 0xad, 0xe8, 0x44, 0x5e, 0x43, 0x1f, 0x41, 0xdd, 0xb5, 0x4d, 0xea, 3100 0x07, 0xc6, 0xb9, 0xef, 0xb6, 0xaa, 0x00, 0x6b, 0xd1, 0xd7, 0xdb, 0x1e, 0x54, 0x7c, 0xe1, 0x53, 3101 0xc3, 0x72, 0x8e, 0x5c, 0x6e, 0x9d, 0xf2, 0xd6, 0x07, 0x73, 0xbb, 0xfb, 0x39, 0xdf, 0xe3, 0x72, 3102 0x74, 0x92, 0xbd, 0x28, 0xc7, 0xd0, 0x4c, 0x28, 0xfb, 0xac, 0x42, 0xbc, 0xb2, 0xb5, 0x67, 0xde, 3103 0xb8, 0xb5, 0x2f, 0x42, 0x9e, 0x17, 0x1b, 0x7e, 0xf5, 0x22, 0x16, 0x2f, 0xca, 0xed, 0x54, 0x27, 3104 0x48, 0x4b, 0x8a, 0x1a, 0x05, 0x4e, 0x5f, 0x24, 0xf4, 0x46, 0x3f, 0xc2, 0x8c, 0x31, 0x2b, 0x32, 3105 0xc5, 0x33, 0x12, 0x39, 0x48, 0xa1, 0xc5, 0x1c, 0x78, 0x7d, 0xe5, 0x67, 0x1a, 0xe2, 0x0c, 0xd3, 3106 0x48, 0xe8, 0xff, 0x5c, 0x10, 0xba, 0xe7, 0xb9, 0xe1, 0xe4, 0x72, 0xa1, 0x73, 0xb8, 0x46, 0xa7, 3107 0x22, 0xae, 0x7f, 0x95, 0x52, 0xe6, 0x7b, 0x12, 0x52, 0xef, 0x8c, 0xc7, 0xd3, 0xf5, 0x46, 0xb4, 3108 0x8f, 0xa0, 0xee, 0x07, 0xc4, 0x0b, 0x2e, 0x4c, 0xef, 0x55, 0x0e, 0x8e, 0x87, 0x77, 0xf4, 0x01, 3109 0xd4, 0x04, 0x5d, 0x12, 0xb3, 0x39, 0xbe, 0x20, 0xaa, 0x70, 0x68, 0x1c, 0xb2, 0xab, 0x50, 0x8a, 3110 0xb9, 0x8d, 0xf8, 0x5c, 0xc5, 0xbe, 0xf2, 0x04, 0x9f, 0x11, 0x7a, 0x37, 0xd5, 0xf0, 0xc5, 0x7a, 3111 0x47, 0xba, 0x3f, 0xed, 0xf9, 0xbf, 0x84, 0x94, 0xd1, 0xd2, 0xda, 0x45, 0x99, 0xfb, 0x15, 0xe4, 3112 0xd8, 0x15, 0xa3, 0x9c, 0xfd, 0x74, 0x5e, 0x16, 0x5c, 0x3c, 0x25, 0x3e, 0x83, 0xf8, 0xc1, 0xe6, 3113 0x1f, 0x4a, 0x90, 0x63, 0xaf, 0x57, 0xde, 0xa6, 0x5c, 0xdc, 0x80, 0x3c, 0x39, 0xb7, 0x5f, 0xf9, 3114 0xbf, 0xb7, 0xb8, 0xd5, 0xec, 0xb2, 0x25, 0x59, 0xb3, 0x28, 0xf1, 0xa2, 0x6e, 0xe8, 0x86, 0x4e, 3115 0xc0, 0x6d, 0xc8, 0xeb, 0xbe, 0xd8, 0xd5, 0xed, 0x32, 0x20, 0xfa, 0x3a, 0x59, 0xbc, 0x2c, 0x70, 3116 0x63, 0x6c, 0xbd, 0x8d, 0xd8, 0x73, 0x5b, 0x98, 0x55, 0x28, 0x1d, 0xba, 0xe6, 0x99, 0xe1, 0x5b, 3117 0x2f, 0x28, 0xef, 0xb7, 0x79, 0x5c, 0x64, 0x80, 0x81, 0xf5, 0x82, 0x26, 0x2b, 0x9a, 0xf2, 0xb9, 3118 0x15, 0xcd, 0x3d, 0x40, 0xbc, 0x0d, 0xb2, 0x82, 0xcf, 0x3e, 0xd4, 0x85, 0xb9, 0x2a, 0xa2, 0x4f, 3119 0xc4, 0x18, 0xf6, 0xe9, 0xcf, 0xed, 0x66, 0x9c, 0xdf, 0xbf, 0x54, 0xf9, 0xfe, 0xe5, 0xad, 0x8c, 3120 0x75, 0xe9, 0x32, 0xe6, 0x6b, 0x28, 0x78, 0xa1, 0x63, 0xbb, 0x23, 0xbe, 0x69, 0x79, 0x4b, 0x7b, 3121 0xe0, 0xd0, 0xe9, 0xb8, 0x23, 0x1c, 0x71, 0x38, 0xbf, 0xd8, 0xb9, 0x75, 0xe9, 0x62, 0x67, 0xe9, 3122 0xea, 0x8b, 0x9d, 0xe5, 0x6b, 0x8c, 0x63, 0x1f, 0x40, 0xed, 0xc8, 0xf2, 0xfc, 0xc0, 0x60, 0x3c, 3123 0xb9, 0xe9, 0x1b, 0x22, 0x17, 0x39, 0x54, 0xf7, 0xce, 0xe2, 0x70, 0x65, 0x59, 0xb8, 0x92, 0x6c, 3124 0x71, 0xd0, 0x27, 0x50, 0x17, 0x4d, 0x9c, 0xf9, 0x4d, 0xc4, 0x57, 0x33, 0x8e, 0xaf, 0x5a, 0x82, 3125 0xe1, 0x31, 0x76, 0x71, 0xe3, 0x53, 0x9c, 0xb3, 0xf1, 0x29, 0xbd, 0xf1, 0xc6, 0xa7, 0x76, 0xc9, 3126 0xc6, 0xa7, 0x3e, 0xbb, 0xf1, 0x69, 0xfe, 0x49, 0x82, 0x82, 0xf0, 0x0a, 0x1b, 0xa0, 0x4d, 0xcb, 3127 0x9f, 0x90, 0x80, 0x9d, 0x13, 0xaa, 0xde, 0xe0, 0x51, 0x56, 0x9b, 0x82, 0xb9, 0xb2, 0x2b, 0x50, 3128 0xb4, 0xc9, 0x48, 0x50, 0x20, 0x91, 0xb6, 0x36, 0x19, 0x71, 0xd4, 0x1d, 0xa8, 0x50, 0x9b, 0x4c, 3129 0xfc, 0x98, 0xc1, 0x4d, 0x8e, 0x2e, 0x47, 0x30, 0x4e, 0x72, 0x17, 0xaa, 0x5e, 0x14, 0x14, 0xc6, 3130 0x90, 0x0d, 0xac, 0x8b, 0xc2, 0x9e, 0x31, 0x90, 0xff, 0xd8, 0x73, 0x07, 0x2a, 0xc2, 0x8b, 0x1e, 3131 0x25, 0xbe, 0xeb, 0x34, 0x56, 0xf9, 0x70, 0x2e, 0xb2, 0x15, 0x73, 0xd0, 0x8f, 0xb1, 0xab, 0x72, 3132 0xd2, 0x5f, 0xfa, 0x6c, 0x06, 0x11, 0xeb, 0x9a, 0x9f, 0x6c, 0xb3, 0xf0, 0x6d, 0xaa, 0xa7, 0xa4, 3133 0xe4, 0x45, 0x45, 0x77, 0x3b, 0x29, 0xba, 0x99, 0xf5, 0xf2, 0xd6, 0x47, 0x6f, 0x96, 0x57, 0xa2, 3134 0xde, 0x2a, 0x4f, 0x40, 0x39, 0xf7, 0xd5, 0x38, 0x08, 0x5c, 0x2f, 0xfe, 0x3d, 0xe1, 0x35, 0x0d, 3135 0x78, 0x11, 0xf2, 0xe2, 0x97, 0x0a, 0x31, 0x7c, 0x8a, 0x17, 0x65, 0x07, 0xee, 0x5e, 0xca, 0x32, 3136 0xba, 0x35, 0x9b, 0xbe, 0xe8, 0xf3, 0xe4, 0xa7, 0x0e, 0xc6, 0xa0, 0xe8, 0xd0, 0xe7, 0x9c, 0x48, 3137 0xf9, 0xb3, 0x94, 0x1a, 0x13, 0xf9, 0xe5, 0x55, 0xc7, 0xec, 0x3d, 0x77, 0x66, 0x7a, 0xe9, 0x6b, 3138 0x16, 0x52, 0x77, 0xa1, 0x6a, 0x53, 0xe2, 0xd3, 0x64, 0xda, 0xcd, 0xf0, 0x69, 0xb7, 0xc2, 0x81, 3139 0xf1, 0x88, 0xbb, 0x0a, 0x25, 0xd6, 0xee, 0xe2, 0xf9, 0x9d, 0xdf, 0x62, 0x4c, 0x4e, 0xc5, 0x0c, 3140 0xf8, 0x31, 0x54, 0x46, 0xac, 0xb9, 0x1b, 0x87, 0x67, 0xbc, 0x57, 0xb2, 0xa6, 0x92, 0x7c, 0xc6, 3141 0x01, 0x47, 0xed, 0x9c, 0xb1, 0xa6, 0x19, 0x65, 0x71, 0x3e, 0xc9, 0x62, 0xe5, 0x9f, 0x12, 0xdc, 3142 0xb9, 0x44, 0x81, 0xc8, 0x06, 0xda, 0x4c, 0xbb, 0xbc, 0xff, 0x4a, 0xcf, 0xcd, 0x39, 0x9b, 0x6e, 3143 0x9a, 0xbf, 0x96, 0xae, 0xd9, 0x34, 0xcf, 0xf5, 0xb3, 0xdc, 0xbc, 0x7e, 0x16, 0xb7, 0x99, 0xfc, 3144 0xb9, 0x36, 0x13, 0xe9, 0x5e, 0x98, 0xea, 0xfe, 0x7b, 0x29, 0xf5, 0xc5, 0xb5, 0xef, 0x9a, 0xd6, 3145 0x11, 0x0f, 0xbd, 0x0e, 0xb3, 0xfb, 0x4f, 0xfc, 0x5b, 0xca, 0x05, 0x9f, 0xe7, 0x2e, 0xfa, 0x5c, 3146 0xe9, 0xa4, 0x62, 0xeb, 0xc2, 0xf5, 0xa6, 0x5b, 0xe7, 0x90, 0xc7, 0xae, 0x39, 0x9d, 0xa5, 0x44, 3147 0x90, 0xd6, 0x22, 0x78, 0x34, 0x4d, 0xed, 0x94, 0xbf, 0x2b, 0x25, 0xbf, 0x77, 0xff, 0x3b, 0x00, 3148 0x00, 0xff, 0xff, 0x67, 0xac, 0x35, 0x53, 0x2a, 0x1f, 0x00, 0x00, 3149} 3150