You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2015/09/28 19:58:32 UTC
[10/11] airavata git commit: data storage preference related changes
to app catalog
http://git-wip-us.apache.org/repos/asf/airavata/blob/d84783da/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
index c4eeea6..6bf7c2b 100644
--- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
+++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-9-11")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-9-28")
public class Airavata {
public interface Iface {
@@ -1671,6 +1671,8 @@ public class Airavata {
*/
public boolean addGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId, org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference computeResourcePreference) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+ public boolean addGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+
/**
* Fetch a Compute Resource Preference of a registered gateway profile.
*
@@ -1690,6 +1692,8 @@ public class Airavata {
*/
public org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference getGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+ public org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference getGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+
/**
* Fetch all Compute Resource Preferences of a registered gateway profile.
*
@@ -1705,6 +1709,8 @@ public class Airavata {
*/
public List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> getAllGatewayComputeResourcePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+ public List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference> getAllGatewayDataStoragePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+
/**
* Fetch all gateway profiles registered
*
@@ -1736,6 +1742,8 @@ public class Airavata {
*/
public boolean updateGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId, org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference computeResourcePreference) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+ public boolean updateGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+
/**
* Delete the Compute Resource Preference of a registered gateway profile.
*
@@ -1755,6 +1763,8 @@ public class Airavata {
*/
public boolean deleteGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+ public boolean deleteGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+
public List<String> getAllWorkflows(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
public org.apache.airavata.model.Workflow getWorkflow(org.apache.airavata.model.security.AuthzToken authzToken, String workflowTemplateId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
@@ -1985,16 +1995,26 @@ public class Airavata {
public void addGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId, org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference computeResourcePreference, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void addGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getAllGatewayComputeResourcePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getAllGatewayDataStoragePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getAllGatewayComputeResources(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void updateGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId, org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference computeResourcePreference, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void updateGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void deleteGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void deleteGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getAllWorkflows(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getWorkflow(org.apache.airavata.model.security.AuthzToken authzToken, String workflowTemplateId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -5938,6 +5958,44 @@ public class Airavata {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addGatewayComputeResourcePreference failed: unknown result");
}
+ public boolean addGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ send_addGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId, dataStoragePreference);
+ return recv_addGatewayDataStoragePreference();
+ }
+
+ public void send_addGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference) throws org.apache.thrift.TException
+ {
+ addGatewayDataStoragePreference_args args = new addGatewayDataStoragePreference_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.setDataMoveId(dataMoveId);
+ args.setDataStoragePreference(dataStoragePreference);
+ sendBase("addGatewayDataStoragePreference", args);
+ }
+
+ public boolean recv_addGatewayDataStoragePreference() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ addGatewayDataStoragePreference_result result = new addGatewayDataStoragePreference_result();
+ receiveBase(result, "addGatewayDataStoragePreference");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ if (result.ae != null) {
+ throw result.ae;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addGatewayDataStoragePreference failed: unknown result");
+ }
+
public org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference getGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
{
send_getGatewayComputeResourcePreference(authzToken, gatewayID, computeResourceId);
@@ -5975,6 +6033,43 @@ public class Airavata {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getGatewayComputeResourcePreference failed: unknown result");
}
+ public org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference getGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ send_getGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId);
+ return recv_getGatewayDataStoragePreference();
+ }
+
+ public void send_getGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId) throws org.apache.thrift.TException
+ {
+ getGatewayDataStoragePreference_args args = new getGatewayDataStoragePreference_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.setDataMoveId(dataMoveId);
+ sendBase("getGatewayDataStoragePreference", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference recv_getGatewayDataStoragePreference() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ getGatewayDataStoragePreference_result result = new getGatewayDataStoragePreference_result();
+ receiveBase(result, "getGatewayDataStoragePreference");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ if (result.ae != null) {
+ throw result.ae;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getGatewayDataStoragePreference failed: unknown result");
+ }
+
public List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> getAllGatewayComputeResourcePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
{
send_getAllGatewayComputeResourcePreferences(authzToken, gatewayID);
@@ -6011,6 +6106,42 @@ public class Airavata {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllGatewayComputeResourcePreferences failed: unknown result");
}
+ public List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference> getAllGatewayDataStoragePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ send_getAllGatewayDataStoragePreferences(authzToken, gatewayID);
+ return recv_getAllGatewayDataStoragePreferences();
+ }
+
+ public void send_getAllGatewayDataStoragePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID) throws org.apache.thrift.TException
+ {
+ getAllGatewayDataStoragePreferences_args args = new getAllGatewayDataStoragePreferences_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ sendBase("getAllGatewayDataStoragePreferences", args);
+ }
+
+ public List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference> recv_getAllGatewayDataStoragePreferences() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ getAllGatewayDataStoragePreferences_result result = new getAllGatewayDataStoragePreferences_result();
+ receiveBase(result, "getAllGatewayDataStoragePreferences");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ if (result.ae != null) {
+ throw result.ae;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllGatewayDataStoragePreferences failed: unknown result");
+ }
+
public List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile> getAllGatewayComputeResources(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
{
send_getAllGatewayComputeResources(authzToken);
@@ -6084,6 +6215,44 @@ public class Airavata {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateGatewayComputeResourcePreference failed: unknown result");
}
+ public boolean updateGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ send_updateGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId, dataStoragePreference);
+ return recv_updateGatewayDataStoragePreference();
+ }
+
+ public void send_updateGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference) throws org.apache.thrift.TException
+ {
+ updateGatewayDataStoragePreference_args args = new updateGatewayDataStoragePreference_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.setDataMoveId(dataMoveId);
+ args.setDataStoragePreference(dataStoragePreference);
+ sendBase("updateGatewayDataStoragePreference", args);
+ }
+
+ public boolean recv_updateGatewayDataStoragePreference() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ updateGatewayDataStoragePreference_result result = new updateGatewayDataStoragePreference_result();
+ receiveBase(result, "updateGatewayDataStoragePreference");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ if (result.ae != null) {
+ throw result.ae;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateGatewayDataStoragePreference failed: unknown result");
+ }
+
public boolean deleteGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
{
send_deleteGatewayComputeResourcePreference(authzToken, gatewayID, computeResourceId);
@@ -6121,6 +6290,43 @@ public class Airavata {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteGatewayComputeResourcePreference failed: unknown result");
}
+ public boolean deleteGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ send_deleteGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId);
+ return recv_deleteGatewayDataStoragePreference();
+ }
+
+ public void send_deleteGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId) throws org.apache.thrift.TException
+ {
+ deleteGatewayDataStoragePreference_args args = new deleteGatewayDataStoragePreference_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.setDataMoveId(dataMoveId);
+ sendBase("deleteGatewayDataStoragePreference", args);
+ }
+
+ public boolean recv_deleteGatewayDataStoragePreference() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ deleteGatewayDataStoragePreference_result result = new deleteGatewayDataStoragePreference_result();
+ receiveBase(result, "deleteGatewayDataStoragePreference");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ if (result.ae != null) {
+ throw result.ae;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteGatewayDataStoragePreference failed: unknown result");
+ }
+
public List<String> getAllWorkflows(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
{
send_getAllWorkflows(authzToken, gatewayId);
@@ -10379,6 +10585,47 @@ public class Airavata {
}
}
+ public void addGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ addGatewayDataStoragePreference_call method_call = new addGatewayDataStoragePreference_call(authzToken, gatewayID, dataMoveId, dataStoragePreference, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class addGatewayDataStoragePreference_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.security.AuthzToken authzToken;
+ private String gatewayID;
+ private String dataMoveId;
+ private org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference;
+ public addGatewayDataStoragePreference_call(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.authzToken = authzToken;
+ this.gatewayID = gatewayID;
+ this.dataMoveId = dataMoveId;
+ this.dataStoragePreference = dataStoragePreference;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addGatewayDataStoragePreference", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ addGatewayDataStoragePreference_args args = new addGatewayDataStoragePreference_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.setDataMoveId(dataMoveId);
+ args.setDataStoragePreference(dataStoragePreference);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_addGatewayDataStoragePreference();
+ }
+ }
+
public void getGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getGatewayComputeResourcePreference_call method_call = new getGatewayComputeResourcePreference_call(authzToken, gatewayID, computeResourceId, resultHandler, this, ___protocolFactory, ___transport);
@@ -10417,6 +10664,44 @@ public class Airavata {
}
}
+ public void getGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getGatewayDataStoragePreference_call method_call = new getGatewayDataStoragePreference_call(authzToken, gatewayID, dataMoveId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getGatewayDataStoragePreference_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.security.AuthzToken authzToken;
+ private String gatewayID;
+ private String dataMoveId;
+ public getGatewayDataStoragePreference_call(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.authzToken = authzToken;
+ this.gatewayID = gatewayID;
+ this.dataMoveId = dataMoveId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getGatewayDataStoragePreference", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getGatewayDataStoragePreference_args args = new getGatewayDataStoragePreference_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.setDataMoveId(dataMoveId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getGatewayDataStoragePreference();
+ }
+ }
+
public void getAllGatewayComputeResourcePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getAllGatewayComputeResourcePreferences_call method_call = new getAllGatewayComputeResourcePreferences_call(authzToken, gatewayID, resultHandler, this, ___protocolFactory, ___transport);
@@ -10452,6 +10737,41 @@ public class Airavata {
}
}
+ public void getAllGatewayDataStoragePreferences(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getAllGatewayDataStoragePreferences_call method_call = new getAllGatewayDataStoragePreferences_call(authzToken, gatewayID, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getAllGatewayDataStoragePreferences_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.security.AuthzToken authzToken;
+ private String gatewayID;
+ public getAllGatewayDataStoragePreferences_call(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.authzToken = authzToken;
+ this.gatewayID = gatewayID;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllGatewayDataStoragePreferences", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getAllGatewayDataStoragePreferences_args args = new getAllGatewayDataStoragePreferences_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getAllGatewayDataStoragePreferences();
+ }
+ }
+
public void getAllGatewayComputeResources(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getAllGatewayComputeResources_call method_call = new getAllGatewayComputeResources_call(authzToken, resultHandler, this, ___protocolFactory, ___transport);
@@ -10525,6 +10845,47 @@ public class Airavata {
}
}
+ public void updateGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ updateGatewayDataStoragePreference_call method_call = new updateGatewayDataStoragePreference_call(authzToken, gatewayID, dataMoveId, dataStoragePreference, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class updateGatewayDataStoragePreference_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.security.AuthzToken authzToken;
+ private String gatewayID;
+ private String dataMoveId;
+ private org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference;
+ public updateGatewayDataStoragePreference_call(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference dataStoragePreference, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.authzToken = authzToken;
+ this.gatewayID = gatewayID;
+ this.dataMoveId = dataMoveId;
+ this.dataStoragePreference = dataStoragePreference;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateGatewayDataStoragePreference", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ updateGatewayDataStoragePreference_args args = new updateGatewayDataStoragePreference_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.setDataMoveId(dataMoveId);
+ args.setDataStoragePreference(dataStoragePreference);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_updateGatewayDataStoragePreference();
+ }
+ }
+
public void deleteGatewayComputeResourcePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String computeResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
deleteGatewayComputeResourcePreference_call method_call = new deleteGatewayComputeResourcePreference_call(authzToken, gatewayID, computeResourceId, resultHandler, this, ___protocolFactory, ___transport);
@@ -10563,6 +10924,44 @@ public class Airavata {
}
}
+ public void deleteGatewayDataStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ deleteGatewayDataStoragePreference_call method_call = new deleteGatewayDataStoragePreference_call(authzToken, gatewayID, dataMoveId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class deleteGatewayDataStoragePreference_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.security.AuthzToken authzToken;
+ private String gatewayID;
+ private String dataMoveId;
+ public deleteGatewayDataStoragePreference_call(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String dataMoveId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.authzToken = authzToken;
+ this.gatewayID = gatewayID;
+ this.dataMoveId = dataMoveId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteGatewayDataStoragePreference", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ deleteGatewayDataStoragePreference_args args = new deleteGatewayDataStoragePreference_args();
+ args.setAuthzToken(authzToken);
+ args.setGatewayID(gatewayID);
+ args.setDataMoveId(dataMoveId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_deleteGatewayDataStoragePreference();
+ }
+ }
+
public void getAllWorkflows(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getAllWorkflows_call method_call = new getAllWorkflows_call(authzToken, gatewayId, resultHandler, this, ___protocolFactory, ___transport);
@@ -10933,11 +11332,16 @@ public class Airavata {
processMap.put("updateGatewayResourceProfile", new updateGatewayResourceProfile());
processMap.put("deleteGatewayResourceProfile", new deleteGatewayResourceProfile());
processMap.put("addGatewayComputeResourcePreference", new addGatewayComputeResourcePreference());
+ processMap.put("addGatewayDataStoragePreference", new addGatewayDataStoragePreference());
processMap.put("getGatewayComputeResourcePreference", new getGatewayComputeResourcePreference());
+ processMap.put("getGatewayDataStoragePreference", new getGatewayDataStoragePreference());
processMap.put("getAllGatewayComputeResourcePreferences", new getAllGatewayComputeResourcePreferences());
+ processMap.put("getAllGatewayDataStoragePreferences", new getAllGatewayDataStoragePreferences());
processMap.put("getAllGatewayComputeResources", new getAllGatewayComputeResources());
processMap.put("updateGatewayComputeResourcePreference", new updateGatewayComputeResourcePreference());
+ processMap.put("updateGatewayDataStoragePreference", new updateGatewayDataStoragePreference());
processMap.put("deleteGatewayComputeResourcePreference", new deleteGatewayComputeResourcePreference());
+ processMap.put("deleteGatewayDataStoragePreference", new deleteGatewayDataStoragePreference());
processMap.put("getAllWorkflows", new getAllWorkflows());
processMap.put("getWorkflow", new getWorkflow());
processMap.put("deleteWorkflow", new deleteWorkflow());
@@ -14172,6 +14576,37 @@ public class Airavata {
}
}
+ public static class addGatewayDataStoragePreference<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addGatewayDataStoragePreference_args> {
+ public addGatewayDataStoragePreference() {
+ super("addGatewayDataStoragePreference");
+ }
+
+ public addGatewayDataStoragePreference_args getEmptyArgsInstance() {
+ return new addGatewayDataStoragePreference_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public addGatewayDataStoragePreference_result getResult(I iface, addGatewayDataStoragePreference_args args) throws org.apache.thrift.TException {
+ addGatewayDataStoragePreference_result result = new addGatewayDataStoragePreference_result();
+ try {
+ result.success = iface.addGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.dataStoragePreference);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.model.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.model.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.model.error.AiravataSystemException ase) {
+ result.ase = ase;
+ } catch (org.apache.airavata.model.error.AuthorizationException ae) {
+ result.ae = ae;
+ }
+ return result;
+ }
+ }
+
public static class getGatewayComputeResourcePreference<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getGatewayComputeResourcePreference_args> {
public getGatewayComputeResourcePreference() {
super("getGatewayComputeResourcePreference");
@@ -14202,6 +14637,36 @@ public class Airavata {
}
}
+ public static class getGatewayDataStoragePreference<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getGatewayDataStoragePreference_args> {
+ public getGatewayDataStoragePreference() {
+ super("getGatewayDataStoragePreference");
+ }
+
+ public getGatewayDataStoragePreference_args getEmptyArgsInstance() {
+ return new getGatewayDataStoragePreference_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getGatewayDataStoragePreference_result getResult(I iface, getGatewayDataStoragePreference_args args) throws org.apache.thrift.TException {
+ getGatewayDataStoragePreference_result result = new getGatewayDataStoragePreference_result();
+ try {
+ result.success = iface.getGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId);
+ } catch (org.apache.airavata.model.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.model.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.model.error.AiravataSystemException ase) {
+ result.ase = ase;
+ } catch (org.apache.airavata.model.error.AuthorizationException ae) {
+ result.ae = ae;
+ }
+ return result;
+ }
+ }
+
public static class getAllGatewayComputeResourcePreferences<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllGatewayComputeResourcePreferences_args> {
public getAllGatewayComputeResourcePreferences() {
super("getAllGatewayComputeResourcePreferences");
@@ -14232,6 +14697,36 @@ public class Airavata {
}
}
+ public static class getAllGatewayDataStoragePreferences<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllGatewayDataStoragePreferences_args> {
+ public getAllGatewayDataStoragePreferences() {
+ super("getAllGatewayDataStoragePreferences");
+ }
+
+ public getAllGatewayDataStoragePreferences_args getEmptyArgsInstance() {
+ return new getAllGatewayDataStoragePreferences_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getAllGatewayDataStoragePreferences_result getResult(I iface, getAllGatewayDataStoragePreferences_args args) throws org.apache.thrift.TException {
+ getAllGatewayDataStoragePreferences_result result = new getAllGatewayDataStoragePreferences_result();
+ try {
+ result.success = iface.getAllGatewayDataStoragePreferences(args.authzToken, args.gatewayID);
+ } catch (org.apache.airavata.model.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.model.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.model.error.AiravataSystemException ase) {
+ result.ase = ase;
+ } catch (org.apache.airavata.model.error.AuthorizationException ae) {
+ result.ae = ae;
+ }
+ return result;
+ }
+ }
+
public static class getAllGatewayComputeResources<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllGatewayComputeResources_args> {
public getAllGatewayComputeResources() {
super("getAllGatewayComputeResources");
@@ -14293,6 +14788,37 @@ public class Airavata {
}
}
+ public static class updateGatewayDataStoragePreference<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateGatewayDataStoragePreference_args> {
+ public updateGatewayDataStoragePreference() {
+ super("updateGatewayDataStoragePreference");
+ }
+
+ public updateGatewayDataStoragePreference_args getEmptyArgsInstance() {
+ return new updateGatewayDataStoragePreference_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public updateGatewayDataStoragePreference_result getResult(I iface, updateGatewayDataStoragePreference_args args) throws org.apache.thrift.TException {
+ updateGatewayDataStoragePreference_result result = new updateGatewayDataStoragePreference_result();
+ try {
+ result.success = iface.updateGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.dataStoragePreference);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.model.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.model.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.model.error.AiravataSystemException ase) {
+ result.ase = ase;
+ } catch (org.apache.airavata.model.error.AuthorizationException ae) {
+ result.ae = ae;
+ }
+ return result;
+ }
+ }
+
public static class deleteGatewayComputeResourcePreference<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteGatewayComputeResourcePreference_args> {
public deleteGatewayComputeResourcePreference() {
super("deleteGatewayComputeResourcePreference");
@@ -14324,6 +14850,37 @@ public class Airavata {
}
}
+ public static class deleteGatewayDataStoragePreference<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteGatewayDataStoragePreference_args> {
+ public deleteGatewayDataStoragePreference() {
+ super("deleteGatewayDataStoragePreference");
+ }
+
+ public deleteGatewayDataStoragePreference_args getEmptyArgsInstance() {
+ return new deleteGatewayDataStoragePreference_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public deleteGatewayDataStoragePreference_result getResult(I iface, deleteGatewayDataStoragePreference_args args) throws org.apache.thrift.TException {
+ deleteGatewayDataStoragePreference_result result = new deleteGatewayDataStoragePreference_result();
+ try {
+ result.success = iface.deleteGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.model.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.model.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.model.error.AiravataSystemException ase) {
+ result.ase = ase;
+ } catch (org.apache.airavata.model.error.AuthorizationException ae) {
+ result.ae = ae;
+ }
+ return result;
+ }
+ }
+
public static class getAllWorkflows<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllWorkflows_args> {
public getAllWorkflows() {
super("getAllWorkflows");
@@ -14654,11 +15211,16 @@ public class Airavata {
processMap.put("updateGatewayResourceProfile", new updateGatewayResourceProfile());
processMap.put("deleteGatewayResourceProfile", new deleteGatewayResourceProfile());
processMap.put("addGatewayComputeResourcePreference", new addGatewayComputeResourcePreference());
+ processMap.put("addGatewayDataStoragePreference", new addGatewayDataStoragePreference());
processMap.put("getGatewayComputeResourcePreference", new getGatewayComputeResourcePreference());
+ processMap.put("getGatewayDataStoragePreference", new getGatewayDataStoragePreference());
processMap.put("getAllGatewayComputeResourcePreferences", new getAllGatewayComputeResourcePreferences());
+ processMap.put("getAllGatewayDataStoragePreferences", new getAllGatewayDataStoragePreferences());
processMap.put("getAllGatewayComputeResources", new getAllGatewayComputeResources());
processMap.put("updateGatewayComputeResourcePreference", new updateGatewayComputeResourcePreference());
+ processMap.put("updateGatewayDataStoragePreference", new updateGatewayDataStoragePreference());
processMap.put("deleteGatewayComputeResourcePreference", new deleteGatewayComputeResourcePreference());
+ processMap.put("deleteGatewayDataStoragePreference", new deleteGatewayDataStoragePreference());
processMap.put("getAllWorkflows", new getAllWorkflows());
processMap.put("getWorkflow", new getWorkflow());
processMap.put("deleteWorkflow", new deleteWorkflow());
@@ -22356,21 +22918,22 @@ public class Airavata {
}
}
- public static class getGatewayComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGatewayComputeResourcePreference_args, org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> {
- public getGatewayComputeResourcePreference() {
- super("getGatewayComputeResourcePreference");
+ public static class addGatewayDataStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGatewayDataStoragePreference_args, Boolean> {
+ public addGatewayDataStoragePreference() {
+ super("addGatewayDataStoragePreference");
}
- public getGatewayComputeResourcePreference_args getEmptyArgsInstance() {
- return new getGatewayComputeResourcePreference_args();
+ public addGatewayDataStoragePreference_args getEmptyArgsInstance() {
+ return new addGatewayDataStoragePreference_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>() {
- public void onComplete(org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference o) {
- getGatewayComputeResourcePreference_result result = new getGatewayComputeResourcePreference_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ addGatewayDataStoragePreference_result result = new addGatewayDataStoragePreference_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22382,7 +22945,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getGatewayComputeResourcePreference_result result = new getGatewayComputeResourcePreference_result();
+ addGatewayDataStoragePreference_result result = new addGatewayDataStoragePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22423,25 +22986,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getGatewayComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> resultHandler) throws TException {
- iface.getGatewayComputeResourcePreference(args.authzToken, args.gatewayID, args.computeResourceId,resultHandler);
+ public void start(I iface, addGatewayDataStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.addGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.dataStoragePreference,resultHandler);
}
}
- public static class getAllGatewayComputeResourcePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayComputeResourcePreferences_args, List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>> {
- public getAllGatewayComputeResourcePreferences() {
- super("getAllGatewayComputeResourcePreferences");
+ public static class getGatewayComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGatewayComputeResourcePreference_args, org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> {
+ public getGatewayComputeResourcePreference() {
+ super("getGatewayComputeResourcePreference");
}
- public getAllGatewayComputeResourcePreferences_args getEmptyArgsInstance() {
- return new getAllGatewayComputeResourcePreferences_args();
+ public getGatewayComputeResourcePreference_args getEmptyArgsInstance() {
+ return new getGatewayComputeResourcePreference_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> o) {
- getAllGatewayComputeResourcePreferences_result result = new getAllGatewayComputeResourcePreferences_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference o) {
+ getGatewayComputeResourcePreference_result result = new getGatewayComputeResourcePreference_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22454,7 +23017,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllGatewayComputeResourcePreferences_result result = new getAllGatewayComputeResourcePreferences_result();
+ getGatewayComputeResourcePreference_result result = new getGatewayComputeResourcePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22495,25 +23058,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllGatewayComputeResourcePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>> resultHandler) throws TException {
- iface.getAllGatewayComputeResourcePreferences(args.authzToken, args.gatewayID,resultHandler);
+ public void start(I iface, getGatewayComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> resultHandler) throws TException {
+ iface.getGatewayComputeResourcePreference(args.authzToken, args.gatewayID, args.computeResourceId,resultHandler);
}
}
- public static class getAllGatewayComputeResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayComputeResources_args, List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>> {
- public getAllGatewayComputeResources() {
- super("getAllGatewayComputeResources");
+ public static class getGatewayDataStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGatewayDataStoragePreference_args, org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference> {
+ public getGatewayDataStoragePreference() {
+ super("getGatewayDataStoragePreference");
}
- public getAllGatewayComputeResources_args getEmptyArgsInstance() {
- return new getAllGatewayComputeResources_args();
+ public getGatewayDataStoragePreference_args getEmptyArgsInstance() {
+ return new getGatewayDataStoragePreference_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile> o) {
- getAllGatewayComputeResources_result result = new getAllGatewayComputeResources_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference o) {
+ getGatewayDataStoragePreference_result result = new getGatewayDataStoragePreference_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22526,7 +23089,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllGatewayComputeResources_result result = new getAllGatewayComputeResources_result();
+ getGatewayDataStoragePreference_result result = new getGatewayDataStoragePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22567,27 +23130,26 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllGatewayComputeResources_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>> resultHandler) throws TException {
- iface.getAllGatewayComputeResources(args.authzToken,resultHandler);
+ public void start(I iface, getGatewayDataStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference> resultHandler) throws TException {
+ iface.getGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId,resultHandler);
}
}
- public static class updateGatewayComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGatewayComputeResourcePreference_args, Boolean> {
- public updateGatewayComputeResourcePreference() {
- super("updateGatewayComputeResourcePreference");
+ public static class getAllGatewayComputeResourcePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayComputeResourcePreferences_args, List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>> {
+ public getAllGatewayComputeResourcePreferences() {
+ super("getAllGatewayComputeResourcePreferences");
}
- public updateGatewayComputeResourcePreference_args getEmptyArgsInstance() {
- return new updateGatewayComputeResourcePreference_args();
+ public getAllGatewayComputeResourcePreferences_args getEmptyArgsInstance() {
+ return new getAllGatewayComputeResourcePreferences_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- updateGatewayComputeResourcePreference_result result = new updateGatewayComputeResourcePreference_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference> o) {
+ getAllGatewayComputeResourcePreferences_result result = new getAllGatewayComputeResourcePreferences_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22599,7 +23161,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateGatewayComputeResourcePreference_result result = new updateGatewayComputeResourcePreference_result();
+ getAllGatewayComputeResourcePreferences_result result = new getAllGatewayComputeResourcePreferences_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22640,27 +23202,26 @@ public class Airavata {
return false;
}
- public void start(I iface, updateGatewayComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateGatewayComputeResourcePreference(args.authzToken, args.gatewayID, args.computeResourceId, args.computeResourcePreference,resultHandler);
+ public void start(I iface, getAllGatewayComputeResourcePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference>> resultHandler) throws TException {
+ iface.getAllGatewayComputeResourcePreferences(args.authzToken, args.gatewayID,resultHandler);
}
}
- public static class deleteGatewayComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteGatewayComputeResourcePreference_args, Boolean> {
- public deleteGatewayComputeResourcePreference() {
- super("deleteGatewayComputeResourcePreference");
+ public static class getAllGatewayDataStoragePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayDataStoragePreferences_args, List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference>> {
+ public getAllGatewayDataStoragePreferences() {
+ super("getAllGatewayDataStoragePreferences");
}
- public deleteGatewayComputeResourcePreference_args getEmptyArgsInstance() {
- return new deleteGatewayComputeResourcePreference_args();
+ public getAllGatewayDataStoragePreferences_args getEmptyArgsInstance() {
+ return new getAllGatewayDataStoragePreferences_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- deleteGatewayComputeResourcePreference_result result = new deleteGatewayComputeResourcePreference_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference> o) {
+ getAllGatewayDataStoragePreferences_result result = new getAllGatewayDataStoragePreferences_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22672,7 +23233,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteGatewayComputeResourcePreference_result result = new deleteGatewayComputeResourcePreference_result();
+ getAllGatewayDataStoragePreferences_result result = new getAllGatewayDataStoragePreferences_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22713,25 +23274,25 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteGatewayComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteGatewayComputeResourcePreference(args.authzToken, args.gatewayID, args.computeResourceId,resultHandler);
+ public void start(I iface, getAllGatewayDataStoragePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.DataStoragePreference>> resultHandler) throws TException {
+ iface.getAllGatewayDataStoragePreferences(args.authzToken, args.gatewayID,resultHandler);
}
}
- public static class getAllWorkflows<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllWorkflows_args, List<String>> {
- public getAllWorkflows() {
- super("getAllWorkflows");
+ public static class getAllGatewayComputeResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayComputeResources_args, List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>> {
+ public getAllGatewayComputeResources() {
+ super("getAllGatewayComputeResources");
}
- public getAllWorkflows_args getEmptyArgsInstance() {
- return new getAllWorkflows_args();
+ public getAllGatewayComputeResources_args getEmptyArgsInstance() {
+ return new getAllGatewayComputeResources_args();
}
- public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<String>>() {
- public void onComplete(List<String> o) {
- getAllWorkflows_result result = new getAllWorkflows_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile> o) {
+ getAllGatewayComputeResources_result result = new getAllGatewayComputeResources_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22744,7 +23305,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllWorkflows_result result = new getAllWorkflows_result();
+ getAllGatewayComputeResources_result result = new getAllGatewayComputeResources_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22785,26 +23346,27 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllWorkflows_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
- iface.getAllWorkflows(args.authzToken, args.gatewayId,resultHandler);
+ public void start(I iface, getAllGatewayComputeResources_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>> resultHandler) throws TException {
+ iface.getAllGatewayComputeResources(args.authzToken,resultHandler);
}
}
- public static class getWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflow_args, org.apache.airavata.model.Workflow> {
- public getWorkflow() {
- super("getWorkflow");
+ public static class updateGatewayComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGatewayComputeResourcePreference_args, Boolean> {
+ public updateGatewayComputeResourcePreference() {
+ super("updateGatewayComputeResourcePreference");
}
- public getWorkflow_args getEmptyArgsInstance() {
- return new getWorkflow_args();
+ public updateGatewayComputeResourcePreference_args getEmptyArgsInstance() {
+ return new updateGatewayComputeResourcePreference_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.Workflow> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.Workflow>() {
- public void onComplete(org.apache.airavata.model.Workflow o) {
- getWorkflow_result result = new getWorkflow_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ updateGatewayComputeResourcePreference_result result = new updateGatewayComputeResourcePreference_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22816,7 +23378,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getWorkflow_result result = new getWorkflow_result();
+ updateGatewayComputeResourcePreference_result result = new updateGatewayComputeResourcePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22857,25 +23419,27 @@ public class Airavata {
return false;
}
- public void start(I iface, getWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.Workflow> resultHandler) throws TException {
- iface.getWorkflow(args.authzToken, args.workflowTemplateId,resultHandler);
+ public void start(I iface, updateGatewayComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateGatewayComputeResourcePreference(args.authzToken, args.gatewayID, args.computeResourceId, args.computeResourcePreference,resultHandler);
}
}
- public static class deleteWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteWorkflow_args, Void> {
- public deleteWorkflow() {
- super("deleteWorkflow");
+ public static class updateGatewayDataStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGatewayDataStoragePreference_args, Boolean> {
+ public updateGatewayDataStoragePreference() {
+ super("updateGatewayDataStoragePreference");
}
- public deleteWorkflow_args getEmptyArgsInstance() {
- return new deleteWorkflow_args();
+ public updateGatewayDataStoragePreference_args getEmptyArgsInstance() {
+ return new updateGatewayDataStoragePreference_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
- deleteWorkflow_result result = new deleteWorkflow_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ updateGatewayDataStoragePreference_result result = new updateGatewayDataStoragePreference_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22887,7 +23451,368 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteWorkflow_result result = new deleteWorkflow_result();
+ updateGatewayDataStoragePreference_result result = new updateGatewayDataStoragePreference_result();
+ if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
+ result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
+ result.setIreIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
+ result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
+ result.setAceIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
+ result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
+ result.setAseIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.airavata.model.error.AuthorizationException) {
+ result.ae = (org.apache.airavata.model.error.AuthorizationException) e;
+ result.setAeIsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, updateGatewayDataStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.dataStoragePreference,resultHandler);
+ }
+ }
+
+ public static class deleteGatewayComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteGatewayComputeResourcePreference_args, Boolean> {
+ public deleteGatewayComputeResourcePreference() {
+ super("deleteGatewayComputeResourcePreference");
+ }
+
+ public deleteGatewayComputeResourcePreference_args getEmptyArgsInstance() {
+ return new deleteGatewayComputeResourcePreference_args();
+ }
+
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteGatewayComputeResourcePreference_result result = new deleteGatewayComputeResourcePreference_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ deleteGatewayComputeResourcePreference_result result = new deleteGatewayComputeResourcePreference_result();
+ if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
+ result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
+ result.setIreIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
+ result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
+ result.setAceIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
+ result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
+ result.setAseIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.airavata.model.error.AuthorizationException) {
+ result.ae = (org.apache.airavata.model.error.AuthorizationException) e;
+ result.setAeIsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, deleteGatewayComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteGatewayComputeResourcePreference(args.authzToken, args.gatewayID, args.computeResourceId,resultHandler);
+ }
+ }
+
+ public static class deleteGatewayDataStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteGatewayDataStoragePreference_args, Boolean> {
+ public deleteGatewayDataStoragePreference() {
+ super("deleteGatewayDataStoragePreference");
+ }
+
+ public deleteGatewayDataStoragePreference_args getEmptyArgsInstance() {
+ return new deleteGatewayDataStoragePreference_args();
+ }
+
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteGatewayDataStoragePreference_result result = new deleteGatewayDataStoragePreference_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ deleteGatewayDataStoragePreference_result result = new deleteGatewayDataStoragePreference_result();
+ if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
+ result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
+ result.setIreIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.airavata.model.error.AiravataClientExce
<TRUNCATED>