You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ma...@apache.org on 2017/08/04 20:10:43 UTC
[26/51] [partial] airavata git commit: AIRAVATA-2505 Upgrade Airavata
to Thrift 0.10.0
http://git-wip-us.apache.org/repos/asf/airavata/blob/9d165bd8/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/credential_store_data_models/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/credential_store_data_models/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/credential_store_data_models/ttypes.py
index be5e93d..7d6cadf 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/credential_store_data_models/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/credential_store_data_models/ttypes.py
@@ -1,786 +1,729 @@
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-class CredentialOwnerType:
- GATEWAY = 0
- USER = 1
-
- _VALUES_TO_NAMES = {
- 0: "GATEWAY",
- 1: "USER",
- }
-
- _NAMES_TO_VALUES = {
- "GATEWAY": 0,
- "USER": 1,
- }
-
-class SummaryType:
- """
- Data Types supported in Airavata. The primitive data types
-
- """
- SSH = 0
- PASSWD = 1
- CERT = 2
-
- _VALUES_TO_NAMES = {
- 0: "SSH",
- 1: "PASSWD",
- 2: "CERT",
- }
-
- _NAMES_TO_VALUES = {
- "SSH": 0,
- "PASSWD": 1,
- "CERT": 2,
- }
-
-
-class SSHCredential:
- """
- Attributes:
- - gatewayId
- - username
- - passphrase
- - publicKey
- - privateKey
- - persistedTime
- - token
- - description
- - credentialOwnerType
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'gatewayId', None, None, ), # 1
- (2, TType.STRING, 'username', None, None, ), # 2
- (3, TType.STRING, 'passphrase', None, None, ), # 3
- (4, TType.STRING, 'publicKey', None, None, ), # 4
- (5, TType.STRING, 'privateKey', None, None, ), # 5
- (6, TType.I64, 'persistedTime', None, None, ), # 6
- (7, TType.STRING, 'token', None, None, ), # 7
- (8, TType.STRING, 'description', None, None, ), # 8
- (9, TType.I32, 'credentialOwnerType', None, 0, ), # 9
- )
-
- def __init__(self, gatewayId=None, username=None, passphrase=None, publicKey=None, privateKey=None, persistedTime=None, token=None, description=None, credentialOwnerType=thrift_spec[9][4],):
- self.gatewayId = gatewayId
- self.username = username
- self.passphrase = passphrase
- self.publicKey = publicKey
- self.privateKey = privateKey
- self.persistedTime = persistedTime
- self.token = token
- self.description = description
- self.credentialOwnerType = credentialOwnerType
-
- 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
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.gatewayId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.username = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.passphrase = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.publicKey = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.privateKey = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I64:
- self.persistedTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.token = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRING:
- self.description = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.I32:
- self.credentialOwnerType = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- 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
- oprot.writeStructBegin('SSHCredential')
- if self.gatewayId is not None:
- oprot.writeFieldBegin('gatewayId', TType.STRING, 1)
- oprot.writeString(self.gatewayId)
- oprot.writeFieldEnd()
- if self.username is not None:
- oprot.writeFieldBegin('username', TType.STRING, 2)
- oprot.writeString(self.username)
- oprot.writeFieldEnd()
- if self.passphrase is not None:
- oprot.writeFieldBegin('passphrase', TType.STRING, 3)
- oprot.writeString(self.passphrase)
- oprot.writeFieldEnd()
- if self.publicKey is not None:
- oprot.writeFieldBegin('publicKey', TType.STRING, 4)
- oprot.writeString(self.publicKey)
- oprot.writeFieldEnd()
- if self.privateKey is not None:
- oprot.writeFieldBegin('privateKey', TType.STRING, 5)
- oprot.writeString(self.privateKey)
- oprot.writeFieldEnd()
- if self.persistedTime is not None:
- oprot.writeFieldBegin('persistedTime', TType.I64, 6)
- oprot.writeI64(self.persistedTime)
- oprot.writeFieldEnd()
- if self.token is not None:
- oprot.writeFieldBegin('token', TType.STRING, 7)
- oprot.writeString(self.token)
- oprot.writeFieldEnd()
- if self.description is not None:
- oprot.writeFieldBegin('description', TType.STRING, 8)
- oprot.writeString(self.description)
- oprot.writeFieldEnd()
- if self.credentialOwnerType is not None:
- oprot.writeFieldBegin('credentialOwnerType', TType.I32, 9)
- oprot.writeI32(self.credentialOwnerType)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.gatewayId is None:
- raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
- if self.username is None:
- raise TProtocol.TProtocolException(message='Required field username is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.gatewayId)
- value = (value * 31) ^ hash(self.username)
- value = (value * 31) ^ hash(self.passphrase)
- value = (value * 31) ^ hash(self.publicKey)
- value = (value * 31) ^ hash(self.privateKey)
- value = (value * 31) ^ hash(self.persistedTime)
- value = (value * 31) ^ hash(self.token)
- value = (value * 31) ^ hash(self.description)
- value = (value * 31) ^ hash(self.credentialOwnerType)
- return value
-
- 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 CredentialSummary:
- """
- Attributes:
- - type
- - gatewayId
- - username
- - publicKey
- - persistedTime
- - token
- - description
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'type', None, None, ), # 1
- (2, TType.STRING, 'gatewayId', None, None, ), # 2
- (3, TType.STRING, 'username', None, None, ), # 3
- (4, TType.STRING, 'publicKey', None, None, ), # 4
- (5, TType.I64, 'persistedTime', None, None, ), # 5
- (6, TType.STRING, 'token', None, None, ), # 6
- (7, TType.STRING, 'description', None, None, ), # 7
- )
-
- def __init__(self, type=None, gatewayId=None, username=None, publicKey=None, persistedTime=None, token=None, description=None,):
- self.type = type
- self.gatewayId = gatewayId
- self.username = username
- self.publicKey = publicKey
- self.persistedTime = persistedTime
- self.token = token
- self.description = description
-
- 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
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.I32:
- self.type = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.gatewayId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.username = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.publicKey = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I64:
- self.persistedTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.token = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.description = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- 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
- oprot.writeStructBegin('CredentialSummary')
- if self.type is not None:
- oprot.writeFieldBegin('type', TType.I32, 1)
- oprot.writeI32(self.type)
- oprot.writeFieldEnd()
- if self.gatewayId is not None:
- oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
- oprot.writeString(self.gatewayId)
- oprot.writeFieldEnd()
- if self.username is not None:
- oprot.writeFieldBegin('username', TType.STRING, 3)
- oprot.writeString(self.username)
- oprot.writeFieldEnd()
- if self.publicKey is not None:
- oprot.writeFieldBegin('publicKey', TType.STRING, 4)
- oprot.writeString(self.publicKey)
- oprot.writeFieldEnd()
- if self.persistedTime is not None:
- oprot.writeFieldBegin('persistedTime', TType.I64, 5)
- oprot.writeI64(self.persistedTime)
- oprot.writeFieldEnd()
- if self.token is not None:
- oprot.writeFieldBegin('token', TType.STRING, 6)
- oprot.writeString(self.token)
- oprot.writeFieldEnd()
- if self.description is not None:
- oprot.writeFieldBegin('description', TType.STRING, 7)
- oprot.writeString(self.description)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.type is None:
- raise TProtocol.TProtocolException(message='Required field type is unset!')
- if self.gatewayId is None:
- raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
- if self.username is None:
- raise TProtocol.TProtocolException(message='Required field username is unset!')
- if self.token is None:
- raise TProtocol.TProtocolException(message='Required field token is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.type)
- value = (value * 31) ^ hash(self.gatewayId)
- value = (value * 31) ^ hash(self.username)
- value = (value * 31) ^ hash(self.publicKey)
- value = (value * 31) ^ hash(self.persistedTime)
- value = (value * 31) ^ hash(self.token)
- value = (value * 31) ^ hash(self.description)
- return value
-
- 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 CommunityUser:
- """
- Attributes:
- - gatewayName
- - username
- - userEmail
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'gatewayName', None, None, ), # 1
- (2, TType.STRING, 'username', None, None, ), # 2
- (3, TType.STRING, 'userEmail', None, None, ), # 3
- )
-
- def __init__(self, gatewayName=None, username=None, userEmail=None,):
- self.gatewayName = gatewayName
- self.username = username
- self.userEmail = userEmail
-
- 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
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.gatewayName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.username = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.userEmail = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- 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
- oprot.writeStructBegin('CommunityUser')
- if self.gatewayName is not None:
- oprot.writeFieldBegin('gatewayName', TType.STRING, 1)
- oprot.writeString(self.gatewayName)
- oprot.writeFieldEnd()
- if self.username is not None:
- oprot.writeFieldBegin('username', TType.STRING, 2)
- oprot.writeString(self.username)
- oprot.writeFieldEnd()
- if self.userEmail is not None:
- oprot.writeFieldBegin('userEmail', TType.STRING, 3)
- oprot.writeString(self.userEmail)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.gatewayName is None:
- raise TProtocol.TProtocolException(message='Required field gatewayName is unset!')
- if self.username is None:
- raise TProtocol.TProtocolException(message='Required field username is unset!')
- if self.userEmail is None:
- raise TProtocol.TProtocolException(message='Required field userEmail is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.gatewayName)
- value = (value * 31) ^ hash(self.username)
- value = (value * 31) ^ hash(self.userEmail)
- return value
-
- 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 CertificateCredential:
- """
- Attributes:
- - communityUser
- - x509Cert
- - notAfter
- - privateKey
- - lifeTime
- - notBefore
- - persistedTime
- - token
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'communityUser', (CommunityUser, CommunityUser.thrift_spec), None, ), # 1
- (2, TType.STRING, 'x509Cert', None, None, ), # 2
- (3, TType.STRING, 'notAfter', None, None, ), # 3
- (4, TType.STRING, 'privateKey', None, None, ), # 4
- (5, TType.I64, 'lifeTime', None, None, ), # 5
- (6, TType.STRING, 'notBefore', None, None, ), # 6
- (7, TType.I64, 'persistedTime', None, None, ), # 7
- (8, TType.STRING, 'token', None, None, ), # 8
- )
-
- def __init__(self, communityUser=None, x509Cert=None, notAfter=None, privateKey=None, lifeTime=None, notBefore=None, persistedTime=None, token=None,):
- self.communityUser = communityUser
- self.x509Cert = x509Cert
- self.notAfter = notAfter
- self.privateKey = privateKey
- self.lifeTime = lifeTime
- self.notBefore = notBefore
- self.persistedTime = persistedTime
- self.token = token
-
- 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
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.communityUser = CommunityUser()
- self.communityUser.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.x509Cert = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.notAfter = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.privateKey = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I64:
- self.lifeTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.notBefore = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I64:
- self.persistedTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.STRING:
- self.token = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- 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
- oprot.writeStructBegin('CertificateCredential')
- if self.communityUser is not None:
- oprot.writeFieldBegin('communityUser', TType.STRUCT, 1)
- self.communityUser.write(oprot)
- oprot.writeFieldEnd()
- if self.x509Cert is not None:
- oprot.writeFieldBegin('x509Cert', TType.STRING, 2)
- oprot.writeString(self.x509Cert)
- oprot.writeFieldEnd()
- if self.notAfter is not None:
- oprot.writeFieldBegin('notAfter', TType.STRING, 3)
- oprot.writeString(self.notAfter)
- oprot.writeFieldEnd()
- if self.privateKey is not None:
- oprot.writeFieldBegin('privateKey', TType.STRING, 4)
- oprot.writeString(self.privateKey)
- oprot.writeFieldEnd()
- if self.lifeTime is not None:
- oprot.writeFieldBegin('lifeTime', TType.I64, 5)
- oprot.writeI64(self.lifeTime)
- oprot.writeFieldEnd()
- if self.notBefore is not None:
- oprot.writeFieldBegin('notBefore', TType.STRING, 6)
- oprot.writeString(self.notBefore)
- oprot.writeFieldEnd()
- if self.persistedTime is not None:
- oprot.writeFieldBegin('persistedTime', TType.I64, 7)
- oprot.writeI64(self.persistedTime)
- oprot.writeFieldEnd()
- if self.token is not None:
- oprot.writeFieldBegin('token', TType.STRING, 8)
- oprot.writeString(self.token)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.communityUser is None:
- raise TProtocol.TProtocolException(message='Required field communityUser is unset!')
- if self.x509Cert is None:
- raise TProtocol.TProtocolException(message='Required field x509Cert is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.communityUser)
- value = (value * 31) ^ hash(self.x509Cert)
- value = (value * 31) ^ hash(self.notAfter)
- value = (value * 31) ^ hash(self.privateKey)
- value = (value * 31) ^ hash(self.lifeTime)
- value = (value * 31) ^ hash(self.notBefore)
- value = (value * 31) ^ hash(self.persistedTime)
- value = (value * 31) ^ hash(self.token)
- return value
-
- 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 PasswordCredential:
- """
- Attributes:
- - gatewayId
- - portalUserName
- - loginUserName
- - password
- - description
- - persistedTime
- - token
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'gatewayId', None, None, ), # 1
- (2, TType.STRING, 'portalUserName', None, None, ), # 2
- (3, TType.STRING, 'loginUserName', None, None, ), # 3
- (4, TType.STRING, 'password', None, None, ), # 4
- (5, TType.STRING, 'description', None, None, ), # 5
- (6, TType.I64, 'persistedTime', None, None, ), # 6
- (7, TType.STRING, 'token', None, None, ), # 7
- )
-
- def __init__(self, gatewayId=None, portalUserName=None, loginUserName=None, password=None, description=None, persistedTime=None, token=None,):
- self.gatewayId = gatewayId
- self.portalUserName = portalUserName
- self.loginUserName = loginUserName
- self.password = password
- self.description = description
- self.persistedTime = persistedTime
- self.token = token
-
- 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
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.gatewayId = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.portalUserName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.loginUserName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.password = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.description = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I64:
- self.persistedTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.STRING:
- self.token = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- 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
- oprot.writeStructBegin('PasswordCredential')
- if self.gatewayId is not None:
- oprot.writeFieldBegin('gatewayId', TType.STRING, 1)
- oprot.writeString(self.gatewayId)
- oprot.writeFieldEnd()
- if self.portalUserName is not None:
- oprot.writeFieldBegin('portalUserName', TType.STRING, 2)
- oprot.writeString(self.portalUserName)
- oprot.writeFieldEnd()
- if self.loginUserName is not None:
- oprot.writeFieldBegin('loginUserName', TType.STRING, 3)
- oprot.writeString(self.loginUserName)
- oprot.writeFieldEnd()
- if self.password is not None:
- oprot.writeFieldBegin('password', TType.STRING, 4)
- oprot.writeString(self.password)
- oprot.writeFieldEnd()
- if self.description is not None:
- oprot.writeFieldBegin('description', TType.STRING, 5)
- oprot.writeString(self.description)
- oprot.writeFieldEnd()
- if self.persistedTime is not None:
- oprot.writeFieldBegin('persistedTime', TType.I64, 6)
- oprot.writeI64(self.persistedTime)
- oprot.writeFieldEnd()
- if self.token is not None:
- oprot.writeFieldBegin('token', TType.STRING, 7)
- oprot.writeString(self.token)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.gatewayId is None:
- raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
- if self.portalUserName is None:
- raise TProtocol.TProtocolException(message='Required field portalUserName is unset!')
- if self.loginUserName is None:
- raise TProtocol.TProtocolException(message='Required field loginUserName is unset!')
- if self.password is None:
- raise TProtocol.TProtocolException(message='Required field password is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.gatewayId)
- value = (value * 31) ^ hash(self.portalUserName)
- value = (value * 31) ^ hash(self.loginUserName)
- value = (value * 31) ^ hash(self.password)
- value = (value * 31) ^ hash(self.description)
- value = (value * 31) ^ hash(self.persistedTime)
- value = (value * 31) ^ hash(self.token)
- return value
-
- 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 CredentialOwnerType(object):
+ GATEWAY = 0
+ USER = 1
+
+ _VALUES_TO_NAMES = {
+ 0: "GATEWAY",
+ 1: "USER",
+ }
+
+ _NAMES_TO_VALUES = {
+ "GATEWAY": 0,
+ "USER": 1,
+ }
+
+
+class SummaryType(object):
+ """
+ Data Types supported in Airavata. The primitive data types
+
+ """
+ SSH = 0
+ PASSWD = 1
+ CERT = 2
+
+ _VALUES_TO_NAMES = {
+ 0: "SSH",
+ 1: "PASSWD",
+ 2: "CERT",
+ }
+
+ _NAMES_TO_VALUES = {
+ "SSH": 0,
+ "PASSWD": 1,
+ "CERT": 2,
+ }
+
+
+class SSHCredential(object):
+ """
+ Attributes:
+ - gatewayId
+ - username
+ - passphrase
+ - publicKey
+ - privateKey
+ - persistedTime
+ - token
+ - description
+ - credentialOwnerType
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'gatewayId', 'UTF8', None, ), # 1
+ (2, TType.STRING, 'username', 'UTF8', None, ), # 2
+ (3, TType.STRING, 'passphrase', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'publicKey', 'UTF8', None, ), # 4
+ (5, TType.STRING, 'privateKey', 'UTF8', None, ), # 5
+ (6, TType.I64, 'persistedTime', None, None, ), # 6
+ (7, TType.STRING, 'token', 'UTF8', None, ), # 7
+ (8, TType.STRING, 'description', 'UTF8', None, ), # 8
+ (9, TType.I32, 'credentialOwnerType', None, 0, ), # 9
+ )
+
+ def __init__(self, gatewayId=None, username=None, passphrase=None, publicKey=None, privateKey=None, persistedTime=None, token=None, description=None, credentialOwnerType=thrift_spec[9][4],):
+ self.gatewayId = gatewayId
+ self.username = username
+ self.passphrase = passphrase
+ self.publicKey = publicKey
+ self.privateKey = privateKey
+ self.persistedTime = persistedTime
+ self.token = token
+ self.description = description
+ self.credentialOwnerType = credentialOwnerType
+
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.gatewayId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.username = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.passphrase = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.publicKey = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.privateKey = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.I64:
+ self.persistedTime = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.token = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.description = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.I32:
+ self.credentialOwnerType = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot._fast_encode is not None and self.thrift_spec is not None:
+ oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('SSHCredential')
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 1)
+ oprot.writeString(self.gatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayId)
+ oprot.writeFieldEnd()
+ if self.username is not None:
+ oprot.writeFieldBegin('username', TType.STRING, 2)
+ oprot.writeString(self.username.encode('utf-8') if sys.version_info[0] == 2 else self.username)
+ oprot.writeFieldEnd()
+ if self.passphrase is not None:
+ oprot.writeFieldBegin('passphrase', TType.STRING, 3)
+ oprot.writeString(self.passphrase.encode('utf-8') if sys.version_info[0] == 2 else self.passphrase)
+ oprot.writeFieldEnd()
+ if self.publicKey is not None:
+ oprot.writeFieldBegin('publicKey', TType.STRING, 4)
+ oprot.writeString(self.publicKey.encode('utf-8') if sys.version_info[0] == 2 else self.publicKey)
+ oprot.writeFieldEnd()
+ if self.privateKey is not None:
+ oprot.writeFieldBegin('privateKey', TType.STRING, 5)
+ oprot.writeString(self.privateKey.encode('utf-8') if sys.version_info[0] == 2 else self.privateKey)
+ oprot.writeFieldEnd()
+ if self.persistedTime is not None:
+ oprot.writeFieldBegin('persistedTime', TType.I64, 6)
+ oprot.writeI64(self.persistedTime)
+ oprot.writeFieldEnd()
+ if self.token is not None:
+ oprot.writeFieldBegin('token', TType.STRING, 7)
+ oprot.writeString(self.token.encode('utf-8') if sys.version_info[0] == 2 else self.token)
+ oprot.writeFieldEnd()
+ if self.description is not None:
+ oprot.writeFieldBegin('description', TType.STRING, 8)
+ oprot.writeString(self.description.encode('utf-8') if sys.version_info[0] == 2 else self.description)
+ oprot.writeFieldEnd()
+ if self.credentialOwnerType is not None:
+ oprot.writeFieldBegin('credentialOwnerType', TType.I32, 9)
+ oprot.writeI32(self.credentialOwnerType)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.gatewayId is None:
+ raise TProtocolException(message='Required field gatewayId is unset!')
+ if self.username is None:
+ raise TProtocolException(message='Required field username is unset!')
+ return
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.items()]
+ 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 CredentialSummary(object):
+ """
+ Attributes:
+ - type
+ - gatewayId
+ - username
+ - publicKey
+ - persistedTime
+ - token
+ - description
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'type', None, None, ), # 1
+ (2, TType.STRING, 'gatewayId', 'UTF8', None, ), # 2
+ (3, TType.STRING, 'username', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'publicKey', 'UTF8', None, ), # 4
+ (5, TType.I64, 'persistedTime', None, None, ), # 5
+ (6, TType.STRING, 'token', 'UTF8', None, ), # 6
+ (7, TType.STRING, 'description', 'UTF8', None, ), # 7
+ )
+
+ def __init__(self, type=None, gatewayId=None, username=None, publicKey=None, persistedTime=None, token=None, description=None,):
+ self.type = type
+ self.gatewayId = gatewayId
+ self.username = username
+ self.publicKey = publicKey
+ self.persistedTime = persistedTime
+ self.token = token
+ self.description = description
+
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.I32:
+ self.type = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.gatewayId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.username = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.publicKey = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I64:
+ self.persistedTime = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.token = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.description = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot._fast_encode is not None and self.thrift_spec is not None:
+ oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('CredentialSummary')
+ if self.type is not None:
+ oprot.writeFieldBegin('type', TType.I32, 1)
+ oprot.writeI32(self.type)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
+ oprot.writeString(self.gatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayId)
+ oprot.writeFieldEnd()
+ if self.username is not None:
+ oprot.writeFieldBegin('username', TType.STRING, 3)
+ oprot.writeString(self.username.encode('utf-8') if sys.version_info[0] == 2 else self.username)
+ oprot.writeFieldEnd()
+ if self.publicKey is not None:
+ oprot.writeFieldBegin('publicKey', TType.STRING, 4)
+ oprot.writeString(self.publicKey.encode('utf-8') if sys.version_info[0] == 2 else self.publicKey)
+ oprot.writeFieldEnd()
+ if self.persistedTime is not None:
+ oprot.writeFieldBegin('persistedTime', TType.I64, 5)
+ oprot.writeI64(self.persistedTime)
+ oprot.writeFieldEnd()
+ if self.token is not None:
+ oprot.writeFieldBegin('token', TType.STRING, 6)
+ oprot.writeString(self.token.encode('utf-8') if sys.version_info[0] == 2 else self.token)
+ oprot.writeFieldEnd()
+ if self.description is not None:
+ oprot.writeFieldBegin('description', TType.STRING, 7)
+ oprot.writeString(self.description.encode('utf-8') if sys.version_info[0] == 2 else self.description)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.type is None:
+ raise TProtocolException(message='Required field type is unset!')
+ if self.gatewayId is None:
+ raise TProtocolException(message='Required field gatewayId is unset!')
+ if self.username is None:
+ raise TProtocolException(message='Required field username is unset!')
+ if self.token is None:
+ raise TProtocolException(message='Required field token is unset!')
+ return
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.items()]
+ 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 CommunityUser(object):
+ """
+ Attributes:
+ - gatewayName
+ - username
+ - userEmail
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'gatewayName', 'UTF8', None, ), # 1
+ (2, TType.STRING, 'username', 'UTF8', None, ), # 2
+ (3, TType.STRING, 'userEmail', 'UTF8', None, ), # 3
+ )
+
+ def __init__(self, gatewayName=None, username=None, userEmail=None,):
+ self.gatewayName = gatewayName
+ self.username = username
+ self.userEmail = userEmail
+
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.gatewayName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.username = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.userEmail = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot._fast_encode is not None and self.thrift_spec is not None:
+ oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('CommunityUser')
+ if self.gatewayName is not None:
+ oprot.writeFieldBegin('gatewayName', TType.STRING, 1)
+ oprot.writeString(self.gatewayName.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayName)
+ oprot.writeFieldEnd()
+ if self.username is not None:
+ oprot.writeFieldBegin('username', TType.STRING, 2)
+ oprot.writeString(self.username.encode('utf-8') if sys.version_info[0] == 2 else self.username)
+ oprot.writeFieldEnd()
+ if self.userEmail is not None:
+ oprot.writeFieldBegin('userEmail', TType.STRING, 3)
+ oprot.writeString(self.userEmail.encode('utf-8') if sys.version_info[0] == 2 else self.userEmail)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.gatewayName is None:
+ raise TProtocolException(message='Required field gatewayName is unset!')
+ if self.username is None:
+ raise TProtocolException(message='Required field username is unset!')
+ if self.userEmail is None:
+ raise TProtocolException(message='Required field userEmail is unset!')
+ return
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.items()]
+ 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 CertificateCredential(object):
+ """
+ Attributes:
+ - communityUser
+ - x509Cert
+ - notAfter
+ - privateKey
+ - lifeTime
+ - notBefore
+ - persistedTime
+ - token
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'communityUser', (CommunityUser, CommunityUser.thrift_spec), None, ), # 1
+ (2, TType.STRING, 'x509Cert', 'UTF8', None, ), # 2
+ (3, TType.STRING, 'notAfter', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'privateKey', 'UTF8', None, ), # 4
+ (5, TType.I64, 'lifeTime', None, None, ), # 5
+ (6, TType.STRING, 'notBefore', 'UTF8', None, ), # 6
+ (7, TType.I64, 'persistedTime', None, None, ), # 7
+ (8, TType.STRING, 'token', 'UTF8', None, ), # 8
+ )
+
+ def __init__(self, communityUser=None, x509Cert=None, notAfter=None, privateKey=None, lifeTime=None, notBefore=None, persistedTime=None, token=None,):
+ self.communityUser = communityUser
+ self.x509Cert = x509Cert
+ self.notAfter = notAfter
+ self.privateKey = privateKey
+ self.lifeTime = lifeTime
+ self.notBefore = notBefore
+ self.persistedTime = persistedTime
+ self.token = token
+
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.communityUser = CommunityUser()
+ self.communityUser.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.x509Cert = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.notAfter = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.privateKey = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I64:
+ self.lifeTime = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.notBefore = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.I64:
+ self.persistedTime = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.token = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot._fast_encode is not None and self.thrift_spec is not None:
+ oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('CertificateCredential')
+ if self.communityUser is not None:
+ oprot.writeFieldBegin('communityUser', TType.STRUCT, 1)
+ self.communityUser.write(oprot)
+ oprot.writeFieldEnd()
+ if self.x509Cert is not None:
+ oprot.writeFieldBegin('x509Cert', TType.STRING, 2)
+ oprot.writeString(self.x509Cert.encode('utf-8') if sys.version_info[0] == 2 else self.x509Cert)
+ oprot.writeFieldEnd()
+ if self.notAfter is not None:
+ oprot.writeFieldBegin('notAfter', TType.STRING, 3)
+ oprot.writeString(self.notAfter.encode('utf-8') if sys.version_info[0] == 2 else self.notAfter)
+ oprot.writeFieldEnd()
+ if self.privateKey is not None:
+ oprot.writeFieldBegin('privateKey', TType.STRING, 4)
+ oprot.writeString(self.privateKey.encode('utf-8') if sys.version_info[0] == 2 else self.privateKey)
+ oprot.writeFieldEnd()
+ if self.lifeTime is not None:
+ oprot.writeFieldBegin('lifeTime', TType.I64, 5)
+ oprot.writeI64(self.lifeTime)
+ oprot.writeFieldEnd()
+ if self.notBefore is not None:
+ oprot.writeFieldBegin('notBefore', TType.STRING, 6)
+ oprot.writeString(self.notBefore.encode('utf-8') if sys.version_info[0] == 2 else self.notBefore)
+ oprot.writeFieldEnd()
+ if self.persistedTime is not None:
+ oprot.writeFieldBegin('persistedTime', TType.I64, 7)
+ oprot.writeI64(self.persistedTime)
+ oprot.writeFieldEnd()
+ if self.token is not None:
+ oprot.writeFieldBegin('token', TType.STRING, 8)
+ oprot.writeString(self.token.encode('utf-8') if sys.version_info[0] == 2 else self.token)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.communityUser is None:
+ raise TProtocolException(message='Required field communityUser is unset!')
+ if self.x509Cert is None:
+ raise TProtocolException(message='Required field x509Cert is unset!')
+ return
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.items()]
+ 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 PasswordCredential(object):
+ """
+ Attributes:
+ - gatewayId
+ - portalUserName
+ - loginUserName
+ - password
+ - description
+ - persistedTime
+ - token
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'gatewayId', 'UTF8', None, ), # 1
+ (2, TType.STRING, 'portalUserName', 'UTF8', None, ), # 2
+ (3, TType.STRING, 'loginUserName', 'UTF8', None, ), # 3
+ (4, TType.STRING, 'password', 'UTF8', None, ), # 4
+ (5, TType.STRING, 'description', 'UTF8', None, ), # 5
+ (6, TType.I64, 'persistedTime', None, None, ), # 6
+ (7, TType.STRING, 'token', 'UTF8', None, ), # 7
+ )
+
+ def __init__(self, gatewayId=None, portalUserName=None, loginUserName=None, password=None, description=None, persistedTime=None, token=None,):
+ self.gatewayId = gatewayId
+ self.portalUserName = portalUserName
+ self.loginUserName = loginUserName
+ self.password = password
+ self.description = description
+ self.persistedTime = persistedTime
+ self.token = token
+
+ def read(self, iprot):
+ if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
+ iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.gatewayId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.portalUserName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.loginUserName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.password = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.description = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.I64:
+ self.persistedTime = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.token = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot._fast_encode is not None and self.thrift_spec is not None:
+ oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('PasswordCredential')
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 1)
+ oprot.writeString(self.gatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayId)
+ oprot.writeFieldEnd()
+ if self.portalUserName is not None:
+ oprot.writeFieldBegin('portalUserName', TType.STRING, 2)
+ oprot.writeString(self.portalUserName.encode('utf-8') if sys.version_info[0] == 2 else self.portalUserName)
+ oprot.writeFieldEnd()
+ if self.loginUserName is not None:
+ oprot.writeFieldBegin('loginUserName', TType.STRING, 3)
+ oprot.writeString(self.loginUserName.encode('utf-8') if sys.version_info[0] == 2 else self.loginUserName)
+ oprot.writeFieldEnd()
+ if self.password is not None:
+ oprot.writeFieldBegin('password', TType.STRING, 4)
+ oprot.writeString(self.password.encode('utf-8') if sys.version_info[0] == 2 else self.password)
+ oprot.writeFieldEnd()
+ if self.description is not None:
+ oprot.writeFieldBegin('description', TType.STRING, 5)
+ oprot.writeString(self.description.encode('utf-8') if sys.version_info[0] == 2 else self.description)
+ oprot.writeFieldEnd()
+ if self.persistedTime is not None:
+ oprot.writeFieldBegin('persistedTime', TType.I64, 6)
+ oprot.writeI64(self.persistedTime)
+ oprot.writeFieldEnd()
+ if self.token is not None:
+ oprot.writeFieldBegin('token', TType.STRING, 7)
+ oprot.writeString(self.token.encode('utf-8') if sys.version_info[0] == 2 else self.token)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.gatewayId is None:
+ raise TProtocolException(message='Required field gatewayId is unset!')
+ if self.portalUserName is None:
+ raise TProtocolException(message='Required field portalUserName is unset!')
+ if self.loginUserName is None:
+ raise TProtocolException(message='Required field loginUserName is unset!')
+ if self.password is None:
+ raise TProtocolException(message='Required field password is unset!')
+ return
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.items()]
+ 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)
http://git-wip-us.apache.org/repos/asf/airavata/blob/9d165bd8/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentState.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentState.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentState.java
index 1e68782..5015794 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentState.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentState.java
@@ -16,7 +16,7 @@
*/
/**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.10.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/airavata/blob/9d165bd8/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java
index 4da27d6..bbe4e6a 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java
@@ -16,42 +16,15 @@
*/
/**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.10.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.airavata.model;
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
+@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.10.0)")
public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus, ComponentStatus._Fields>, java.io.Serializable, Cloneable, Comparable<ComponentStatus> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComponentStatus");
@@ -59,14 +32,11 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
private static final org.apache.thrift.protocol.TField REASON_FIELD_DESC = new org.apache.thrift.protocol.TField("reason", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField TIMEOF_STATE_CHANGE_FIELD_DESC = new org.apache.thrift.protocol.TField("timeofStateChange", org.apache.thrift.protocol.TType.I64, (short)3);
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new ComponentStatusStandardSchemeFactory());
- schemes.put(TupleScheme.class, new ComponentStatusTupleSchemeFactory());
- }
+ private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new ComponentStatusStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new ComponentStatusTupleSchemeFactory();
private ComponentState state; // required
- private String reason; // optional
+ private java.lang.String reason; // optional
private long timeofStateChange; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -79,10 +49,10 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
REASON((short)2, "reason"),
TIMEOF_STATE_CHANGE((short)3, "timeofStateChange");
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+ private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>();
static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
@@ -109,21 +79,21 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
- public static _Fields findByName(String name) {
+ public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
- private final String _fieldName;
+ private final java.lang.String _fieldName;
- _Fields(short thriftId, String fieldName) {
+ _Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
@@ -132,7 +102,7 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
@@ -141,16 +111,16 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
private static final int __TIMEOFSTATECHANGE_ISSET_ID = 0;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.REASON,_Fields.TIMEOF_STATE_CHANGE};
- public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.STATE, new org.apache.thrift.meta_data.FieldMetaData("state", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ComponentState.class)));
tmpMap.put(_Fields.REASON, new org.apache.thrift.meta_data.FieldMetaData("reason", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.TIMEOF_STATE_CHANGE, new org.apache.thrift.meta_data.FieldMetaData("timeofStateChange", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ComponentStatus.class, metaDataMap);
}
@@ -224,11 +194,11 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
}
}
- public String getReason() {
+ public java.lang.String getReason() {
return this.reason;
}
- public void setReason(String reason) {
+ public void setReason(java.lang.String reason) {
this.reason = reason;
}
@@ -257,19 +227,19 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
}
public void unsetTimeofStateChange() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID);
+ __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID);
}
/** Returns true if field timeofStateChange is set (has been assigned a value) and false otherwise */
public boolean isSetTimeofStateChange() {
- return EncodingUtils.testBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID);
+ return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID);
}
public void setTimeofStateChangeIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID, value);
+ __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID, value);
}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case STATE:
if (value == null) {
@@ -283,7 +253,7 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
if (value == null) {
unsetReason();
} else {
- setReason((String)value);
+ setReason((java.lang.String)value);
}
break;
@@ -291,14 +261,14 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
if (value == null) {
unsetTimeofStateChange();
} else {
- setTimeofStateChange((Long)value);
+ setTimeofStateChange((java.lang.Long)value);
}
break;
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case STATE:
return getState();
@@ -310,13 +280,13 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
return getTimeofStateChange();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
public boolean isSet(_Fields field) {
if (field == null) {
- throw new IllegalArgumentException();
+ throw new java.lang.IllegalArgumentException();
}
switch (field) {
@@ -327,11 +297,11 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
case TIMEOF_STATE_CHANGE:
return isSetTimeofStateChange();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
@Override
- public boolean equals(Object that) {
+ public boolean equals(java.lang.Object that) {
if (that == null)
return false;
if (that instanceof ComponentStatus)
@@ -342,6 +312,8 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
public boolean equals(ComponentStatus that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_state = true && this.isSetState();
boolean that_present_state = true && that.isSetState();
@@ -375,24 +347,21 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
@Override
public int hashCode() {
- List<Object> list = new ArrayList<Object>();
+ int hashCode = 1;
- boolean present_state = true && (isSetState());
- list.add(present_state);
- if (present_state)
- list.add(state.getValue());
+ hashCode = hashCode * 8191 + ((isSetState()) ? 131071 : 524287);
+ if (isSetState())
+ hashCode = hashCode * 8191 + state.getValue();
- boolean present_reason = true && (isSetReason());
- list.add(present_reason);
- if (present_reason)
- list.add(reason);
+ hashCode = hashCode * 8191 + ((isSetReason()) ? 131071 : 524287);
+ if (isSetReason())
+ hashCode = hashCode * 8191 + reason.hashCode();
- boolean present_timeofStateChange = true && (isSetTimeofStateChange());
- list.add(present_timeofStateChange);
- if (present_timeofStateChange)
- list.add(timeofStateChange);
+ hashCode = hashCode * 8191 + ((isSetTimeofStateChange()) ? 131071 : 524287);
+ if (isSetTimeofStateChange())
+ hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(timeofStateChange);
- return list.hashCode();
+ return hashCode;
}
@Override
@@ -403,7 +372,7 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
int lastComparison = 0;
- lastComparison = Boolean.valueOf(isSetState()).compareTo(other.isSetState());
+ lastComparison = java.lang.Boolean.valueOf(isSetState()).compareTo(other.isSetState());
if (lastComparison != 0) {
return lastComparison;
}
@@ -413,7 +382,7 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetReason()).compareTo(other.isSetReason());
+ lastComparison = java.lang.Boolean.valueOf(isSetReason()).compareTo(other.isSetReason());
if (lastComparison != 0) {
return lastComparison;
}
@@ -423,7 +392,7 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetTimeofStateChange()).compareTo(other.isSetTimeofStateChange());
+ lastComparison = java.lang.Boolean.valueOf(isSetTimeofStateChange()).compareTo(other.isSetTimeofStateChange());
if (lastComparison != 0) {
return lastComparison;
}
@@ -441,16 +410,16 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ scheme(iprot).read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ scheme(oprot).write(oprot, this);
}
@Override
- public String toString() {
- StringBuilder sb = new StringBuilder("ComponentStatus(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("ComponentStatus(");
boolean first = true;
sb.append("state:");
@@ -497,7 +466,7 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
}
}
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bitfield = 0;
@@ -507,13 +476,13 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
}
}
- private static class ComponentStatusStandardSchemeFactory implements SchemeFactory {
+ private static class ComponentStatusStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public ComponentStatusStandardScheme getScheme() {
return new ComponentStatusStandardScheme();
}
}
- private static class ComponentStatusStandardScheme extends StandardScheme<ComponentStatus> {
+ private static class ComponentStatusStandardScheme extends org.apache.thrift.scheme.StandardScheme<ComponentStatus> {
public void read(org.apache.thrift.protocol.TProtocol iprot, ComponentStatus struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
@@ -585,19 +554,19 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
}
- private static class ComponentStatusTupleSchemeFactory implements SchemeFactory {
+ private static class ComponentStatusTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public ComponentStatusTupleScheme getScheme() {
return new ComponentStatusTupleScheme();
}
}
- private static class ComponentStatusTupleScheme extends TupleScheme<ComponentStatus> {
+ private static class ComponentStatusTupleScheme extends org.apache.thrift.scheme.TupleScheme<ComponentStatus> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, ComponentStatus struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
+ org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
oprot.writeI32(struct.state.getValue());
- BitSet optionals = new BitSet();
+ java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetReason()) {
optionals.set(0);
}
@@ -615,10 +584,10 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, ComponentStatus struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
+ org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
struct.state = org.apache.airavata.model.ComponentState.findByValue(iprot.readI32());
struct.setStateIsSet(true);
- BitSet incoming = iprot.readBitSet(2);
+ java.util.BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.reason = iprot.readString();
struct.setReasonIsSet(true);
@@ -630,5 +599,8 @@ public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus,
}
}
+ private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) {
+ return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
+ }
}