http://git-wip-us.apache.org/repos/asf/airavata/blob/13b50f7a/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 4f25769..080a6b7 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 @@ -2091,13 +2091,13 @@ class Iface: """ pass - def addGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + def addGatewayStoragePreference(self, authzToken, gatewayID, dataMoveId, storagePreference): """ Parameters: - authzToken - gatewayID - dataMoveId - - dataStoragePreference + - storagePreference """ pass @@ -2122,7 +2122,7 @@ class Iface: """ pass - def getGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + def getGatewayStoragePreference(self, authzToken, gatewayID, dataMoveId): """ Parameters: - authzToken @@ -2148,7 +2148,7 @@ class Iface: """ pass - def getAllGatewayDataStoragePreferences(self, authzToken, gatewayID): + def getAllGatewayStoragePreferences(self, authzToken, gatewayID): """ Parameters: - authzToken @@ -2191,13 +2191,13 @@ class Iface: """ pass - def updateGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + def updateGatewayStoragePreference(self, authzToken, gatewayID, storageId, storagePreference): """ Parameters: - authzToken - gatewayID - - dataMoveId - - dataStoragePreference + - storageId + - storagePreference """ pass @@ -2222,12 +2222,12 @@ class Iface: """ pass - def deleteGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + def deleteGatewayStoragePreference(self, authzToken, gatewayID, storageId): """ Parameters: - authzToken - gatewayID - - dataMoveId + - storageId """ pass @@ -8193,29 +8193,29 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayComputeResourcePreference failed: unknown result"); - def addGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + def addGatewayStoragePreference(self, authzToken, gatewayID, dataMoveId, storagePreference): """ Parameters: - authzToken - gatewayID - dataMoveId - - dataStoragePreference + - storagePreference """ - self.send_addGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId, dataStoragePreference) - return self.recv_addGatewayDataStoragePreference() + self.send_addGatewayStoragePreference(authzToken, gatewayID, dataMoveId, storagePreference) + return self.recv_addGatewayStoragePreference() - def send_addGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): - self._oprot.writeMessageBegin('addGatewayDataStoragePreference', TMessageType.CALL, self._seqid) - args = addGatewayDataStoragePreference_args() + def send_addGatewayStoragePreference(self, authzToken, gatewayID, dataMoveId, storagePreference): + self._oprot.writeMessageBegin('addGatewayStoragePreference', TMessageType.CALL, self._seqid) + args = addGatewayStoragePreference_args() args.authzToken = authzToken args.gatewayID = gatewayID args.dataMoveId = dataMoveId - args.dataStoragePreference = dataStoragePreference + args.storagePreference = storagePreference args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_addGatewayDataStoragePreference(self): + def recv_addGatewayStoragePreference(self): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: @@ -8223,7 +8223,7 @@ class Client(Iface): x.read(iprot) iprot.readMessageEnd() raise x - result = addGatewayDataStoragePreference_result() + result = addGatewayStoragePreference_result() result.read(iprot) iprot.readMessageEnd() if result.success is not None: @@ -8236,7 +8236,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayDataStoragePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayStoragePreference failed: unknown result"); def getGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId): """ @@ -8293,19 +8293,19 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayComputeResourcePreference failed: unknown result"); - def getGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + def getGatewayStoragePreference(self, authzToken, gatewayID, dataMoveId): """ Parameters: - authzToken - gatewayID - dataMoveId """ - self.send_getGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId) - return self.recv_getGatewayDataStoragePreference() + self.send_getGatewayStoragePreference(authzToken, gatewayID, dataMoveId) + return self.recv_getGatewayStoragePreference() - def send_getGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): - self._oprot.writeMessageBegin('getGatewayDataStoragePreference', TMessageType.CALL, self._seqid) - args = getGatewayDataStoragePreference_args() + def send_getGatewayStoragePreference(self, authzToken, gatewayID, dataMoveId): + self._oprot.writeMessageBegin('getGatewayStoragePreference', TMessageType.CALL, self._seqid) + args = getGatewayStoragePreference_args() args.authzToken = authzToken args.gatewayID = gatewayID args.dataMoveId = dataMoveId @@ -8313,7 +8313,7 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getGatewayDataStoragePreference(self): + def recv_getGatewayStoragePreference(self): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: @@ -8321,7 +8321,7 @@ class Client(Iface): x.read(iprot) iprot.readMessageEnd() raise x - result = getGatewayDataStoragePreference_result() + result = getGatewayStoragePreference_result() result.read(iprot) iprot.readMessageEnd() if result.success is not None: @@ -8334,7 +8334,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayDataStoragePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayStoragePreference failed: unknown result"); def getAllGatewayComputeResourcePreferences(self, authzToken, gatewayID): """ @@ -8386,25 +8386,25 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayComputeResourcePreferences failed: unknown result"); - def getAllGatewayDataStoragePreferences(self, authzToken, gatewayID): + def getAllGatewayStoragePreferences(self, authzToken, gatewayID): """ Parameters: - authzToken - gatewayID """ - self.send_getAllGatewayDataStoragePreferences(authzToken, gatewayID) - return self.recv_getAllGatewayDataStoragePreferences() + self.send_getAllGatewayStoragePreferences(authzToken, gatewayID) + return self.recv_getAllGatewayStoragePreferences() - def send_getAllGatewayDataStoragePreferences(self, authzToken, gatewayID): - self._oprot.writeMessageBegin('getAllGatewayDataStoragePreferences', TMessageType.CALL, self._seqid) - args = getAllGatewayDataStoragePreferences_args() + def send_getAllGatewayStoragePreferences(self, authzToken, gatewayID): + self._oprot.writeMessageBegin('getAllGatewayStoragePreferences', TMessageType.CALL, self._seqid) + args = getAllGatewayStoragePreferences_args() args.authzToken = authzToken args.gatewayID = gatewayID args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getAllGatewayDataStoragePreferences(self): + def recv_getAllGatewayStoragePreferences(self): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: @@ -8412,7 +8412,7 @@ class Client(Iface): x.read(iprot) iprot.readMessageEnd() raise x - result = getAllGatewayDataStoragePreferences_result() + result = getAllGatewayStoragePreferences_result() result.read(iprot) iprot.readMessageEnd() if result.success is not None: @@ -8425,7 +8425,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayDataStoragePreferences failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayStoragePreferences failed: unknown result"); def getAllGatewayResourceProfiles(self, authzToken): """ @@ -8529,29 +8529,29 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayComputeResourcePreference failed: unknown result"); - def updateGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + def updateGatewayStoragePreference(self, authzToken, gatewayID, storageId, storagePreference): """ Parameters: - authzToken - gatewayID - - dataMoveId - - dataStoragePreference + - storageId + - storagePreference """ - self.send_updateGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId, dataStoragePreference) - return self.recv_updateGatewayDataStoragePreference() + self.send_updateGatewayStoragePreference(authzToken, gatewayID, storageId, storagePreference) + return self.recv_updateGatewayStoragePreference() - def send_updateGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): - self._oprot.writeMessageBegin('updateGatewayDataStoragePreference', TMessageType.CALL, self._seqid) - args = updateGatewayDataStoragePreference_args() + def send_updateGatewayStoragePreference(self, authzToken, gatewayID, storageId, storagePreference): + self._oprot.writeMessageBegin('updateGatewayStoragePreference', TMessageType.CALL, self._seqid) + args = updateGatewayStoragePreference_args() args.authzToken = authzToken args.gatewayID = gatewayID - args.dataMoveId = dataMoveId - args.dataStoragePreference = dataStoragePreference + args.storageId = storageId + args.storagePreference = storagePreference args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_updateGatewayDataStoragePreference(self): + def recv_updateGatewayStoragePreference(self): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: @@ -8559,7 +8559,7 @@ class Client(Iface): x.read(iprot) iprot.readMessageEnd() raise x - result = updateGatewayDataStoragePreference_result() + result = updateGatewayStoragePreference_result() result.read(iprot) iprot.readMessageEnd() if result.success is not None: @@ -8572,7 +8572,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayDataStoragePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayStoragePreference failed: unknown result"); def deleteGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId): """ @@ -8629,27 +8629,27 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayComputeResourcePreference failed: unknown result"); - def deleteGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + def deleteGatewayStoragePreference(self, authzToken, gatewayID, storageId): """ Parameters: - authzToken - gatewayID - - dataMoveId + - storageId """ - self.send_deleteGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId) - return self.recv_deleteGatewayDataStoragePreference() + self.send_deleteGatewayStoragePreference(authzToken, gatewayID, storageId) + return self.recv_deleteGatewayStoragePreference() - def send_deleteGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): - self._oprot.writeMessageBegin('deleteGatewayDataStoragePreference', TMessageType.CALL, self._seqid) - args = deleteGatewayDataStoragePreference_args() + def send_deleteGatewayStoragePreference(self, authzToken, gatewayID, storageId): + self._oprot.writeMessageBegin('deleteGatewayStoragePreference', TMessageType.CALL, self._seqid) + args = deleteGatewayStoragePreference_args() args.authzToken = authzToken args.gatewayID = gatewayID - args.dataMoveId = dataMoveId + args.storageId = storageId args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_deleteGatewayDataStoragePreference(self): + def recv_deleteGatewayStoragePreference(self): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: @@ -8657,7 +8657,7 @@ class Client(Iface): x.read(iprot) iprot.readMessageEnd() raise x - result = deleteGatewayDataStoragePreference_result() + result = deleteGatewayStoragePreference_result() result.read(iprot) iprot.readMessageEnd() if result.success is not None: @@ -8670,7 +8670,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayDataStoragePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayStoragePreference failed: unknown result"); def getAllWorkflows(self, authzToken, gatewayId): """ @@ -9077,16 +9077,16 @@ class Processor(Iface, TProcessor): self._processMap["updateGatewayResourceProfile"] = Processor.process_updateGatewayResourceProfile self._processMap["deleteGatewayResourceProfile"] = Processor.process_deleteGatewayResourceProfile self._processMap["addGatewayComputeResourcePreference"] = Processor.process_addGatewayComputeResourcePreference - self._processMap["addGatewayDataStoragePreference"] = Processor.process_addGatewayDataStoragePreference + self._processMap["addGatewayStoragePreference"] = Processor.process_addGatewayStoragePreference self._processMap["getGatewayComputeResourcePreference"] = Processor.process_getGatewayComputeResourcePreference - self._processMap["getGatewayDataStoragePreference"] = Processor.process_getGatewayDataStoragePreference + self._processMap["getGatewayStoragePreference"] = Processor.process_getGatewayStoragePreference self._processMap["getAllGatewayComputeResourcePreferences"] = Processor.process_getAllGatewayComputeResourcePreferences - self._processMap["getAllGatewayDataStoragePreferences"] = Processor.process_getAllGatewayDataStoragePreferences + self._processMap["getAllGatewayStoragePreferences"] = Processor.process_getAllGatewayStoragePreferences self._processMap["getAllGatewayResourceProfiles"] = Processor.process_getAllGatewayResourceProfiles self._processMap["updateGatewayComputeResourcePreference"] = Processor.process_updateGatewayComputeResourcePreference - self._processMap["updateGatewayDataStoragePreference"] = Processor.process_updateGatewayDataStoragePreference + self._processMap["updateGatewayStoragePreference"] = Processor.process_updateGatewayStoragePreference self._processMap["deleteGatewayComputeResourcePreference"] = Processor.process_deleteGatewayComputeResourcePreference - self._processMap["deleteGatewayDataStoragePreference"] = Processor.process_deleteGatewayDataStoragePreference + self._processMap["deleteGatewayStoragePreference"] = Processor.process_deleteGatewayStoragePreference self._processMap["getAllWorkflows"] = Processor.process_getAllWorkflows self._processMap["getWorkflow"] = Processor.process_getWorkflow self._processMap["deleteWorkflow"] = Processor.process_deleteWorkflow @@ -11384,13 +11384,13 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_addGatewayDataStoragePreference(self, seqid, iprot, oprot): - args = addGatewayDataStoragePreference_args() + def process_addGatewayStoragePreference(self, seqid, iprot, oprot): + args = addGatewayStoragePreference_args() args.read(iprot) iprot.readMessageEnd() - result = addGatewayDataStoragePreference_result() + result = addGatewayStoragePreference_result() try: - result.success = self._handler.addGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.dataStoragePreference) + result.success = self._handler.addGatewayStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.storagePreference) except apache.airavata.api.error.ttypes.InvalidRequestException, ire: result.ire = ire except apache.airavata.api.error.ttypes.AiravataClientException, ace: @@ -11399,7 +11399,7 @@ class Processor(Iface, TProcessor): result.ase = ase except apache.airavata.api.error.ttypes.AuthorizationException, ae: result.ae = ae - oprot.writeMessageBegin("addGatewayDataStoragePreference", TMessageType.REPLY, seqid) + oprot.writeMessageBegin("addGatewayStoragePreference", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -11424,13 +11424,13 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_getGatewayDataStoragePreference(self, seqid, iprot, oprot): - args = getGatewayDataStoragePreference_args() + def process_getGatewayStoragePreference(self, seqid, iprot, oprot): + args = getGatewayStoragePreference_args() args.read(iprot) iprot.readMessageEnd() - result = getGatewayDataStoragePreference_result() + result = getGatewayStoragePreference_result() try: - result.success = self._handler.getGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId) + result.success = self._handler.getGatewayStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId) except apache.airavata.api.error.ttypes.InvalidRequestException, ire: result.ire = ire except apache.airavata.api.error.ttypes.AiravataClientException, ace: @@ -11439,7 +11439,7 @@ class Processor(Iface, TProcessor): result.ase = ase except apache.airavata.api.error.ttypes.AuthorizationException, ae: result.ae = ae - oprot.writeMessageBegin("getGatewayDataStoragePreference", TMessageType.REPLY, seqid) + oprot.writeMessageBegin("getGatewayStoragePreference", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -11464,13 +11464,13 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_getAllGatewayDataStoragePreferences(self, seqid, iprot, oprot): - args = getAllGatewayDataStoragePreferences_args() + def process_getAllGatewayStoragePreferences(self, seqid, iprot, oprot): + args = getAllGatewayStoragePreferences_args() args.read(iprot) iprot.readMessageEnd() - result = getAllGatewayDataStoragePreferences_result() + result = getAllGatewayStoragePreferences_result() try: - result.success = self._handler.getAllGatewayDataStoragePreferences(args.authzToken, args.gatewayID) + result.success = self._handler.getAllGatewayStoragePreferences(args.authzToken, args.gatewayID) except apache.airavata.api.error.ttypes.InvalidRequestException, ire: result.ire = ire except apache.airavata.api.error.ttypes.AiravataClientException, ace: @@ -11479,7 +11479,7 @@ class Processor(Iface, TProcessor): result.ase = ase except apache.airavata.api.error.ttypes.AuthorizationException, ae: result.ae = ae - oprot.writeMessageBegin("getAllGatewayDataStoragePreferences", TMessageType.REPLY, seqid) + oprot.writeMessageBegin("getAllGatewayStoragePreferences", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -11524,13 +11524,13 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_updateGatewayDataStoragePreference(self, seqid, iprot, oprot): - args = updateGatewayDataStoragePreference_args() + def process_updateGatewayStoragePreference(self, seqid, iprot, oprot): + args = updateGatewayStoragePreference_args() args.read(iprot) iprot.readMessageEnd() - result = updateGatewayDataStoragePreference_result() + result = updateGatewayStoragePreference_result() try: - result.success = self._handler.updateGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.dataStoragePreference) + result.success = self._handler.updateGatewayStoragePreference(args.authzToken, args.gatewayID, args.storageId, args.storagePreference) except apache.airavata.api.error.ttypes.InvalidRequestException, ire: result.ire = ire except apache.airavata.api.error.ttypes.AiravataClientException, ace: @@ -11539,7 +11539,7 @@ class Processor(Iface, TProcessor): result.ase = ase except apache.airavata.api.error.ttypes.AuthorizationException, ae: result.ae = ae - oprot.writeMessageBegin("updateGatewayDataStoragePreference", TMessageType.REPLY, seqid) + oprot.writeMessageBegin("updateGatewayStoragePreference", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -11564,13 +11564,13 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_deleteGatewayDataStoragePreference(self, seqid, iprot, oprot): - args = deleteGatewayDataStoragePreference_args() + def process_deleteGatewayStoragePreference(self, seqid, iprot, oprot): + args = deleteGatewayStoragePreference_args() args.read(iprot) iprot.readMessageEnd() - result = deleteGatewayDataStoragePreference_result() + result = deleteGatewayStoragePreference_result() try: - result.success = self._handler.deleteGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId) + result.success = self._handler.deleteGatewayStoragePreference(args.authzToken, args.gatewayID, args.storageId) except apache.airavata.api.error.ttypes.InvalidRequestException, ire: result.ire = ire except apache.airavata.api.error.ttypes.AiravataClientException, ace: @@ -11579,7 +11579,7 @@ class Processor(Iface, TProcessor): result.ase = ase except apache.airavata.api.error.ttypes.AuthorizationException, ae: result.ae = ae - oprot.writeMessageBegin("deleteGatewayDataStoragePreference", TMessageType.REPLY, seqid) + oprot.writeMessageBegin("deleteGatewayStoragePreference", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -36420,13 +36420,13 @@ class addGatewayComputeResourcePreference_result: def __ne__(self, other): return not (self == other) -class addGatewayDataStoragePreference_args: +class addGatewayStoragePreference_args: """ Attributes: - authzToken - gatewayID - dataMoveId - - dataStoragePreference + - storagePreference """ thrift_spec = ( @@ -36434,14 +36434,14 @@ class addGatewayDataStoragePreference_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, 'dataMoveId', None, None, ), # 3 - (4, TType.STRUCT, 'dataStoragePreference', (apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference, apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference.thrift_spec), None, ), # 4 + (4, TType.STRUCT, 'storagePreference', (apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference, apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference.thrift_spec), None, ), # 4 ) - def __init__(self, authzToken=None, gatewayID=None, dataMoveId=None, dataStoragePreference=None,): + def __init__(self, authzToken=None, gatewayID=None, dataMoveId=None, storagePreference=None,): self.authzToken = authzToken self.gatewayID = gatewayID self.dataMoveId = dataMoveId - self.dataStoragePreference = dataStoragePreference + self.storagePreference = storagePreference 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: @@ -36470,8 +36470,8 @@ class addGatewayDataStoragePreference_args: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRUCT: - self.dataStoragePreference = apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference() - self.dataStoragePreference.read(iprot) + self.storagePreference = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() + self.storagePreference.read(iprot) else: iprot.skip(ftype) else: @@ -36483,7 +36483,7 @@ class addGatewayDataStoragePreference_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('addGatewayDataStoragePreference_args') + oprot.writeStructBegin('addGatewayStoragePreference_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -36496,9 +36496,9 @@ class addGatewayDataStoragePreference_args: oprot.writeFieldBegin('dataMoveId', TType.STRING, 3) oprot.writeString(self.dataMoveId) oprot.writeFieldEnd() - if self.dataStoragePreference is not None: - oprot.writeFieldBegin('dataStoragePreference', TType.STRUCT, 4) - self.dataStoragePreference.write(oprot) + if self.storagePreference is not None: + oprot.writeFieldBegin('storagePreference', TType.STRUCT, 4) + self.storagePreference.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -36510,8 +36510,8 @@ class addGatewayDataStoragePreference_args: raise TProtocol.TProtocolException(message='Required field gatewayID is unset!') if self.dataMoveId is None: raise TProtocol.TProtocolException(message='Required field dataMoveId is unset!') - if self.dataStoragePreference is None: - raise TProtocol.TProtocolException(message='Required field dataStoragePreference is unset!') + if self.storagePreference is None: + raise TProtocol.TProtocolException(message='Required field storagePreference is unset!') return @@ -36520,7 +36520,7 @@ class addGatewayDataStoragePreference_args: value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayID) value = (value * 31) ^ hash(self.dataMoveId) - value = (value * 31) ^ hash(self.dataStoragePreference) + value = (value * 31) ^ hash(self.storagePreference) return value def __repr__(self): @@ -36534,7 +36534,7 @@ class addGatewayDataStoragePreference_args: def __ne__(self, other): return not (self == other) -class addGatewayDataStoragePreference_result: +class addGatewayStoragePreference_result: """ Attributes: - success @@ -36606,7 +36606,7 @@ class addGatewayDataStoragePreference_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('addGatewayDataStoragePreference_result') + oprot.writeStructBegin('addGatewayStoragePreference_result') if self.success is not None: oprot.writeFieldBegin('success', TType.BOOL, 0) oprot.writeBool(self.success) @@ -36873,7 +36873,7 @@ class getGatewayComputeResourcePreference_result: def __ne__(self, other): return not (self == other) -class getGatewayDataStoragePreference_args: +class getGatewayStoragePreference_args: """ Attributes: - authzToken @@ -36927,7 +36927,7 @@ class getGatewayDataStoragePreference_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('getGatewayDataStoragePreference_args') + oprot.writeStructBegin('getGatewayStoragePreference_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -36971,7 +36971,7 @@ class getGatewayDataStoragePreference_args: def __ne__(self, other): return not (self == other) -class getGatewayDataStoragePreference_result: +class getGatewayStoragePreference_result: """ Attributes: - success @@ -36982,7 +36982,7 @@ class getGatewayDataStoragePreference_result: """ thrift_spec = ( - (0, TType.STRUCT, 'success', (apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference, apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference.thrift_spec), None, ), # 0 + (0, TType.STRUCT, 'success', (apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference, apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference.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 @@ -37007,7 +37007,7 @@ class getGatewayDataStoragePreference_result: break if fid == 0: if ftype == TType.STRUCT: - self.success = apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference() + self.success = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() self.success.read(iprot) else: iprot.skip(ftype) @@ -37044,7 +37044,7 @@ class getGatewayDataStoragePreference_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('getGatewayDataStoragePreference_result') + oprot.writeStructBegin('getGatewayStoragePreference_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRUCT, 0) self.success.write(oprot) @@ -37304,7 +37304,7 @@ class getAllGatewayComputeResourcePreferences_result: def __ne__(self, other): return not (self == other) -class getAllGatewayDataStoragePreferences_args: +class getAllGatewayStoragePreferences_args: """ Attributes: - authzToken @@ -37350,7 +37350,7 @@ class getAllGatewayDataStoragePreferences_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('getAllGatewayDataStoragePreferences_args') + oprot.writeStructBegin('getAllGatewayStoragePreferences_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -37387,7 +37387,7 @@ class getAllGatewayDataStoragePreferences_args: def __ne__(self, other): return not (self == other) -class getAllGatewayDataStoragePreferences_result: +class getAllGatewayStoragePreferences_result: """ Attributes: - success @@ -37398,7 +37398,7 @@ class getAllGatewayDataStoragePreferences_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference, apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference.thrift_spec)), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference, apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference.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 @@ -37426,7 +37426,7 @@ class getAllGatewayDataStoragePreferences_result: self.success = [] (_etype238, _size235) = iprot.readListBegin() for _i239 in xrange(_size235): - _elem240 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference() + _elem240 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() _elem240.read(iprot) self.success.append(_elem240) iprot.readListEnd() @@ -37465,7 +37465,7 @@ class getAllGatewayDataStoragePreferences_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('getAllGatewayDataStoragePreferences_result') + oprot.writeStructBegin('getAllGatewayStoragePreferences_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) @@ -37947,28 +37947,28 @@ class updateGatewayComputeResourcePreference_result: def __ne__(self, other): return not (self == other) -class updateGatewayDataStoragePreference_args: +class updateGatewayStoragePreference_args: """ Attributes: - authzToken - gatewayID - - dataMoveId - - dataStoragePreference + - storageId + - storagePreference """ 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, 'dataMoveId', None, None, ), # 3 - (4, TType.STRUCT, 'dataStoragePreference', (apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference, apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference.thrift_spec), None, ), # 4 + (3, TType.STRING, 'storageId', None, None, ), # 3 + (4, TType.STRUCT, 'storagePreference', (apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference, apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference.thrift_spec), None, ), # 4 ) - def __init__(self, authzToken=None, gatewayID=None, dataMoveId=None, dataStoragePreference=None,): + def __init__(self, authzToken=None, gatewayID=None, storageId=None, storagePreference=None,): self.authzToken = authzToken self.gatewayID = gatewayID - self.dataMoveId = dataMoveId - self.dataStoragePreference = dataStoragePreference + self.storageId = storageId + self.storagePreference = storagePreference 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: @@ -37992,13 +37992,13 @@ class updateGatewayDataStoragePreference_args: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.dataMoveId = iprot.readString(); + self.storageId = iprot.readString(); else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRUCT: - self.dataStoragePreference = apache.airavata.model.appcatalog.gatewayprofile.ttypes.DataStoragePreference() - self.dataStoragePreference.read(iprot) + self.storagePreference = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() + self.storagePreference.read(iprot) else: iprot.skip(ftype) else: @@ -38010,7 +38010,7 @@ class updateGatewayDataStoragePreference_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('updateGatewayDataStoragePreference_args') + oprot.writeStructBegin('updateGatewayStoragePreference_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -38019,13 +38019,13 @@ class updateGatewayDataStoragePreference_args: oprot.writeFieldBegin('gatewayID', TType.STRING, 2) oprot.writeString(self.gatewayID) oprot.writeFieldEnd() - if self.dataMoveId is not None: - oprot.writeFieldBegin('dataMoveId', TType.STRING, 3) - oprot.writeString(self.dataMoveId) + if self.storageId is not None: + oprot.writeFieldBegin('storageId', TType.STRING, 3) + oprot.writeString(self.storageId) oprot.writeFieldEnd() - if self.dataStoragePreference is not None: - oprot.writeFieldBegin('dataStoragePreference', TType.STRUCT, 4) - self.dataStoragePreference.write(oprot) + if self.storagePreference is not None: + oprot.writeFieldBegin('storagePreference', TType.STRUCT, 4) + self.storagePreference.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -38035,10 +38035,10 @@ class updateGatewayDataStoragePreference_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.dataMoveId is None: - raise TProtocol.TProtocolException(message='Required field dataMoveId is unset!') - if self.dataStoragePreference is None: - raise TProtocol.TProtocolException(message='Required field dataStoragePreference is unset!') + if self.storageId is None: + raise TProtocol.TProtocolException(message='Required field storageId is unset!') + if self.storagePreference is None: + raise TProtocol.TProtocolException(message='Required field storagePreference is unset!') return @@ -38046,8 +38046,8 @@ class updateGatewayDataStoragePreference_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayID) - value = (value * 31) ^ hash(self.dataMoveId) - value = (value * 31) ^ hash(self.dataStoragePreference) + value = (value * 31) ^ hash(self.storageId) + value = (value * 31) ^ hash(self.storagePreference) return value def __repr__(self): @@ -38061,7 +38061,7 @@ class updateGatewayDataStoragePreference_args: def __ne__(self, other): return not (self == other) -class updateGatewayDataStoragePreference_result: +class updateGatewayStoragePreference_result: """ Attributes: - success @@ -38133,7 +38133,7 @@ class updateGatewayDataStoragePreference_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('updateGatewayDataStoragePreference_result') + oprot.writeStructBegin('updateGatewayStoragePreference_result') if self.success is not None: oprot.writeFieldBegin('success', TType.BOOL, 0) oprot.writeBool(self.success) @@ -38399,25 +38399,25 @@ class deleteGatewayComputeResourcePreference_result: def __ne__(self, other): return not (self == other) -class deleteGatewayDataStoragePreference_args: +class deleteGatewayStoragePreference_args: """ Attributes: - authzToken - gatewayID - - dataMoveId + - storageId """ 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, 'dataMoveId', None, None, ), # 3 + (3, TType.STRING, 'storageId', None, None, ), # 3 ) - def __init__(self, authzToken=None, gatewayID=None, dataMoveId=None,): + def __init__(self, authzToken=None, gatewayID=None, storageId=None,): self.authzToken = authzToken self.gatewayID = gatewayID - self.dataMoveId = dataMoveId + self.storageId = storageId 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: @@ -38441,7 +38441,7 @@ class deleteGatewayDataStoragePreference_args: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.dataMoveId = iprot.readString(); + self.storageId = iprot.readString(); else: iprot.skip(ftype) else: @@ -38453,7 +38453,7 @@ class deleteGatewayDataStoragePreference_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('deleteGatewayDataStoragePreference_args') + oprot.writeStructBegin('deleteGatewayStoragePreference_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -38462,9 +38462,9 @@ class deleteGatewayDataStoragePreference_args: oprot.writeFieldBegin('gatewayID', TType.STRING, 2) oprot.writeString(self.gatewayID) oprot.writeFieldEnd() - if self.dataMoveId is not None: - oprot.writeFieldBegin('dataMoveId', TType.STRING, 3) - oprot.writeString(self.dataMoveId) + if self.storageId is not None: + oprot.writeFieldBegin('storageId', TType.STRING, 3) + oprot.writeString(self.storageId) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -38474,8 +38474,8 @@ class deleteGatewayDataStoragePreference_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.dataMoveId is None: - raise TProtocol.TProtocolException(message='Required field dataMoveId is unset!') + if self.storageId is None: + raise TProtocol.TProtocolException(message='Required field storageId is unset!') return @@ -38483,7 +38483,7 @@ class deleteGatewayDataStoragePreference_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayID) - value = (value * 31) ^ hash(self.dataMoveId) + value = (value * 31) ^ hash(self.storageId) return value def __repr__(self): @@ -38497,7 +38497,7 @@ class deleteGatewayDataStoragePreference_args: def __ne__(self, other): return not (self == other) -class deleteGatewayDataStoragePreference_result: +class deleteGatewayStoragePreference_result: """ Attributes: - success @@ -38569,7 +38569,7 @@ class deleteGatewayDataStoragePreference_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('deleteGatewayDataStoragePreference_result') + oprot.writeStructBegin('deleteGatewayStoragePreference_result') if self.success is not None: oprot.writeFieldBegin('success', TType.BOOL, 0) oprot.writeBool(self.success)
http://git-wip-us.apache.org/repos/asf/airavata/blob/13b50f7a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py index 9799e52..941655d 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/gatewayprofile/ttypes.py @@ -225,10 +225,10 @@ class ComputeResourcePreference: def __ne__(self, other): return not (self == other) -class DataStoragePreference: +class StoragePreference: """ Attributes: - - dataMovememtResourceId + - storageResourceId - loginUserName - fileSystemRootLocation - resourceSpecificCredentialStoreToken @@ -236,14 +236,14 @@ class DataStoragePreference: thrift_spec = ( None, # 0 - (1, TType.STRING, 'dataMovememtResourceId', None, None, ), # 1 + (1, TType.STRING, 'storageResourceId', None, None, ), # 1 (2, TType.STRING, 'loginUserName', None, None, ), # 2 (3, TType.STRING, 'fileSystemRootLocation', None, None, ), # 3 (4, TType.STRING, 'resourceSpecificCredentialStoreToken', None, None, ), # 4 ) - def __init__(self, dataMovememtResourceId=None, loginUserName=None, fileSystemRootLocation=None, resourceSpecificCredentialStoreToken=None,): - self.dataMovememtResourceId = dataMovememtResourceId + def __init__(self, storageResourceId=None, loginUserName=None, fileSystemRootLocation=None, resourceSpecificCredentialStoreToken=None,): + self.storageResourceId = storageResourceId self.loginUserName = loginUserName self.fileSystemRootLocation = fileSystemRootLocation self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken @@ -259,7 +259,7 @@ class DataStoragePreference: break if fid == 1: if ftype == TType.STRING: - self.dataMovememtResourceId = iprot.readString(); + self.storageResourceId = iprot.readString(); else: iprot.skip(ftype) elif fid == 2: @@ -286,10 +286,10 @@ class DataStoragePreference: 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('DataStoragePreference') - if self.dataMovememtResourceId is not None: - oprot.writeFieldBegin('dataMovememtResourceId', TType.STRING, 1) - oprot.writeString(self.dataMovememtResourceId) + oprot.writeStructBegin('StoragePreference') + if self.storageResourceId is not None: + oprot.writeFieldBegin('storageResourceId', TType.STRING, 1) + oprot.writeString(self.storageResourceId) oprot.writeFieldEnd() if self.loginUserName is not None: oprot.writeFieldBegin('loginUserName', TType.STRING, 2) @@ -307,14 +307,14 @@ class DataStoragePreference: oprot.writeStructEnd() def validate(self): - if self.dataMovememtResourceId is None: - raise TProtocol.TProtocolException(message='Required field dataMovememtResourceId is unset!') + if self.storageResourceId is None: + raise TProtocol.TProtocolException(message='Required field storageResourceId is unset!') return def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.dataMovememtResourceId) + value = (value * 31) ^ hash(self.storageResourceId) value = (value * 31) ^ hash(self.loginUserName) value = (value * 31) ^ hash(self.fileSystemRootLocation) value = (value * 31) ^ hash(self.resourceSpecificCredentialStoreToken) @@ -349,7 +349,7 @@ class GatewayResourceProfile: - gatewayID - credentialStoreToken - computeResourcePreferences - - dataStoragePreferences + - storagePreferences """ thrift_spec = ( @@ -357,14 +357,14 @@ class GatewayResourceProfile: (1, TType.STRING, 'gatewayID', None, None, ), # 1 (2, TType.STRING, 'credentialStoreToken', None, None, ), # 2 (3, TType.LIST, 'computeResourcePreferences', (TType.STRUCT,(ComputeResourcePreference, ComputeResourcePreference.thrift_spec)), None, ), # 3 - (4, TType.LIST, 'dataStoragePreferences', (TType.STRUCT,(DataStoragePreference, DataStoragePreference.thrift_spec)), None, ), # 4 + (4, TType.LIST, 'storagePreferences', (TType.STRUCT,(StoragePreference, StoragePreference.thrift_spec)), None, ), # 4 ) - def __init__(self, gatewayID=None, credentialStoreToken=None, computeResourcePreferences=None, dataStoragePreferences=None,): + def __init__(self, gatewayID=None, credentialStoreToken=None, computeResourcePreferences=None, storagePreferences=None,): self.gatewayID = gatewayID self.credentialStoreToken = credentialStoreToken self.computeResourcePreferences = computeResourcePreferences - self.dataStoragePreferences = dataStoragePreferences + self.storagePreferences = storagePreferences 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: @@ -398,12 +398,12 @@ class GatewayResourceProfile: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: - self.dataStoragePreferences = [] + self.storagePreferences = [] (_etype9, _size6) = iprot.readListBegin() for _i10 in xrange(_size6): - _elem11 = DataStoragePreference() + _elem11 = StoragePreference() _elem11.read(iprot) - self.dataStoragePreferences.append(_elem11) + self.storagePreferences.append(_elem11) iprot.readListEnd() else: iprot.skip(ftype) @@ -432,10 +432,10 @@ class GatewayResourceProfile: iter12.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() - if self.dataStoragePreferences is not None: - oprot.writeFieldBegin('dataStoragePreferences', TType.LIST, 4) - oprot.writeListBegin(TType.STRUCT, len(self.dataStoragePreferences)) - for iter13 in self.dataStoragePreferences: + if self.storagePreferences is not None: + oprot.writeFieldBegin('storagePreferences', TType.LIST, 4) + oprot.writeListBegin(TType.STRUCT, len(self.storagePreferences)) + for iter13 in self.storagePreferences: iter13.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() @@ -453,7 +453,7 @@ class GatewayResourceProfile: value = (value * 31) ^ hash(self.gatewayID) value = (value * 31) ^ hash(self.credentialStoreToken) value = (value * 31) ^ hash(self.computeResourcePreferences) - value = (value * 31) ^ hash(self.dataStoragePreferences) + value = (value * 31) ^ hash(self.storagePreferences) return value def __repr__(self): http://git-wip-us.apache.org/repos/asf/airavata/blob/13b50f7a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/DataStoragePreference.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/DataStoragePreference.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/DataStoragePreference.java deleted file mode 100644 index c309d41..0000000 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/gatewayprofile/DataStoragePreference.java +++ /dev/null @@ -1,728 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.2) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.airavata.model.appcatalog.gatewayprofile; - -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-11-17") -public class DataStoragePreference implements org.apache.thrift.TBase<DataStoragePreference, DataStoragePreference._Fields>, java.io.Serializable, Cloneable, Comparable<DataStoragePreference> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("DataStoragePreference"); - - private static final org.apache.thrift.protocol.TField DATA_MOVEMEMT_RESOURCE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("dataMovememtResourceId", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField LOGIN_USER_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("loginUserName", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField FILE_SYSTEM_ROOT_LOCATION_FIELD_DESC = new org.apache.thrift.protocol.TField("fileSystemRootLocation", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN_FIELD_DESC = new org.apache.thrift.protocol.TField("resourceSpecificCredentialStoreToken", org.apache.thrift.protocol.TType.STRING, (short)4); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new DataStoragePreferenceStandardSchemeFactory()); - schemes.put(TupleScheme.class, new DataStoragePreferenceTupleSchemeFactory()); - } - - private String dataMovememtResourceId; // required - private String loginUserName; // optional - private String fileSystemRootLocation; // optional - private String resourceSpecificCredentialStoreToken; // optional - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - DATA_MOVEMEMT_RESOURCE_ID((short)1, "dataMovememtResourceId"), - LOGIN_USER_NAME((short)2, "loginUserName"), - FILE_SYSTEM_ROOT_LOCATION((short)3, "fileSystemRootLocation"), - RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN((short)4, "resourceSpecificCredentialStoreToken"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // DATA_MOVEMEMT_RESOURCE_ID - return DATA_MOVEMEMT_RESOURCE_ID; - case 2: // LOGIN_USER_NAME - return LOGIN_USER_NAME; - case 3: // FILE_SYSTEM_ROOT_LOCATION - return FILE_SYSTEM_ROOT_LOCATION; - case 4: // RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN - return RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final _Fields optionals[] = {_Fields.LOGIN_USER_NAME,_Fields.FILE_SYSTEM_ROOT_LOCATION,_Fields.RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN}; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.DATA_MOVEMEMT_RESOURCE_ID, new org.apache.thrift.meta_data.FieldMetaData("dataMovememtResourceId", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.LOGIN_USER_NAME, new org.apache.thrift.meta_data.FieldMetaData("loginUserName", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.FILE_SYSTEM_ROOT_LOCATION, new org.apache.thrift.meta_data.FieldMetaData("fileSystemRootLocation", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN, new org.apache.thrift.meta_data.FieldMetaData("resourceSpecificCredentialStoreToken", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(DataStoragePreference.class, metaDataMap); - } - - public DataStoragePreference() { - } - - public DataStoragePreference( - String dataMovememtResourceId) - { - this(); - this.dataMovememtResourceId = dataMovememtResourceId; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public DataStoragePreference(DataStoragePreference other) { - if (other.isSetDataMovememtResourceId()) { - this.dataMovememtResourceId = other.dataMovememtResourceId; - } - if (other.isSetLoginUserName()) { - this.loginUserName = other.loginUserName; - } - if (other.isSetFileSystemRootLocation()) { - this.fileSystemRootLocation = other.fileSystemRootLocation; - } - if (other.isSetResourceSpecificCredentialStoreToken()) { - this.resourceSpecificCredentialStoreToken = other.resourceSpecificCredentialStoreToken; - } - } - - public DataStoragePreference deepCopy() { - return new DataStoragePreference(this); - } - - @Override - public void clear() { - this.dataMovememtResourceId = null; - this.loginUserName = null; - this.fileSystemRootLocation = null; - this.resourceSpecificCredentialStoreToken = null; - } - - public String getDataMovememtResourceId() { - return this.dataMovememtResourceId; - } - - public void setDataMovememtResourceId(String dataMovememtResourceId) { - this.dataMovememtResourceId = dataMovememtResourceId; - } - - public void unsetDataMovememtResourceId() { - this.dataMovememtResourceId = null; - } - - /** Returns true if field dataMovememtResourceId is set (has been assigned a value) and false otherwise */ - public boolean isSetDataMovememtResourceId() { - return this.dataMovememtResourceId != null; - } - - public void setDataMovememtResourceIdIsSet(boolean value) { - if (!value) { - this.dataMovememtResourceId = null; - } - } - - public String getLoginUserName() { - return this.loginUserName; - } - - public void setLoginUserName(String loginUserName) { - this.loginUserName = loginUserName; - } - - public void unsetLoginUserName() { - this.loginUserName = null; - } - - /** Returns true if field loginUserName is set (has been assigned a value) and false otherwise */ - public boolean isSetLoginUserName() { - return this.loginUserName != null; - } - - public void setLoginUserNameIsSet(boolean value) { - if (!value) { - this.loginUserName = null; - } - } - - public String getFileSystemRootLocation() { - return this.fileSystemRootLocation; - } - - public void setFileSystemRootLocation(String fileSystemRootLocation) { - this.fileSystemRootLocation = fileSystemRootLocation; - } - - public void unsetFileSystemRootLocation() { - this.fileSystemRootLocation = null; - } - - /** Returns true if field fileSystemRootLocation is set (has been assigned a value) and false otherwise */ - public boolean isSetFileSystemRootLocation() { - return this.fileSystemRootLocation != null; - } - - public void setFileSystemRootLocationIsSet(boolean value) { - if (!value) { - this.fileSystemRootLocation = null; - } - } - - public String getResourceSpecificCredentialStoreToken() { - return this.resourceSpecificCredentialStoreToken; - } - - public void setResourceSpecificCredentialStoreToken(String resourceSpecificCredentialStoreToken) { - this.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken; - } - - public void unsetResourceSpecificCredentialStoreToken() { - this.resourceSpecificCredentialStoreToken = null; - } - - /** Returns true if field resourceSpecificCredentialStoreToken is set (has been assigned a value) and false otherwise */ - public boolean isSetResourceSpecificCredentialStoreToken() { - return this.resourceSpecificCredentialStoreToken != null; - } - - public void setResourceSpecificCredentialStoreTokenIsSet(boolean value) { - if (!value) { - this.resourceSpecificCredentialStoreToken = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case DATA_MOVEMEMT_RESOURCE_ID: - if (value == null) { - unsetDataMovememtResourceId(); - } else { - setDataMovememtResourceId((String)value); - } - break; - - case LOGIN_USER_NAME: - if (value == null) { - unsetLoginUserName(); - } else { - setLoginUserName((String)value); - } - break; - - case FILE_SYSTEM_ROOT_LOCATION: - if (value == null) { - unsetFileSystemRootLocation(); - } else { - setFileSystemRootLocation((String)value); - } - break; - - case RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN: - if (value == null) { - unsetResourceSpecificCredentialStoreToken(); - } else { - setResourceSpecificCredentialStoreToken((String)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case DATA_MOVEMEMT_RESOURCE_ID: - return getDataMovememtResourceId(); - - case LOGIN_USER_NAME: - return getLoginUserName(); - - case FILE_SYSTEM_ROOT_LOCATION: - return getFileSystemRootLocation(); - - case RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN: - return getResourceSpecificCredentialStoreToken(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case DATA_MOVEMEMT_RESOURCE_ID: - return isSetDataMovememtResourceId(); - case LOGIN_USER_NAME: - return isSetLoginUserName(); - case FILE_SYSTEM_ROOT_LOCATION: - return isSetFileSystemRootLocation(); - case RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN: - return isSetResourceSpecificCredentialStoreToken(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof DataStoragePreference) - return this.equals((DataStoragePreference)that); - return false; - } - - public boolean equals(DataStoragePreference that) { - if (that == null) - return false; - - boolean this_present_dataMovememtResourceId = true && this.isSetDataMovememtResourceId(); - boolean that_present_dataMovememtResourceId = true && that.isSetDataMovememtResourceId(); - if (this_present_dataMovememtResourceId || that_present_dataMovememtResourceId) { - if (!(this_present_dataMovememtResourceId && that_present_dataMovememtResourceId)) - return false; - if (!this.dataMovememtResourceId.equals(that.dataMovememtResourceId)) - return false; - } - - boolean this_present_loginUserName = true && this.isSetLoginUserName(); - boolean that_present_loginUserName = true && that.isSetLoginUserName(); - if (this_present_loginUserName || that_present_loginUserName) { - if (!(this_present_loginUserName && that_present_loginUserName)) - return false; - if (!this.loginUserName.equals(that.loginUserName)) - return false; - } - - boolean this_present_fileSystemRootLocation = true && this.isSetFileSystemRootLocation(); - boolean that_present_fileSystemRootLocation = true && that.isSetFileSystemRootLocation(); - if (this_present_fileSystemRootLocation || that_present_fileSystemRootLocation) { - if (!(this_present_fileSystemRootLocation && that_present_fileSystemRootLocation)) - return false; - if (!this.fileSystemRootLocation.equals(that.fileSystemRootLocation)) - return false; - } - - boolean this_present_resourceSpecificCredentialStoreToken = true && this.isSetResourceSpecificCredentialStoreToken(); - boolean that_present_resourceSpecificCredentialStoreToken = true && that.isSetResourceSpecificCredentialStoreToken(); - if (this_present_resourceSpecificCredentialStoreToken || that_present_resourceSpecificCredentialStoreToken) { - if (!(this_present_resourceSpecificCredentialStoreToken && that_present_resourceSpecificCredentialStoreToken)) - return false; - if (!this.resourceSpecificCredentialStoreToken.equals(that.resourceSpecificCredentialStoreToken)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_dataMovememtResourceId = true && (isSetDataMovememtResourceId()); - list.add(present_dataMovememtResourceId); - if (present_dataMovememtResourceId) - list.add(dataMovememtResourceId); - - boolean present_loginUserName = true && (isSetLoginUserName()); - list.add(present_loginUserName); - if (present_loginUserName) - list.add(loginUserName); - - boolean present_fileSystemRootLocation = true && (isSetFileSystemRootLocation()); - list.add(present_fileSystemRootLocation); - if (present_fileSystemRootLocation) - list.add(fileSystemRootLocation); - - boolean present_resourceSpecificCredentialStoreToken = true && (isSetResourceSpecificCredentialStoreToken()); - list.add(present_resourceSpecificCredentialStoreToken); - if (present_resourceSpecificCredentialStoreToken) - list.add(resourceSpecificCredentialStoreToken); - - return list.hashCode(); - } - - @Override - public int compareTo(DataStoragePreference other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetDataMovememtResourceId()).compareTo(other.isSetDataMovememtResourceId()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetDataMovememtResourceId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dataMovememtResourceId, other.dataMovememtResourceId); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetLoginUserName()).compareTo(other.isSetLoginUserName()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetLoginUserName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.loginUserName, other.loginUserName); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetFileSystemRootLocation()).compareTo(other.isSetFileSystemRootLocation()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetFileSystemRootLocation()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fileSystemRootLocation, other.fileSystemRootLocation); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetResourceSpecificCredentialStoreToken()).compareTo(other.isSetResourceSpecificCredentialStoreToken()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetResourceSpecificCredentialStoreToken()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.resourceSpecificCredentialStoreToken, other.resourceSpecificCredentialStoreToken); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("DataStoragePreference("); - boolean first = true; - - sb.append("dataMovememtResourceId:"); - if (this.dataMovememtResourceId == null) { - sb.append("null"); - } else { - sb.append(this.dataMovememtResourceId); - } - first = false; - if (isSetLoginUserName()) { - if (!first) sb.append(", "); - sb.append("loginUserName:"); - if (this.loginUserName == null) { - sb.append("null"); - } else { - sb.append(this.loginUserName); - } - first = false; - } - if (isSetFileSystemRootLocation()) { - if (!first) sb.append(", "); - sb.append("fileSystemRootLocation:"); - if (this.fileSystemRootLocation == null) { - sb.append("null"); - } else { - sb.append(this.fileSystemRootLocation); - } - first = false; - } - if (isSetResourceSpecificCredentialStoreToken()) { - if (!first) sb.append(", "); - sb.append("resourceSpecificCredentialStoreToken:"); - if (this.resourceSpecificCredentialStoreToken == null) { - sb.append("null"); - } else { - sb.append(this.resourceSpecificCredentialStoreToken); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!isSetDataMovememtResourceId()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'dataMovememtResourceId' is unset! Struct:" + toString()); - } - - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class DataStoragePreferenceStandardSchemeFactory implements SchemeFactory { - public DataStoragePreferenceStandardScheme getScheme() { - return new DataStoragePreferenceStandardScheme(); - } - } - - private static class DataStoragePreferenceStandardScheme extends StandardScheme<DataStoragePreference> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, DataStoragePreference struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // DATA_MOVEMEMT_RESOURCE_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.dataMovememtResourceId = iprot.readString(); - struct.setDataMovememtResourceIdIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // LOGIN_USER_NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.loginUserName = iprot.readString(); - struct.setLoginUserNameIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // FILE_SYSTEM_ROOT_LOCATION - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.fileSystemRootLocation = iprot.readString(); - struct.setFileSystemRootLocationIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.resourceSpecificCredentialStoreToken = iprot.readString(); - struct.setResourceSpecificCredentialStoreTokenIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, DataStoragePreference struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.dataMovememtResourceId != null) { - oprot.writeFieldBegin(DATA_MOVEMEMT_RESOURCE_ID_FIELD_DESC); - oprot.writeString(struct.dataMovememtResourceId); - oprot.writeFieldEnd(); - } - if (struct.loginUserName != null) { - if (struct.isSetLoginUserName()) { - oprot.writeFieldBegin(LOGIN_USER_NAME_FIELD_DESC); - oprot.writeString(struct.loginUserName); - oprot.writeFieldEnd(); - } - } - if (struct.fileSystemRootLocation != null) { - if (struct.isSetFileSystemRootLocation()) { - oprot.writeFieldBegin(FILE_SYSTEM_ROOT_LOCATION_FIELD_DESC); - oprot.writeString(struct.fileSystemRootLocation); - oprot.writeFieldEnd(); - } - } - if (struct.resourceSpecificCredentialStoreToken != null) { - if (struct.isSetResourceSpecificCredentialStoreToken()) { - oprot.writeFieldBegin(RESOURCE_SPECIFIC_CREDENTIAL_STORE_TOKEN_FIELD_DESC); - oprot.writeString(struct.resourceSpecificCredentialStoreToken); - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class DataStoragePreferenceTupleSchemeFactory implements SchemeFactory { - public DataStoragePreferenceTupleScheme getScheme() { - return new DataStoragePreferenceTupleScheme(); - } - } - - private static class DataStoragePreferenceTupleScheme extends TupleScheme<DataStoragePreference> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, DataStoragePreference struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.dataMovememtResourceId); - BitSet optionals = new BitSet(); - if (struct.isSetLoginUserName()) { - optionals.set(0); - } - if (struct.isSetFileSystemRootLocation()) { - optionals.set(1); - } - if (struct.isSetResourceSpecificCredentialStoreToken()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetLoginUserName()) { - oprot.writeString(struct.loginUserName); - } - if (struct.isSetFileSystemRootLocation()) { - oprot.writeString(struct.fileSystemRootLocation); - } - if (struct.isSetResourceSpecificCredentialStoreToken()) { - oprot.writeString(struct.resourceSpecificCredentialStoreToken); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, DataStoragePreference struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.dataMovememtResourceId = iprot.readString(); - struct.setDataMovememtResourceIdIsSet(true); - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - struct.loginUserName = iprot.readString(); - struct.setLoginUserNameIsSet(true); - } - if (incoming.get(1)) { - struct.fileSystemRootLocation = iprot.readString(); - struct.setFileSystemRootLocationIsSet(true); - } - if (incoming.get(2)) { - struct.resourceSpecificCredentialStoreToken = iprot.readString(); - struct.setResourceSpecificCredentialStoreTokenIsSet(true); - } - } - } - -} -
