You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/05/01 20:28:47 UTC
[04/10] airavata git commit: adding capability to store and retreive
PWD credentials in the Airavata API
http://git-wip-us.apache.org/repos/asf/airavata/blob/3bb7f493/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py
index 9f56005..46f4a4b 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py
@@ -223,6 +223,33 @@ class Iface:
"""
pass
+ def registerPwdCredential(self, authzToken, gatewayId, userName, password):
+ """
+ Generate and Register Username PWD Pair with Airavata Credential Store.
+
+ @param gatewayId
+ The identifier for the requested Gateway.
+
+ @param userName
+ The User for which the credential should be registered. For community accounts, this user is the name of the
+ community user name. For computational resources, this user name need not be the same user name on resoruces.
+
+ @param password
+
+ @return airavataCredStoreToken
+ An SSH Key pair is generated and stored in the credential store and associated with users or community account
+ belonging to a Gateway.
+
+
+
+ Parameters:
+ - authzToken
+ - gatewayId
+ - userName
+ - password
+ """
+ pass
+
def getSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId):
"""
Get a Public Key by Providing the Token
@@ -286,6 +313,14 @@ class Iface:
"""
pass
+ def getAllGatewayPWDCredentials(self, authzToken, gatewayId):
+ """
+ Parameters:
+ - authzToken
+ - gatewayId
+ """
+ pass
+
def deleteSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId):
"""
@@ -306,6 +341,15 @@ class Iface:
"""
pass
+ def deletePWDCredential(self, authzToken, airavataCredStoreToken, gatewayId):
+ """
+ Parameters:
+ - authzToken
+ - airavataCredStoreToken
+ - gatewayId
+ """
+ pass
+
def createProject(self, authzToken, gatewayId, project):
"""
@@ -3678,6 +3722,66 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result")
+ def registerPwdCredential(self, authzToken, gatewayId, userName, password):
+ """
+ Generate and Register Username PWD Pair with Airavata Credential Store.
+
+ @param gatewayId
+ The identifier for the requested Gateway.
+
+ @param userName
+ The User for which the credential should be registered. For community accounts, this user is the name of the
+ community user name. For computational resources, this user name need not be the same user name on resoruces.
+
+ @param password
+
+ @return airavataCredStoreToken
+ An SSH Key pair is generated and stored in the credential store and associated with users or community account
+ belonging to a Gateway.
+
+
+
+ Parameters:
+ - authzToken
+ - gatewayId
+ - userName
+ - password
+ """
+ self.send_registerPwdCredential(authzToken, gatewayId, userName, password)
+ return self.recv_registerPwdCredential()
+
+ def send_registerPwdCredential(self, authzToken, gatewayId, userName, password):
+ self._oprot.writeMessageBegin('registerPwdCredential', TMessageType.CALL, self._seqid)
+ args = registerPwdCredential_args()
+ args.authzToken = authzToken
+ args.gatewayId = gatewayId
+ args.userName = userName
+ args.password = password
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_registerPwdCredential(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = registerPwdCredential_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.ire is not None:
+ raise result.ire
+ if result.ace is not None:
+ raise result.ace
+ if result.ase is not None:
+ raise result.ase
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "registerPwdCredential failed: unknown result")
+
def getSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId):
"""
Get a Public Key by Providing the Token
@@ -3835,6 +3939,45 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result")
+ def getAllGatewayPWDCredentials(self, authzToken, gatewayId):
+ """
+ Parameters:
+ - authzToken
+ - gatewayId
+ """
+ self.send_getAllGatewayPWDCredentials(authzToken, gatewayId)
+ return self.recv_getAllGatewayPWDCredentials()
+
+ def send_getAllGatewayPWDCredentials(self, authzToken, gatewayId):
+ self._oprot.writeMessageBegin('getAllGatewayPWDCredentials', TMessageType.CALL, self._seqid)
+ args = getAllGatewayPWDCredentials_args()
+ args.authzToken = authzToken
+ args.gatewayId = gatewayId
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getAllGatewayPWDCredentials(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = getAllGatewayPWDCredentials_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.ire is not None:
+ raise result.ire
+ if result.ace is not None:
+ raise result.ace
+ if result.ase is not None:
+ raise result.ase
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayPWDCredentials failed: unknown result")
+
def deleteSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId):
"""
@@ -3887,6 +4030,47 @@ class Client(Iface):
raise result.ase
raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteSSHPubKey failed: unknown result")
+ def deletePWDCredential(self, authzToken, airavataCredStoreToken, gatewayId):
+ """
+ Parameters:
+ - authzToken
+ - airavataCredStoreToken
+ - gatewayId
+ """
+ self.send_deletePWDCredential(authzToken, airavataCredStoreToken, gatewayId)
+ return self.recv_deletePWDCredential()
+
+ def send_deletePWDCredential(self, authzToken, airavataCredStoreToken, gatewayId):
+ self._oprot.writeMessageBegin('deletePWDCredential', TMessageType.CALL, self._seqid)
+ args = deletePWDCredential_args()
+ args.authzToken = authzToken
+ args.airavataCredStoreToken = airavataCredStoreToken
+ args.gatewayId = gatewayId
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_deletePWDCredential(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = deletePWDCredential_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.ire is not None:
+ raise result.ire
+ if result.ace is not None:
+ raise result.ace
+ if result.ase is not None:
+ raise result.ase
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "deletePWDCredential failed: unknown result")
+
def createProject(self, authzToken, gatewayId, project):
"""
@@ -10878,10 +11062,13 @@ class Processor(Iface, TProcessor):
self._processMap["getNotification"] = Processor.process_getNotification
self._processMap["getAllNotifications"] = Processor.process_getAllNotifications
self._processMap["generateAndRegisterSSHKeys"] = Processor.process_generateAndRegisterSSHKeys
+ self._processMap["registerPwdCredential"] = Processor.process_registerPwdCredential
self._processMap["getSSHPubKey"] = Processor.process_getSSHPubKey
self._processMap["getAllUserSSHPubKeys"] = Processor.process_getAllUserSSHPubKeys
self._processMap["getAllGatewaySSHPubKeys"] = Processor.process_getAllGatewaySSHPubKeys
+ self._processMap["getAllGatewayPWDCredentials"] = Processor.process_getAllGatewayPWDCredentials
self._processMap["deleteSSHPubKey"] = Processor.process_deleteSSHPubKey
+ self._processMap["deletePWDCredential"] = Processor.process_deletePWDCredential
self._processMap["createProject"] = Processor.process_createProject
self._processMap["updateProject"] = Processor.process_updateProject
self._processMap["getProject"] = Processor.process_getProject
@@ -11455,6 +11642,34 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_registerPwdCredential(self, seqid, iprot, oprot):
+ args = registerPwdCredential_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = registerPwdCredential_result()
+ try:
+ result.success = self._handler.registerPwdCredential(args.authzToken, args.gatewayId, args.userName, args.password)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
+ msg_type = TMessageType.REPLY
+ result.ire = ire
+ except apache.airavata.api.error.ttypes.AiravataClientException as ace:
+ msg_type = TMessageType.REPLY
+ result.ace = ace
+ except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
+ msg_type = TMessageType.REPLY
+ result.ase = ase
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("registerPwdCredential", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_getSSHPubKey(self, seqid, iprot, oprot):
args = getSSHPubKey_args()
args.read(iprot)
@@ -11539,6 +11754,34 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_getAllGatewayPWDCredentials(self, seqid, iprot, oprot):
+ args = getAllGatewayPWDCredentials_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = getAllGatewayPWDCredentials_result()
+ try:
+ result.success = self._handler.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
+ msg_type = TMessageType.REPLY
+ result.ire = ire
+ except apache.airavata.api.error.ttypes.AiravataClientException as ace:
+ msg_type = TMessageType.REPLY
+ result.ace = ace
+ except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
+ msg_type = TMessageType.REPLY
+ result.ase = ase
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getAllGatewayPWDCredentials", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_deleteSSHPubKey(self, seqid, iprot, oprot):
args = deleteSSHPubKey_args()
args.read(iprot)
@@ -11567,6 +11810,34 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_deletePWDCredential(self, seqid, iprot, oprot):
+ args = deletePWDCredential_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = deletePWDCredential_result()
+ try:
+ result.success = self._handler.deletePWDCredential(args.authzToken, args.airavataCredStoreToken, args.gatewayId)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except apache.airavata.api.error.ttypes.InvalidRequestException as ire:
+ msg_type = TMessageType.REPLY
+ result.ire = ire
+ except apache.airavata.api.error.ttypes.AiravataClientException as ace:
+ msg_type = TMessageType.REPLY
+ result.ace = ace
+ except apache.airavata.api.error.ttypes.AiravataSystemException as ase:
+ msg_type = TMessageType.REPLY
+ result.ase = ase
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("deletePWDCredential", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_createProject(self, seqid, iprot, oprot):
args = createProject_args()
args.read(iprot)
@@ -17975,22 +18246,237 @@ class getNotification_result:
def __ne__(self, other):
return not (self == other)
-class getAllNotifications_args:
+class getAllNotifications_args:
+ """
+ Attributes:
+ - authzToken
+ - gatewayId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1
+ (2, TType.STRING, 'gatewayId', None, None, ), # 2
+ )
+
+ def __init__(self, authzToken=None, gatewayId=None,):
+ self.authzToken = authzToken
+ self.gatewayId = gatewayId
+
+ 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.authzToken = apache.airavata.model.security.ttypes.AuthzToken()
+ self.authzToken.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.gatewayId = 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('getAllNotifications_args')
+ if self.authzToken is not None:
+ oprot.writeFieldBegin('authzToken', TType.STRUCT, 1)
+ self.authzToken.write(oprot)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.authzToken is None:
+ raise TProtocol.TProtocolException(message='Required field authzToken is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.authzToken)
+ value = (value * 31) ^ hash(self.gatewayId)
+ 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 getAllNotifications_result:
+ """
+ Attributes:
+ - success
+ - ire
+ - ace
+ - ase
+ - ae
+ """
+
+ thrift_spec = (
+ (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Notification, apache.airavata.model.workspace.ttypes.Notification.thrift_spec)), None, ), # 0
+ (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3
+ (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4
+ )
+
+ def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,):
+ self.success = success
+ self.ire = ire
+ self.ace = ace
+ self.ase = ase
+ self.ae = ae
+
+ 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 == 0:
+ if ftype == TType.LIST:
+ self.success = []
+ (_etype10, _size7) = iprot.readListBegin()
+ for _i11 in xrange(_size7):
+ _elem12 = apache.airavata.model.workspace.ttypes.Notification()
+ _elem12.read(iprot)
+ self.success.append(_elem12)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.ire = apache.airavata.api.error.ttypes.InvalidRequestException()
+ self.ire.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.ace = apache.airavata.api.error.ttypes.AiravataClientException()
+ self.ace.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.ase = apache.airavata.api.error.ttypes.AiravataSystemException()
+ self.ase.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRUCT:
+ self.ae = apache.airavata.api.error.ttypes.AuthorizationException()
+ self.ae.read(iprot)
+ 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('getAllNotifications_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRUCT, len(self.success))
+ for iter13 in self.success:
+ iter13.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.ire is not None:
+ oprot.writeFieldBegin('ire', TType.STRUCT, 1)
+ self.ire.write(oprot)
+ oprot.writeFieldEnd()
+ if self.ace is not None:
+ oprot.writeFieldBegin('ace', TType.STRUCT, 2)
+ self.ace.write(oprot)
+ oprot.writeFieldEnd()
+ if self.ase is not None:
+ oprot.writeFieldBegin('ase', TType.STRUCT, 3)
+ self.ase.write(oprot)
+ oprot.writeFieldEnd()
+ if self.ae is not None:
+ oprot.writeFieldBegin('ae', TType.STRUCT, 4)
+ self.ae.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.ire)
+ value = (value * 31) ^ hash(self.ace)
+ value = (value * 31) ^ hash(self.ase)
+ value = (value * 31) ^ hash(self.ae)
+ 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 generateAndRegisterSSHKeys_args:
"""
Attributes:
- authzToken
- gatewayId
+ - userName
"""
thrift_spec = (
None, # 0
(1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1
(2, TType.STRING, 'gatewayId', None, None, ), # 2
+ (3, TType.STRING, 'userName', None, None, ), # 3
)
- def __init__(self, authzToken=None, gatewayId=None,):
+ def __init__(self, authzToken=None, gatewayId=None, userName=None,):
self.authzToken = authzToken
self.gatewayId = gatewayId
+ self.userName = userName
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:
@@ -18012,6 +18498,11 @@ class getAllNotifications_args:
self.gatewayId = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.userName = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -18021,7 +18512,7 @@ class getAllNotifications_args:
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('getAllNotifications_args')
+ oprot.writeStructBegin('generateAndRegisterSSHKeys_args')
if self.authzToken is not None:
oprot.writeFieldBegin('authzToken', TType.STRUCT, 1)
self.authzToken.write(oprot)
@@ -18030,6 +18521,10 @@ class getAllNotifications_args:
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()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -18038,6 +18533,8 @@ class getAllNotifications_args:
raise TProtocol.TProtocolException(message='Required field authzToken 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!')
return
@@ -18045,6 +18542,7 @@ class getAllNotifications_args:
value = 17
value = (value * 31) ^ hash(self.authzToken)
value = (value * 31) ^ hash(self.gatewayId)
+ value = (value * 31) ^ hash(self.userName)
return value
def __repr__(self):
@@ -18058,30 +18556,27 @@ class getAllNotifications_args:
def __ne__(self, other):
return not (self == other)
-class getAllNotifications_result:
+class generateAndRegisterSSHKeys_result:
"""
Attributes:
- success
- ire
- ace
- ase
- - ae
"""
thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.workspace.ttypes.Notification, apache.airavata.model.workspace.ttypes.Notification.thrift_spec)), None, ), # 0
+ (0, TType.STRING, 'success', None, None, ), # 0
(1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1
(2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2
(3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3
- (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4
)
- def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,):
+ def __init__(self, success=None, ire=None, ace=None, ase=None,):
self.success = success
self.ire = ire
self.ace = ace
self.ase = ase
- self.ae = ae
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:
@@ -18093,14 +18588,8 @@ class getAllNotifications_result:
if ftype == TType.STOP:
break
if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype10, _size7) = iprot.readListBegin()
- for _i11 in xrange(_size7):
- _elem12 = apache.airavata.model.workspace.ttypes.Notification()
- _elem12.read(iprot)
- self.success.append(_elem12)
- iprot.readListEnd()
+ if ftype == TType.STRING:
+ self.success = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 1:
@@ -18121,12 +18610,6 @@ class getAllNotifications_result:
self.ase.read(iprot)
else:
iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRUCT:
- self.ae = apache.airavata.api.error.ttypes.AuthorizationException()
- self.ae.read(iprot)
- else:
- iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -18136,13 +18619,10 @@ class getAllNotifications_result:
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('getAllNotifications_result')
+ oprot.writeStructBegin('generateAndRegisterSSHKeys_result')
if self.success is not None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter13 in self.success:
- iter13.write(oprot)
- oprot.writeListEnd()
+ oprot.writeFieldBegin('success', TType.STRING, 0)
+ oprot.writeString(self.success)
oprot.writeFieldEnd()
if self.ire is not None:
oprot.writeFieldBegin('ire', TType.STRUCT, 1)
@@ -18156,10 +18636,6 @@ class getAllNotifications_result:
oprot.writeFieldBegin('ase', TType.STRUCT, 3)
self.ase.write(oprot)
oprot.writeFieldEnd()
- if self.ae is not None:
- oprot.writeFieldBegin('ae', TType.STRUCT, 4)
- self.ae.write(oprot)
- oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -18173,7 +18649,6 @@ class getAllNotifications_result:
value = (value * 31) ^ hash(self.ire)
value = (value * 31) ^ hash(self.ace)
value = (value * 31) ^ hash(self.ase)
- value = (value * 31) ^ hash(self.ae)
return value
def __repr__(self):
@@ -18187,12 +18662,13 @@ class getAllNotifications_result:
def __ne__(self, other):
return not (self == other)
-class generateAndRegisterSSHKeys_args:
+class registerPwdCredential_args:
"""
Attributes:
- authzToken
- gatewayId
- userName
+ - password
"""
thrift_spec = (
@@ -18200,12 +18676,14 @@ class generateAndRegisterSSHKeys_args:
(1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1
(2, TType.STRING, 'gatewayId', None, None, ), # 2
(3, TType.STRING, 'userName', None, None, ), # 3
+ (4, TType.STRING, 'password', None, None, ), # 4
)
- def __init__(self, authzToken=None, gatewayId=None, userName=None,):
+ def __init__(self, authzToken=None, gatewayId=None, userName=None, password=None,):
self.authzToken = authzToken
self.gatewayId = gatewayId
self.userName = userName
+ self.password = password
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:
@@ -18232,6 +18710,11 @@ class generateAndRegisterSSHKeys_args:
self.userName = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.password = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -18241,7 +18724,7 @@ class generateAndRegisterSSHKeys_args:
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('generateAndRegisterSSHKeys_args')
+ oprot.writeStructBegin('registerPwdCredential_args')
if self.authzToken is not None:
oprot.writeFieldBegin('authzToken', TType.STRUCT, 1)
self.authzToken.write(oprot)
@@ -18254,6 +18737,10 @@ class generateAndRegisterSSHKeys_args:
oprot.writeFieldBegin('userName', TType.STRING, 3)
oprot.writeString(self.userName)
oprot.writeFieldEnd()
+ if self.password is not None:
+ oprot.writeFieldBegin('password', TType.STRING, 4)
+ oprot.writeString(self.password)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -18264,6 +18751,8 @@ class generateAndRegisterSSHKeys_args:
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.password is None:
+ raise TProtocol.TProtocolException(message='Required field password is unset!')
return
@@ -18272,6 +18761,7 @@ class generateAndRegisterSSHKeys_args:
value = (value * 31) ^ hash(self.authzToken)
value = (value * 31) ^ hash(self.gatewayId)
value = (value * 31) ^ hash(self.userName)
+ value = (value * 31) ^ hash(self.password)
return value
def __repr__(self):
@@ -18285,7 +18775,7 @@ class generateAndRegisterSSHKeys_args:
def __ne__(self, other):
return not (self == other)
-class generateAndRegisterSSHKeys_result:
+class registerPwdCredential_result:
"""
Attributes:
- success
@@ -18348,7 +18838,7 @@ class generateAndRegisterSSHKeys_result:
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('generateAndRegisterSSHKeys_result')
+ oprot.writeStructBegin('registerPwdCredential_result')
if self.success is not None:
oprot.writeFieldBegin('success', TType.STRING, 0)
oprot.writeString(self.success)
@@ -18993,6 +19483,205 @@ class getAllGatewaySSHPubKeys_result:
def __ne__(self, other):
return not (self == other)
+class getAllGatewayPWDCredentials_args:
+ """
+ Attributes:
+ - authzToken
+ - gatewayId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1
+ (2, TType.STRING, 'gatewayId', None, None, ), # 2
+ )
+
+ def __init__(self, authzToken=None, gatewayId=None,):
+ self.authzToken = authzToken
+ self.gatewayId = gatewayId
+
+ 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.authzToken = apache.airavata.model.security.ttypes.AuthzToken()
+ self.authzToken.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.gatewayId = 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('getAllGatewayPWDCredentials_args')
+ if self.authzToken is not None:
+ oprot.writeFieldBegin('authzToken', TType.STRUCT, 1)
+ self.authzToken.write(oprot)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.authzToken is None:
+ raise TProtocol.TProtocolException(message='Required field authzToken is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.authzToken)
+ value = (value * 31) ^ hash(self.gatewayId)
+ 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 getAllGatewayPWDCredentials_result:
+ """
+ Attributes:
+ - success
+ - ire
+ - ace
+ - ase
+ """
+
+ thrift_spec = (
+ (0, TType.MAP, 'success', (TType.STRING,None,TType.STRING,None), None, ), # 0
+ (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3
+ )
+
+ def __init__(self, success=None, ire=None, ace=None, ase=None,):
+ self.success = success
+ self.ire = ire
+ self.ace = ace
+ self.ase = ase
+
+ 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 == 0:
+ if ftype == TType.MAP:
+ self.success = {}
+ (_ktype33, _vtype34, _size32 ) = iprot.readMapBegin()
+ for _i36 in xrange(_size32):
+ _key37 = iprot.readString()
+ _val38 = iprot.readString()
+ self.success[_key37] = _val38
+ iprot.readMapEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.ire = apache.airavata.api.error.ttypes.InvalidRequestException()
+ self.ire.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.ace = apache.airavata.api.error.ttypes.AiravataClientException()
+ self.ace.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.ase = apache.airavata.api.error.ttypes.AiravataSystemException()
+ self.ase.read(iprot)
+ 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('getAllGatewayPWDCredentials_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.MAP, 0)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
+ for kiter39,viter40 in self.success.items():
+ oprot.writeString(kiter39)
+ oprot.writeString(viter40)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ if self.ire is not None:
+ oprot.writeFieldBegin('ire', TType.STRUCT, 1)
+ self.ire.write(oprot)
+ oprot.writeFieldEnd()
+ if self.ace is not None:
+ oprot.writeFieldBegin('ace', TType.STRUCT, 2)
+ self.ace.write(oprot)
+ oprot.writeFieldEnd()
+ if self.ase is not None:
+ oprot.writeFieldBegin('ase', TType.STRUCT, 3)
+ self.ase.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.ire)
+ value = (value * 31) ^ hash(self.ace)
+ value = (value * 31) ^ hash(self.ase)
+ 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 deleteSSHPubKey_args:
"""
Attributes:
@@ -19197,6 +19886,210 @@ class deleteSSHPubKey_result:
def __ne__(self, other):
return not (self == other)
+class deletePWDCredential_args:
+ """
+ Attributes:
+ - authzToken
+ - airavataCredStoreToken
+ - gatewayId
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1
+ (2, TType.STRING, 'airavataCredStoreToken', None, None, ), # 2
+ (3, TType.STRING, 'gatewayId', None, None, ), # 3
+ )
+
+ def __init__(self, authzToken=None, airavataCredStoreToken=None, gatewayId=None,):
+ self.authzToken = authzToken
+ self.airavataCredStoreToken = airavataCredStoreToken
+ self.gatewayId = gatewayId
+
+ 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.authzToken = apache.airavata.model.security.ttypes.AuthzToken()
+ self.authzToken.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.airavataCredStoreToken = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.gatewayId = 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('deletePWDCredential_args')
+ if self.authzToken is not None:
+ oprot.writeFieldBegin('authzToken', TType.STRUCT, 1)
+ self.authzToken.write(oprot)
+ oprot.writeFieldEnd()
+ if self.airavataCredStoreToken is not None:
+ oprot.writeFieldBegin('airavataCredStoreToken', TType.STRING, 2)
+ oprot.writeString(self.airavataCredStoreToken)
+ oprot.writeFieldEnd()
+ if self.gatewayId is not None:
+ oprot.writeFieldBegin('gatewayId', TType.STRING, 3)
+ oprot.writeString(self.gatewayId)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.authzToken is None:
+ raise TProtocol.TProtocolException(message='Required field authzToken is unset!')
+ if self.airavataCredStoreToken is None:
+ raise TProtocol.TProtocolException(message='Required field airavataCredStoreToken is unset!')
+ if self.gatewayId is None:
+ raise TProtocol.TProtocolException(message='Required field gatewayId is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.authzToken)
+ value = (value * 31) ^ hash(self.airavataCredStoreToken)
+ value = (value * 31) ^ hash(self.gatewayId)
+ 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 deletePWDCredential_result:
+ """
+ Attributes:
+ - success
+ - ire
+ - ace
+ - ase
+ """
+
+ thrift_spec = (
+ (0, TType.BOOL, 'success', None, None, ), # 0
+ (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3
+ )
+
+ def __init__(self, success=None, ire=None, ace=None, ase=None,):
+ self.success = success
+ self.ire = ire
+ self.ace = ace
+ self.ase = ase
+
+ 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 == 0:
+ if ftype == TType.BOOL:
+ self.success = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.ire = apache.airavata.api.error.ttypes.InvalidRequestException()
+ self.ire.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.ace = apache.airavata.api.error.ttypes.AiravataClientException()
+ self.ace.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.ase = apache.airavata.api.error.ttypes.AiravataSystemException()
+ self.ase.read(iprot)
+ 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('deletePWDCredential_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.BOOL, 0)
+ oprot.writeBool(self.success)
+ oprot.writeFieldEnd()
+ if self.ire is not None:
+ oprot.writeFieldBegin('ire', TType.STRUCT, 1)
+ self.ire.write(oprot)
+ oprot.writeFieldEnd()
+ if self.ace is not None:
+ oprot.writeFieldBegin('ace', TType.STRUCT, 2)
+ self.ace.write(oprot)
+ oprot.writeFieldEnd()
+ if self.ase is not None:
+ oprot.writeFieldBegin('ase', TType.STRUCT, 3)
+ self.ase.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.ire)
+ value = (value * 31) ^ hash(self.ace)
+ value = (value * 31) ^ hash(self.ase)
+ 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 createProject_args:
"""
Attributes:
@@ -20237,11 +21130,11 @@ class getUserProjects_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype35, _size32) = iprot.readListBegin()
- for _i36 in xrange(_size32):
- _elem37 = apache.airavata.model.workspace.ttypes.Project()
- _elem37.read(iprot)
- self.success.append(_elem37)
+ (_etype44, _size41) = iprot.readListBegin()
+ for _i45 in xrange(_size41):
+ _elem46 = apache.airavata.model.workspace.ttypes.Project()
+ _elem46.read(iprot)
+ self.success.append(_elem46)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20282,8 +21175,8 @@ class getUserProjects_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter38 in self.success:
- iter38.write(oprot)
+ for iter47 in self.success:
+ iter47.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -20509,11 +21402,11 @@ class searchProjectsByProjectName_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype42, _size39) = iprot.readListBegin()
- for _i43 in xrange(_size39):
- _elem44 = apache.airavata.model.workspace.ttypes.Project()
- _elem44.read(iprot)
- self.success.append(_elem44)
+ (_etype51, _size48) = iprot.readListBegin()
+ for _i52 in xrange(_size48):
+ _elem53 = apache.airavata.model.workspace.ttypes.Project()
+ _elem53.read(iprot)
+ self.success.append(_elem53)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20554,8 +21447,8 @@ class searchProjectsByProjectName_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter45 in self.success:
- iter45.write(oprot)
+ for iter54 in self.success:
+ iter54.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -20781,11 +21674,11 @@ class searchProjectsByProjectDesc_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype49, _size46) = iprot.readListBegin()
- for _i50 in xrange(_size46):
- _elem51 = apache.airavata.model.workspace.ttypes.Project()
- _elem51.read(iprot)
- self.success.append(_elem51)
+ (_etype58, _size55) = iprot.readListBegin()
+ for _i59 in xrange(_size55):
+ _elem60 = apache.airavata.model.workspace.ttypes.Project()
+ _elem60.read(iprot)
+ self.success.append(_elem60)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20826,8 +21719,8 @@ class searchProjectsByProjectDesc_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter52 in self.success:
- iter52.write(oprot)
+ for iter61 in self.success:
+ iter61.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -21053,11 +21946,11 @@ class searchExperimentsByName_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype56, _size53) = iprot.readListBegin()
- for _i57 in xrange(_size53):
- _elem58 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
- _elem58.read(iprot)
- self.success.append(_elem58)
+ (_etype65, _size62) = iprot.readListBegin()
+ for _i66 in xrange(_size62):
+ _elem67 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
+ _elem67.read(iprot)
+ self.success.append(_elem67)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21098,8 +21991,8 @@ class searchExperimentsByName_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter59 in self.success:
- iter59.write(oprot)
+ for iter68 in self.success:
+ iter68.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -21325,11 +22218,11 @@ class searchExperimentsByDesc_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype63, _size60) = iprot.readListBegin()
- for _i64 in xrange(_size60):
- _elem65 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
- _elem65.read(iprot)
- self.success.append(_elem65)
+ (_etype72, _size69) = iprot.readListBegin()
+ for _i73 in xrange(_size69):
+ _elem74 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
+ _elem74.read(iprot)
+ self.success.append(_elem74)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21370,8 +22263,8 @@ class searchExperimentsByDesc_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter66 in self.success:
- iter66.write(oprot)
+ for iter75 in self.success:
+ iter75.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -21597,11 +22490,11 @@ class searchExperimentsByApplication_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype70, _size67) = iprot.readListBegin()
- for _i71 in xrange(_size67):
- _elem72 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
- _elem72.read(iprot)
- self.success.append(_elem72)
+ (_etype79, _size76) = iprot.readListBegin()
+ for _i80 in xrange(_size76):
+ _elem81 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
+ _elem81.read(iprot)
+ self.success.append(_elem81)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21642,8 +22535,8 @@ class searchExperimentsByApplication_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter73 in self.success:
- iter73.write(oprot)
+ for iter82 in self.success:
+ iter82.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -21869,11 +22762,11 @@ class searchExperimentsByStatus_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype77, _size74) = iprot.readListBegin()
- for _i78 in xrange(_size74):
- _elem79 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
- _elem79.read(iprot)
- self.success.append(_elem79)
+ (_etype86, _size83) = iprot.readListBegin()
+ for _i87 in xrange(_size83):
+ _elem88 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
+ _elem88.read(iprot)
+ self.success.append(_elem88)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21914,8 +22807,8 @@ class searchExperimentsByStatus_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter80 in self.success:
- iter80.write(oprot)
+ for iter89 in self.success:
+ iter89.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -22156,11 +23049,11 @@ class searchExperimentsByCreationTime_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype84, _size81) = iprot.readListBegin()
- for _i85 in xrange(_size81):
- _elem86 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
- _elem86.read(iprot)
- self.success.append(_elem86)
+ (_etype93, _size90) = iprot.readListBegin()
+ for _i94 in xrange(_size90):
+ _elem95 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
+ _elem95.read(iprot)
+ self.success.append(_elem95)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22201,8 +23094,8 @@ class searchExperimentsByCreationTime_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter87 in self.success:
- iter87.write(oprot)
+ for iter96 in self.success:
+ iter96.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -22305,11 +23198,11 @@ class searchExperiments_args:
elif fid == 4:
if ftype == TType.MAP:
self.filters = {}
- (_ktype89, _vtype90, _size88 ) = iprot.readMapBegin()
- for _i92 in xrange(_size88):
- _key93 = iprot.readI32()
- _val94 = iprot.readString()
- self.filters[_key93] = _val94
+ (_ktype98, _vtype99, _size97 ) = iprot.readMapBegin()
+ for _i101 in xrange(_size97):
+ _key102 = iprot.readI32()
+ _val103 = iprot.readString()
+ self.filters[_key102] = _val103
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -22348,9 +23241,9 @@ class searchExperiments_args:
if self.filters is not None:
oprot.writeFieldBegin('filters', TType.MAP, 4)
oprot.writeMapBegin(TType.I32, TType.STRING, len(self.filters))
- for kiter95,viter96 in self.filters.items():
- oprot.writeI32(kiter95)
- oprot.writeString(viter96)
+ for kiter104,viter105 in self.filters.items():
+ oprot.writeI32(kiter104)
+ oprot.writeString(viter105)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.limit is not None:
@@ -22436,11 +23329,11 @@ class searchExperiments_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype100, _size97) = iprot.readListBegin()
- for _i101 in xrange(_size97):
- _elem102 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
- _elem102.read(iprot)
- self.success.append(_elem102)
+ (_etype109, _size106) = iprot.readListBegin()
+ for _i110 in xrange(_size106):
+ _elem111 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel()
+ _elem111.read(iprot)
+ self.success.append(_elem111)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22481,8 +23374,8 @@ class searchExperiments_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter103 in self.success:
- iter103.write(oprot)
+ for iter112 in self.success:
+ iter112.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -22915,11 +23808,11 @@ class getExperimentsInProject_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype107, _size104) = iprot.readListBegin()
- for _i108 in xrange(_size104):
- _elem109 = apache.airavata.model.experiment.ttypes.ExperimentModel()
- _elem109.read(iprot)
- self.success.append(_elem109)
+ (_etype116, _size113) = iprot.readListBegin()
+ for _i117 in xrange(_size113):
+ _elem118 = apache.airavata.model.experiment.ttypes.ExperimentModel()
+ _elem118.read(iprot)
+ self.success.append(_elem118)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22966,8 +23859,8 @@ class getExperimentsInProject_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter110 in self.success:
- iter110.write(oprot)
+ for iter119 in self.success:
+ iter119.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -23183,11 +24076,11 @@ class getUserExperiments_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype114, _size111) = iprot.readListBegin()
- for _i115 in xrange(_size111):
- _elem116 = apache.airavata.model.experiment.ttypes.ExperimentModel()
- _elem116.read(iprot)
- self.success.append(_elem116)
+ (_etype123, _size120) = iprot.readListBegin()
+ for _i124 in xrange(_size120):
+ _elem125 = apache.airavata.model.experiment.ttypes.ExperimentModel()
+ _elem125.read(iprot)
+ self.success.append(_elem125)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23228,8 +24121,8 @@ class getUserExperiments_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter117 in self.success:
- iter117.write(oprot)
+ for iter126 in self.success:
+ iter126.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -25462,11 +26355,11 @@ class getExperimentOutputs_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype121, _size118) = iprot.readListBegin()
- for _i122 in xrange(_size118):
- _elem123 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
- _elem123.read(iprot)
- self.success.append(_elem123)
+ (_etype130, _size127) = iprot.readListBegin()
+ for _i131 in xrange(_size127):
+ _elem132 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
+ _elem132.read(iprot)
+ self.success.append(_elem132)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25513,8 +26406,8 @@ class getExperimentOutputs_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter124 in self.success:
- iter124.write(oprot)
+ for iter133 in self.success:
+ iter133.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -25688,11 +26581,11 @@ class getIntermediateOutputs_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype128, _size125) = iprot.readListBegin()
- for _i129 in xrange(_size125):
- _elem130 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
- _elem130.read(iprot)
- self.success.append(_elem130)
+ (_etype137, _size134) = iprot.readListBegin()
+ for _i138 in xrange(_size134):
+ _elem139 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
+ _elem139.read(iprot)
+ self.success.append(_elem139)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25739,8 +26632,8 @@ class getIntermediateOutputs_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter131 in self.success:
- iter131.write(oprot)
+ for iter140 in self.success:
+ iter140.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -25914,12 +26807,12 @@ class getJobStatuses_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype133, _vtype134, _size132 ) = iprot.readMapBegin()
- for _i136 in xrange(_size132):
- _key137 = iprot.readString()
- _val138 = apache.airavata.model.status.ttypes.JobStatus()
- _val138.read(iprot)
- self.success[_key137] = _val138
+ (_ktype142, _vtype143, _size141 ) = iprot.readMapBegin()
+ for _i145 in xrange(_size141):
+ _key146 = iprot.readString()
+ _val147 = apache.airavata.model.status.ttypes.JobStatus()
+ _val147.read(iprot)
+ self.success[_key146] = _val147
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25966,9 +26859,9 @@ class getJobStatuses_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter139,viter140 in self.success.items():
- oprot.writeString(kiter139)
- viter140.write(oprot)
+ for kiter148,viter149 in self.success.items():
+ oprot.writeString(kiter148)
+ viter149.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -26142,11 +27035,11 @@ class getJobDetails_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype144, _size141) = iprot.readListBegin()
- for _i145 in xrange(_size141):
- _elem146 = apache.airavata.model.job.ttypes.JobModel()
- _elem146.read(iprot)
- self.success.append(_elem146)
+ (_etype153, _size150) = iprot.readListBegin()
+ for _i154 in xrange(_size150):
+ _elem155 = apache.airavata.model.job.ttypes.JobModel()
+ _elem155.read(iprot)
+ self.success.append(_elem155)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26193,8 +27086,8 @@ class getJobDetails_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter147 in self.success:
- iter147.write(oprot)
+ for iter156 in self.success:
+ iter156.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -27451,11 +28344,11 @@ class getAllAppModules_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype151, _size148) = iprot.readListBegin()
- for _i152 in xrange(_size148):
- _elem153 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule()
- _elem153.read(iprot)
- self.success.append(_elem153)
+ (_etype160, _size157) = iprot.readListBegin()
+ for _i161 in xrange(_size157):
+ _elem162 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule()
+ _elem162.read(iprot)
+ self.success.append(_elem162)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27496,8 +28389,8 @@ class getAllAppModules_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter154 in self.success:
- iter154.write(oprot)
+ for iter163 in self.success:
+ iter163.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -28711,11 +29604,11 @@ class getAllApplicationDeployments_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype158, _size155) = iprot.readListBegin()
- for _i159 in xrange(_size155):
- _elem160 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription()
- _elem160.read(iprot)
- self.success.append(_elem160)
+ (_etype167, _size164) = iprot.readListBegin()
+ for _i168 in xrange(_size164):
+ _elem169 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription()
+ _elem169.read(iprot)
+ self.success.append(_elem169)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28756,8 +29649,8 @@ class getAllApplicationDeployments_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter161 in self.success:
- iter161.write(oprot)
+ for iter170 in self.success:
+ iter170.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -28923,10 +29816,10 @@ class getAppModuleDeployedResources_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype165, _size162) = iprot.readListBegin()
- for _i166 in xrange(_size162):
- _elem167 = iprot.readString()
- self.success.append(_elem167)
+ (_etype174, _size171) = iprot.readListBegin()
+ for _i175 in xrange(_size171):
+ _elem176 = iprot.readString()
+ self.success.append(_elem176)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28967,8 +29860,8 @@ class getAppModuleDeployedResources_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter168 in self.success:
- oprot.writeString(iter168)
+ for iter177 in self.success:
+ oprot.writeString(iter177)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -30206,11 +31099,11 @@ class getAllApplicationInterfaceNames_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype170, _vtype171, _size169 ) = iprot.readMapBegin()
- for _i173 in xrange(_size169):
- _key174 = iprot.readString()
- _val175 = iprot.readString()
- self.success[_key174] = _val175
+ (_ktype179, _vtype180, _size178 ) = iprot.readMapBegin()
+ for _i182 in xrange(_size178):
+ _key183 = iprot.readString()
+ _val184 = iprot.readString()
+ self.success[_key183] = _val184
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30251,9 +31144,9 @@ class getAllApplicationInterfaceNames_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter176,viter177 in self.success.items():
- oprot.writeString(kiter176)
- oprot.writeString(viter177)
+ for kiter185,viter186 in self.success.items():
+ oprot.writeString(kiter185)
+ oprot.writeString(viter186)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -30419,11 +31312,11 @@ class getAllApplicationInterfaces_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype181, _size178) = iprot.readListBegin()
- for _i182 in xrange(_size178):
- _elem183 = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription()
- _elem183.read(iprot)
- self.success.append(_elem183)
+ (_etype190, _size187) = iprot.readListBegin()
+ for _i191 in xrange(_size187):
+ _elem192 = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription()
+ _elem192.read(iprot)
+ self.success.append(_elem192)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30464,8 +31357,8 @@ class getAllApplicationInterfaces_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter184 in self.success:
- iter184.write(oprot)
+ for iter193 in self.success:
+ iter193.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -30631,11 +31524,11 @@ class getApplicationInputs_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype188, _size185) = iprot.readListBegin()
- for _i189 in xrange(_size185):
- _elem190 = apache.airavata.model.application.io.ttypes.InputDataObjectType()
- _elem190.read(iprot)
- self.success.append(_elem190)
+ (_etype197, _size194) = iprot.readListBegin()
+ for _i198 in xrange(_size194):
+ _elem199 = apache.airavata.model.application.io.ttypes.InputDataObjectType()
+ _elem199.read(iprot)
+ self.success.append(_elem199)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30676,8 +31569,8 @@ class getApplicationInputs_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter191 in self.success:
- iter191.write(oprot)
+ for iter200 in self.success:
+ iter200.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -30843,11 +31736,11 @@ class getApplicationOutputs_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype195, _size192) = iprot.readListBegin()
- for _i196 in xrange(_size192):
- _elem197 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
- _elem197.read(iprot)
- self.success.append(_elem197)
+ (_etype204, _size201) = iprot.readListBegin()
+ for _i205 in xrange(_size201):
+ _elem206 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
+ _elem206.read(iprot)
+ self.success.append(_elem206)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30888,8 +31781,8 @@ class getApplicationOutputs_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter198 in self.success:
- iter198.write(oprot)
+ for iter207 in self.success:
+ iter207.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -31055,11 +31948,11 @@ class getAvailableAppInterfaceComputeResources_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype200, _vtype201, _size199 ) = iprot.readMapBegin()
- for _i203 in xrange(_size199):
- _key204 = iprot.readString()
- _val205 = iprot.readString()
- self.success[_key204] = _val205
+ (_ktype209, _vtype210, _size208 ) = iprot.readMapBegin()
+ for _i212 in xrange(_size208):
+ _key213 = iprot.readString()
+ _val214 = iprot.readString()
+ self.success[_key213] = _val214
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -31100,9 +31993,9 @@ class getAvailableAppInterfaceComputeResources_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter206,viter207 in self.success.items():
- oprot.writeString(kiter206)
- oprot.writeString(viter207)
+ for kiter215,viter216 in self.success.items():
+ oprot.writeString(kiter215)
+ oprot.writeString(viter216)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -31661,11 +32554,11 @@ class getAllComputeResourceNames_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype209, _vtype210, _size208 ) = iprot.readMapBegin()
- for _i212 in xrange(_size208):
- _key213 = iprot.readString()
- _val214 = iprot.readString()
- self.success[_key213] = _val214
+ (_ktype218, _vtype219, _size217 ) = iprot.readMapBegin()
+ for _i221 in xrange(_size217):
+ _key222 = iprot.readString()
+ _val223 = iprot.readString()
+ self.success[_key222] = _val223
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -31706,9 +32599,9 @@ class getAllComputeResourceNames_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter215,viter216 in self.success.items():
- oprot.writeString(kiter215)
- oprot.writeString(viter216)
+ for kiter224,viter225 in self.success.items():
+ oprot.writeString(kiter224)
+ oprot.writeString(viter225)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -32689,11 +33582,11 @@ class getAllStorageResourceNames_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype218, _vtype219, _size217 ) = iprot.readMapBegin()
- for _i221 in xrange(_size217):
- _key222 = iprot.readString()
- _val223 = iprot.readString()
- self.success[_key222] = _val223
+ (_ktype227, _vtype228, _size226 ) = iprot.readMapBegin()
+ for _i230 in xrange(_size226):
+ _key231 = iprot.readString()
+ _val232 = iprot.readString()
+ self.success[_key231] = _val232
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -32734,9 +33627,9 @@ class getAllStorageResourceNames_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter224,viter225 in self.success.items():
- oprot.writeString(kiter224)
- oprot.writeString(viter225)
+ for kiter233,viter234 in self.success.items():
+ oprot.writeString(kiter233)
+ oprot.writeString(viter234)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -39225,11 +40118,11 @@ class changeJobSubmissionPriorities_args:
elif fid == 2:
if ftype == TType.MAP:
self.jobSubmissionPriorityMap = {}
- (_ktype227, _vtype228, _size226 ) = iprot.readMapBegin()
- for _i230 in xrange(_size226):
- _key231 = iprot.readString()
- _val232 = iprot.readI32()
- self.jobSubmissionPriorityMap[_key231] = _val232
+ (_ktype236, _vtype237, _size235 ) = iprot.readMapBegin()
+ for _i239 in xrange(_size235):
+ _key240 = iprot.readString()
+ _val241 = iprot.readI32()
+ self.jobSubmissionPriorityMap[_key240] = _val241
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -39250,9 +40143,9 @@ class changeJobSubmissionPriorities_args:
if self.jobSubmissionPriorityMap is not None:
oprot.writeFieldBegin('jobSubmissionPriorityMap', TType.MAP, 2)
oprot.writeMapBegin(TType.STRING, TType.I32, len(self.jobSubmissionPriorityMap))
- for kiter233,viter234 in self.jobSubmissionPriorityMap.items():
- oprot.writeString(kiter233)
- oprot.writeI32(viter234)
+ for kiter242,viter243 in self.jobSubmissionPriorityMap.items():
+ oprot.writeString(kiter242)
+ oprot.writeI32(viter243)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -39438,11 +40331,11 @@ class changeDataMovementPriorities_args:
elif fid == 2:
if ftype == TType.MAP:
self.dataMovementPriorityMap = {}
- (_ktype236, _vtype237, _size235 ) = iprot.readMapBegin()
- for _i239 in xrange(_size235):
- _key240 = iprot.readString()
- _val241 = iprot.readI32()
- self.dataMovementPriorityMap[_key240] = _val241
+ (_ktype245, _vtype246, _size244 ) = iprot.readMapBegin()
+ for _i248 in xrange(_size244):
+ _key249 = iprot.readString()
+ _val250 = iprot.readI32()
+ self.dataMovementPriorityMap[_key249] = _val250
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -39463,9 +40356,9 @@ class changeDataMovementPriorities_args:
if self.dataMovementPriorityMap is not None:
oprot.writeFieldBegin('dataMovementPriorityMap', TType.MAP, 2)
oprot.writeMapBegin(TType.STRING, TType.I32, len(self.dataMovementPriorityMap))
- for kiter242,viter243 in self.dataMovementPriorityMap.items():
- oprot.writeString(kiter242)
- oprot.writeI32(viter243)
+ for kiter251,viter252 in self.dataMovementPriorityMap.items():
+ oprot.writeString(kiter251)
+ oprot.writeI32(viter252)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -42971,11 +43864,11 @@ class getAllGatewayComputeResourcePreferences_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype247, _size244) = iprot.readListBegin()
- for _i248 in xrange(_size244):
- _elem249 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.ComputeResourcePreference()
- _elem249.read(iprot)
- self.success.append(_elem249)
+ (_etype256, _size253) = iprot.readListBegin()
+ for _i257 in xrange(_size253):
+ _elem258 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.ComputeResourcePreference()
+ _elem258.read(iprot)
+ self.success.append(_elem258)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -43016,8 +43909,8 @@ class getAllGatewayComputeResourcePreferences_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter250 in self.success:
- iter250.write(oprot)
+ for iter259 in self.success:
+ iter259.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -43183,11 +44076,11 @@ class getAllGatewayStoragePreferences_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype254, _size251) = iprot.readListBegin()
- for _i255 in xrange(_size251):
- _elem256 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference()
- _elem256.read(iprot)
- self.success.append(_elem256)
+ (_etype263, _size260) = iprot.readListBegin()
+ for _i264 in xrange(_size260):
+ _elem265 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference()
+ _elem265.read(iprot)
+ self.success.append(_elem265)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -43228,8 +44121,8 @@ class getAllGatewayStoragePreferences_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter257 in self.success:
- iter257.write(oprot)
+ for iter266 in self.success:
+ iter266.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -43380,11 +44273,11 @@ class getAllGatewayResourceProfiles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype261, _size258) = iprot.readListBegin()
- for _i262 in xrange(_size258):
- _elem263 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.GatewayResourceProfile()
- _elem263.read(iprot)
- self.success.append(_elem263)
+ (_etype270, _size267) = iprot.readListBegin()
+ for _i271 in xrange(_size267):
+ _elem272 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.GatewayResourceProfile()
+ _elem272.read(iprot)
+ self.success.append(_elem272)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -43425,8 +44318,8 @@ class getAllGatewayResourceProfiles_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter264 in self.success:
- iter264.write(oprot)
+ for iter273 in self.success:
+ iter273.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -44496,10 +45389,10 @@ class getAllWorkflows_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype268, _size265) = iprot.readListBegin()
- for _i269 in xrange(_size265):
- _elem270 = iprot.readString()
- self.success.append(_elem270)
+ (_etype277, _size274) = iprot.readListBegin()
+ for _i278 in xrange(_size274):
+ _elem279 = iprot.readString()
+ self.success.append(_elem279)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -44540,8 +45433,8 @@ class getAllWorkflows_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter271 in self.success:
- oprot.writeString(iter271)
+ for iter280 in self.success:
+ oprot.writeString(iter280)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
@@ -46750,11 +47643,11 @@ class getChildDataProducts_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype275, _size272) = iprot.readListBegin()
- for _i276 in xrange(_size272):
- _elem277 = apache.airavata.model.data.replica.ttypes.DataProductModel()
- _elem277.read(iprot)
- self.success.append(_elem277)
+ (_etype284, _size281) = iprot.readListBegin()
+ for _i285 in xrange(_size281):
+ _elem286 = apache.airavata.model.data.replica.ttypes.DataProductModel()
+ _elem286.read(iprot)
+ self.success.append(_elem286)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -46795,8 +47688,8 @@ class getChildDataProducts_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter278 in self.success:
- iter278.write(oprot)
+ for iter287 in self.success:
+ iter287.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ire is not None:
http://git-wip-us.apache.org/repos/asf/airavata/blob/3bb7f493/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java
----------------------------------------------------------------------
diff --git a/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java b/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java
index a31c98b..21cc271 100644
--- a/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java
+++ b/modules/credential-store/credential-store-service/src/main/java/org/apache/airavata/credential/store/credential/impl/password/PasswordCredential.java
@@ -21,11 +21,8 @@
package org.apache.airavata.credential.store.credential.impl.password;
-import org.apache.airavata.credential.store.credential.Credential;
import org.apache.airavata.credential.store.credential.impl.ssh.SSHCredential;
-import java.util.Date;
-
/**
* User name password credentials.
*/
@@ -33,6 +30,7 @@ public class PasswordCredential extends SSHCredential {
private String userName;
private String password;
+ private String description;
public String getUserName() {
return userName;
@@ -50,4 +48,11 @@ public class PasswordCredential extends SSHCredential {
this.password = password;
}
+ public String getDescription() {
+ return description;
+ }
+
+ public void setDescription(String description) {
+ this.description = description;
+ }
}