This is an automated email from the ASF dual-hosted git repository. smarru pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/airavata-sandbox.git
commit bf6e876cfa1e558ceaaa0a1029c1acaa8b7d4f85 Author: Saurabh Agrawal <[email protected]> AuthorDate: Sat Dec 16 00:55:13 2017 -0500 Thrift files --- .../credential_store_data_models/__init__.py | 1 + .../credential_store_data_models/constants.py | 13 + .../credential_store_data_models/ttypes.py | 729 +++++++++++++++++++++ 3 files changed, 743 insertions(+) diff --git a/cwl-workflows/credential_store_data_models/__init__.py b/cwl-workflows/credential_store_data_models/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/cwl-workflows/credential_store_data_models/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] diff --git a/cwl-workflows/credential_store_data_models/constants.py b/cwl-workflows/credential_store_data_models/constants.py new file mode 100644 index 0000000..2b09fa9 --- /dev/null +++ b/cwl-workflows/credential_store_data_models/constants.py @@ -0,0 +1,13 @@ +# +# 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, TFrozenDict, TException, TApplicationException +from thrift.protocol.TProtocol import TProtocolException +import sys +from .ttypes import * +DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS" diff --git a/cwl-workflows/credential_store_data_models/ttypes.py b/cwl-workflows/credential_store_data_models/ttypes.py new file mode 100644 index 0000000..7d6cadf --- /dev/null +++ b/cwl-workflows/credential_store_data_models/ttypes.py @@ -0,0 +1,729 @@ +# +# 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, TFrozenDict, TException, TApplicationException +from thrift.protocol.TProtocol import TProtocolException +import sys + +from thrift.transport import TTransport + + +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) -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
