diff options
Diffstat (limited to 'Testcases/cfgm_common/uve/virtual_machine/ttypes.py')
| -rw-r--r-- | Testcases/cfgm_common/uve/virtual_machine/ttypes.py | 517 |
1 files changed, 517 insertions, 0 deletions
diff --git a/Testcases/cfgm_common/uve/virtual_machine/ttypes.py b/Testcases/cfgm_common/uve/virtual_machine/ttypes.py new file mode 100644 index 0000000..d2a95f0 --- /dev/null +++ b/Testcases/cfgm_common/uve/virtual_machine/ttypes.py @@ -0,0 +1,517 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +from pysandesh.Thrift import TType, TMessageType, TException + +from pysandesh.transport import TTransport +from pysandesh.protocol import TBinaryProtocol, TProtocol +try: + from pysandesh.protocol import fastbinary +except: + fastbinary = None + +import cStringIO +import uuid +import bottle +from pysandesh import sandesh_base +from pysandesh.sandesh_http import SandeshHttp +from pysandesh.sandesh_uve import SandeshUVETypeMaps +from pysandesh.util import UTCTimestampUsec, UTCTimestampUsecToString +from pysandesh.gen_py.sandesh.constants import * + + + +class VmInterfaceConfig(object): + """ + Attributes: + - name + - ip_address + - virtual_network + - floating_ips + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.STRING, 'ip_address', None, None, ), # 2 + (3, TType.STRING, 'virtual_network', None, None, ), # 3 + (4, TType.LIST, 'floating_ips', (TType.STRING,None), None, ), # 4 + ) + + def __init__(self, name=None, ip_address=None, virtual_network=None, floating_ips=None,): + self.name = name + self.ip_address = ip_address + self.virtual_network = virtual_network + self.floating_ips = floating_ips + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.name) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + (length, self.ip_address) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + (length, self.virtual_network) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.LIST: + self.floating_ips = [] + (length, _etype3, _size0) = iprot.readListBegin() + read_cnt += length + for _i4 in xrange(_size0): + read_cnt += iprot.readContainerElementBegin() + (length, _elem5) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + self.floating_ips.append(_elem5) + read_cnt += iprot.readContainerElementEnd() + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('VmInterfaceConfig') < 0: return -1 + if self.name is not None: + annotations = {} + if oprot.writeFieldBegin('name', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.name) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.ip_address is not None: + annotations = {} + if oprot.writeFieldBegin('ip_address', TType.STRING, 2, annotations) < 0: return -1 + if oprot.writeString(self.ip_address) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.virtual_network is not None: + annotations = {} + annotations['aggtype'] = 'listkey' + if oprot.writeFieldBegin('virtual_network', TType.STRING, 3, annotations) < 0: return -1 + if oprot.writeString(self.virtual_network) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.floating_ips is not None: + annotations = {} + if oprot.writeFieldBegin('floating_ips', TType.LIST, 4, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRING, len(self.floating_ips)) < 0: return -1 + for iter6 in self.floating_ips: + if oprot.writeContainerElementBegin() < 0: return -1 + if oprot.writeString(iter6) < 0: return -1 + if oprot.writeContainerElementEnd() < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.name is not None: + log_str.write('name = ') + log_str.write(self.name) + log_str.write(' ') + if self.ip_address is not None: + log_str.write('ip_address = ') + log_str.write(self.ip_address) + log_str.write(' ') + if self.virtual_network is not None: + log_str.write('virtual_network = ') + log_str.write(self.virtual_network) + log_str.write(' ') + if self.floating_ips is not None: + log_str.write('floating_ips = ') + log_str.write('[ ') + for iter7 in self.floating_ips: + log_str.write(iter7) + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class UveVirtualMachineConfig(object): + """ + Attributes: + - name + - deleted + - attached_groups + - interface_list + - vrouter + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.BOOL, 'deleted', None, None, ), # 2 + (3, TType.LIST, 'attached_groups', (TType.STRING,None), None, ), # 3 + (4, TType.LIST, 'interface_list', (TType.STRUCT,(VmInterfaceConfig, VmInterfaceConfig.thrift_spec)), None, ), # 4 + (5, TType.STRING, 'vrouter', None, None, ), # 5 + ) + + def __init__(self, name=None, deleted=None, attached_groups=None, interface_list=None, vrouter=None,): + self.name = name + self.deleted = deleted + self.attached_groups = attached_groups + self.interface_list = interface_list + self.vrouter = vrouter + self._table = 'ObjectVMTable' + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.name) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.BOOL: + (length, self.deleted) = iprot.readBool(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.LIST: + self.attached_groups = [] + (length, _etype11, _size8) = iprot.readListBegin() + read_cnt += length + for _i12 in xrange(_size8): + read_cnt += iprot.readContainerElementBegin() + (length, _elem13) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + self.attached_groups.append(_elem13) + read_cnt += iprot.readContainerElementEnd() + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.LIST: + self.interface_list = [] + (length, _etype17, _size14) = iprot.readListBegin() + read_cnt += length + for _i18 in xrange(_size14): + _elem19 = VmInterfaceConfig() + read_cnt += _elem19.read(iprot) + self.interface_list.append(_elem19) + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + (length, self.vrouter) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('UveVirtualMachineConfig') < 0: return -1 + if self.name is not None: + annotations = {} + if self._table is None or self._table is '': return -1 + annotations['key'] = self._table + if oprot.writeFieldBegin('name', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.name) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.deleted is not None: + annotations = {} + if oprot.writeFieldBegin('deleted', TType.BOOL, 2, annotations) < 0: return -1 + if oprot.writeBool(self.deleted) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.attached_groups is not None: + annotations = {} + if oprot.writeFieldBegin('attached_groups', TType.LIST, 3, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRING, len(self.attached_groups)) < 0: return -1 + for iter20 in self.attached_groups: + if oprot.writeContainerElementBegin() < 0: return -1 + if oprot.writeString(iter20) < 0: return -1 + if oprot.writeContainerElementEnd() < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.interface_list is not None: + annotations = {} + if oprot.writeFieldBegin('interface_list', TType.LIST, 4, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRUCT, len(self.interface_list)) < 0: return -1 + for iter21 in self.interface_list: + if iter21.write(oprot) < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.vrouter is not None: + annotations = {} + if oprot.writeFieldBegin('vrouter', TType.STRING, 5, annotations) < 0: return -1 + if oprot.writeString(self.vrouter) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.name is not None: + log_str.write('name = ') + log_str.write(self.name) + log_str.write(' ') + if self.deleted is not None: + log_str.write('deleted = ') + if self.deleted: + log_str.write('True') + else: + log_str.write('False') + log_str.write(' ') + if self.attached_groups is not None: + log_str.write('attached_groups = ') + log_str.write('[ ') + for iter22 in self.attached_groups: + log_str.write(iter22) + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.interface_list is not None: + log_str.write('interface_list = ') + log_str.write('[ ') + for iter23 in self.interface_list: + log_str.write('<< ') + log_str.write(iter23.log()) + log_str.write('>>') + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.vrouter is not None: + log_str.write('vrouter = ') + log_str.write(self.vrouter) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class UveVirtualMachineConfigTrace(sandesh_base.SandeshUVE): + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'data', (UveVirtualMachineConfig, UveVirtualMachineConfig.thrift_spec), None, ), # 1 + ) + + def __init__(self, data=None, table=None, sandesh=sandesh_base.sandesh_global): + sandesh_base.SandeshUVE.__init__(self) + self.data = data + self._scope = sandesh.scope() + self._module = sandesh.module() + self._source = sandesh.source_id() + self._node_type = sandesh.node_type() + self._instance_id = sandesh.instance_id() + self._seqnum = 0 + self._timestamp = UTCTimestampUsec() + self._versionsig = 4221818251 + self._hints = 0 | SANDESH_KEY_HINT + if table is not None: + self.data._table = table + + def update_uve(self, tdata): + if self.data.name is not None: + tdata.name = self.data.name + if self.data.deleted is not None: + tdata.deleted = self.data.deleted + if self.data.attached_groups is not None: + tdata.attached_groups = self.data.attached_groups + if self.data.interface_list is not None: + tdata.interface_list = self.data.interface_list + if self.data.vrouter is not None: + tdata.vrouter = self.data.vrouter + return tdata + + def log(self, trace=False): + log_str = cStringIO.StringIO() + if trace: + log_str.write(str(self._timestamp)) + log_str.write(' ') + log_str.write('UveVirtualMachineConfigTrace: ') + if self.data is not None: + log_str.write('data = ') + log_str.write('<< ') + log_str.write(self.data.log()) + log_str.write('>>') + log_str.write(' ') + return log_str.getvalue() + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return -1 + read_cnt = 0 + (length, sandesh_name) = iprot.readSandeshBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.data = UveVirtualMachineConfig() + read_cnt += self.data.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readSandeshEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeSandeshBegin('UveVirtualMachineConfigTrace') < 0: return -1 + if self.data is not None: + annotations = {} + if oprot.writeFieldBegin('data', TType.STRUCT, 1, annotations) < 0: return -1 + if self.data.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeSandeshEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def compare(self, other): + if not isinstance(other, self.__class__): + return False + if self.data != other.data: + return False + return True + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + + +_SANDESH_REQUEST_LIST = [ +] + + +_SANDESH_UVE_LIST = [ +'UveVirtualMachineConfigTrace', +] + + +_SANDESH_UVE_DATA_LIST = [ +'UveVirtualMachineConfig', +] + + +_SANDESH_ALARM_LIST = [ +] + + +_SANDESH_ALARM_DATA_LIST = [ +] |