You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/05/02 22:57:11 UTC
[4/5] airavata git commit: removing get all user SSH keys
http://git-wip-us.apache.org/repos/asf/airavata/blob/e1013926/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 d395425..b638076 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
@@ -263,25 +263,6 @@ public class Airavata {
/**
*
- * Get a Public Key by Providing the Token
- *
- * @param CredStoreToken
- * Credential Store Token which you want to find the Public Key for.
- *
- * @param gatewayId
- * This is the unique identifier of your gateway where the token and public key was generated from.
- *
- * @return SSHpubKey
- *
- *
- *
- * @param authzToken
- * @param userName
- */
- public Map<String,String> getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
-
- /**
- *
* Get all Public Keys of the Gateway
*
* @param CredStoreToken
@@ -2739,8 +2720,6 @@ public class Airavata {
public void getSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
public void getAllGatewaySSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getAllGatewayPWDCredentials(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -3594,39 +3573,6 @@ public class Airavata {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSSHPubKey failed: unknown result");
}
- public Map<String,String> getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
- {
- send_getAllUserSSHPubKeys(authzToken, userName);
- return recv_getAllUserSSHPubKeys();
- }
-
- public void send_getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName) throws org.apache.thrift.TException
- {
- getAllUserSSHPubKeys_args args = new getAllUserSSHPubKeys_args();
- args.setAuthzToken(authzToken);
- args.setUserName(userName);
- sendBase("getAllUserSSHPubKeys", args);
- }
-
- public Map<String,String> recv_getAllUserSSHPubKeys() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
- {
- getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result();
- receiveBase(result, "getAllUserSSHPubKeys");
- 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;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllUserSSHPubKeys failed: unknown result");
- }
-
public Map<String,String> getAllGatewaySSHPubKeys(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.thrift.TException
{
send_getAllGatewaySSHPubKeys(authzToken, gatewayId);
@@ -9013,41 +8959,6 @@ public class Airavata {
}
}
- public void getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- getAllUserSSHPubKeys_call method_call = new getAllUserSSHPubKeys_call(authzToken, userName, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getAllUserSSHPubKeys_call extends org.apache.thrift.async.TAsyncMethodCall {
- private org.apache.airavata.model.security.AuthzToken authzToken;
- private String userName;
- public getAllUserSSHPubKeys_call(org.apache.airavata.model.security.AuthzToken authzToken, String userName, 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.userName = userName;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllUserSSHPubKeys", org.apache.thrift.protocol.TMessageType.CALL, 0));
- getAllUserSSHPubKeys_args args = new getAllUserSSHPubKeys_args();
- args.setAuthzToken(authzToken);
- args.setUserName(userName);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public Map<String,String> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, 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_getAllUserSSHPubKeys();
- }
- }
-
public void getAllGatewaySSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getAllGatewaySSHPubKeys_call method_call = new getAllGatewaySSHPubKeys_call(authzToken, gatewayId, resultHandler, this, ___protocolFactory, ___transport);
@@ -13966,7 +13877,6 @@ public class Airavata {
processMap.put("generateAndRegisterSSHKeys", new generateAndRegisterSSHKeys());
processMap.put("registerPwdCredential", new registerPwdCredential());
processMap.put("getSSHPubKey", new getSSHPubKey());
- processMap.put("getAllUserSSHPubKeys", new getAllUserSSHPubKeys());
processMap.put("getAllGatewaySSHPubKeys", new getAllGatewaySSHPubKeys());
processMap.put("getAllGatewayPWDCredentials", new getAllGatewayPWDCredentials());
processMap.put("deleteSSHPubKey", new deleteSSHPubKey());
@@ -14579,34 +14489,6 @@ public class Airavata {
}
}
- public static class getAllUserSSHPubKeys<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllUserSSHPubKeys_args> {
- public getAllUserSSHPubKeys() {
- super("getAllUserSSHPubKeys");
- }
-
- public getAllUserSSHPubKeys_args getEmptyArgsInstance() {
- return new getAllUserSSHPubKeys_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public getAllUserSSHPubKeys_result getResult(I iface, getAllUserSSHPubKeys_args args) throws org.apache.thrift.TException {
- getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result();
- try {
- result.success = iface.getAllUserSSHPubKeys(args.authzToken, args.userName);
- } 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;
- }
- return result;
- }
- }
-
public static class getAllGatewaySSHPubKeys<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllGatewaySSHPubKeys_args> {
public getAllGatewaySSHPubKeys() {
super("getAllGatewaySSHPubKeys");
@@ -18589,7 +18471,6 @@ public class Airavata {
processMap.put("generateAndRegisterSSHKeys", new generateAndRegisterSSHKeys());
processMap.put("registerPwdCredential", new registerPwdCredential());
processMap.put("getSSHPubKey", new getSSHPubKey());
- processMap.put("getAllUserSSHPubKeys", new getAllUserSSHPubKeys());
processMap.put("getAllGatewaySSHPubKeys", new getAllGatewaySSHPubKeys());
processMap.put("getAllGatewayPWDCredentials", new getAllGatewayPWDCredentials());
processMap.put("deleteSSHPubKey", new deleteSSHPubKey());
@@ -19864,20 +19745,20 @@ public class Airavata {
}
}
- public static class getAllUserSSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserSSHPubKeys_args, Map<String,String>> {
- public getAllUserSSHPubKeys() {
- super("getAllUserSSHPubKeys");
+ public static class getAllGatewaySSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewaySSHPubKeys_args, Map<String,String>> {
+ public getAllGatewaySSHPubKeys() {
+ super("getAllGatewaySSHPubKeys");
}
- public getAllUserSSHPubKeys_args getEmptyArgsInstance() {
- return new getAllUserSSHPubKeys_args();
+ public getAllGatewaySSHPubKeys_args getEmptyArgsInstance() {
+ return new getAllGatewaySSHPubKeys_args();
}
public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Map<String,String>>() {
public void onComplete(Map<String,String> o) {
- getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result();
+ getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -19890,7 +19771,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result();
+ getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -19926,25 +19807,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllUserSSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAllUserSSHPubKeys(args.authzToken, args.userName,resultHandler);
+ public void start(I iface, getAllGatewaySSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
+ iface.getAllGatewaySSHPubKeys(args.authzToken, args.gatewayId,resultHandler);
}
}
- public static class getAllGatewaySSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewaySSHPubKeys_args, Map<String,String>> {
- public getAllGatewaySSHPubKeys() {
- super("getAllGatewaySSHPubKeys");
+ public static class getAllGatewayPWDCredentials<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayPWDCredentials_args, Map<String,String>> {
+ public getAllGatewayPWDCredentials() {
+ super("getAllGatewayPWDCredentials");
}
- public getAllGatewaySSHPubKeys_args getEmptyArgsInstance() {
- return new getAllGatewaySSHPubKeys_args();
+ public getAllGatewayPWDCredentials_args getEmptyArgsInstance() {
+ return new getAllGatewayPWDCredentials_args();
}
public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Map<String,String>>() {
public void onComplete(Map<String,String> o) {
- getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result();
+ getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -19957,7 +19838,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result();
+ getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -19993,26 +19874,27 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllGatewaySSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAllGatewaySSHPubKeys(args.authzToken, args.gatewayId,resultHandler);
+ public void start(I iface, getAllGatewayPWDCredentials_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
+ iface.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId,resultHandler);
}
}
- public static class getAllGatewayPWDCredentials<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayPWDCredentials_args, Map<String,String>> {
- public getAllGatewayPWDCredentials() {
- super("getAllGatewayPWDCredentials");
+ public static class deleteSSHPubKey<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteSSHPubKey_args, Boolean> {
+ public deleteSSHPubKey() {
+ super("deleteSSHPubKey");
}
- public getAllGatewayPWDCredentials_args getEmptyArgsInstance() {
- return new getAllGatewayPWDCredentials_args();
+ public deleteSSHPubKey_args getEmptyArgsInstance() {
+ return new deleteSSHPubKey_args();
}
- public AsyncMethodCallback<Map<String,String>> 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<Map<String,String>>() {
- public void onComplete(Map<String,String> o) {
- getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteSSHPubKey_result result = new deleteSSHPubKey_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -20024,7 +19906,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result();
+ deleteSSHPubKey_result result = new deleteSSHPubKey_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20060,25 +19942,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllGatewayPWDCredentials_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId,resultHandler);
+ public void start(I iface, deleteSSHPubKey_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler);
}
}
- public static class deleteSSHPubKey<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteSSHPubKey_args, Boolean> {
- public deleteSSHPubKey() {
- super("deleteSSHPubKey");
+ public static class deletePWDCredential<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePWDCredential_args, Boolean> {
+ public deletePWDCredential() {
+ super("deletePWDCredential");
}
- public deleteSSHPubKey_args getEmptyArgsInstance() {
- return new deleteSSHPubKey_args();
+ public deletePWDCredential_args getEmptyArgsInstance() {
+ return new deletePWDCredential_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) {
- deleteSSHPubKey_result result = new deleteSSHPubKey_result();
+ deletePWDCredential_result result = new deletePWDCredential_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -20092,7 +19974,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteSSHPubKey_result result = new deleteSSHPubKey_result();
+ deletePWDCredential_result result = new deletePWDCredential_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20128,27 +20010,26 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteSSHPubKey_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler);
+ public void start(I iface, deletePWDCredential_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deletePWDCredential(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler);
}
}
- public static class deletePWDCredential<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePWDCredential_args, Boolean> {
- public deletePWDCredential() {
- super("deletePWDCredential");
+ public static class createProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createProject_args, String> {
+ public createProject() {
+ super("createProject");
}
- public deletePWDCredential_args getEmptyArgsInstance() {
- return new deletePWDCredential_args();
+ public createProject_args getEmptyArgsInstance() {
+ return new createProject_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- deletePWDCredential_result result = new deletePWDCredential_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ createProject_result result = new createProject_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -20160,7 +20041,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deletePWDCredential_result result = new deletePWDCredential_result();
+ createProject_result result = new createProject_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20176,6 +20057,11 @@ public class Airavata {
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;
@@ -20196,25 +20082,101 @@ public class Airavata {
return false;
}
- public void start(I iface, deletePWDCredential_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deletePWDCredential(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler);
+ public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.createProject(args.authzToken, args.gatewayId, args.project,resultHandler);
}
}
- public static class createProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createProject_args, String> {
- public createProject() {
- super("createProject");
+ public static class updateProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateProject_args, Void> {
+ public updateProject() {
+ super("updateProject");
}
- public createProject_args getEmptyArgsInstance() {
- return new createProject_args();
+ public updateProject_args getEmptyArgsInstance() {
+ return new updateProject_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- createProject_result result = new createProject_result();
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ updateProject_result result = new updateProject_result();
+ 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;
+ updateProject_result result = new updateProject_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.ProjectNotFoundException) {
+ result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e;
+ result.setPnfeIsSet(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, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.updateProject(args.authzToken, args.projectId, args.updatedProject,resultHandler);
+ }
+ }
+
+ public static class getProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getProject_args, org.apache.airavata.model.workspace.Project> {
+ public getProject() {
+ super("getProject");
+ }
+
+ public getProject_args getEmptyArgsInstance() {
+ return new getProject_args();
+ }
+
+ public AsyncMethodCallback<org.apache.airavata.model.workspace.Project> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<org.apache.airavata.model.workspace.Project>() {
+ public void onComplete(org.apache.airavata.model.workspace.Project o) {
+ getProject_result result = new getProject_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20227,7 +20189,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- createProject_result result = new createProject_result();
+ getProject_result result = new getProject_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20243,6 +20205,11 @@ public class Airavata {
result.setAseIsSet(true);
msg = result;
}
+ else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) {
+ result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e;
+ result.setPnfeIsSet(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);
@@ -20268,25 +20235,27 @@ public class Airavata {
return false;
}
- public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.createProject(args.authzToken, args.gatewayId, args.project,resultHandler);
+ public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Project> resultHandler) throws TException {
+ iface.getProject(args.authzToken, args.projectId,resultHandler);
}
}
- public static class updateProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateProject_args, Void> {
- public updateProject() {
- super("updateProject");
+ public static class deleteProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteProject_args, Boolean> {
+ public deleteProject() {
+ super("deleteProject");
}
- public updateProject_args getEmptyArgsInstance() {
- return new updateProject_args();
+ public deleteProject_args getEmptyArgsInstance() {
+ return new deleteProject_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) {
- updateProject_result result = new updateProject_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteProject_result result = new deleteProject_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -20298,7 +20267,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateProject_result result = new updateProject_result();
+ deleteProject_result result = new deleteProject_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20344,25 +20313,25 @@ public class Airavata {
return false;
}
- public void start(I iface, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.updateProject(args.authzToken, args.projectId, args.updatedProject,resultHandler);
+ public void start(I iface, deleteProject_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteProject(args.authzToken, args.projectId,resultHandler);
}
}
- public static class getProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getProject_args, org.apache.airavata.model.workspace.Project> {
- public getProject() {
- super("getProject");
+ public static class getUserProjects<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserProjects_args, List<org.apache.airavata.model.workspace.Project>> {
+ public getUserProjects() {
+ super("getUserProjects");
}
- public getProject_args getEmptyArgsInstance() {
- return new getProject_args();
+ public getUserProjects_args getEmptyArgsInstance() {
+ return new getUserProjects_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.workspace.Project> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.workspace.Project>() {
- public void onComplete(org.apache.airavata.model.workspace.Project o) {
- getProject_result result = new getProject_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() {
+ public void onComplete(List<org.apache.airavata.model.workspace.Project> o) {
+ getUserProjects_result result = new getUserProjects_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20375,7 +20344,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getProject_result result = new getProject_result();
+ getUserProjects_result result = new getUserProjects_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20391,11 +20360,6 @@ public class Airavata {
result.setAseIsSet(true);
msg = result;
}
- else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) {
- result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e;
- result.setPnfeIsSet(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);
@@ -20421,27 +20385,26 @@ public class Airavata {
return false;
}
- public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Project> resultHandler) throws TException {
- iface.getProject(args.authzToken, args.projectId,resultHandler);
+ public void start(I iface, getUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException {
+ iface.getUserProjects(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler);
}
}
- public static class deleteProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteProject_args, Boolean> {
- public deleteProject() {
- super("deleteProject");
+ public static class searchProjectsByProjectName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectName_args, List<org.apache.airavata.model.workspace.Project>> {
+ public searchProjectsByProjectName() {
+ super("searchProjectsByProjectName");
}
- public deleteProject_args getEmptyArgsInstance() {
- return new deleteProject_args();
+ public searchProjectsByProjectName_args getEmptyArgsInstance() {
+ return new searchProjectsByProjectName_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- deleteProject_result result = new deleteProject_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() {
+ public void onComplete(List<org.apache.airavata.model.workspace.Project> o) {
+ searchProjectsByProjectName_result result = new searchProjectsByProjectName_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -20453,7 +20416,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteProject_result result = new deleteProject_result();
+ searchProjectsByProjectName_result result = new searchProjectsByProjectName_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20469,11 +20432,6 @@ public class Airavata {
result.setAseIsSet(true);
msg = result;
}
- else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) {
- result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e;
- result.setPnfeIsSet(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);
@@ -20499,25 +20457,25 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteProject_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteProject(args.authzToken, args.projectId,resultHandler);
+ public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException {
+ iface.searchProjectsByProjectName(args.authzToken, args.gatewayId, args.userName, args.projectName, args.limit, args.offset,resultHandler);
}
}
- public static class getUserProjects<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserProjects_args, List<org.apache.airavata.model.workspace.Project>> {
- public getUserProjects() {
- super("getUserProjects");
+ public static class searchProjectsByProjectDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectDesc_args, List<org.apache.airavata.model.workspace.Project>> {
+ public searchProjectsByProjectDesc() {
+ super("searchProjectsByProjectDesc");
}
- public getUserProjects_args getEmptyArgsInstance() {
- return new getUserProjects_args();
+ public searchProjectsByProjectDesc_args getEmptyArgsInstance() {
+ return new searchProjectsByProjectDesc_args();
}
public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() {
public void onComplete(List<org.apache.airavata.model.workspace.Project> o) {
- getUserProjects_result result = new getUserProjects_result();
+ searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20530,7 +20488,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getUserProjects_result result = new getUserProjects_result();
+ searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20571,25 +20529,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException {
- iface.getUserProjects(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler);
+ public void start(I iface, searchProjectsByProjectDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException {
+ iface.searchProjectsByProjectDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler);
}
}
- public static class searchProjectsByProjectName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectName_args, List<org.apache.airavata.model.workspace.Project>> {
- public searchProjectsByProjectName() {
- super("searchProjectsByProjectName");
+ public static class searchExperimentsByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByName_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
+ public searchExperimentsByName() {
+ super("searchExperimentsByName");
}
- public searchProjectsByProjectName_args getEmptyArgsInstance() {
- return new searchProjectsByProjectName_args();
+ public searchExperimentsByName_args getEmptyArgsInstance() {
+ return new searchExperimentsByName_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() {
- public void onComplete(List<org.apache.airavata.model.workspace.Project> o) {
- searchProjectsByProjectName_result result = new searchProjectsByProjectName_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() {
+ public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) {
+ searchExperimentsByName_result result = new searchExperimentsByName_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20602,7 +20560,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- searchProjectsByProjectName_result result = new searchProjectsByProjectName_result();
+ searchExperimentsByName_result result = new searchExperimentsByName_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20643,25 +20601,25 @@ public class Airavata {
return false;
}
- public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException {
- iface.searchProjectsByProjectName(args.authzToken, args.gatewayId, args.userName, args.projectName, args.limit, args.offset,resultHandler);
+ public void start(I iface, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
+ iface.searchExperimentsByName(args.authzToken, args.gatewayId, args.userName, args.expName, args.limit, args.offset,resultHandler);
}
}
- public static class searchProjectsByProjectDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectDesc_args, List<org.apache.airavata.model.workspace.Project>> {
- public searchProjectsByProjectDesc() {
- super("searchProjectsByProjectDesc");
+ public static class searchExperimentsByDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByDesc_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
+ public searchExperimentsByDesc() {
+ super("searchExperimentsByDesc");
}
- public searchProjectsByProjectDesc_args getEmptyArgsInstance() {
- return new searchProjectsByProjectDesc_args();
+ public searchExperimentsByDesc_args getEmptyArgsInstance() {
+ return new searchExperimentsByDesc_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() {
- public void onComplete(List<org.apache.airavata.model.workspace.Project> o) {
- searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() {
+ public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) {
+ searchExperimentsByDesc_result result = new searchExperimentsByDesc_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20674,7 +20632,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result();
+ searchExperimentsByDesc_result result = new searchExperimentsByDesc_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20715,25 +20673,25 @@ public class Airavata {
return false;
}
- public void start(I iface, searchProjectsByProjectDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException {
- iface.searchProjectsByProjectDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler);
+ public void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
+ iface.searchExperimentsByDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler);
}
}
- public static class searchExperimentsByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByName_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
- public searchExperimentsByName() {
- super("searchExperimentsByName");
+ public static class searchExperimentsByApplication<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByApplication_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
+ public searchExperimentsByApplication() {
+ super("searchExperimentsByApplication");
}
- public searchExperimentsByName_args getEmptyArgsInstance() {
- return new searchExperimentsByName_args();
+ public searchExperimentsByApplication_args getEmptyArgsInstance() {
+ return new searchExperimentsByApplication_args();
}
public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() {
public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) {
- searchExperimentsByName_result result = new searchExperimentsByName_result();
+ searchExperimentsByApplication_result result = new searchExperimentsByApplication_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20746,7 +20704,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- searchExperimentsByName_result result = new searchExperimentsByName_result();
+ searchExperimentsByApplication_result result = new searchExperimentsByApplication_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20787,25 +20745,25 @@ public class Airavata {
return false;
}
- public void start(I iface, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
- iface.searchExperimentsByName(args.authzToken, args.gatewayId, args.userName, args.expName, args.limit, args.offset,resultHandler);
+ public void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
+ iface.searchExperimentsByApplication(args.authzToken, args.gatewayId, args.userName, args.applicationId, args.limit, args.offset,resultHandler);
}
}
- public static class searchExperimentsByDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByDesc_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
- public searchExperimentsByDesc() {
- super("searchExperimentsByDesc");
+ public static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
+ public searchExperimentsByStatus() {
+ super("searchExperimentsByStatus");
}
- public searchExperimentsByDesc_args getEmptyArgsInstance() {
- return new searchExperimentsByDesc_args();
+ public searchExperimentsByStatus_args getEmptyArgsInstance() {
+ return new searchExperimentsByStatus_args();
}
public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() {
public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) {
- searchExperimentsByDesc_result result = new searchExperimentsByDesc_result();
+ searchExperimentsByStatus_result result = new searchExperimentsByStatus_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20818,7 +20776,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- searchExperimentsByDesc_result result = new searchExperimentsByDesc_result();
+ searchExperimentsByStatus_result result = new searchExperimentsByStatus_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20859,25 +20817,25 @@ public class Airavata {
return false;
}
- public void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
- iface.searchExperimentsByDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler);
+ public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
+ iface.searchExperimentsByStatus(args.authzToken, args.gatewayId, args.userName, args.experimentState, args.limit, args.offset,resultHandler);
}
}
- public static class searchExperimentsByApplication<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByApplication_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
- public searchExperimentsByApplication() {
- super("searchExperimentsByApplication");
+ public static class searchExperimentsByCreationTime<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByCreationTime_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
+ public searchExperimentsByCreationTime() {
+ super("searchExperimentsByCreationTime");
}
- public searchExperimentsByApplication_args getEmptyArgsInstance() {
- return new searchExperimentsByApplication_args();
+ public searchExperimentsByCreationTime_args getEmptyArgsInstance() {
+ return new searchExperimentsByCreationTime_args();
}
public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() {
public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) {
- searchExperimentsByApplication_result result = new searchExperimentsByApplication_result();
+ searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20890,7 +20848,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- searchExperimentsByApplication_result result = new searchExperimentsByApplication_result();
+ searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -20931,25 +20889,25 @@ public class Airavata {
return false;
}
- public void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
- iface.searchExperimentsByApplication(args.authzToken, args.gatewayId, args.userName, args.applicationId, args.limit, args.offset,resultHandler);
+ public void start(I iface, searchExperimentsByCreationTime_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
+ iface.searchExperimentsByCreationTime(args.authzToken, args.gatewayId, args.userName, args.fromTime, args.toTime, args.limit, args.offset,resultHandler);
}
}
- public static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
- public searchExperimentsByStatus() {
- super("searchExperimentsByStatus");
+ public static class searchExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperiments_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
+ public searchExperiments() {
+ super("searchExperiments");
}
- public searchExperimentsByStatus_args getEmptyArgsInstance() {
- return new searchExperimentsByStatus_args();
+ public searchExperiments_args getEmptyArgsInstance() {
+ return new searchExperiments_args();
}
public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() {
public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) {
- searchExperimentsByStatus_result result = new searchExperimentsByStatus_result();
+ searchExperiments_result result = new searchExperiments_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -20962,7 +20920,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- searchExperimentsByStatus_result result = new searchExperimentsByStatus_result();
+ searchExperiments_result result = new searchExperiments_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21003,25 +20961,25 @@ public class Airavata {
return false;
}
- public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
- iface.searchExperimentsByStatus(args.authzToken, args.gatewayId, args.userName, args.experimentState, args.limit, args.offset,resultHandler);
+ public void start(I iface, searchExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
+ iface.searchExperiments(args.authzToken, args.gatewayId, args.userName, args.filters, args.limit, args.offset,resultHandler);
}
}
- public static class searchExperimentsByCreationTime<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByCreationTime_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
- public searchExperimentsByCreationTime() {
- super("searchExperimentsByCreationTime");
+ public static class getExperimentStatistics<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatistics_args, org.apache.airavata.model.experiment.ExperimentStatistics> {
+ public getExperimentStatistics() {
+ super("getExperimentStatistics");
}
- public searchExperimentsByCreationTime_args getEmptyArgsInstance() {
- return new searchExperimentsByCreationTime_args();
+ public getExperimentStatistics_args getEmptyArgsInstance() {
+ return new getExperimentStatistics_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() {
- public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) {
- searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics>() {
+ public void onComplete(org.apache.airavata.model.experiment.ExperimentStatistics o) {
+ getExperimentStatistics_result result = new getExperimentStatistics_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -21034,7 +20992,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result();
+ getExperimentStatistics_result result = new getExperimentStatistics_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21075,25 +21033,25 @@ public class Airavata {
return false;
}
- public void start(I iface, searchExperimentsByCreationTime_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
- iface.searchExperimentsByCreationTime(args.authzToken, args.gatewayId, args.userName, args.fromTime, args.toTime, args.limit, args.offset,resultHandler);
+ public void start(I iface, getExperimentStatistics_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> resultHandler) throws TException {
+ iface.getExperimentStatistics(args.authzToken, args.gatewayId, args.fromTime, args.toTime,resultHandler);
}
}
- public static class searchExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperiments_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> {
- public searchExperiments() {
- super("searchExperiments");
+ public static class getExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentsInProject_args, List<org.apache.airavata.model.experiment.ExperimentModel>> {
+ public getExperimentsInProject() {
+ super("getExperimentsInProject");
}
- public searchExperiments_args getEmptyArgsInstance() {
- return new searchExperiments_args();
+ public getExperimentsInProject_args getEmptyArgsInstance() {
+ return new getExperimentsInProject_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() {
- public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) {
- searchExperiments_result result = new searchExperiments_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>>() {
+ public void onComplete(List<org.apache.airavata.model.experiment.ExperimentModel> o) {
+ getExperimentsInProject_result result = new getExperimentsInProject_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -21106,7 +21064,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- searchExperiments_result result = new searchExperiments_result();
+ getExperimentsInProject_result result = new getExperimentsInProject_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21122,6 +21080,11 @@ public class Airavata {
result.setAseIsSet(true);
msg = result;
}
+ else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) {
+ result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e;
+ result.setPnfeIsSet(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);
@@ -21147,25 +21110,25 @@ public class Airavata {
return false;
}
- public void start(I iface, searchExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException {
- iface.searchExperiments(args.authzToken, args.gatewayId, args.userName, args.filters, args.limit, args.offset,resultHandler);
+ public void start(I iface, getExperimentsInProject_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> resultHandler) throws TException {
+ iface.getExperimentsInProject(args.authzToken, args.projectId, args.limit, args.offset,resultHandler);
}
}
- public static class getExperimentStatistics<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatistics_args, org.apache.airavata.model.experiment.ExperimentStatistics> {
- public getExperimentStatistics() {
- super("getExperimentStatistics");
+ public static class getUserExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserExperiments_args, List<org.apache.airavata.model.experiment.ExperimentModel>> {
+ public getUserExperiments() {
+ super("getUserExperiments");
}
- public getExperimentStatistics_args getEmptyArgsInstance() {
- return new getExperimentStatistics_args();
+ public getUserExperiments_args getEmptyArgsInstance() {
+ return new getUserExperiments_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics>() {
- public void onComplete(org.apache.airavata.model.experiment.ExperimentStatistics o) {
- getExperimentStatistics_result result = new getExperimentStatistics_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>>() {
+ public void onComplete(List<org.apache.airavata.model.experiment.ExperimentModel> o) {
+ getUserExperiments_result result = new getUserExperiments_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -21178,7 +21141,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getExperimentStatistics_result result = new getExperimentStatistics_result();
+ getUserExperiments_result result = new getUserExperiments_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21219,25 +21182,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getExperimentStatistics_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> resultHandler) throws TException {
- iface.getExperimentStatistics(args.authzToken, args.gatewayId, args.fromTime, args.toTime,resultHandler);
+ public void start(I iface, getUserExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> resultHandler) throws TException {
+ iface.getUserExperiments(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler);
}
}
- public static class getExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentsInProject_args, List<org.apache.airavata.model.experiment.ExperimentModel>> {
- public getExperimentsInProject() {
- super("getExperimentsInProject");
+ public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> {
+ public createExperiment() {
+ super("createExperiment");
}
- public getExperimentsInProject_args getEmptyArgsInstance() {
- return new getExperimentsInProject_args();
+ public createExperiment_args getEmptyArgsInstance() {
+ return new createExperiment_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>>() {
- public void onComplete(List<org.apache.airavata.model.experiment.ExperimentModel> o) {
- getExperimentsInProject_result result = new getExperimentsInProject_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ createExperiment_result result = new createExperiment_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -21250,7 +21213,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getExperimentsInProject_result result = new getExperimentsInProject_result();
+ createExperiment_result result = new createExperiment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21266,11 +21229,6 @@ public class Airavata {
result.setAseIsSet(true);
msg = result;
}
- else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) {
- result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e;
- result.setPnfeIsSet(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);
@@ -21296,26 +21254,27 @@ public class Airavata {
return false;
}
- public void start(I iface, getExperimentsInProject_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> resultHandler) throws TException {
- iface.getExperimentsInProject(args.authzToken, args.projectId, args.limit, args.offset,resultHandler);
+ public void start(I iface, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.createExperiment(args.authzToken, args.gatewayId, args.experiment,resultHandler);
}
}
- public static class getUserExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserExperiments_args, List<org.apache.airavata.model.experiment.ExperimentModel>> {
- public getUserExperiments() {
- super("getUserExperiments");
+ public static class deleteExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteExperiment_args, Boolean> {
+ public deleteExperiment() {
+ super("deleteExperiment");
}
- public getUserExperiments_args getEmptyArgsInstance() {
- return new getUserExperiments_args();
+ public deleteExperiment_args getEmptyArgsInstance() {
+ return new deleteExperiment_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> 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<List<org.apache.airavata.model.experiment.ExperimentModel>>() {
- public void onComplete(List<org.apache.airavata.model.experiment.ExperimentModel> o) {
- getUserExperiments_result result = new getUserExperiments_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteExperiment_result result = new deleteExperiment_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -21327,7 +21286,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getUserExperiments_result result = new getUserExperiments_result();
+ deleteExperiment_result result = new deleteExperiment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21368,25 +21327,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getUserExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> resultHandler) throws TException {
- iface.getUserExperiments(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler);
+ public void start(I iface, deleteExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteExperiment(args.authzToken, args.experimentId,resultHandler);
}
}
- public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> {
- public createExperiment() {
- super("createExperiment");
+ public static class getExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperiment_args, org.apache.airavata.model.experiment.ExperimentModel> {
+ public getExperiment() {
+ super("getExperiment");
}
- public createExperiment_args getEmptyArgsInstance() {
- return new createExperiment_args();
+ public getExperiment_args getEmptyArgsInstance() {
+ return new getExperiment_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- createExperiment_result result = new createExperiment_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel>() {
+ public void onComplete(org.apache.airavata.model.experiment.ExperimentModel o) {
+ getExperiment_result result = new getExperiment_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -21399,12 +21358,17 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- createExperiment_result result = new createExperiment_result();
+ getExperiment_result result = new getExperiment_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.ExperimentNotFoundException) {
+ result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e;
+ result.setEnfIsSet(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);
@@ -21440,27 +21404,26 @@ public class Airavata {
return false;
}
- public void start(I iface, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.createExperiment(args.authzToken, args.gatewayId, args.experiment,resultHandler);
+ public void start(I iface, getExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel> resultHandler) throws TException {
+ iface.getExperiment(args.authzToken, args.airavataExperimentId,resultHandler);
}
}
- public static class deleteExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteExperiment_args, Boolean> {
- public deleteExperiment() {
- super("deleteExperiment");
+ public static class getDetailedExperimentTree<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getDetailedExperimentTree_args, org.apache.airavata.model.experiment.ExperimentModel> {
+ public getDetailedExperimentTree() {
+ super("getDetailedExperimentTree");
}
- public deleteExperiment_args getEmptyArgsInstance() {
- return new deleteExperiment_args();
+ public getDetailedExperimentTree_args getEmptyArgsInstance() {
+ return new getDetailedExperimentTree_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- deleteExperiment_result result = new deleteExperiment_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel>() {
+ public void onComplete(org.apache.airavata.model.experiment.ExperimentModel o) {
+ getDetailedExperimentTree_result result = new getDetailedExperimentTree_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -21472,12 +21435,17 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteExperiment_result result = new deleteExperiment_result();
+ getDetailedExperimentTree_result result = new getDetailedExperimentTree_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.ExperimentNotFoundException) {
+ result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e;
+ result.setEnfIsSet(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);
@@ -21513,26 +21481,25 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteExperiment(args.authzToken, args.experimentId,resultHandler);
+ public void start(I iface, getDetailedExperimentTree_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel> resultHandler) throws TException {
+ iface.getDetailedExperimentTree(args.authzToken, args.airavataExperimentId,resultHandler);
}
}
- public static class getExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperiment_args, org.apache.airavata.model.experiment.ExperimentModel> {
- public getExperiment() {
- super("getExperiment");
+ public static class updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> {
+ public updateExperiment() {
+ super("updateExperiment");
}
- public getExperiment_args getEmptyArgsInstance() {
- return new getExperiment_args();
+ public updateExperiment_args getEmptyArgsInstance() {
+ return new updateExperiment_args();
}
- public
<TRUNCATED>