taskqueue_service.pb.go 63 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888
  1. // Code generated by protoc-gen-go.
  2. // source: google.golang.org/appengine/internal/taskqueue/taskqueue_service.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package taskqueue is a generated protocol buffer package.
  6. It is generated from these files:
  7. google.golang.org/appengine/internal/taskqueue/taskqueue_service.proto
  8. It has these top-level messages:
  9. TaskQueueServiceError
  10. TaskPayload
  11. TaskQueueRetryParameters
  12. TaskQueueAcl
  13. TaskQueueHttpHeader
  14. TaskQueueMode
  15. TaskQueueAddRequest
  16. TaskQueueAddResponse
  17. TaskQueueBulkAddRequest
  18. TaskQueueBulkAddResponse
  19. TaskQueueDeleteRequest
  20. TaskQueueDeleteResponse
  21. TaskQueueForceRunRequest
  22. TaskQueueForceRunResponse
  23. TaskQueueUpdateQueueRequest
  24. TaskQueueUpdateQueueResponse
  25. TaskQueueFetchQueuesRequest
  26. TaskQueueFetchQueuesResponse
  27. TaskQueueFetchQueueStatsRequest
  28. TaskQueueScannerQueueInfo
  29. TaskQueueFetchQueueStatsResponse
  30. TaskQueuePauseQueueRequest
  31. TaskQueuePauseQueueResponse
  32. TaskQueuePurgeQueueRequest
  33. TaskQueuePurgeQueueResponse
  34. TaskQueueDeleteQueueRequest
  35. TaskQueueDeleteQueueResponse
  36. TaskQueueDeleteGroupRequest
  37. TaskQueueDeleteGroupResponse
  38. TaskQueueQueryTasksRequest
  39. TaskQueueQueryTasksResponse
  40. TaskQueueFetchTaskRequest
  41. TaskQueueFetchTaskResponse
  42. TaskQueueUpdateStorageLimitRequest
  43. TaskQueueUpdateStorageLimitResponse
  44. TaskQueueQueryAndOwnTasksRequest
  45. TaskQueueQueryAndOwnTasksResponse
  46. TaskQueueModifyTaskLeaseRequest
  47. TaskQueueModifyTaskLeaseResponse
  48. */
  49. package taskqueue
  50. import proto "github.com/golang/protobuf/proto"
  51. import fmt "fmt"
  52. import math "math"
  53. import appengine "google.golang.org/appengine/internal/datastore"
  54. // Reference imports to suppress errors if they are not otherwise used.
  55. var _ = proto.Marshal
  56. var _ = fmt.Errorf
  57. var _ = math.Inf
  58. type TaskQueueServiceError_ErrorCode int32
  59. const (
  60. TaskQueueServiceError_OK TaskQueueServiceError_ErrorCode = 0
  61. TaskQueueServiceError_UNKNOWN_QUEUE TaskQueueServiceError_ErrorCode = 1
  62. TaskQueueServiceError_TRANSIENT_ERROR TaskQueueServiceError_ErrorCode = 2
  63. TaskQueueServiceError_INTERNAL_ERROR TaskQueueServiceError_ErrorCode = 3
  64. TaskQueueServiceError_TASK_TOO_LARGE TaskQueueServiceError_ErrorCode = 4
  65. TaskQueueServiceError_INVALID_TASK_NAME TaskQueueServiceError_ErrorCode = 5
  66. TaskQueueServiceError_INVALID_QUEUE_NAME TaskQueueServiceError_ErrorCode = 6
  67. TaskQueueServiceError_INVALID_URL TaskQueueServiceError_ErrorCode = 7
  68. TaskQueueServiceError_INVALID_QUEUE_RATE TaskQueueServiceError_ErrorCode = 8
  69. TaskQueueServiceError_PERMISSION_DENIED TaskQueueServiceError_ErrorCode = 9
  70. TaskQueueServiceError_TASK_ALREADY_EXISTS TaskQueueServiceError_ErrorCode = 10
  71. TaskQueueServiceError_TOMBSTONED_TASK TaskQueueServiceError_ErrorCode = 11
  72. TaskQueueServiceError_INVALID_ETA TaskQueueServiceError_ErrorCode = 12
  73. TaskQueueServiceError_INVALID_REQUEST TaskQueueServiceError_ErrorCode = 13
  74. TaskQueueServiceError_UNKNOWN_TASK TaskQueueServiceError_ErrorCode = 14
  75. TaskQueueServiceError_TOMBSTONED_QUEUE TaskQueueServiceError_ErrorCode = 15
  76. TaskQueueServiceError_DUPLICATE_TASK_NAME TaskQueueServiceError_ErrorCode = 16
  77. TaskQueueServiceError_SKIPPED TaskQueueServiceError_ErrorCode = 17
  78. TaskQueueServiceError_TOO_MANY_TASKS TaskQueueServiceError_ErrorCode = 18
  79. TaskQueueServiceError_INVALID_PAYLOAD TaskQueueServiceError_ErrorCode = 19
  80. TaskQueueServiceError_INVALID_RETRY_PARAMETERS TaskQueueServiceError_ErrorCode = 20
  81. TaskQueueServiceError_INVALID_QUEUE_MODE TaskQueueServiceError_ErrorCode = 21
  82. TaskQueueServiceError_ACL_LOOKUP_ERROR TaskQueueServiceError_ErrorCode = 22
  83. TaskQueueServiceError_TRANSACTIONAL_REQUEST_TOO_LARGE TaskQueueServiceError_ErrorCode = 23
  84. TaskQueueServiceError_INCORRECT_CREATOR_NAME TaskQueueServiceError_ErrorCode = 24
  85. TaskQueueServiceError_TASK_LEASE_EXPIRED TaskQueueServiceError_ErrorCode = 25
  86. TaskQueueServiceError_QUEUE_PAUSED TaskQueueServiceError_ErrorCode = 26
  87. TaskQueueServiceError_INVALID_TAG TaskQueueServiceError_ErrorCode = 27
  88. // Reserved range for the Datastore error codes.
  89. // Original Datastore error code is shifted by DATASTORE_ERROR offset.
  90. TaskQueueServiceError_DATASTORE_ERROR TaskQueueServiceError_ErrorCode = 10000
  91. )
  92. var TaskQueueServiceError_ErrorCode_name = map[int32]string{
  93. 0: "OK",
  94. 1: "UNKNOWN_QUEUE",
  95. 2: "TRANSIENT_ERROR",
  96. 3: "INTERNAL_ERROR",
  97. 4: "TASK_TOO_LARGE",
  98. 5: "INVALID_TASK_NAME",
  99. 6: "INVALID_QUEUE_NAME",
  100. 7: "INVALID_URL",
  101. 8: "INVALID_QUEUE_RATE",
  102. 9: "PERMISSION_DENIED",
  103. 10: "TASK_ALREADY_EXISTS",
  104. 11: "TOMBSTONED_TASK",
  105. 12: "INVALID_ETA",
  106. 13: "INVALID_REQUEST",
  107. 14: "UNKNOWN_TASK",
  108. 15: "TOMBSTONED_QUEUE",
  109. 16: "DUPLICATE_TASK_NAME",
  110. 17: "SKIPPED",
  111. 18: "TOO_MANY_TASKS",
  112. 19: "INVALID_PAYLOAD",
  113. 20: "INVALID_RETRY_PARAMETERS",
  114. 21: "INVALID_QUEUE_MODE",
  115. 22: "ACL_LOOKUP_ERROR",
  116. 23: "TRANSACTIONAL_REQUEST_TOO_LARGE",
  117. 24: "INCORRECT_CREATOR_NAME",
  118. 25: "TASK_LEASE_EXPIRED",
  119. 26: "QUEUE_PAUSED",
  120. 27: "INVALID_TAG",
  121. 10000: "DATASTORE_ERROR",
  122. }
  123. var TaskQueueServiceError_ErrorCode_value = map[string]int32{
  124. "OK": 0,
  125. "UNKNOWN_QUEUE": 1,
  126. "TRANSIENT_ERROR": 2,
  127. "INTERNAL_ERROR": 3,
  128. "TASK_TOO_LARGE": 4,
  129. "INVALID_TASK_NAME": 5,
  130. "INVALID_QUEUE_NAME": 6,
  131. "INVALID_URL": 7,
  132. "INVALID_QUEUE_RATE": 8,
  133. "PERMISSION_DENIED": 9,
  134. "TASK_ALREADY_EXISTS": 10,
  135. "TOMBSTONED_TASK": 11,
  136. "INVALID_ETA": 12,
  137. "INVALID_REQUEST": 13,
  138. "UNKNOWN_TASK": 14,
  139. "TOMBSTONED_QUEUE": 15,
  140. "DUPLICATE_TASK_NAME": 16,
  141. "SKIPPED": 17,
  142. "TOO_MANY_TASKS": 18,
  143. "INVALID_PAYLOAD": 19,
  144. "INVALID_RETRY_PARAMETERS": 20,
  145. "INVALID_QUEUE_MODE": 21,
  146. "ACL_LOOKUP_ERROR": 22,
  147. "TRANSACTIONAL_REQUEST_TOO_LARGE": 23,
  148. "INCORRECT_CREATOR_NAME": 24,
  149. "TASK_LEASE_EXPIRED": 25,
  150. "QUEUE_PAUSED": 26,
  151. "INVALID_TAG": 27,
  152. "DATASTORE_ERROR": 10000,
  153. }
  154. func (x TaskQueueServiceError_ErrorCode) Enum() *TaskQueueServiceError_ErrorCode {
  155. p := new(TaskQueueServiceError_ErrorCode)
  156. *p = x
  157. return p
  158. }
  159. func (x TaskQueueServiceError_ErrorCode) String() string {
  160. return proto.EnumName(TaskQueueServiceError_ErrorCode_name, int32(x))
  161. }
  162. func (x *TaskQueueServiceError_ErrorCode) UnmarshalJSON(data []byte) error {
  163. value, err := proto.UnmarshalJSONEnum(TaskQueueServiceError_ErrorCode_value, data, "TaskQueueServiceError_ErrorCode")
  164. if err != nil {
  165. return err
  166. }
  167. *x = TaskQueueServiceError_ErrorCode(value)
  168. return nil
  169. }
  170. type TaskQueueMode_Mode int32
  171. const (
  172. TaskQueueMode_PUSH TaskQueueMode_Mode = 0
  173. TaskQueueMode_PULL TaskQueueMode_Mode = 1
  174. )
  175. var TaskQueueMode_Mode_name = map[int32]string{
  176. 0: "PUSH",
  177. 1: "PULL",
  178. }
  179. var TaskQueueMode_Mode_value = map[string]int32{
  180. "PUSH": 0,
  181. "PULL": 1,
  182. }
  183. func (x TaskQueueMode_Mode) Enum() *TaskQueueMode_Mode {
  184. p := new(TaskQueueMode_Mode)
  185. *p = x
  186. return p
  187. }
  188. func (x TaskQueueMode_Mode) String() string {
  189. return proto.EnumName(TaskQueueMode_Mode_name, int32(x))
  190. }
  191. func (x *TaskQueueMode_Mode) UnmarshalJSON(data []byte) error {
  192. value, err := proto.UnmarshalJSONEnum(TaskQueueMode_Mode_value, data, "TaskQueueMode_Mode")
  193. if err != nil {
  194. return err
  195. }
  196. *x = TaskQueueMode_Mode(value)
  197. return nil
  198. }
  199. type TaskQueueAddRequest_RequestMethod int32
  200. const (
  201. TaskQueueAddRequest_GET TaskQueueAddRequest_RequestMethod = 1
  202. TaskQueueAddRequest_POST TaskQueueAddRequest_RequestMethod = 2
  203. TaskQueueAddRequest_HEAD TaskQueueAddRequest_RequestMethod = 3
  204. TaskQueueAddRequest_PUT TaskQueueAddRequest_RequestMethod = 4
  205. TaskQueueAddRequest_DELETE TaskQueueAddRequest_RequestMethod = 5
  206. )
  207. var TaskQueueAddRequest_RequestMethod_name = map[int32]string{
  208. 1: "GET",
  209. 2: "POST",
  210. 3: "HEAD",
  211. 4: "PUT",
  212. 5: "DELETE",
  213. }
  214. var TaskQueueAddRequest_RequestMethod_value = map[string]int32{
  215. "GET": 1,
  216. "POST": 2,
  217. "HEAD": 3,
  218. "PUT": 4,
  219. "DELETE": 5,
  220. }
  221. func (x TaskQueueAddRequest_RequestMethod) Enum() *TaskQueueAddRequest_RequestMethod {
  222. p := new(TaskQueueAddRequest_RequestMethod)
  223. *p = x
  224. return p
  225. }
  226. func (x TaskQueueAddRequest_RequestMethod) String() string {
  227. return proto.EnumName(TaskQueueAddRequest_RequestMethod_name, int32(x))
  228. }
  229. func (x *TaskQueueAddRequest_RequestMethod) UnmarshalJSON(data []byte) error {
  230. value, err := proto.UnmarshalJSONEnum(TaskQueueAddRequest_RequestMethod_value, data, "TaskQueueAddRequest_RequestMethod")
  231. if err != nil {
  232. return err
  233. }
  234. *x = TaskQueueAddRequest_RequestMethod(value)
  235. return nil
  236. }
  237. type TaskQueueQueryTasksResponse_Task_RequestMethod int32
  238. const (
  239. TaskQueueQueryTasksResponse_Task_GET TaskQueueQueryTasksResponse_Task_RequestMethod = 1
  240. TaskQueueQueryTasksResponse_Task_POST TaskQueueQueryTasksResponse_Task_RequestMethod = 2
  241. TaskQueueQueryTasksResponse_Task_HEAD TaskQueueQueryTasksResponse_Task_RequestMethod = 3
  242. TaskQueueQueryTasksResponse_Task_PUT TaskQueueQueryTasksResponse_Task_RequestMethod = 4
  243. TaskQueueQueryTasksResponse_Task_DELETE TaskQueueQueryTasksResponse_Task_RequestMethod = 5
  244. )
  245. var TaskQueueQueryTasksResponse_Task_RequestMethod_name = map[int32]string{
  246. 1: "GET",
  247. 2: "POST",
  248. 3: "HEAD",
  249. 4: "PUT",
  250. 5: "DELETE",
  251. }
  252. var TaskQueueQueryTasksResponse_Task_RequestMethod_value = map[string]int32{
  253. "GET": 1,
  254. "POST": 2,
  255. "HEAD": 3,
  256. "PUT": 4,
  257. "DELETE": 5,
  258. }
  259. func (x TaskQueueQueryTasksResponse_Task_RequestMethod) Enum() *TaskQueueQueryTasksResponse_Task_RequestMethod {
  260. p := new(TaskQueueQueryTasksResponse_Task_RequestMethod)
  261. *p = x
  262. return p
  263. }
  264. func (x TaskQueueQueryTasksResponse_Task_RequestMethod) String() string {
  265. return proto.EnumName(TaskQueueQueryTasksResponse_Task_RequestMethod_name, int32(x))
  266. }
  267. func (x *TaskQueueQueryTasksResponse_Task_RequestMethod) UnmarshalJSON(data []byte) error {
  268. value, err := proto.UnmarshalJSONEnum(TaskQueueQueryTasksResponse_Task_RequestMethod_value, data, "TaskQueueQueryTasksResponse_Task_RequestMethod")
  269. if err != nil {
  270. return err
  271. }
  272. *x = TaskQueueQueryTasksResponse_Task_RequestMethod(value)
  273. return nil
  274. }
  275. type TaskQueueServiceError struct {
  276. XXX_unrecognized []byte `json:"-"`
  277. }
  278. func (m *TaskQueueServiceError) Reset() { *m = TaskQueueServiceError{} }
  279. func (m *TaskQueueServiceError) String() string { return proto.CompactTextString(m) }
  280. func (*TaskQueueServiceError) ProtoMessage() {}
  281. type TaskPayload struct {
  282. XXX_extensions map[int32]proto.Extension `json:"-"`
  283. XXX_unrecognized []byte `json:"-"`
  284. }
  285. func (m *TaskPayload) Reset() { *m = TaskPayload{} }
  286. func (m *TaskPayload) String() string { return proto.CompactTextString(m) }
  287. func (*TaskPayload) ProtoMessage() {}
  288. func (m *TaskPayload) Marshal() ([]byte, error) {
  289. return proto.MarshalMessageSet(m.ExtensionMap())
  290. }
  291. func (m *TaskPayload) Unmarshal(buf []byte) error {
  292. return proto.UnmarshalMessageSet(buf, m.ExtensionMap())
  293. }
  294. func (m *TaskPayload) MarshalJSON() ([]byte, error) {
  295. return proto.MarshalMessageSetJSON(m.XXX_extensions)
  296. }
  297. func (m *TaskPayload) UnmarshalJSON(buf []byte) error {
  298. return proto.UnmarshalMessageSetJSON(buf, m.XXX_extensions)
  299. }
  300. // ensure TaskPayload satisfies proto.Marshaler and proto.Unmarshaler
  301. var _ proto.Marshaler = (*TaskPayload)(nil)
  302. var _ proto.Unmarshaler = (*TaskPayload)(nil)
  303. var extRange_TaskPayload = []proto.ExtensionRange{
  304. {10, 2147483646},
  305. }
  306. func (*TaskPayload) ExtensionRangeArray() []proto.ExtensionRange {
  307. return extRange_TaskPayload
  308. }
  309. func (m *TaskPayload) ExtensionMap() map[int32]proto.Extension {
  310. if m.XXX_extensions == nil {
  311. m.XXX_extensions = make(map[int32]proto.Extension)
  312. }
  313. return m.XXX_extensions
  314. }
  315. type TaskQueueRetryParameters struct {
  316. RetryLimit *int32 `protobuf:"varint,1,opt,name=retry_limit" json:"retry_limit,omitempty"`
  317. AgeLimitSec *int64 `protobuf:"varint,2,opt,name=age_limit_sec" json:"age_limit_sec,omitempty"`
  318. MinBackoffSec *float64 `protobuf:"fixed64,3,opt,name=min_backoff_sec,def=0.1" json:"min_backoff_sec,omitempty"`
  319. MaxBackoffSec *float64 `protobuf:"fixed64,4,opt,name=max_backoff_sec,def=3600" json:"max_backoff_sec,omitempty"`
  320. MaxDoublings *int32 `protobuf:"varint,5,opt,name=max_doublings,def=16" json:"max_doublings,omitempty"`
  321. XXX_unrecognized []byte `json:"-"`
  322. }
  323. func (m *TaskQueueRetryParameters) Reset() { *m = TaskQueueRetryParameters{} }
  324. func (m *TaskQueueRetryParameters) String() string { return proto.CompactTextString(m) }
  325. func (*TaskQueueRetryParameters) ProtoMessage() {}
  326. const Default_TaskQueueRetryParameters_MinBackoffSec float64 = 0.1
  327. const Default_TaskQueueRetryParameters_MaxBackoffSec float64 = 3600
  328. const Default_TaskQueueRetryParameters_MaxDoublings int32 = 16
  329. func (m *TaskQueueRetryParameters) GetRetryLimit() int32 {
  330. if m != nil && m.RetryLimit != nil {
  331. return *m.RetryLimit
  332. }
  333. return 0
  334. }
  335. func (m *TaskQueueRetryParameters) GetAgeLimitSec() int64 {
  336. if m != nil && m.AgeLimitSec != nil {
  337. return *m.AgeLimitSec
  338. }
  339. return 0
  340. }
  341. func (m *TaskQueueRetryParameters) GetMinBackoffSec() float64 {
  342. if m != nil && m.MinBackoffSec != nil {
  343. return *m.MinBackoffSec
  344. }
  345. return Default_TaskQueueRetryParameters_MinBackoffSec
  346. }
  347. func (m *TaskQueueRetryParameters) GetMaxBackoffSec() float64 {
  348. if m != nil && m.MaxBackoffSec != nil {
  349. return *m.MaxBackoffSec
  350. }
  351. return Default_TaskQueueRetryParameters_MaxBackoffSec
  352. }
  353. func (m *TaskQueueRetryParameters) GetMaxDoublings() int32 {
  354. if m != nil && m.MaxDoublings != nil {
  355. return *m.MaxDoublings
  356. }
  357. return Default_TaskQueueRetryParameters_MaxDoublings
  358. }
  359. type TaskQueueAcl struct {
  360. UserEmail [][]byte `protobuf:"bytes,1,rep,name=user_email" json:"user_email,omitempty"`
  361. WriterEmail [][]byte `protobuf:"bytes,2,rep,name=writer_email" json:"writer_email,omitempty"`
  362. XXX_unrecognized []byte `json:"-"`
  363. }
  364. func (m *TaskQueueAcl) Reset() { *m = TaskQueueAcl{} }
  365. func (m *TaskQueueAcl) String() string { return proto.CompactTextString(m) }
  366. func (*TaskQueueAcl) ProtoMessage() {}
  367. func (m *TaskQueueAcl) GetUserEmail() [][]byte {
  368. if m != nil {
  369. return m.UserEmail
  370. }
  371. return nil
  372. }
  373. func (m *TaskQueueAcl) GetWriterEmail() [][]byte {
  374. if m != nil {
  375. return m.WriterEmail
  376. }
  377. return nil
  378. }
  379. type TaskQueueHttpHeader struct {
  380. Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
  381. Value []byte `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
  382. XXX_unrecognized []byte `json:"-"`
  383. }
  384. func (m *TaskQueueHttpHeader) Reset() { *m = TaskQueueHttpHeader{} }
  385. func (m *TaskQueueHttpHeader) String() string { return proto.CompactTextString(m) }
  386. func (*TaskQueueHttpHeader) ProtoMessage() {}
  387. func (m *TaskQueueHttpHeader) GetKey() []byte {
  388. if m != nil {
  389. return m.Key
  390. }
  391. return nil
  392. }
  393. func (m *TaskQueueHttpHeader) GetValue() []byte {
  394. if m != nil {
  395. return m.Value
  396. }
  397. return nil
  398. }
  399. type TaskQueueMode struct {
  400. XXX_unrecognized []byte `json:"-"`
  401. }
  402. func (m *TaskQueueMode) Reset() { *m = TaskQueueMode{} }
  403. func (m *TaskQueueMode) String() string { return proto.CompactTextString(m) }
  404. func (*TaskQueueMode) ProtoMessage() {}
  405. type TaskQueueAddRequest struct {
  406. QueueName []byte `protobuf:"bytes,1,req,name=queue_name" json:"queue_name,omitempty"`
  407. TaskName []byte `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
  408. EtaUsec *int64 `protobuf:"varint,3,req,name=eta_usec" json:"eta_usec,omitempty"`
  409. Method *TaskQueueAddRequest_RequestMethod `protobuf:"varint,5,opt,name=method,enum=appengine.TaskQueueAddRequest_RequestMethod,def=2" json:"method,omitempty"`
  410. Url []byte `protobuf:"bytes,4,opt,name=url" json:"url,omitempty"`
  411. Header []*TaskQueueAddRequest_Header `protobuf:"group,6,rep,name=Header" json:"header,omitempty"`
  412. Body []byte `protobuf:"bytes,9,opt,name=body" json:"body,omitempty"`
  413. Transaction *appengine.Transaction `protobuf:"bytes,10,opt,name=transaction" json:"transaction,omitempty"`
  414. AppId []byte `protobuf:"bytes,11,opt,name=app_id" json:"app_id,omitempty"`
  415. Crontimetable *TaskQueueAddRequest_CronTimetable `protobuf:"group,12,opt,name=CronTimetable" json:"crontimetable,omitempty"`
  416. Description []byte `protobuf:"bytes,15,opt,name=description" json:"description,omitempty"`
  417. Payload *TaskPayload `protobuf:"bytes,16,opt,name=payload" json:"payload,omitempty"`
  418. RetryParameters *TaskQueueRetryParameters `protobuf:"bytes,17,opt,name=retry_parameters" json:"retry_parameters,omitempty"`
  419. Mode *TaskQueueMode_Mode `protobuf:"varint,18,opt,name=mode,enum=appengine.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
  420. Tag []byte `protobuf:"bytes,19,opt,name=tag" json:"tag,omitempty"`
  421. XXX_unrecognized []byte `json:"-"`
  422. }
  423. func (m *TaskQueueAddRequest) Reset() { *m = TaskQueueAddRequest{} }
  424. func (m *TaskQueueAddRequest) String() string { return proto.CompactTextString(m) }
  425. func (*TaskQueueAddRequest) ProtoMessage() {}
  426. const Default_TaskQueueAddRequest_Method TaskQueueAddRequest_RequestMethod = TaskQueueAddRequest_POST
  427. const Default_TaskQueueAddRequest_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH
  428. func (m *TaskQueueAddRequest) GetQueueName() []byte {
  429. if m != nil {
  430. return m.QueueName
  431. }
  432. return nil
  433. }
  434. func (m *TaskQueueAddRequest) GetTaskName() []byte {
  435. if m != nil {
  436. return m.TaskName
  437. }
  438. return nil
  439. }
  440. func (m *TaskQueueAddRequest) GetEtaUsec() int64 {
  441. if m != nil && m.EtaUsec != nil {
  442. return *m.EtaUsec
  443. }
  444. return 0
  445. }
  446. func (m *TaskQueueAddRequest) GetMethod() TaskQueueAddRequest_RequestMethod {
  447. if m != nil && m.Method != nil {
  448. return *m.Method
  449. }
  450. return Default_TaskQueueAddRequest_Method
  451. }
  452. func (m *TaskQueueAddRequest) GetUrl() []byte {
  453. if m != nil {
  454. return m.Url
  455. }
  456. return nil
  457. }
  458. func (m *TaskQueueAddRequest) GetHeader() []*TaskQueueAddRequest_Header {
  459. if m != nil {
  460. return m.Header
  461. }
  462. return nil
  463. }
  464. func (m *TaskQueueAddRequest) GetBody() []byte {
  465. if m != nil {
  466. return m.Body
  467. }
  468. return nil
  469. }
  470. func (m *TaskQueueAddRequest) GetTransaction() *appengine.Transaction {
  471. if m != nil {
  472. return m.Transaction
  473. }
  474. return nil
  475. }
  476. func (m *TaskQueueAddRequest) GetAppId() []byte {
  477. if m != nil {
  478. return m.AppId
  479. }
  480. return nil
  481. }
  482. func (m *TaskQueueAddRequest) GetCrontimetable() *TaskQueueAddRequest_CronTimetable {
  483. if m != nil {
  484. return m.Crontimetable
  485. }
  486. return nil
  487. }
  488. func (m *TaskQueueAddRequest) GetDescription() []byte {
  489. if m != nil {
  490. return m.Description
  491. }
  492. return nil
  493. }
  494. func (m *TaskQueueAddRequest) GetPayload() *TaskPayload {
  495. if m != nil {
  496. return m.Payload
  497. }
  498. return nil
  499. }
  500. func (m *TaskQueueAddRequest) GetRetryParameters() *TaskQueueRetryParameters {
  501. if m != nil {
  502. return m.RetryParameters
  503. }
  504. return nil
  505. }
  506. func (m *TaskQueueAddRequest) GetMode() TaskQueueMode_Mode {
  507. if m != nil && m.Mode != nil {
  508. return *m.Mode
  509. }
  510. return Default_TaskQueueAddRequest_Mode
  511. }
  512. func (m *TaskQueueAddRequest) GetTag() []byte {
  513. if m != nil {
  514. return m.Tag
  515. }
  516. return nil
  517. }
  518. type TaskQueueAddRequest_Header struct {
  519. Key []byte `protobuf:"bytes,7,req,name=key" json:"key,omitempty"`
  520. Value []byte `protobuf:"bytes,8,req,name=value" json:"value,omitempty"`
  521. XXX_unrecognized []byte `json:"-"`
  522. }
  523. func (m *TaskQueueAddRequest_Header) Reset() { *m = TaskQueueAddRequest_Header{} }
  524. func (m *TaskQueueAddRequest_Header) String() string { return proto.CompactTextString(m) }
  525. func (*TaskQueueAddRequest_Header) ProtoMessage() {}
  526. func (m *TaskQueueAddRequest_Header) GetKey() []byte {
  527. if m != nil {
  528. return m.Key
  529. }
  530. return nil
  531. }
  532. func (m *TaskQueueAddRequest_Header) GetValue() []byte {
  533. if m != nil {
  534. return m.Value
  535. }
  536. return nil
  537. }
  538. type TaskQueueAddRequest_CronTimetable struct {
  539. Schedule []byte `protobuf:"bytes,13,req,name=schedule" json:"schedule,omitempty"`
  540. Timezone []byte `protobuf:"bytes,14,req,name=timezone" json:"timezone,omitempty"`
  541. XXX_unrecognized []byte `json:"-"`
  542. }
  543. func (m *TaskQueueAddRequest_CronTimetable) Reset() { *m = TaskQueueAddRequest_CronTimetable{} }
  544. func (m *TaskQueueAddRequest_CronTimetable) String() string { return proto.CompactTextString(m) }
  545. func (*TaskQueueAddRequest_CronTimetable) ProtoMessage() {}
  546. func (m *TaskQueueAddRequest_CronTimetable) GetSchedule() []byte {
  547. if m != nil {
  548. return m.Schedule
  549. }
  550. return nil
  551. }
  552. func (m *TaskQueueAddRequest_CronTimetable) GetTimezone() []byte {
  553. if m != nil {
  554. return m.Timezone
  555. }
  556. return nil
  557. }
  558. type TaskQueueAddResponse struct {
  559. ChosenTaskName []byte `protobuf:"bytes,1,opt,name=chosen_task_name" json:"chosen_task_name,omitempty"`
  560. XXX_unrecognized []byte `json:"-"`
  561. }
  562. func (m *TaskQueueAddResponse) Reset() { *m = TaskQueueAddResponse{} }
  563. func (m *TaskQueueAddResponse) String() string { return proto.CompactTextString(m) }
  564. func (*TaskQueueAddResponse) ProtoMessage() {}
  565. func (m *TaskQueueAddResponse) GetChosenTaskName() []byte {
  566. if m != nil {
  567. return m.ChosenTaskName
  568. }
  569. return nil
  570. }
  571. type TaskQueueBulkAddRequest struct {
  572. AddRequest []*TaskQueueAddRequest `protobuf:"bytes,1,rep,name=add_request" json:"add_request,omitempty"`
  573. XXX_unrecognized []byte `json:"-"`
  574. }
  575. func (m *TaskQueueBulkAddRequest) Reset() { *m = TaskQueueBulkAddRequest{} }
  576. func (m *TaskQueueBulkAddRequest) String() string { return proto.CompactTextString(m) }
  577. func (*TaskQueueBulkAddRequest) ProtoMessage() {}
  578. func (m *TaskQueueBulkAddRequest) GetAddRequest() []*TaskQueueAddRequest {
  579. if m != nil {
  580. return m.AddRequest
  581. }
  582. return nil
  583. }
  584. type TaskQueueBulkAddResponse struct {
  585. Taskresult []*TaskQueueBulkAddResponse_TaskResult `protobuf:"group,1,rep,name=TaskResult" json:"taskresult,omitempty"`
  586. XXX_unrecognized []byte `json:"-"`
  587. }
  588. func (m *TaskQueueBulkAddResponse) Reset() { *m = TaskQueueBulkAddResponse{} }
  589. func (m *TaskQueueBulkAddResponse) String() string { return proto.CompactTextString(m) }
  590. func (*TaskQueueBulkAddResponse) ProtoMessage() {}
  591. func (m *TaskQueueBulkAddResponse) GetTaskresult() []*TaskQueueBulkAddResponse_TaskResult {
  592. if m != nil {
  593. return m.Taskresult
  594. }
  595. return nil
  596. }
  597. type TaskQueueBulkAddResponse_TaskResult struct {
  598. Result *TaskQueueServiceError_ErrorCode `protobuf:"varint,2,req,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
  599. ChosenTaskName []byte `protobuf:"bytes,3,opt,name=chosen_task_name" json:"chosen_task_name,omitempty"`
  600. XXX_unrecognized []byte `json:"-"`
  601. }
  602. func (m *TaskQueueBulkAddResponse_TaskResult) Reset() { *m = TaskQueueBulkAddResponse_TaskResult{} }
  603. func (m *TaskQueueBulkAddResponse_TaskResult) String() string { return proto.CompactTextString(m) }
  604. func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage() {}
  605. func (m *TaskQueueBulkAddResponse_TaskResult) GetResult() TaskQueueServiceError_ErrorCode {
  606. if m != nil && m.Result != nil {
  607. return *m.Result
  608. }
  609. return TaskQueueServiceError_OK
  610. }
  611. func (m *TaskQueueBulkAddResponse_TaskResult) GetChosenTaskName() []byte {
  612. if m != nil {
  613. return m.ChosenTaskName
  614. }
  615. return nil
  616. }
  617. type TaskQueueDeleteRequest struct {
  618. QueueName []byte `protobuf:"bytes,1,req,name=queue_name" json:"queue_name,omitempty"`
  619. TaskName [][]byte `protobuf:"bytes,2,rep,name=task_name" json:"task_name,omitempty"`
  620. AppId []byte `protobuf:"bytes,3,opt,name=app_id" json:"app_id,omitempty"`
  621. XXX_unrecognized []byte `json:"-"`
  622. }
  623. func (m *TaskQueueDeleteRequest) Reset() { *m = TaskQueueDeleteRequest{} }
  624. func (m *TaskQueueDeleteRequest) String() string { return proto.CompactTextString(m) }
  625. func (*TaskQueueDeleteRequest) ProtoMessage() {}
  626. func (m *TaskQueueDeleteRequest) GetQueueName() []byte {
  627. if m != nil {
  628. return m.QueueName
  629. }
  630. return nil
  631. }
  632. func (m *TaskQueueDeleteRequest) GetTaskName() [][]byte {
  633. if m != nil {
  634. return m.TaskName
  635. }
  636. return nil
  637. }
  638. func (m *TaskQueueDeleteRequest) GetAppId() []byte {
  639. if m != nil {
  640. return m.AppId
  641. }
  642. return nil
  643. }
  644. type TaskQueueDeleteResponse struct {
  645. Result []TaskQueueServiceError_ErrorCode `protobuf:"varint,3,rep,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
  646. XXX_unrecognized []byte `json:"-"`
  647. }
  648. func (m *TaskQueueDeleteResponse) Reset() { *m = TaskQueueDeleteResponse{} }
  649. func (m *TaskQueueDeleteResponse) String() string { return proto.CompactTextString(m) }
  650. func (*TaskQueueDeleteResponse) ProtoMessage() {}
  651. func (m *TaskQueueDeleteResponse) GetResult() []TaskQueueServiceError_ErrorCode {
  652. if m != nil {
  653. return m.Result
  654. }
  655. return nil
  656. }
  657. type TaskQueueForceRunRequest struct {
  658. AppId []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
  659. QueueName []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
  660. TaskName []byte `protobuf:"bytes,3,req,name=task_name" json:"task_name,omitempty"`
  661. XXX_unrecognized []byte `json:"-"`
  662. }
  663. func (m *TaskQueueForceRunRequest) Reset() { *m = TaskQueueForceRunRequest{} }
  664. func (m *TaskQueueForceRunRequest) String() string { return proto.CompactTextString(m) }
  665. func (*TaskQueueForceRunRequest) ProtoMessage() {}
  666. func (m *TaskQueueForceRunRequest) GetAppId() []byte {
  667. if m != nil {
  668. return m.AppId
  669. }
  670. return nil
  671. }
  672. func (m *TaskQueueForceRunRequest) GetQueueName() []byte {
  673. if m != nil {
  674. return m.QueueName
  675. }
  676. return nil
  677. }
  678. func (m *TaskQueueForceRunRequest) GetTaskName() []byte {
  679. if m != nil {
  680. return m.TaskName
  681. }
  682. return nil
  683. }
  684. type TaskQueueForceRunResponse struct {
  685. Result *TaskQueueServiceError_ErrorCode `protobuf:"varint,3,req,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
  686. XXX_unrecognized []byte `json:"-"`
  687. }
  688. func (m *TaskQueueForceRunResponse) Reset() { *m = TaskQueueForceRunResponse{} }
  689. func (m *TaskQueueForceRunResponse) String() string { return proto.CompactTextString(m) }
  690. func (*TaskQueueForceRunResponse) ProtoMessage() {}
  691. func (m *TaskQueueForceRunResponse) GetResult() TaskQueueServiceError_ErrorCode {
  692. if m != nil && m.Result != nil {
  693. return *m.Result
  694. }
  695. return TaskQueueServiceError_OK
  696. }
  697. type TaskQueueUpdateQueueRequest struct {
  698. AppId []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
  699. QueueName []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
  700. BucketRefillPerSecond *float64 `protobuf:"fixed64,3,req,name=bucket_refill_per_second" json:"bucket_refill_per_second,omitempty"`
  701. BucketCapacity *int32 `protobuf:"varint,4,req,name=bucket_capacity" json:"bucket_capacity,omitempty"`
  702. UserSpecifiedRate *string `protobuf:"bytes,5,opt,name=user_specified_rate" json:"user_specified_rate,omitempty"`
  703. RetryParameters *TaskQueueRetryParameters `protobuf:"bytes,6,opt,name=retry_parameters" json:"retry_parameters,omitempty"`
  704. MaxConcurrentRequests *int32 `protobuf:"varint,7,opt,name=max_concurrent_requests" json:"max_concurrent_requests,omitempty"`
  705. Mode *TaskQueueMode_Mode `protobuf:"varint,8,opt,name=mode,enum=appengine.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
  706. Acl *TaskQueueAcl `protobuf:"bytes,9,opt,name=acl" json:"acl,omitempty"`
  707. HeaderOverride []*TaskQueueHttpHeader `protobuf:"bytes,10,rep,name=header_override" json:"header_override,omitempty"`
  708. XXX_unrecognized []byte `json:"-"`
  709. }
  710. func (m *TaskQueueUpdateQueueRequest) Reset() { *m = TaskQueueUpdateQueueRequest{} }
  711. func (m *TaskQueueUpdateQueueRequest) String() string { return proto.CompactTextString(m) }
  712. func (*TaskQueueUpdateQueueRequest) ProtoMessage() {}
  713. const Default_TaskQueueUpdateQueueRequest_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH
  714. func (m *TaskQueueUpdateQueueRequest) GetAppId() []byte {
  715. if m != nil {
  716. return m.AppId
  717. }
  718. return nil
  719. }
  720. func (m *TaskQueueUpdateQueueRequest) GetQueueName() []byte {
  721. if m != nil {
  722. return m.QueueName
  723. }
  724. return nil
  725. }
  726. func (m *TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond() float64 {
  727. if m != nil && m.BucketRefillPerSecond != nil {
  728. return *m.BucketRefillPerSecond
  729. }
  730. return 0
  731. }
  732. func (m *TaskQueueUpdateQueueRequest) GetBucketCapacity() int32 {
  733. if m != nil && m.BucketCapacity != nil {
  734. return *m.BucketCapacity
  735. }
  736. return 0
  737. }
  738. func (m *TaskQueueUpdateQueueRequest) GetUserSpecifiedRate() string {
  739. if m != nil && m.UserSpecifiedRate != nil {
  740. return *m.UserSpecifiedRate
  741. }
  742. return ""
  743. }
  744. func (m *TaskQueueUpdateQueueRequest) GetRetryParameters() *TaskQueueRetryParameters {
  745. if m != nil {
  746. return m.RetryParameters
  747. }
  748. return nil
  749. }
  750. func (m *TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests() int32 {
  751. if m != nil && m.MaxConcurrentRequests != nil {
  752. return *m.MaxConcurrentRequests
  753. }
  754. return 0
  755. }
  756. func (m *TaskQueueUpdateQueueRequest) GetMode() TaskQueueMode_Mode {
  757. if m != nil && m.Mode != nil {
  758. return *m.Mode
  759. }
  760. return Default_TaskQueueUpdateQueueRequest_Mode
  761. }
  762. func (m *TaskQueueUpdateQueueRequest) GetAcl() *TaskQueueAcl {
  763. if m != nil {
  764. return m.Acl
  765. }
  766. return nil
  767. }
  768. func (m *TaskQueueUpdateQueueRequest) GetHeaderOverride() []*TaskQueueHttpHeader {
  769. if m != nil {
  770. return m.HeaderOverride
  771. }
  772. return nil
  773. }
  774. type TaskQueueUpdateQueueResponse struct {
  775. XXX_unrecognized []byte `json:"-"`
  776. }
  777. func (m *TaskQueueUpdateQueueResponse) Reset() { *m = TaskQueueUpdateQueueResponse{} }
  778. func (m *TaskQueueUpdateQueueResponse) String() string { return proto.CompactTextString(m) }
  779. func (*TaskQueueUpdateQueueResponse) ProtoMessage() {}
  780. type TaskQueueFetchQueuesRequest struct {
  781. AppId []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
  782. MaxRows *int32 `protobuf:"varint,2,req,name=max_rows" json:"max_rows,omitempty"`
  783. XXX_unrecognized []byte `json:"-"`
  784. }
  785. func (m *TaskQueueFetchQueuesRequest) Reset() { *m = TaskQueueFetchQueuesRequest{} }
  786. func (m *TaskQueueFetchQueuesRequest) String() string { return proto.CompactTextString(m) }
  787. func (*TaskQueueFetchQueuesRequest) ProtoMessage() {}
  788. func (m *TaskQueueFetchQueuesRequest) GetAppId() []byte {
  789. if m != nil {
  790. return m.AppId
  791. }
  792. return nil
  793. }
  794. func (m *TaskQueueFetchQueuesRequest) GetMaxRows() int32 {
  795. if m != nil && m.MaxRows != nil {
  796. return *m.MaxRows
  797. }
  798. return 0
  799. }
  800. type TaskQueueFetchQueuesResponse struct {
  801. Queue []*TaskQueueFetchQueuesResponse_Queue `protobuf:"group,1,rep,name=Queue" json:"queue,omitempty"`
  802. XXX_unrecognized []byte `json:"-"`
  803. }
  804. func (m *TaskQueueFetchQueuesResponse) Reset() { *m = TaskQueueFetchQueuesResponse{} }
  805. func (m *TaskQueueFetchQueuesResponse) String() string { return proto.CompactTextString(m) }
  806. func (*TaskQueueFetchQueuesResponse) ProtoMessage() {}
  807. func (m *TaskQueueFetchQueuesResponse) GetQueue() []*TaskQueueFetchQueuesResponse_Queue {
  808. if m != nil {
  809. return m.Queue
  810. }
  811. return nil
  812. }
  813. type TaskQueueFetchQueuesResponse_Queue struct {
  814. QueueName []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
  815. BucketRefillPerSecond *float64 `protobuf:"fixed64,3,req,name=bucket_refill_per_second" json:"bucket_refill_per_second,omitempty"`
  816. BucketCapacity *float64 `protobuf:"fixed64,4,req,name=bucket_capacity" json:"bucket_capacity,omitempty"`
  817. UserSpecifiedRate *string `protobuf:"bytes,5,opt,name=user_specified_rate" json:"user_specified_rate,omitempty"`
  818. Paused *bool `protobuf:"varint,6,req,name=paused,def=0" json:"paused,omitempty"`
  819. RetryParameters *TaskQueueRetryParameters `protobuf:"bytes,7,opt,name=retry_parameters" json:"retry_parameters,omitempty"`
  820. MaxConcurrentRequests *int32 `protobuf:"varint,8,opt,name=max_concurrent_requests" json:"max_concurrent_requests,omitempty"`
  821. Mode *TaskQueueMode_Mode `protobuf:"varint,9,opt,name=mode,enum=appengine.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
  822. Acl *TaskQueueAcl `protobuf:"bytes,10,opt,name=acl" json:"acl,omitempty"`
  823. HeaderOverride []*TaskQueueHttpHeader `protobuf:"bytes,11,rep,name=header_override" json:"header_override,omitempty"`
  824. CreatorName *string `protobuf:"bytes,12,opt,name=creator_name,def=apphosting" json:"creator_name,omitempty"`
  825. XXX_unrecognized []byte `json:"-"`
  826. }
  827. func (m *TaskQueueFetchQueuesResponse_Queue) Reset() { *m = TaskQueueFetchQueuesResponse_Queue{} }
  828. func (m *TaskQueueFetchQueuesResponse_Queue) String() string { return proto.CompactTextString(m) }
  829. func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage() {}
  830. const Default_TaskQueueFetchQueuesResponse_Queue_Paused bool = false
  831. const Default_TaskQueueFetchQueuesResponse_Queue_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH
  832. const Default_TaskQueueFetchQueuesResponse_Queue_CreatorName string = "apphosting"
  833. func (m *TaskQueueFetchQueuesResponse_Queue) GetQueueName() []byte {
  834. if m != nil {
  835. return m.QueueName
  836. }
  837. return nil
  838. }
  839. func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond() float64 {
  840. if m != nil && m.BucketRefillPerSecond != nil {
  841. return *m.BucketRefillPerSecond
  842. }
  843. return 0
  844. }
  845. func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity() float64 {
  846. if m != nil && m.BucketCapacity != nil {
  847. return *m.BucketCapacity
  848. }
  849. return 0
  850. }
  851. func (m *TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate() string {
  852. if m != nil && m.UserSpecifiedRate != nil {
  853. return *m.UserSpecifiedRate
  854. }
  855. return ""
  856. }
  857. func (m *TaskQueueFetchQueuesResponse_Queue) GetPaused() bool {
  858. if m != nil && m.Paused != nil {
  859. return *m.Paused
  860. }
  861. return Default_TaskQueueFetchQueuesResponse_Queue_Paused
  862. }
  863. func (m *TaskQueueFetchQueuesResponse_Queue) GetRetryParameters() *TaskQueueRetryParameters {
  864. if m != nil {
  865. return m.RetryParameters
  866. }
  867. return nil
  868. }
  869. func (m *TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests() int32 {
  870. if m != nil && m.MaxConcurrentRequests != nil {
  871. return *m.MaxConcurrentRequests
  872. }
  873. return 0
  874. }
  875. func (m *TaskQueueFetchQueuesResponse_Queue) GetMode() TaskQueueMode_Mode {
  876. if m != nil && m.Mode != nil {
  877. return *m.Mode
  878. }
  879. return Default_TaskQueueFetchQueuesResponse_Queue_Mode
  880. }
  881. func (m *TaskQueueFetchQueuesResponse_Queue) GetAcl() *TaskQueueAcl {
  882. if m != nil {
  883. return m.Acl
  884. }
  885. return nil
  886. }
  887. func (m *TaskQueueFetchQueuesResponse_Queue) GetHeaderOverride() []*TaskQueueHttpHeader {
  888. if m != nil {
  889. return m.HeaderOverride
  890. }
  891. return nil
  892. }
  893. func (m *TaskQueueFetchQueuesResponse_Queue) GetCreatorName() string {
  894. if m != nil && m.CreatorName != nil {
  895. return *m.CreatorName
  896. }
  897. return Default_TaskQueueFetchQueuesResponse_Queue_CreatorName
  898. }
  899. type TaskQueueFetchQueueStatsRequest struct {
  900. AppId []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
  901. QueueName [][]byte `protobuf:"bytes,2,rep,name=queue_name" json:"queue_name,omitempty"`
  902. MaxNumTasks *int32 `protobuf:"varint,3,opt,name=max_num_tasks,def=0" json:"max_num_tasks,omitempty"`
  903. XXX_unrecognized []byte `json:"-"`
  904. }
  905. func (m *TaskQueueFetchQueueStatsRequest) Reset() { *m = TaskQueueFetchQueueStatsRequest{} }
  906. func (m *TaskQueueFetchQueueStatsRequest) String() string { return proto.CompactTextString(m) }
  907. func (*TaskQueueFetchQueueStatsRequest) ProtoMessage() {}
  908. const Default_TaskQueueFetchQueueStatsRequest_MaxNumTasks int32 = 0
  909. func (m *TaskQueueFetchQueueStatsRequest) GetAppId() []byte {
  910. if m != nil {
  911. return m.AppId
  912. }
  913. return nil
  914. }
  915. func (m *TaskQueueFetchQueueStatsRequest) GetQueueName() [][]byte {
  916. if m != nil {
  917. return m.QueueName
  918. }
  919. return nil
  920. }
  921. func (m *TaskQueueFetchQueueStatsRequest) GetMaxNumTasks() int32 {
  922. if m != nil && m.MaxNumTasks != nil {
  923. return *m.MaxNumTasks
  924. }
  925. return Default_TaskQueueFetchQueueStatsRequest_MaxNumTasks
  926. }
  927. type TaskQueueScannerQueueInfo struct {
  928. ExecutedLastMinute *int64 `protobuf:"varint,1,req,name=executed_last_minute" json:"executed_last_minute,omitempty"`
  929. ExecutedLastHour *int64 `protobuf:"varint,2,req,name=executed_last_hour" json:"executed_last_hour,omitempty"`
  930. SamplingDurationSeconds *float64 `protobuf:"fixed64,3,req,name=sampling_duration_seconds" json:"sampling_duration_seconds,omitempty"`
  931. RequestsInFlight *int32 `protobuf:"varint,4,opt,name=requests_in_flight" json:"requests_in_flight,omitempty"`
  932. EnforcedRate *float64 `protobuf:"fixed64,5,opt,name=enforced_rate" json:"enforced_rate,omitempty"`
  933. XXX_unrecognized []byte `json:"-"`
  934. }
  935. func (m *TaskQueueScannerQueueInfo) Reset() { *m = TaskQueueScannerQueueInfo{} }
  936. func (m *TaskQueueScannerQueueInfo) String() string { return proto.CompactTextString(m) }
  937. func (*TaskQueueScannerQueueInfo) ProtoMessage() {}
  938. func (m *TaskQueueScannerQueueInfo) GetExecutedLastMinute() int64 {
  939. if m != nil && m.ExecutedLastMinute != nil {
  940. return *m.ExecutedLastMinute
  941. }
  942. return 0
  943. }
  944. func (m *TaskQueueScannerQueueInfo) GetExecutedLastHour() int64 {
  945. if m != nil && m.ExecutedLastHour != nil {
  946. return *m.ExecutedLastHour
  947. }
  948. return 0
  949. }
  950. func (m *TaskQueueScannerQueueInfo) GetSamplingDurationSeconds() float64 {
  951. if m != nil && m.SamplingDurationSeconds != nil {
  952. return *m.SamplingDurationSeconds
  953. }
  954. return 0
  955. }
  956. func (m *TaskQueueScannerQueueInfo) GetRequestsInFlight() int32 {
  957. if m != nil && m.RequestsInFlight != nil {
  958. return *m.RequestsInFlight
  959. }
  960. return 0
  961. }
  962. func (m *TaskQueueScannerQueueInfo) GetEnforcedRate() float64 {
  963. if m != nil && m.EnforcedRate != nil {
  964. return *m.EnforcedRate
  965. }
  966. return 0
  967. }
  968. type TaskQueueFetchQueueStatsResponse struct {
  969. Queuestats []*TaskQueueFetchQueueStatsResponse_QueueStats `protobuf:"group,1,rep,name=QueueStats" json:"queuestats,omitempty"`
  970. XXX_unrecognized []byte `json:"-"`
  971. }
  972. func (m *TaskQueueFetchQueueStatsResponse) Reset() { *m = TaskQueueFetchQueueStatsResponse{} }
  973. func (m *TaskQueueFetchQueueStatsResponse) String() string { return proto.CompactTextString(m) }
  974. func (*TaskQueueFetchQueueStatsResponse) ProtoMessage() {}
  975. func (m *TaskQueueFetchQueueStatsResponse) GetQueuestats() []*TaskQueueFetchQueueStatsResponse_QueueStats {
  976. if m != nil {
  977. return m.Queuestats
  978. }
  979. return nil
  980. }
  981. type TaskQueueFetchQueueStatsResponse_QueueStats struct {
  982. NumTasks *int32 `protobuf:"varint,2,req,name=num_tasks" json:"num_tasks,omitempty"`
  983. OldestEtaUsec *int64 `protobuf:"varint,3,req,name=oldest_eta_usec" json:"oldest_eta_usec,omitempty"`
  984. ScannerInfo *TaskQueueScannerQueueInfo `protobuf:"bytes,4,opt,name=scanner_info" json:"scanner_info,omitempty"`
  985. XXX_unrecognized []byte `json:"-"`
  986. }
  987. func (m *TaskQueueFetchQueueStatsResponse_QueueStats) Reset() {
  988. *m = TaskQueueFetchQueueStatsResponse_QueueStats{}
  989. }
  990. func (m *TaskQueueFetchQueueStatsResponse_QueueStats) String() string {
  991. return proto.CompactTextString(m)
  992. }
  993. func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage() {}
  994. func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks() int32 {
  995. if m != nil && m.NumTasks != nil {
  996. return *m.NumTasks
  997. }
  998. return 0
  999. }
  1000. func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec() int64 {
  1001. if m != nil && m.OldestEtaUsec != nil {
  1002. return *m.OldestEtaUsec
  1003. }
  1004. return 0
  1005. }
  1006. func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo() *TaskQueueScannerQueueInfo {
  1007. if m != nil {
  1008. return m.ScannerInfo
  1009. }
  1010. return nil
  1011. }
  1012. type TaskQueuePauseQueueRequest struct {
  1013. AppId []byte `protobuf:"bytes,1,req,name=app_id" json:"app_id,omitempty"`
  1014. QueueName []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
  1015. Pause *bool `protobuf:"varint,3,req,name=pause" json:"pause,omitempty"`
  1016. XXX_unrecognized []byte `json:"-"`
  1017. }
  1018. func (m *TaskQueuePauseQueueRequest) Reset() { *m = TaskQueuePauseQueueRequest{} }
  1019. func (m *TaskQueuePauseQueueRequest) String() string { return proto.CompactTextString(m) }
  1020. func (*TaskQueuePauseQueueRequest) ProtoMessage() {}
  1021. func (m *TaskQueuePauseQueueRequest) GetAppId() []byte {
  1022. if m != nil {
  1023. return m.AppId
  1024. }
  1025. return nil
  1026. }
  1027. func (m *TaskQueuePauseQueueRequest) GetQueueName() []byte {
  1028. if m != nil {
  1029. return m.QueueName
  1030. }
  1031. return nil
  1032. }
  1033. func (m *TaskQueuePauseQueueRequest) GetPause() bool {
  1034. if m != nil && m.Pause != nil {
  1035. return *m.Pause
  1036. }
  1037. return false
  1038. }
  1039. type TaskQueuePauseQueueResponse struct {
  1040. XXX_unrecognized []byte `json:"-"`
  1041. }
  1042. func (m *TaskQueuePauseQueueResponse) Reset() { *m = TaskQueuePauseQueueResponse{} }
  1043. func (m *TaskQueuePauseQueueResponse) String() string { return proto.CompactTextString(m) }
  1044. func (*TaskQueuePauseQueueResponse) ProtoMessage() {}
  1045. type TaskQueuePurgeQueueRequest struct {
  1046. AppId []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
  1047. QueueName []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
  1048. XXX_unrecognized []byte `json:"-"`
  1049. }
  1050. func (m *TaskQueuePurgeQueueRequest) Reset() { *m = TaskQueuePurgeQueueRequest{} }
  1051. func (m *TaskQueuePurgeQueueRequest) String() string { return proto.CompactTextString(m) }
  1052. func (*TaskQueuePurgeQueueRequest) ProtoMessage() {}
  1053. func (m *TaskQueuePurgeQueueRequest) GetAppId() []byte {
  1054. if m != nil {
  1055. return m.AppId
  1056. }
  1057. return nil
  1058. }
  1059. func (m *TaskQueuePurgeQueueRequest) GetQueueName() []byte {
  1060. if m != nil {
  1061. return m.QueueName
  1062. }
  1063. return nil
  1064. }
  1065. type TaskQueuePurgeQueueResponse struct {
  1066. XXX_unrecognized []byte `json:"-"`
  1067. }
  1068. func (m *TaskQueuePurgeQueueResponse) Reset() { *m = TaskQueuePurgeQueueResponse{} }
  1069. func (m *TaskQueuePurgeQueueResponse) String() string { return proto.CompactTextString(m) }
  1070. func (*TaskQueuePurgeQueueResponse) ProtoMessage() {}
  1071. type TaskQueueDeleteQueueRequest struct {
  1072. AppId []byte `protobuf:"bytes,1,req,name=app_id" json:"app_id,omitempty"`
  1073. QueueName []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
  1074. XXX_unrecognized []byte `json:"-"`
  1075. }
  1076. func (m *TaskQueueDeleteQueueRequest) Reset() { *m = TaskQueueDeleteQueueRequest{} }
  1077. func (m *TaskQueueDeleteQueueRequest) String() string { return proto.CompactTextString(m) }
  1078. func (*TaskQueueDeleteQueueRequest) ProtoMessage() {}
  1079. func (m *TaskQueueDeleteQueueRequest) GetAppId() []byte {
  1080. if m != nil {
  1081. return m.AppId
  1082. }
  1083. return nil
  1084. }
  1085. func (m *TaskQueueDeleteQueueRequest) GetQueueName() []byte {
  1086. if m != nil {
  1087. return m.QueueName
  1088. }
  1089. return nil
  1090. }
  1091. type TaskQueueDeleteQueueResponse struct {
  1092. XXX_unrecognized []byte `json:"-"`
  1093. }
  1094. func (m *TaskQueueDeleteQueueResponse) Reset() { *m = TaskQueueDeleteQueueResponse{} }
  1095. func (m *TaskQueueDeleteQueueResponse) String() string { return proto.CompactTextString(m) }
  1096. func (*TaskQueueDeleteQueueResponse) ProtoMessage() {}
  1097. type TaskQueueDeleteGroupRequest struct {
  1098. AppId []byte `protobuf:"bytes,1,req,name=app_id" json:"app_id,omitempty"`
  1099. XXX_unrecognized []byte `json:"-"`
  1100. }
  1101. func (m *TaskQueueDeleteGroupRequest) Reset() { *m = TaskQueueDeleteGroupRequest{} }
  1102. func (m *TaskQueueDeleteGroupRequest) String() string { return proto.CompactTextString(m) }
  1103. func (*TaskQueueDeleteGroupRequest) ProtoMessage() {}
  1104. func (m *TaskQueueDeleteGroupRequest) GetAppId() []byte {
  1105. if m != nil {
  1106. return m.AppId
  1107. }
  1108. return nil
  1109. }
  1110. type TaskQueueDeleteGroupResponse struct {
  1111. XXX_unrecognized []byte `json:"-"`
  1112. }
  1113. func (m *TaskQueueDeleteGroupResponse) Reset() { *m = TaskQueueDeleteGroupResponse{} }
  1114. func (m *TaskQueueDeleteGroupResponse) String() string { return proto.CompactTextString(m) }
  1115. func (*TaskQueueDeleteGroupResponse) ProtoMessage() {}
  1116. type TaskQueueQueryTasksRequest struct {
  1117. AppId []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
  1118. QueueName []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
  1119. StartTaskName []byte `protobuf:"bytes,3,opt,name=start_task_name" json:"start_task_name,omitempty"`
  1120. StartEtaUsec *int64 `protobuf:"varint,4,opt,name=start_eta_usec" json:"start_eta_usec,omitempty"`
  1121. StartTag []byte `protobuf:"bytes,6,opt,name=start_tag" json:"start_tag,omitempty"`
  1122. MaxRows *int32 `protobuf:"varint,5,opt,name=max_rows,def=1" json:"max_rows,omitempty"`
  1123. XXX_unrecognized []byte `json:"-"`
  1124. }
  1125. func (m *TaskQueueQueryTasksRequest) Reset() { *m = TaskQueueQueryTasksRequest{} }
  1126. func (m *TaskQueueQueryTasksRequest) String() string { return proto.CompactTextString(m) }
  1127. func (*TaskQueueQueryTasksRequest) ProtoMessage() {}
  1128. const Default_TaskQueueQueryTasksRequest_MaxRows int32 = 1
  1129. func (m *TaskQueueQueryTasksRequest) GetAppId() []byte {
  1130. if m != nil {
  1131. return m.AppId
  1132. }
  1133. return nil
  1134. }
  1135. func (m *TaskQueueQueryTasksRequest) GetQueueName() []byte {
  1136. if m != nil {
  1137. return m.QueueName
  1138. }
  1139. return nil
  1140. }
  1141. func (m *TaskQueueQueryTasksRequest) GetStartTaskName() []byte {
  1142. if m != nil {
  1143. return m.StartTaskName
  1144. }
  1145. return nil
  1146. }
  1147. func (m *TaskQueueQueryTasksRequest) GetStartEtaUsec() int64 {
  1148. if m != nil && m.StartEtaUsec != nil {
  1149. return *m.StartEtaUsec
  1150. }
  1151. return 0
  1152. }
  1153. func (m *TaskQueueQueryTasksRequest) GetStartTag() []byte {
  1154. if m != nil {
  1155. return m.StartTag
  1156. }
  1157. return nil
  1158. }
  1159. func (m *TaskQueueQueryTasksRequest) GetMaxRows() int32 {
  1160. if m != nil && m.MaxRows != nil {
  1161. return *m.MaxRows
  1162. }
  1163. return Default_TaskQueueQueryTasksRequest_MaxRows
  1164. }
  1165. type TaskQueueQueryTasksResponse struct {
  1166. Task []*TaskQueueQueryTasksResponse_Task `protobuf:"group,1,rep,name=Task" json:"task,omitempty"`
  1167. XXX_unrecognized []byte `json:"-"`
  1168. }
  1169. func (m *TaskQueueQueryTasksResponse) Reset() { *m = TaskQueueQueryTasksResponse{} }
  1170. func (m *TaskQueueQueryTasksResponse) String() string { return proto.CompactTextString(m) }
  1171. func (*TaskQueueQueryTasksResponse) ProtoMessage() {}
  1172. func (m *TaskQueueQueryTasksResponse) GetTask() []*TaskQueueQueryTasksResponse_Task {
  1173. if m != nil {
  1174. return m.Task
  1175. }
  1176. return nil
  1177. }
  1178. type TaskQueueQueryTasksResponse_Task struct {
  1179. TaskName []byte `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
  1180. EtaUsec *int64 `protobuf:"varint,3,req,name=eta_usec" json:"eta_usec,omitempty"`
  1181. Url []byte `protobuf:"bytes,4,opt,name=url" json:"url,omitempty"`
  1182. Method *TaskQueueQueryTasksResponse_Task_RequestMethod `protobuf:"varint,5,opt,name=method,enum=appengine.TaskQueueQueryTasksResponse_Task_RequestMethod" json:"method,omitempty"`
  1183. RetryCount *int32 `protobuf:"varint,6,opt,name=retry_count,def=0" json:"retry_count,omitempty"`
  1184. Header []*TaskQueueQueryTasksResponse_Task_Header `protobuf:"group,7,rep,name=Header" json:"header,omitempty"`
  1185. BodySize *int32 `protobuf:"varint,10,opt,name=body_size" json:"body_size,omitempty"`
  1186. Body []byte `protobuf:"bytes,11,opt,name=body" json:"body,omitempty"`
  1187. CreationTimeUsec *int64 `protobuf:"varint,12,req,name=creation_time_usec" json:"creation_time_usec,omitempty"`
  1188. Crontimetable *TaskQueueQueryTasksResponse_Task_CronTimetable `protobuf:"group,13,opt,name=CronTimetable" json:"crontimetable,omitempty"`
  1189. Runlog *TaskQueueQueryTasksResponse_Task_RunLog `protobuf:"group,16,opt,name=RunLog" json:"runlog,omitempty"`
  1190. Description []byte `protobuf:"bytes,21,opt,name=description" json:"description,omitempty"`
  1191. Payload *TaskPayload `protobuf:"bytes,22,opt,name=payload" json:"payload,omitempty"`
  1192. RetryParameters *TaskQueueRetryParameters `protobuf:"bytes,23,opt,name=retry_parameters" json:"retry_parameters,omitempty"`
  1193. FirstTryUsec *int64 `protobuf:"varint,24,opt,name=first_try_usec" json:"first_try_usec,omitempty"`
  1194. Tag []byte `protobuf:"bytes,25,opt,name=tag" json:"tag,omitempty"`
  1195. ExecutionCount *int32 `protobuf:"varint,26,opt,name=execution_count,def=0" json:"execution_count,omitempty"`
  1196. XXX_unrecognized []byte `json:"-"`
  1197. }
  1198. func (m *TaskQueueQueryTasksResponse_Task) Reset() { *m = TaskQueueQueryTasksResponse_Task{} }
  1199. func (m *TaskQueueQueryTasksResponse_Task) String() string { return proto.CompactTextString(m) }
  1200. func (*TaskQueueQueryTasksResponse_Task) ProtoMessage() {}
  1201. const Default_TaskQueueQueryTasksResponse_Task_RetryCount int32 = 0
  1202. const Default_TaskQueueQueryTasksResponse_Task_ExecutionCount int32 = 0
  1203. func (m *TaskQueueQueryTasksResponse_Task) GetTaskName() []byte {
  1204. if m != nil {
  1205. return m.TaskName
  1206. }
  1207. return nil
  1208. }
  1209. func (m *TaskQueueQueryTasksResponse_Task) GetEtaUsec() int64 {
  1210. if m != nil && m.EtaUsec != nil {
  1211. return *m.EtaUsec
  1212. }
  1213. return 0
  1214. }
  1215. func (m *TaskQueueQueryTasksResponse_Task) GetUrl() []byte {
  1216. if m != nil {
  1217. return m.Url
  1218. }
  1219. return nil
  1220. }
  1221. func (m *TaskQueueQueryTasksResponse_Task) GetMethod() TaskQueueQueryTasksResponse_Task_RequestMethod {
  1222. if m != nil && m.Method != nil {
  1223. return *m.Method
  1224. }
  1225. return TaskQueueQueryTasksResponse_Task_GET
  1226. }
  1227. func (m *TaskQueueQueryTasksResponse_Task) GetRetryCount() int32 {
  1228. if m != nil && m.RetryCount != nil {
  1229. return *m.RetryCount
  1230. }
  1231. return Default_TaskQueueQueryTasksResponse_Task_RetryCount
  1232. }
  1233. func (m *TaskQueueQueryTasksResponse_Task) GetHeader() []*TaskQueueQueryTasksResponse_Task_Header {
  1234. if m != nil {
  1235. return m.Header
  1236. }
  1237. return nil
  1238. }
  1239. func (m *TaskQueueQueryTasksResponse_Task) GetBodySize() int32 {
  1240. if m != nil && m.BodySize != nil {
  1241. return *m.BodySize
  1242. }
  1243. return 0
  1244. }
  1245. func (m *TaskQueueQueryTasksResponse_Task) GetBody() []byte {
  1246. if m != nil {
  1247. return m.Body
  1248. }
  1249. return nil
  1250. }
  1251. func (m *TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec() int64 {
  1252. if m != nil && m.CreationTimeUsec != nil {
  1253. return *m.CreationTimeUsec
  1254. }
  1255. return 0
  1256. }
  1257. func (m *TaskQueueQueryTasksResponse_Task) GetCrontimetable() *TaskQueueQueryTasksResponse_Task_CronTimetable {
  1258. if m != nil {
  1259. return m.Crontimetable
  1260. }
  1261. return nil
  1262. }
  1263. func (m *TaskQueueQueryTasksResponse_Task) GetRunlog() *TaskQueueQueryTasksResponse_Task_RunLog {
  1264. if m != nil {
  1265. return m.Runlog
  1266. }
  1267. return nil
  1268. }
  1269. func (m *TaskQueueQueryTasksResponse_Task) GetDescription() []byte {
  1270. if m != nil {
  1271. return m.Description
  1272. }
  1273. return nil
  1274. }
  1275. func (m *TaskQueueQueryTasksResponse_Task) GetPayload() *TaskPayload {
  1276. if m != nil {
  1277. return m.Payload
  1278. }
  1279. return nil
  1280. }
  1281. func (m *TaskQueueQueryTasksResponse_Task) GetRetryParameters() *TaskQueueRetryParameters {
  1282. if m != nil {
  1283. return m.RetryParameters
  1284. }
  1285. return nil
  1286. }
  1287. func (m *TaskQueueQueryTasksResponse_Task) GetFirstTryUsec() int64 {
  1288. if m != nil && m.FirstTryUsec != nil {
  1289. return *m.FirstTryUsec
  1290. }
  1291. return 0
  1292. }
  1293. func (m *TaskQueueQueryTasksResponse_Task) GetTag() []byte {
  1294. if m != nil {
  1295. return m.Tag
  1296. }
  1297. return nil
  1298. }
  1299. func (m *TaskQueueQueryTasksResponse_Task) GetExecutionCount() int32 {
  1300. if m != nil && m.ExecutionCount != nil {
  1301. return *m.ExecutionCount
  1302. }
  1303. return Default_TaskQueueQueryTasksResponse_Task_ExecutionCount
  1304. }
  1305. type TaskQueueQueryTasksResponse_Task_Header struct {
  1306. Key []byte `protobuf:"bytes,8,req,name=key" json:"key,omitempty"`
  1307. Value []byte `protobuf:"bytes,9,req,name=value" json:"value,omitempty"`
  1308. XXX_unrecognized []byte `json:"-"`
  1309. }
  1310. func (m *TaskQueueQueryTasksResponse_Task_Header) Reset() {
  1311. *m = TaskQueueQueryTasksResponse_Task_Header{}
  1312. }
  1313. func (m *TaskQueueQueryTasksResponse_Task_Header) String() string { return proto.CompactTextString(m) }
  1314. func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage() {}
  1315. func (m *TaskQueueQueryTasksResponse_Task_Header) GetKey() []byte {
  1316. if m != nil {
  1317. return m.Key
  1318. }
  1319. return nil
  1320. }
  1321. func (m *TaskQueueQueryTasksResponse_Task_Header) GetValue() []byte {
  1322. if m != nil {
  1323. return m.Value
  1324. }
  1325. return nil
  1326. }
  1327. type TaskQueueQueryTasksResponse_Task_CronTimetable struct {
  1328. Schedule []byte `protobuf:"bytes,14,req,name=schedule" json:"schedule,omitempty"`
  1329. Timezone []byte `protobuf:"bytes,15,req,name=timezone" json:"timezone,omitempty"`
  1330. XXX_unrecognized []byte `json:"-"`
  1331. }
  1332. func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) Reset() {
  1333. *m = TaskQueueQueryTasksResponse_Task_CronTimetable{}
  1334. }
  1335. func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) String() string {
  1336. return proto.CompactTextString(m)
  1337. }
  1338. func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage() {}
  1339. func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) GetSchedule() []byte {
  1340. if m != nil {
  1341. return m.Schedule
  1342. }
  1343. return nil
  1344. }
  1345. func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) GetTimezone() []byte {
  1346. if m != nil {
  1347. return m.Timezone
  1348. }
  1349. return nil
  1350. }
  1351. type TaskQueueQueryTasksResponse_Task_RunLog struct {
  1352. DispatchedUsec *int64 `protobuf:"varint,17,req,name=dispatched_usec" json:"dispatched_usec,omitempty"`
  1353. LagUsec *int64 `protobuf:"varint,18,req,name=lag_usec" json:"lag_usec,omitempty"`
  1354. ElapsedUsec *int64 `protobuf:"varint,19,req,name=elapsed_usec" json:"elapsed_usec,omitempty"`
  1355. ResponseCode *int64 `protobuf:"varint,20,opt,name=response_code" json:"response_code,omitempty"`
  1356. RetryReason *string `protobuf:"bytes,27,opt,name=retry_reason" json:"retry_reason,omitempty"`
  1357. XXX_unrecognized []byte `json:"-"`
  1358. }
  1359. func (m *TaskQueueQueryTasksResponse_Task_RunLog) Reset() {
  1360. *m = TaskQueueQueryTasksResponse_Task_RunLog{}
  1361. }
  1362. func (m *TaskQueueQueryTasksResponse_Task_RunLog) String() string { return proto.CompactTextString(m) }
  1363. func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage() {}
  1364. func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec() int64 {
  1365. if m != nil && m.DispatchedUsec != nil {
  1366. return *m.DispatchedUsec
  1367. }
  1368. return 0
  1369. }
  1370. func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec() int64 {
  1371. if m != nil && m.LagUsec != nil {
  1372. return *m.LagUsec
  1373. }
  1374. return 0
  1375. }
  1376. func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec() int64 {
  1377. if m != nil && m.ElapsedUsec != nil {
  1378. return *m.ElapsedUsec
  1379. }
  1380. return 0
  1381. }
  1382. func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode() int64 {
  1383. if m != nil && m.ResponseCode != nil {
  1384. return *m.ResponseCode
  1385. }
  1386. return 0
  1387. }
  1388. func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason() string {
  1389. if m != nil && m.RetryReason != nil {
  1390. return *m.RetryReason
  1391. }
  1392. return ""
  1393. }
  1394. type TaskQueueFetchTaskRequest struct {
  1395. AppId []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
  1396. QueueName []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
  1397. TaskName []byte `protobuf:"bytes,3,req,name=task_name" json:"task_name,omitempty"`
  1398. XXX_unrecognized []byte `json:"-"`
  1399. }
  1400. func (m *TaskQueueFetchTaskRequest) Reset() { *m = TaskQueueFetchTaskRequest{} }
  1401. func (m *TaskQueueFetchTaskRequest) String() string { return proto.CompactTextString(m) }
  1402. func (*TaskQueueFetchTaskRequest) ProtoMessage() {}
  1403. func (m *TaskQueueFetchTaskRequest) GetAppId() []byte {
  1404. if m != nil {
  1405. return m.AppId
  1406. }
  1407. return nil
  1408. }
  1409. func (m *TaskQueueFetchTaskRequest) GetQueueName() []byte {
  1410. if m != nil {
  1411. return m.QueueName
  1412. }
  1413. return nil
  1414. }
  1415. func (m *TaskQueueFetchTaskRequest) GetTaskName() []byte {
  1416. if m != nil {
  1417. return m.TaskName
  1418. }
  1419. return nil
  1420. }
  1421. type TaskQueueFetchTaskResponse struct {
  1422. Task *TaskQueueQueryTasksResponse `protobuf:"bytes,1,req,name=task" json:"task,omitempty"`
  1423. XXX_unrecognized []byte `json:"-"`
  1424. }
  1425. func (m *TaskQueueFetchTaskResponse) Reset() { *m = TaskQueueFetchTaskResponse{} }
  1426. func (m *TaskQueueFetchTaskResponse) String() string { return proto.CompactTextString(m) }
  1427. func (*TaskQueueFetchTaskResponse) ProtoMessage() {}
  1428. func (m *TaskQueueFetchTaskResponse) GetTask() *TaskQueueQueryTasksResponse {
  1429. if m != nil {
  1430. return m.Task
  1431. }
  1432. return nil
  1433. }
  1434. type TaskQueueUpdateStorageLimitRequest struct {
  1435. AppId []byte `protobuf:"bytes,1,req,name=app_id" json:"app_id,omitempty"`
  1436. Limit *int64 `protobuf:"varint,2,req,name=limit" json:"limit,omitempty"`
  1437. XXX_unrecognized []byte `json:"-"`
  1438. }
  1439. func (m *TaskQueueUpdateStorageLimitRequest) Reset() { *m = TaskQueueUpdateStorageLimitRequest{} }
  1440. func (m *TaskQueueUpdateStorageLimitRequest) String() string { return proto.CompactTextString(m) }
  1441. func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage() {}
  1442. func (m *TaskQueueUpdateStorageLimitRequest) GetAppId() []byte {
  1443. if m != nil {
  1444. return m.AppId
  1445. }
  1446. return nil
  1447. }
  1448. func (m *TaskQueueUpdateStorageLimitRequest) GetLimit() int64 {
  1449. if m != nil && m.Limit != nil {
  1450. return *m.Limit
  1451. }
  1452. return 0
  1453. }
  1454. type TaskQueueUpdateStorageLimitResponse struct {
  1455. NewLimit *int64 `protobuf:"varint,1,req,name=new_limit" json:"new_limit,omitempty"`
  1456. XXX_unrecognized []byte `json:"-"`
  1457. }
  1458. func (m *TaskQueueUpdateStorageLimitResponse) Reset() { *m = TaskQueueUpdateStorageLimitResponse{} }
  1459. func (m *TaskQueueUpdateStorageLimitResponse) String() string { return proto.CompactTextString(m) }
  1460. func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage() {}
  1461. func (m *TaskQueueUpdateStorageLimitResponse) GetNewLimit() int64 {
  1462. if m != nil && m.NewLimit != nil {
  1463. return *m.NewLimit
  1464. }
  1465. return 0
  1466. }
  1467. type TaskQueueQueryAndOwnTasksRequest struct {
  1468. QueueName []byte `protobuf:"bytes,1,req,name=queue_name" json:"queue_name,omitempty"`
  1469. LeaseSeconds *float64 `protobuf:"fixed64,2,req,name=lease_seconds" json:"lease_seconds,omitempty"`
  1470. MaxTasks *int64 `protobuf:"varint,3,req,name=max_tasks" json:"max_tasks,omitempty"`
  1471. GroupByTag *bool `protobuf:"varint,4,opt,name=group_by_tag,def=0" json:"group_by_tag,omitempty"`
  1472. Tag []byte `protobuf:"bytes,5,opt,name=tag" json:"tag,omitempty"`
  1473. XXX_unrecognized []byte `json:"-"`
  1474. }
  1475. func (m *TaskQueueQueryAndOwnTasksRequest) Reset() { *m = TaskQueueQueryAndOwnTasksRequest{} }
  1476. func (m *TaskQueueQueryAndOwnTasksRequest) String() string { return proto.CompactTextString(m) }
  1477. func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage() {}
  1478. const Default_TaskQueueQueryAndOwnTasksRequest_GroupByTag bool = false
  1479. func (m *TaskQueueQueryAndOwnTasksRequest) GetQueueName() []byte {
  1480. if m != nil {
  1481. return m.QueueName
  1482. }
  1483. return nil
  1484. }
  1485. func (m *TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds() float64 {
  1486. if m != nil && m.LeaseSeconds != nil {
  1487. return *m.LeaseSeconds
  1488. }
  1489. return 0
  1490. }
  1491. func (m *TaskQueueQueryAndOwnTasksRequest) GetMaxTasks() int64 {
  1492. if m != nil && m.MaxTasks != nil {
  1493. return *m.MaxTasks
  1494. }
  1495. return 0
  1496. }
  1497. func (m *TaskQueueQueryAndOwnTasksRequest) GetGroupByTag() bool {
  1498. if m != nil && m.GroupByTag != nil {
  1499. return *m.GroupByTag
  1500. }
  1501. return Default_TaskQueueQueryAndOwnTasksRequest_GroupByTag
  1502. }
  1503. func (m *TaskQueueQueryAndOwnTasksRequest) GetTag() []byte {
  1504. if m != nil {
  1505. return m.Tag
  1506. }
  1507. return nil
  1508. }
  1509. type TaskQueueQueryAndOwnTasksResponse struct {
  1510. Task []*TaskQueueQueryAndOwnTasksResponse_Task `protobuf:"group,1,rep,name=Task" json:"task,omitempty"`
  1511. XXX_unrecognized []byte `json:"-"`
  1512. }
  1513. func (m *TaskQueueQueryAndOwnTasksResponse) Reset() { *m = TaskQueueQueryAndOwnTasksResponse{} }
  1514. func (m *TaskQueueQueryAndOwnTasksResponse) String() string { return proto.CompactTextString(m) }
  1515. func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage() {}
  1516. func (m *TaskQueueQueryAndOwnTasksResponse) GetTask() []*TaskQueueQueryAndOwnTasksResponse_Task {
  1517. if m != nil {
  1518. return m.Task
  1519. }
  1520. return nil
  1521. }
  1522. type TaskQueueQueryAndOwnTasksResponse_Task struct {
  1523. TaskName []byte `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
  1524. EtaUsec *int64 `protobuf:"varint,3,req,name=eta_usec" json:"eta_usec,omitempty"`
  1525. RetryCount *int32 `protobuf:"varint,4,opt,name=retry_count,def=0" json:"retry_count,omitempty"`
  1526. Body []byte `protobuf:"bytes,5,opt,name=body" json:"body,omitempty"`
  1527. Tag []byte `protobuf:"bytes,6,opt,name=tag" json:"tag,omitempty"`
  1528. XXX_unrecognized []byte `json:"-"`
  1529. }
  1530. func (m *TaskQueueQueryAndOwnTasksResponse_Task) Reset() {
  1531. *m = TaskQueueQueryAndOwnTasksResponse_Task{}
  1532. }
  1533. func (m *TaskQueueQueryAndOwnTasksResponse_Task) String() string { return proto.CompactTextString(m) }
  1534. func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage() {}
  1535. const Default_TaskQueueQueryAndOwnTasksResponse_Task_RetryCount int32 = 0
  1536. func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetTaskName() []byte {
  1537. if m != nil {
  1538. return m.TaskName
  1539. }
  1540. return nil
  1541. }
  1542. func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec() int64 {
  1543. if m != nil && m.EtaUsec != nil {
  1544. return *m.EtaUsec
  1545. }
  1546. return 0
  1547. }
  1548. func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount() int32 {
  1549. if m != nil && m.RetryCount != nil {
  1550. return *m.RetryCount
  1551. }
  1552. return Default_TaskQueueQueryAndOwnTasksResponse_Task_RetryCount
  1553. }
  1554. func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetBody() []byte {
  1555. if m != nil {
  1556. return m.Body
  1557. }
  1558. return nil
  1559. }
  1560. func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetTag() []byte {
  1561. if m != nil {
  1562. return m.Tag
  1563. }
  1564. return nil
  1565. }
  1566. type TaskQueueModifyTaskLeaseRequest struct {
  1567. QueueName []byte `protobuf:"bytes,1,req,name=queue_name" json:"queue_name,omitempty"`
  1568. TaskName []byte `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
  1569. EtaUsec *int64 `protobuf:"varint,3,req,name=eta_usec" json:"eta_usec,omitempty"`
  1570. LeaseSeconds *float64 `protobuf:"fixed64,4,req,name=lease_seconds" json:"lease_seconds,omitempty"`
  1571. XXX_unrecognized []byte `json:"-"`
  1572. }
  1573. func (m *TaskQueueModifyTaskLeaseRequest) Reset() { *m = TaskQueueModifyTaskLeaseRequest{} }
  1574. func (m *TaskQueueModifyTaskLeaseRequest) String() string { return proto.CompactTextString(m) }
  1575. func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage() {}
  1576. func (m *TaskQueueModifyTaskLeaseRequest) GetQueueName() []byte {
  1577. if m != nil {
  1578. return m.QueueName
  1579. }
  1580. return nil
  1581. }
  1582. func (m *TaskQueueModifyTaskLeaseRequest) GetTaskName() []byte {
  1583. if m != nil {
  1584. return m.TaskName
  1585. }
  1586. return nil
  1587. }
  1588. func (m *TaskQueueModifyTaskLeaseRequest) GetEtaUsec() int64 {
  1589. if m != nil && m.EtaUsec != nil {
  1590. return *m.EtaUsec
  1591. }
  1592. return 0
  1593. }
  1594. func (m *TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds() float64 {
  1595. if m != nil && m.LeaseSeconds != nil {
  1596. return *m.LeaseSeconds
  1597. }
  1598. return 0
  1599. }
  1600. type TaskQueueModifyTaskLeaseResponse struct {
  1601. UpdatedEtaUsec *int64 `protobuf:"varint,1,req,name=updated_eta_usec" json:"updated_eta_usec,omitempty"`
  1602. XXX_unrecognized []byte `json:"-"`
  1603. }
  1604. func (m *TaskQueueModifyTaskLeaseResponse) Reset() { *m = TaskQueueModifyTaskLeaseResponse{} }
  1605. func (m *TaskQueueModifyTaskLeaseResponse) String() string { return proto.CompactTextString(m) }
  1606. func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage() {}
  1607. func (m *TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec() int64 {
  1608. if m != nil && m.UpdatedEtaUsec != nil {
  1609. return *m.UpdatedEtaUsec
  1610. }
  1611. return 0
  1612. }
  1613. func init() {
  1614. }