http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/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/14ff0916/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/14ff0916/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"}) [email protected](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(); + } }
