--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/thirdparty/google_appengine/google/appengine/api/labs/taskqueue/taskqueue_service_pb.py Fri Jun 19 16:13:32 2009 +0200
@@ -0,0 +1,1590 @@
+#!/usr/bin/env python
+#
+# Copyright 2007 Google Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+from google.net.proto import ProtocolBuffer
+import array
+import dummy_thread as thread
+
+__pychecker__ = """maxreturns=0 maxbranches=0 no-callinit
+ unusednames=printElemNumber,debug_strs no-special"""
+
+class TaskQueueServiceError(ProtocolBuffer.ProtocolMessage):
+
+ OK = 0
+ UNKNOWN_QUEUE = 1
+ TRANSIENT_ERROR = 2
+ INTERNAL_ERROR = 3
+ TASK_TOO_LARGE = 4
+ INVALID_TASK_NAME = 5
+ INVALID_QUEUE_NAME = 6
+ INVALID_URL = 7
+ INVALID_QUEUE_RATE = 8
+ PERMISSION_DENIED = 9
+ TASK_ALREADY_EXISTS = 10
+ TOMBSTONED_TASK = 11
+ INVALID_ETA = 12
+
+ _ErrorCode_NAMES = {
+ 0: "OK",
+ 1: "UNKNOWN_QUEUE",
+ 2: "TRANSIENT_ERROR",
+ 3: "INTERNAL_ERROR",
+ 4: "TASK_TOO_LARGE",
+ 5: "INVALID_TASK_NAME",
+ 6: "INVALID_QUEUE_NAME",
+ 7: "INVALID_URL",
+ 8: "INVALID_QUEUE_RATE",
+ 9: "PERMISSION_DENIED",
+ 10: "TASK_ALREADY_EXISTS",
+ 11: "TOMBSTONED_TASK",
+ 12: "INVALID_ETA",
+ }
+
+ def ErrorCode_Name(cls, x): return cls._ErrorCode_NAMES.get(x, "")
+ ErrorCode_Name = classmethod(ErrorCode_Name)
+
+
+ def __init__(self, contents=None):
+ pass
+ if contents is not None: self.MergeFromString(contents)
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+
+ def Equals(self, x):
+ if x is self: return 1
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ return n + 0
+
+ def Clear(self):
+ pass
+
+ def OutputUnchecked(self, out):
+ pass
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ return res
+
+
+ _TEXT = (
+ "ErrorCode",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+class TaskQueueAddRequest_Header(ProtocolBuffer.ProtocolMessage):
+ has_key_ = 0
+ key_ = ""
+ has_value_ = 0
+ value_ = ""
+
+ def __init__(self, contents=None):
+ if contents is not None: self.MergeFromString(contents)
+
+ def key(self): return self.key_
+
+ def set_key(self, x):
+ self.has_key_ = 1
+ self.key_ = x
+
+ def clear_key(self):
+ if self.has_key_:
+ self.has_key_ = 0
+ self.key_ = ""
+
+ def has_key(self): return self.has_key_
+
+ def value(self): return self.value_
+
+ def set_value(self, x):
+ self.has_value_ = 1
+ self.value_ = x
+
+ def clear_value(self):
+ if self.has_value_:
+ self.has_value_ = 0
+ self.value_ = ""
+
+ def has_value(self): return self.has_value_
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+ if (x.has_key()): self.set_key(x.key())
+ if (x.has_value()): self.set_value(x.value())
+
+ def Equals(self, x):
+ if x is self: return 1
+ if self.has_key_ != x.has_key_: return 0
+ if self.has_key_ and self.key_ != x.key_: return 0
+ if self.has_value_ != x.has_value_: return 0
+ if self.has_value_ and self.value_ != x.value_: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ if (not self.has_key_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: key not set.')
+ if (not self.has_value_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: value not set.')
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += self.lengthString(len(self.key_))
+ n += self.lengthString(len(self.value_))
+ return n + 2
+
+ def Clear(self):
+ self.clear_key()
+ self.clear_value()
+
+ def OutputUnchecked(self, out):
+ out.putVarInt32(58)
+ out.putPrefixedString(self.key_)
+ out.putVarInt32(66)
+ out.putPrefixedString(self.value_)
+
+ def TryMerge(self, d):
+ while 1:
+ tt = d.getVarInt32()
+ if tt == 52: break
+ if tt == 58:
+ self.set_key(d.getPrefixedString())
+ continue
+ if tt == 66:
+ self.set_value(d.getPrefixedString())
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ if self.has_key_: res+=prefix+("key: %s\n" % self.DebugFormatString(self.key_))
+ if self.has_value_: res+=prefix+("value: %s\n" % self.DebugFormatString(self.value_))
+ return res
+
+class TaskQueueAddRequest(ProtocolBuffer.ProtocolMessage):
+
+ GET = 1
+ POST = 2
+ HEAD = 3
+ PUT = 4
+ DELETE = 5
+
+ _RequestMethod_NAMES = {
+ 1: "GET",
+ 2: "POST",
+ 3: "HEAD",
+ 4: "PUT",
+ 5: "DELETE",
+ }
+
+ def RequestMethod_Name(cls, x): return cls._RequestMethod_NAMES.get(x, "")
+ RequestMethod_Name = classmethod(RequestMethod_Name)
+
+ has_queue_name_ = 0
+ queue_name_ = ""
+ has_task_name_ = 0
+ task_name_ = ""
+ has_eta_usec_ = 0
+ eta_usec_ = 0
+ has_method_ = 0
+ method_ = 2
+ has_url_ = 0
+ url_ = ""
+ has_body_ = 0
+ body_ = ""
+
+ def __init__(self, contents=None):
+ self.header_ = []
+ if contents is not None: self.MergeFromString(contents)
+
+ def queue_name(self): return self.queue_name_
+
+ def set_queue_name(self, x):
+ self.has_queue_name_ = 1
+ self.queue_name_ = x
+
+ def clear_queue_name(self):
+ if self.has_queue_name_:
+ self.has_queue_name_ = 0
+ self.queue_name_ = ""
+
+ def has_queue_name(self): return self.has_queue_name_
+
+ def task_name(self): return self.task_name_
+
+ def set_task_name(self, x):
+ self.has_task_name_ = 1
+ self.task_name_ = x
+
+ def clear_task_name(self):
+ if self.has_task_name_:
+ self.has_task_name_ = 0
+ self.task_name_ = ""
+
+ def has_task_name(self): return self.has_task_name_
+
+ def eta_usec(self): return self.eta_usec_
+
+ def set_eta_usec(self, x):
+ self.has_eta_usec_ = 1
+ self.eta_usec_ = x
+
+ def clear_eta_usec(self):
+ if self.has_eta_usec_:
+ self.has_eta_usec_ = 0
+ self.eta_usec_ = 0
+
+ def has_eta_usec(self): return self.has_eta_usec_
+
+ def method(self): return self.method_
+
+ def set_method(self, x):
+ self.has_method_ = 1
+ self.method_ = x
+
+ def clear_method(self):
+ if self.has_method_:
+ self.has_method_ = 0
+ self.method_ = 2
+
+ def has_method(self): return self.has_method_
+
+ def url(self): return self.url_
+
+ def set_url(self, x):
+ self.has_url_ = 1
+ self.url_ = x
+
+ def clear_url(self):
+ if self.has_url_:
+ self.has_url_ = 0
+ self.url_ = ""
+
+ def has_url(self): return self.has_url_
+
+ def header_size(self): return len(self.header_)
+ def header_list(self): return self.header_
+
+ def header(self, i):
+ return self.header_[i]
+
+ def mutable_header(self, i):
+ return self.header_[i]
+
+ def add_header(self):
+ x = TaskQueueAddRequest_Header()
+ self.header_.append(x)
+ return x
+
+ def clear_header(self):
+ self.header_ = []
+ def body(self): return self.body_
+
+ def set_body(self, x):
+ self.has_body_ = 1
+ self.body_ = x
+
+ def clear_body(self):
+ if self.has_body_:
+ self.has_body_ = 0
+ self.body_ = ""
+
+ def has_body(self): return self.has_body_
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+ if (x.has_queue_name()): self.set_queue_name(x.queue_name())
+ if (x.has_task_name()): self.set_task_name(x.task_name())
+ if (x.has_eta_usec()): self.set_eta_usec(x.eta_usec())
+ if (x.has_method()): self.set_method(x.method())
+ if (x.has_url()): self.set_url(x.url())
+ for i in xrange(x.header_size()): self.add_header().CopyFrom(x.header(i))
+ if (x.has_body()): self.set_body(x.body())
+
+ def Equals(self, x):
+ if x is self: return 1
+ if self.has_queue_name_ != x.has_queue_name_: return 0
+ if self.has_queue_name_ and self.queue_name_ != x.queue_name_: return 0
+ if self.has_task_name_ != x.has_task_name_: return 0
+ if self.has_task_name_ and self.task_name_ != x.task_name_: return 0
+ if self.has_eta_usec_ != x.has_eta_usec_: return 0
+ if self.has_eta_usec_ and self.eta_usec_ != x.eta_usec_: return 0
+ if self.has_method_ != x.has_method_: return 0
+ if self.has_method_ and self.method_ != x.method_: return 0
+ if self.has_url_ != x.has_url_: return 0
+ if self.has_url_ and self.url_ != x.url_: return 0
+ if len(self.header_) != len(x.header_): return 0
+ for e1, e2 in zip(self.header_, x.header_):
+ if e1 != e2: return 0
+ if self.has_body_ != x.has_body_: return 0
+ if self.has_body_ and self.body_ != x.body_: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ if (not self.has_queue_name_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: queue_name not set.')
+ if (not self.has_task_name_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: task_name not set.')
+ if (not self.has_eta_usec_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: eta_usec not set.')
+ if (not self.has_url_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: url not set.')
+ for p in self.header_:
+ if not p.IsInitialized(debug_strs): initialized=0
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += self.lengthString(len(self.queue_name_))
+ n += self.lengthString(len(self.task_name_))
+ n += self.lengthVarInt64(self.eta_usec_)
+ if (self.has_method_): n += 1 + self.lengthVarInt64(self.method_)
+ n += self.lengthString(len(self.url_))
+ n += 2 * len(self.header_)
+ for i in xrange(len(self.header_)): n += self.header_[i].ByteSize()
+ if (self.has_body_): n += 1 + self.lengthString(len(self.body_))
+ return n + 4
+
+ def Clear(self):
+ self.clear_queue_name()
+ self.clear_task_name()
+ self.clear_eta_usec()
+ self.clear_method()
+ self.clear_url()
+ self.clear_header()
+ self.clear_body()
+
+ def OutputUnchecked(self, out):
+ out.putVarInt32(10)
+ out.putPrefixedString(self.queue_name_)
+ out.putVarInt32(18)
+ out.putPrefixedString(self.task_name_)
+ out.putVarInt32(24)
+ out.putVarInt64(self.eta_usec_)
+ out.putVarInt32(34)
+ out.putPrefixedString(self.url_)
+ if (self.has_method_):
+ out.putVarInt32(40)
+ out.putVarInt32(self.method_)
+ for i in xrange(len(self.header_)):
+ out.putVarInt32(51)
+ self.header_[i].OutputUnchecked(out)
+ out.putVarInt32(52)
+ if (self.has_body_):
+ out.putVarInt32(74)
+ out.putPrefixedString(self.body_)
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if tt == 10:
+ self.set_queue_name(d.getPrefixedString())
+ continue
+ if tt == 18:
+ self.set_task_name(d.getPrefixedString())
+ continue
+ if tt == 24:
+ self.set_eta_usec(d.getVarInt64())
+ continue
+ if tt == 34:
+ self.set_url(d.getPrefixedString())
+ continue
+ if tt == 40:
+ self.set_method(d.getVarInt32())
+ continue
+ if tt == 51:
+ self.add_header().TryMerge(d)
+ continue
+ if tt == 74:
+ self.set_body(d.getPrefixedString())
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ if self.has_queue_name_: res+=prefix+("queue_name: %s\n" % self.DebugFormatString(self.queue_name_))
+ if self.has_task_name_: res+=prefix+("task_name: %s\n" % self.DebugFormatString(self.task_name_))
+ if self.has_eta_usec_: res+=prefix+("eta_usec: %s\n" % self.DebugFormatInt64(self.eta_usec_))
+ if self.has_method_: res+=prefix+("method: %s\n" % self.DebugFormatInt32(self.method_))
+ if self.has_url_: res+=prefix+("url: %s\n" % self.DebugFormatString(self.url_))
+ cnt=0
+ for e in self.header_:
+ elm=""
+ if printElemNumber: elm="(%d)" % cnt
+ res+=prefix+("Header%s {\n" % elm)
+ res+=e.__str__(prefix + " ", printElemNumber)
+ res+=prefix+"}\n"
+ cnt+=1
+ if self.has_body_: res+=prefix+("body: %s\n" % self.DebugFormatString(self.body_))
+ return res
+
+ kqueue_name = 1
+ ktask_name = 2
+ keta_usec = 3
+ kmethod = 5
+ kurl = 4
+ kHeaderGroup = 6
+ kHeaderkey = 7
+ kHeadervalue = 8
+ kbody = 9
+
+ _TEXT = (
+ "ErrorCode",
+ "queue_name",
+ "task_name",
+ "eta_usec",
+ "url",
+ "method",
+ "Header",
+ "key",
+ "value",
+ "body",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.NUMERIC,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.NUMERIC,
+
+ ProtocolBuffer.Encoder.STARTGROUP,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+class TaskQueueAddResponse(ProtocolBuffer.ProtocolMessage):
+ has_chosen_task_name_ = 0
+ chosen_task_name_ = ""
+
+ def __init__(self, contents=None):
+ if contents is not None: self.MergeFromString(contents)
+
+ def chosen_task_name(self): return self.chosen_task_name_
+
+ def set_chosen_task_name(self, x):
+ self.has_chosen_task_name_ = 1
+ self.chosen_task_name_ = x
+
+ def clear_chosen_task_name(self):
+ if self.has_chosen_task_name_:
+ self.has_chosen_task_name_ = 0
+ self.chosen_task_name_ = ""
+
+ def has_chosen_task_name(self): return self.has_chosen_task_name_
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+ if (x.has_chosen_task_name()): self.set_chosen_task_name(x.chosen_task_name())
+
+ def Equals(self, x):
+ if x is self: return 1
+ if self.has_chosen_task_name_ != x.has_chosen_task_name_: return 0
+ if self.has_chosen_task_name_ and self.chosen_task_name_ != x.chosen_task_name_: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ if (self.has_chosen_task_name_): n += 1 + self.lengthString(len(self.chosen_task_name_))
+ return n + 0
+
+ def Clear(self):
+ self.clear_chosen_task_name()
+
+ def OutputUnchecked(self, out):
+ if (self.has_chosen_task_name_):
+ out.putVarInt32(10)
+ out.putPrefixedString(self.chosen_task_name_)
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if tt == 10:
+ self.set_chosen_task_name(d.getPrefixedString())
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ if self.has_chosen_task_name_: res+=prefix+("chosen_task_name: %s\n" % self.DebugFormatString(self.chosen_task_name_))
+ return res
+
+ kchosen_task_name = 1
+
+ _TEXT = (
+ "ErrorCode",
+ "chosen_task_name",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ ProtocolBuffer.Encoder.STRING,
+
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+class TaskQueueUpdateQueueRequest(ProtocolBuffer.ProtocolMessage):
+ has_app_id_ = 0
+ app_id_ = ""
+ has_queue_name_ = 0
+ queue_name_ = ""
+ has_bucket_refill_per_second_ = 0
+ bucket_refill_per_second_ = 0.0
+ has_bucket_capacity_ = 0
+ bucket_capacity_ = 0
+ has_user_specified_rate_ = 0
+ user_specified_rate_ = ""
+
+ def __init__(self, contents=None):
+ if contents is not None: self.MergeFromString(contents)
+
+ def app_id(self): return self.app_id_
+
+ def set_app_id(self, x):
+ self.has_app_id_ = 1
+ self.app_id_ = x
+
+ def clear_app_id(self):
+ if self.has_app_id_:
+ self.has_app_id_ = 0
+ self.app_id_ = ""
+
+ def has_app_id(self): return self.has_app_id_
+
+ def queue_name(self): return self.queue_name_
+
+ def set_queue_name(self, x):
+ self.has_queue_name_ = 1
+ self.queue_name_ = x
+
+ def clear_queue_name(self):
+ if self.has_queue_name_:
+ self.has_queue_name_ = 0
+ self.queue_name_ = ""
+
+ def has_queue_name(self): return self.has_queue_name_
+
+ def bucket_refill_per_second(self): return self.bucket_refill_per_second_
+
+ def set_bucket_refill_per_second(self, x):
+ self.has_bucket_refill_per_second_ = 1
+ self.bucket_refill_per_second_ = x
+
+ def clear_bucket_refill_per_second(self):
+ if self.has_bucket_refill_per_second_:
+ self.has_bucket_refill_per_second_ = 0
+ self.bucket_refill_per_second_ = 0.0
+
+ def has_bucket_refill_per_second(self): return self.has_bucket_refill_per_second_
+
+ def bucket_capacity(self): return self.bucket_capacity_
+
+ def set_bucket_capacity(self, x):
+ self.has_bucket_capacity_ = 1
+ self.bucket_capacity_ = x
+
+ def clear_bucket_capacity(self):
+ if self.has_bucket_capacity_:
+ self.has_bucket_capacity_ = 0
+ self.bucket_capacity_ = 0
+
+ def has_bucket_capacity(self): return self.has_bucket_capacity_
+
+ def user_specified_rate(self): return self.user_specified_rate_
+
+ def set_user_specified_rate(self, x):
+ self.has_user_specified_rate_ = 1
+ self.user_specified_rate_ = x
+
+ def clear_user_specified_rate(self):
+ if self.has_user_specified_rate_:
+ self.has_user_specified_rate_ = 0
+ self.user_specified_rate_ = ""
+
+ def has_user_specified_rate(self): return self.has_user_specified_rate_
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+ if (x.has_app_id()): self.set_app_id(x.app_id())
+ if (x.has_queue_name()): self.set_queue_name(x.queue_name())
+ if (x.has_bucket_refill_per_second()): self.set_bucket_refill_per_second(x.bucket_refill_per_second())
+ if (x.has_bucket_capacity()): self.set_bucket_capacity(x.bucket_capacity())
+ if (x.has_user_specified_rate()): self.set_user_specified_rate(x.user_specified_rate())
+
+ def Equals(self, x):
+ if x is self: return 1
+ if self.has_app_id_ != x.has_app_id_: return 0
+ if self.has_app_id_ and self.app_id_ != x.app_id_: return 0
+ if self.has_queue_name_ != x.has_queue_name_: return 0
+ if self.has_queue_name_ and self.queue_name_ != x.queue_name_: return 0
+ if self.has_bucket_refill_per_second_ != x.has_bucket_refill_per_second_: return 0
+ if self.has_bucket_refill_per_second_ and self.bucket_refill_per_second_ != x.bucket_refill_per_second_: return 0
+ if self.has_bucket_capacity_ != x.has_bucket_capacity_: return 0
+ if self.has_bucket_capacity_ and self.bucket_capacity_ != x.bucket_capacity_: return 0
+ if self.has_user_specified_rate_ != x.has_user_specified_rate_: return 0
+ if self.has_user_specified_rate_ and self.user_specified_rate_ != x.user_specified_rate_: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ if (not self.has_app_id_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: app_id not set.')
+ if (not self.has_queue_name_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: queue_name not set.')
+ if (not self.has_bucket_refill_per_second_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: bucket_refill_per_second not set.')
+ if (not self.has_bucket_capacity_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: bucket_capacity not set.')
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += self.lengthString(len(self.app_id_))
+ n += self.lengthString(len(self.queue_name_))
+ n += self.lengthVarInt64(self.bucket_capacity_)
+ if (self.has_user_specified_rate_): n += 1 + self.lengthString(len(self.user_specified_rate_))
+ return n + 12
+
+ def Clear(self):
+ self.clear_app_id()
+ self.clear_queue_name()
+ self.clear_bucket_refill_per_second()
+ self.clear_bucket_capacity()
+ self.clear_user_specified_rate()
+
+ def OutputUnchecked(self, out):
+ out.putVarInt32(10)
+ out.putPrefixedString(self.app_id_)
+ out.putVarInt32(18)
+ out.putPrefixedString(self.queue_name_)
+ out.putVarInt32(25)
+ out.putDouble(self.bucket_refill_per_second_)
+ out.putVarInt32(32)
+ out.putVarInt32(self.bucket_capacity_)
+ if (self.has_user_specified_rate_):
+ out.putVarInt32(42)
+ out.putPrefixedString(self.user_specified_rate_)
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if tt == 10:
+ self.set_app_id(d.getPrefixedString())
+ continue
+ if tt == 18:
+ self.set_queue_name(d.getPrefixedString())
+ continue
+ if tt == 25:
+ self.set_bucket_refill_per_second(d.getDouble())
+ continue
+ if tt == 32:
+ self.set_bucket_capacity(d.getVarInt32())
+ continue
+ if tt == 42:
+ self.set_user_specified_rate(d.getPrefixedString())
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ if self.has_app_id_: res+=prefix+("app_id: %s\n" % self.DebugFormatString(self.app_id_))
+ if self.has_queue_name_: res+=prefix+("queue_name: %s\n" % self.DebugFormatString(self.queue_name_))
+ if self.has_bucket_refill_per_second_: res+=prefix+("bucket_refill_per_second: %s\n" % self.DebugFormat(self.bucket_refill_per_second_))
+ if self.has_bucket_capacity_: res+=prefix+("bucket_capacity: %s\n" % self.DebugFormatInt32(self.bucket_capacity_))
+ if self.has_user_specified_rate_: res+=prefix+("user_specified_rate: %s\n" % self.DebugFormatString(self.user_specified_rate_))
+ return res
+
+ kapp_id = 1
+ kqueue_name = 2
+ kbucket_refill_per_second = 3
+ kbucket_capacity = 4
+ kuser_specified_rate = 5
+
+ _TEXT = (
+ "ErrorCode",
+ "app_id",
+ "queue_name",
+ "bucket_refill_per_second",
+ "bucket_capacity",
+ "user_specified_rate",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.DOUBLE,
+
+ ProtocolBuffer.Encoder.NUMERIC,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+class TaskQueueUpdateQueueResponse(ProtocolBuffer.ProtocolMessage):
+
+ def __init__(self, contents=None):
+ pass
+ if contents is not None: self.MergeFromString(contents)
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+
+ def Equals(self, x):
+ if x is self: return 1
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ return n + 0
+
+ def Clear(self):
+ pass
+
+ def OutputUnchecked(self, out):
+ pass
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ return res
+
+
+ _TEXT = (
+ "ErrorCode",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+class TaskQueueFetchQueuesRequest(ProtocolBuffer.ProtocolMessage):
+ has_app_id_ = 0
+ app_id_ = ""
+ has_max_rows_ = 0
+ max_rows_ = 0
+
+ def __init__(self, contents=None):
+ if contents is not None: self.MergeFromString(contents)
+
+ def app_id(self): return self.app_id_
+
+ def set_app_id(self, x):
+ self.has_app_id_ = 1
+ self.app_id_ = x
+
+ def clear_app_id(self):
+ if self.has_app_id_:
+ self.has_app_id_ = 0
+ self.app_id_ = ""
+
+ def has_app_id(self): return self.has_app_id_
+
+ def max_rows(self): return self.max_rows_
+
+ def set_max_rows(self, x):
+ self.has_max_rows_ = 1
+ self.max_rows_ = x
+
+ def clear_max_rows(self):
+ if self.has_max_rows_:
+ self.has_max_rows_ = 0
+ self.max_rows_ = 0
+
+ def has_max_rows(self): return self.has_max_rows_
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+ if (x.has_app_id()): self.set_app_id(x.app_id())
+ if (x.has_max_rows()): self.set_max_rows(x.max_rows())
+
+ def Equals(self, x):
+ if x is self: return 1
+ if self.has_app_id_ != x.has_app_id_: return 0
+ if self.has_app_id_ and self.app_id_ != x.app_id_: return 0
+ if self.has_max_rows_ != x.has_max_rows_: return 0
+ if self.has_max_rows_ and self.max_rows_ != x.max_rows_: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ if (not self.has_app_id_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: app_id not set.')
+ if (not self.has_max_rows_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: max_rows not set.')
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += self.lengthString(len(self.app_id_))
+ n += self.lengthVarInt64(self.max_rows_)
+ return n + 2
+
+ def Clear(self):
+ self.clear_app_id()
+ self.clear_max_rows()
+
+ def OutputUnchecked(self, out):
+ out.putVarInt32(10)
+ out.putPrefixedString(self.app_id_)
+ out.putVarInt32(16)
+ out.putVarInt32(self.max_rows_)
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if tt == 10:
+ self.set_app_id(d.getPrefixedString())
+ continue
+ if tt == 16:
+ self.set_max_rows(d.getVarInt32())
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ if self.has_app_id_: res+=prefix+("app_id: %s\n" % self.DebugFormatString(self.app_id_))
+ if self.has_max_rows_: res+=prefix+("max_rows: %s\n" % self.DebugFormatInt32(self.max_rows_))
+ return res
+
+ kapp_id = 1
+ kmax_rows = 2
+
+ _TEXT = (
+ "ErrorCode",
+ "app_id",
+ "max_rows",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.NUMERIC,
+
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+class TaskQueueFetchQueuesResponse_Queue(ProtocolBuffer.ProtocolMessage):
+ has_queue_name_ = 0
+ queue_name_ = ""
+ has_bucket_refill_per_second_ = 0
+ bucket_refill_per_second_ = 0.0
+ has_bucket_capacity_ = 0
+ bucket_capacity_ = 0.0
+ has_user_specified_rate_ = 0
+ user_specified_rate_ = ""
+
+ def __init__(self, contents=None):
+ if contents is not None: self.MergeFromString(contents)
+
+ def queue_name(self): return self.queue_name_
+
+ def set_queue_name(self, x):
+ self.has_queue_name_ = 1
+ self.queue_name_ = x
+
+ def clear_queue_name(self):
+ if self.has_queue_name_:
+ self.has_queue_name_ = 0
+ self.queue_name_ = ""
+
+ def has_queue_name(self): return self.has_queue_name_
+
+ def bucket_refill_per_second(self): return self.bucket_refill_per_second_
+
+ def set_bucket_refill_per_second(self, x):
+ self.has_bucket_refill_per_second_ = 1
+ self.bucket_refill_per_second_ = x
+
+ def clear_bucket_refill_per_second(self):
+ if self.has_bucket_refill_per_second_:
+ self.has_bucket_refill_per_second_ = 0
+ self.bucket_refill_per_second_ = 0.0
+
+ def has_bucket_refill_per_second(self): return self.has_bucket_refill_per_second_
+
+ def bucket_capacity(self): return self.bucket_capacity_
+
+ def set_bucket_capacity(self, x):
+ self.has_bucket_capacity_ = 1
+ self.bucket_capacity_ = x
+
+ def clear_bucket_capacity(self):
+ if self.has_bucket_capacity_:
+ self.has_bucket_capacity_ = 0
+ self.bucket_capacity_ = 0.0
+
+ def has_bucket_capacity(self): return self.has_bucket_capacity_
+
+ def user_specified_rate(self): return self.user_specified_rate_
+
+ def set_user_specified_rate(self, x):
+ self.has_user_specified_rate_ = 1
+ self.user_specified_rate_ = x
+
+ def clear_user_specified_rate(self):
+ if self.has_user_specified_rate_:
+ self.has_user_specified_rate_ = 0
+ self.user_specified_rate_ = ""
+
+ def has_user_specified_rate(self): return self.has_user_specified_rate_
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+ if (x.has_queue_name()): self.set_queue_name(x.queue_name())
+ if (x.has_bucket_refill_per_second()): self.set_bucket_refill_per_second(x.bucket_refill_per_second())
+ if (x.has_bucket_capacity()): self.set_bucket_capacity(x.bucket_capacity())
+ if (x.has_user_specified_rate()): self.set_user_specified_rate(x.user_specified_rate())
+
+ def Equals(self, x):
+ if x is self: return 1
+ if self.has_queue_name_ != x.has_queue_name_: return 0
+ if self.has_queue_name_ and self.queue_name_ != x.queue_name_: return 0
+ if self.has_bucket_refill_per_second_ != x.has_bucket_refill_per_second_: return 0
+ if self.has_bucket_refill_per_second_ and self.bucket_refill_per_second_ != x.bucket_refill_per_second_: return 0
+ if self.has_bucket_capacity_ != x.has_bucket_capacity_: return 0
+ if self.has_bucket_capacity_ and self.bucket_capacity_ != x.bucket_capacity_: return 0
+ if self.has_user_specified_rate_ != x.has_user_specified_rate_: return 0
+ if self.has_user_specified_rate_ and self.user_specified_rate_ != x.user_specified_rate_: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ if (not self.has_queue_name_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: queue_name not set.')
+ if (not self.has_bucket_refill_per_second_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: bucket_refill_per_second not set.')
+ if (not self.has_bucket_capacity_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: bucket_capacity not set.')
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += self.lengthString(len(self.queue_name_))
+ if (self.has_user_specified_rate_): n += 1 + self.lengthString(len(self.user_specified_rate_))
+ return n + 19
+
+ def Clear(self):
+ self.clear_queue_name()
+ self.clear_bucket_refill_per_second()
+ self.clear_bucket_capacity()
+ self.clear_user_specified_rate()
+
+ def OutputUnchecked(self, out):
+ out.putVarInt32(18)
+ out.putPrefixedString(self.queue_name_)
+ out.putVarInt32(25)
+ out.putDouble(self.bucket_refill_per_second_)
+ out.putVarInt32(33)
+ out.putDouble(self.bucket_capacity_)
+ if (self.has_user_specified_rate_):
+ out.putVarInt32(42)
+ out.putPrefixedString(self.user_specified_rate_)
+
+ def TryMerge(self, d):
+ while 1:
+ tt = d.getVarInt32()
+ if tt == 12: break
+ if tt == 18:
+ self.set_queue_name(d.getPrefixedString())
+ continue
+ if tt == 25:
+ self.set_bucket_refill_per_second(d.getDouble())
+ continue
+ if tt == 33:
+ self.set_bucket_capacity(d.getDouble())
+ continue
+ if tt == 42:
+ self.set_user_specified_rate(d.getPrefixedString())
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ if self.has_queue_name_: res+=prefix+("queue_name: %s\n" % self.DebugFormatString(self.queue_name_))
+ if self.has_bucket_refill_per_second_: res+=prefix+("bucket_refill_per_second: %s\n" % self.DebugFormat(self.bucket_refill_per_second_))
+ if self.has_bucket_capacity_: res+=prefix+("bucket_capacity: %s\n" % self.DebugFormat(self.bucket_capacity_))
+ if self.has_user_specified_rate_: res+=prefix+("user_specified_rate: %s\n" % self.DebugFormatString(self.user_specified_rate_))
+ return res
+
+class TaskQueueFetchQueuesResponse(ProtocolBuffer.ProtocolMessage):
+
+ def __init__(self, contents=None):
+ self.queue_ = []
+ if contents is not None: self.MergeFromString(contents)
+
+ def queue_size(self): return len(self.queue_)
+ def queue_list(self): return self.queue_
+
+ def queue(self, i):
+ return self.queue_[i]
+
+ def mutable_queue(self, i):
+ return self.queue_[i]
+
+ def add_queue(self):
+ x = TaskQueueFetchQueuesResponse_Queue()
+ self.queue_.append(x)
+ return x
+
+ def clear_queue(self):
+ self.queue_ = []
+
+ def MergeFrom(self, x):
+ assert x is not self
+ for i in xrange(x.queue_size()): self.add_queue().CopyFrom(x.queue(i))
+
+ def Equals(self, x):
+ if x is self: return 1
+ if len(self.queue_) != len(x.queue_): return 0
+ for e1, e2 in zip(self.queue_, x.queue_):
+ if e1 != e2: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ for p in self.queue_:
+ if not p.IsInitialized(debug_strs): initialized=0
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += 2 * len(self.queue_)
+ for i in xrange(len(self.queue_)): n += self.queue_[i].ByteSize()
+ return n + 0
+
+ def Clear(self):
+ self.clear_queue()
+
+ def OutputUnchecked(self, out):
+ for i in xrange(len(self.queue_)):
+ out.putVarInt32(11)
+ self.queue_[i].OutputUnchecked(out)
+ out.putVarInt32(12)
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if tt == 11:
+ self.add_queue().TryMerge(d)
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ cnt=0
+ for e in self.queue_:
+ elm=""
+ if printElemNumber: elm="(%d)" % cnt
+ res+=prefix+("Queue%s {\n" % elm)
+ res+=e.__str__(prefix + " ", printElemNumber)
+ res+=prefix+"}\n"
+ cnt+=1
+ return res
+
+ kQueueGroup = 1
+ kQueuequeue_name = 2
+ kQueuebucket_refill_per_second = 3
+ kQueuebucket_capacity = 4
+ kQueueuser_specified_rate = 5
+
+ _TEXT = (
+ "ErrorCode",
+ "Queue",
+ "queue_name",
+ "bucket_refill_per_second",
+ "bucket_capacity",
+ "user_specified_rate",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ ProtocolBuffer.Encoder.STARTGROUP,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.DOUBLE,
+
+ ProtocolBuffer.Encoder.DOUBLE,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+class TaskQueueFetchQueueStatsRequest(ProtocolBuffer.ProtocolMessage):
+ has_app_id_ = 0
+ app_id_ = ""
+ has_max_num_tasks_ = 0
+ max_num_tasks_ = 0
+
+ def __init__(self, contents=None):
+ self.queue_name_ = []
+ if contents is not None: self.MergeFromString(contents)
+
+ def app_id(self): return self.app_id_
+
+ def set_app_id(self, x):
+ self.has_app_id_ = 1
+ self.app_id_ = x
+
+ def clear_app_id(self):
+ if self.has_app_id_:
+ self.has_app_id_ = 0
+ self.app_id_ = ""
+
+ def has_app_id(self): return self.has_app_id_
+
+ def queue_name_size(self): return len(self.queue_name_)
+ def queue_name_list(self): return self.queue_name_
+
+ def queue_name(self, i):
+ return self.queue_name_[i]
+
+ def set_queue_name(self, i, x):
+ self.queue_name_[i] = x
+
+ def add_queue_name(self, x):
+ self.queue_name_.append(x)
+
+ def clear_queue_name(self):
+ self.queue_name_ = []
+
+ def max_num_tasks(self): return self.max_num_tasks_
+
+ def set_max_num_tasks(self, x):
+ self.has_max_num_tasks_ = 1
+ self.max_num_tasks_ = x
+
+ def clear_max_num_tasks(self):
+ if self.has_max_num_tasks_:
+ self.has_max_num_tasks_ = 0
+ self.max_num_tasks_ = 0
+
+ def has_max_num_tasks(self): return self.has_max_num_tasks_
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+ if (x.has_app_id()): self.set_app_id(x.app_id())
+ for i in xrange(x.queue_name_size()): self.add_queue_name(x.queue_name(i))
+ if (x.has_max_num_tasks()): self.set_max_num_tasks(x.max_num_tasks())
+
+ def Equals(self, x):
+ if x is self: return 1
+ if self.has_app_id_ != x.has_app_id_: return 0
+ if self.has_app_id_ and self.app_id_ != x.app_id_: return 0
+ if len(self.queue_name_) != len(x.queue_name_): return 0
+ for e1, e2 in zip(self.queue_name_, x.queue_name_):
+ if e1 != e2: return 0
+ if self.has_max_num_tasks_ != x.has_max_num_tasks_: return 0
+ if self.has_max_num_tasks_ and self.max_num_tasks_ != x.max_num_tasks_: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ if (not self.has_app_id_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: app_id not set.')
+ if (not self.has_max_num_tasks_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: max_num_tasks not set.')
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += self.lengthString(len(self.app_id_))
+ n += 1 * len(self.queue_name_)
+ for i in xrange(len(self.queue_name_)): n += self.lengthString(len(self.queue_name_[i]))
+ n += self.lengthVarInt64(self.max_num_tasks_)
+ return n + 2
+
+ def Clear(self):
+ self.clear_app_id()
+ self.clear_queue_name()
+ self.clear_max_num_tasks()
+
+ def OutputUnchecked(self, out):
+ out.putVarInt32(10)
+ out.putPrefixedString(self.app_id_)
+ for i in xrange(len(self.queue_name_)):
+ out.putVarInt32(18)
+ out.putPrefixedString(self.queue_name_[i])
+ out.putVarInt32(24)
+ out.putVarInt32(self.max_num_tasks_)
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if tt == 10:
+ self.set_app_id(d.getPrefixedString())
+ continue
+ if tt == 18:
+ self.add_queue_name(d.getPrefixedString())
+ continue
+ if tt == 24:
+ self.set_max_num_tasks(d.getVarInt32())
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ if self.has_app_id_: res+=prefix+("app_id: %s\n" % self.DebugFormatString(self.app_id_))
+ cnt=0
+ for e in self.queue_name_:
+ elm=""
+ if printElemNumber: elm="(%d)" % cnt
+ res+=prefix+("queue_name%s: %s\n" % (elm, self.DebugFormatString(e)))
+ cnt+=1
+ if self.has_max_num_tasks_: res+=prefix+("max_num_tasks: %s\n" % self.DebugFormatInt32(self.max_num_tasks_))
+ return res
+
+ kapp_id = 1
+ kqueue_name = 2
+ kmax_num_tasks = 3
+
+ _TEXT = (
+ "ErrorCode",
+ "app_id",
+ "queue_name",
+ "max_num_tasks",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.STRING,
+
+ ProtocolBuffer.Encoder.NUMERIC,
+
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+class TaskQueueFetchQueueStatsResponse_QueueStats(ProtocolBuffer.ProtocolMessage):
+ has_num_tasks_ = 0
+ num_tasks_ = 0
+ has_oldest_eta_usec_ = 0
+ oldest_eta_usec_ = 0
+
+ def __init__(self, contents=None):
+ if contents is not None: self.MergeFromString(contents)
+
+ def num_tasks(self): return self.num_tasks_
+
+ def set_num_tasks(self, x):
+ self.has_num_tasks_ = 1
+ self.num_tasks_ = x
+
+ def clear_num_tasks(self):
+ if self.has_num_tasks_:
+ self.has_num_tasks_ = 0
+ self.num_tasks_ = 0
+
+ def has_num_tasks(self): return self.has_num_tasks_
+
+ def oldest_eta_usec(self): return self.oldest_eta_usec_
+
+ def set_oldest_eta_usec(self, x):
+ self.has_oldest_eta_usec_ = 1
+ self.oldest_eta_usec_ = x
+
+ def clear_oldest_eta_usec(self):
+ if self.has_oldest_eta_usec_:
+ self.has_oldest_eta_usec_ = 0
+ self.oldest_eta_usec_ = 0
+
+ def has_oldest_eta_usec(self): return self.has_oldest_eta_usec_
+
+
+ def MergeFrom(self, x):
+ assert x is not self
+ if (x.has_num_tasks()): self.set_num_tasks(x.num_tasks())
+ if (x.has_oldest_eta_usec()): self.set_oldest_eta_usec(x.oldest_eta_usec())
+
+ def Equals(self, x):
+ if x is self: return 1
+ if self.has_num_tasks_ != x.has_num_tasks_: return 0
+ if self.has_num_tasks_ and self.num_tasks_ != x.num_tasks_: return 0
+ if self.has_oldest_eta_usec_ != x.has_oldest_eta_usec_: return 0
+ if self.has_oldest_eta_usec_ and self.oldest_eta_usec_ != x.oldest_eta_usec_: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ if (not self.has_num_tasks_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: num_tasks not set.')
+ if (not self.has_oldest_eta_usec_):
+ initialized = 0
+ if debug_strs is not None:
+ debug_strs.append('Required field: oldest_eta_usec not set.')
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += self.lengthVarInt64(self.num_tasks_)
+ n += self.lengthVarInt64(self.oldest_eta_usec_)
+ return n + 2
+
+ def Clear(self):
+ self.clear_num_tasks()
+ self.clear_oldest_eta_usec()
+
+ def OutputUnchecked(self, out):
+ out.putVarInt32(16)
+ out.putVarInt32(self.num_tasks_)
+ out.putVarInt32(24)
+ out.putVarInt64(self.oldest_eta_usec_)
+
+ def TryMerge(self, d):
+ while 1:
+ tt = d.getVarInt32()
+ if tt == 12: break
+ if tt == 16:
+ self.set_num_tasks(d.getVarInt32())
+ continue
+ if tt == 24:
+ self.set_oldest_eta_usec(d.getVarInt64())
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ if self.has_num_tasks_: res+=prefix+("num_tasks: %s\n" % self.DebugFormatInt32(self.num_tasks_))
+ if self.has_oldest_eta_usec_: res+=prefix+("oldest_eta_usec: %s\n" % self.DebugFormatInt64(self.oldest_eta_usec_))
+ return res
+
+class TaskQueueFetchQueueStatsResponse(ProtocolBuffer.ProtocolMessage):
+
+ def __init__(self, contents=None):
+ self.queuestats_ = []
+ if contents is not None: self.MergeFromString(contents)
+
+ def queuestats_size(self): return len(self.queuestats_)
+ def queuestats_list(self): return self.queuestats_
+
+ def queuestats(self, i):
+ return self.queuestats_[i]
+
+ def mutable_queuestats(self, i):
+ return self.queuestats_[i]
+
+ def add_queuestats(self):
+ x = TaskQueueFetchQueueStatsResponse_QueueStats()
+ self.queuestats_.append(x)
+ return x
+
+ def clear_queuestats(self):
+ self.queuestats_ = []
+
+ def MergeFrom(self, x):
+ assert x is not self
+ for i in xrange(x.queuestats_size()): self.add_queuestats().CopyFrom(x.queuestats(i))
+
+ def Equals(self, x):
+ if x is self: return 1
+ if len(self.queuestats_) != len(x.queuestats_): return 0
+ for e1, e2 in zip(self.queuestats_, x.queuestats_):
+ if e1 != e2: return 0
+ return 1
+
+ def IsInitialized(self, debug_strs=None):
+ initialized = 1
+ for p in self.queuestats_:
+ if not p.IsInitialized(debug_strs): initialized=0
+ return initialized
+
+ def ByteSize(self):
+ n = 0
+ n += 2 * len(self.queuestats_)
+ for i in xrange(len(self.queuestats_)): n += self.queuestats_[i].ByteSize()
+ return n + 0
+
+ def Clear(self):
+ self.clear_queuestats()
+
+ def OutputUnchecked(self, out):
+ for i in xrange(len(self.queuestats_)):
+ out.putVarInt32(11)
+ self.queuestats_[i].OutputUnchecked(out)
+ out.putVarInt32(12)
+
+ def TryMerge(self, d):
+ while d.avail() > 0:
+ tt = d.getVarInt32()
+ if tt == 11:
+ self.add_queuestats().TryMerge(d)
+ continue
+ if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError
+ d.skipData(tt)
+
+
+ def __str__(self, prefix="", printElemNumber=0):
+ res=""
+ cnt=0
+ for e in self.queuestats_:
+ elm=""
+ if printElemNumber: elm="(%d)" % cnt
+ res+=prefix+("QueueStats%s {\n" % elm)
+ res+=e.__str__(prefix + " ", printElemNumber)
+ res+=prefix+"}\n"
+ cnt+=1
+ return res
+
+ kQueueStatsGroup = 1
+ kQueueStatsnum_tasks = 2
+ kQueueStatsoldest_eta_usec = 3
+
+ _TEXT = (
+ "ErrorCode",
+ "QueueStats",
+ "num_tasks",
+ "oldest_eta_usec",
+ )
+
+ _TYPES = (
+ ProtocolBuffer.Encoder.NUMERIC,
+ ProtocolBuffer.Encoder.STARTGROUP,
+
+ ProtocolBuffer.Encoder.NUMERIC,
+
+ ProtocolBuffer.Encoder.NUMERIC,
+
+ )
+
+ _STYLE = """"""
+ _STYLE_CONTENT_TYPE = """"""
+
+__all__ = ['TaskQueueServiceError','TaskQueueAddRequest','TaskQueueAddRequest_Header','TaskQueueAddResponse','TaskQueueUpdateQueueRequest','TaskQueueUpdateQueueResponse','TaskQueueFetchQueuesRequest','TaskQueueFetchQueuesResponse','TaskQueueFetchQueuesResponse_Queue','TaskQueueFetchQueueStatsRequest','TaskQueueFetchQueueStatsResponse','TaskQueueFetchQueueStatsResponse_QueueStats']