You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ma...@apache.org on 2017/08/11 20:58:25 UTC
[2/3] airavata git commit: WIP
http://git-wip-us.apache.org/repos/asf/airavata/blob/fcf8c471/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 6ef1610..851f96e 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
@@ -2621,6 +2621,10 @@ public class Airavata {
*/
public boolean deleteGatewayStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String storageId) 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> getSSHAccountProvisionerNames(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;
+
+ public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam> getSSHAccountProvisionerConfigParams(org.apache.airavata.model.security.AuthzToken authzToken, String provisionerName) 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;
+
/**
* Register User Resource Profile.
*
@@ -3291,6 +3295,10 @@ public class Airavata {
public void deleteGatewayStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String storageId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getSSHAccountProvisionerNames(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getSSHAccountProvisionerConfigParams(org.apache.airavata.model.security.AuthzToken authzToken, String provisionerName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void registerUserResourceProfile(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile userResourceProfile, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getUserResourceProfile(org.apache.airavata.model.security.AuthzToken authzToken, String userId, String gatewayID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -8275,6 +8283,77 @@ public class Airavata {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteGatewayStoragePreference failed: unknown result");
}
+ public List<String> getSSHAccountProvisionerNames(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_getSSHAccountProvisionerNames(authzToken);
+ return recv_getSSHAccountProvisionerNames();
+ }
+
+ public void send_getSSHAccountProvisionerNames(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.thrift.TException
+ {
+ getSSHAccountProvisionerNames_args args = new getSSHAccountProvisionerNames_args();
+ args.setAuthzToken(authzToken);
+ sendBase("getSSHAccountProvisionerNames", args);
+ }
+
+ public List<String> recv_getSSHAccountProvisionerNames() 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
+ {
+ getSSHAccountProvisionerNames_result result = new getSSHAccountProvisionerNames_result();
+ receiveBase(result, "getSSHAccountProvisionerNames");
+ 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, "getSSHAccountProvisionerNames failed: unknown result");
+ }
+
+ public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam> getSSHAccountProvisionerConfigParams(org.apache.airavata.model.security.AuthzToken authzToken, String provisionerName) 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_getSSHAccountProvisionerConfigParams(authzToken, provisionerName);
+ return recv_getSSHAccountProvisionerConfigParams();
+ }
+
+ public void send_getSSHAccountProvisionerConfigParams(org.apache.airavata.model.security.AuthzToken authzToken, String provisionerName) throws org.apache.thrift.TException
+ {
+ getSSHAccountProvisionerConfigParams_args args = new getSSHAccountProvisionerConfigParams_args();
+ args.setAuthzToken(authzToken);
+ args.setProvisionerName(provisionerName);
+ sendBase("getSSHAccountProvisionerConfigParams", args);
+ }
+
+ public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam> recv_getSSHAccountProvisionerConfigParams() 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
+ {
+ getSSHAccountProvisionerConfigParams_result result = new getSSHAccountProvisionerConfigParams_result();
+ receiveBase(result, "getSSHAccountProvisionerConfigParams");
+ 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, "getSSHAccountProvisionerConfigParams failed: unknown result");
+ }
+
public String registerUserResourceProfile(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile userResourceProfile) 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_registerUserResourceProfile(authzToken, userResourceProfile);
@@ -14586,6 +14665,73 @@ public class Airavata {
}
}
+ public void getSSHAccountProvisionerNames(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getSSHAccountProvisionerNames_call method_call = new getSSHAccountProvisionerNames_call(authzToken, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getSSHAccountProvisionerNames_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.security.AuthzToken authzToken;
+ public getSSHAccountProvisionerNames_call(org.apache.airavata.model.security.AuthzToken authzToken, 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;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getSSHAccountProvisionerNames", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getSSHAccountProvisionerNames_args args = new getSSHAccountProvisionerNames_args();
+ args.setAuthzToken(authzToken);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<String> 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_getSSHAccountProvisionerNames();
+ }
+ }
+
+ public void getSSHAccountProvisionerConfigParams(org.apache.airavata.model.security.AuthzToken authzToken, String provisionerName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getSSHAccountProvisionerConfigParams_call method_call = new getSSHAccountProvisionerConfigParams_call(authzToken, provisionerName, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getSSHAccountProvisionerConfigParams_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.security.AuthzToken authzToken;
+ private String provisionerName;
+ public getSSHAccountProvisionerConfigParams_call(org.apache.airavata.model.security.AuthzToken authzToken, String provisionerName, 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.provisionerName = provisionerName;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getSSHAccountProvisionerConfigParams", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getSSHAccountProvisionerConfigParams_args args = new getSSHAccountProvisionerConfigParams_args();
+ args.setAuthzToken(authzToken);
+ args.setProvisionerName(provisionerName);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam> 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_getSSHAccountProvisionerConfigParams();
+ }
+ }
+
public void registerUserResourceProfile(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile userResourceProfile, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
registerUserResourceProfile_call method_call = new registerUserResourceProfile_call(authzToken, userResourceProfile, resultHandler, this, ___protocolFactory, ___transport);
@@ -16091,6 +16237,8 @@ public class Airavata {
processMap.put("updateGatewayStoragePreference", new updateGatewayStoragePreference());
processMap.put("deleteGatewayComputeResourcePreference", new deleteGatewayComputeResourcePreference());
processMap.put("deleteGatewayStoragePreference", new deleteGatewayStoragePreference());
+ processMap.put("getSSHAccountProvisionerNames", new getSSHAccountProvisionerNames());
+ processMap.put("getSSHAccountProvisionerConfigParams", new getSSHAccountProvisionerConfigParams());
processMap.put("registerUserResourceProfile", new registerUserResourceProfile());
processMap.put("getUserResourceProfile", new getUserResourceProfile());
processMap.put("updateUserResourceProfile", new updateUserResourceProfile());
@@ -20176,6 +20324,66 @@ public class Airavata {
}
}
+ public static class getSSHAccountProvisionerNames<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getSSHAccountProvisionerNames_args> {
+ public getSSHAccountProvisionerNames() {
+ super("getSSHAccountProvisionerNames");
+ }
+
+ public getSSHAccountProvisionerNames_args getEmptyArgsInstance() {
+ return new getSSHAccountProvisionerNames_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getSSHAccountProvisionerNames_result getResult(I iface, getSSHAccountProvisionerNames_args args) throws org.apache.thrift.TException {
+ getSSHAccountProvisionerNames_result result = new getSSHAccountProvisionerNames_result();
+ try {
+ result.success = iface.getSSHAccountProvisionerNames(args.authzToken);
+ } 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 getSSHAccountProvisionerConfigParams<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getSSHAccountProvisionerConfigParams_args> {
+ public getSSHAccountProvisionerConfigParams() {
+ super("getSSHAccountProvisionerConfigParams");
+ }
+
+ public getSSHAccountProvisionerConfigParams_args getEmptyArgsInstance() {
+ return new getSSHAccountProvisionerConfigParams_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getSSHAccountProvisionerConfigParams_result getResult(I iface, getSSHAccountProvisionerConfigParams_args args) throws org.apache.thrift.TException {
+ getSSHAccountProvisionerConfigParams_result result = new getSSHAccountProvisionerConfigParams_result();
+ try {
+ result.success = iface.getSSHAccountProvisionerConfigParams(args.authzToken, args.provisionerName);
+ } 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 registerUserResourceProfile<I extends Iface> extends org.apache.thrift.ProcessFunction<I, registerUserResourceProfile_args> {
public registerUserResourceProfile() {
super("registerUserResourceProfile");
@@ -21415,6 +21623,8 @@ public class Airavata {
processMap.put("updateGatewayStoragePreference", new updateGatewayStoragePreference());
processMap.put("deleteGatewayComputeResourcePreference", new deleteGatewayComputeResourcePreference());
processMap.put("deleteGatewayStoragePreference", new deleteGatewayStoragePreference());
+ processMap.put("getSSHAccountProvisionerNames", new getSSHAccountProvisionerNames());
+ processMap.put("getSSHAccountProvisionerConfigParams", new getSSHAccountProvisionerConfigParams());
processMap.put("registerUserResourceProfile", new registerUserResourceProfile());
processMap.put("getUserResourceProfile", new getUserResourceProfile());
processMap.put("updateUserResourceProfile", new updateUserResourceProfile());
@@ -31095,20 +31305,20 @@ public class Airavata {
}
}
- public static class registerUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerUserResourceProfile_args, String> {
- public registerUserResourceProfile() {
- super("registerUserResourceProfile");
+ public static class getSSHAccountProvisionerNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHAccountProvisionerNames_args, List<String>> {
+ public getSSHAccountProvisionerNames() {
+ super("getSSHAccountProvisionerNames");
}
- public registerUserResourceProfile_args getEmptyArgsInstance() {
- return new registerUserResourceProfile_args();
+ public getSSHAccountProvisionerNames_args getEmptyArgsInstance() {
+ return new getSSHAccountProvisionerNames_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- registerUserResourceProfile_result result = new registerUserResourceProfile_result();
+ return new AsyncMethodCallback<List<String>>() {
+ public void onComplete(List<String> o) {
+ getSSHAccountProvisionerNames_result result = new getSSHAccountProvisionerNames_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -31121,7 +31331,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerUserResourceProfile_result result = new registerUserResourceProfile_result();
+ getSSHAccountProvisionerNames_result result = new getSSHAccountProvisionerNames_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31162,25 +31372,25 @@ public class Airavata {
return false;
}
- public void start(I iface, registerUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerUserResourceProfile(args.authzToken, args.userResourceProfile,resultHandler);
+ public void start(I iface, getSSHAccountProvisionerNames_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
+ iface.getSSHAccountProvisionerNames(args.authzToken,resultHandler);
}
}
- public static class getUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserResourceProfile_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> {
- public getUserResourceProfile() {
- super("getUserResourceProfile");
+ public static class getSSHAccountProvisionerConfigParams<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHAccountProvisionerConfigParams_args, List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam>> {
+ public getSSHAccountProvisionerConfigParams() {
+ super("getSSHAccountProvisionerConfigParams");
}
- public getUserResourceProfile_args getEmptyArgsInstance() {
- return new getUserResourceProfile_args();
+ public getSSHAccountProvisionerConfigParams_args getEmptyArgsInstance() {
+ return new getSSHAccountProvisionerConfigParams_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>() {
- public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile o) {
- getUserResourceProfile_result result = new getUserResourceProfile_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam> o) {
+ getSSHAccountProvisionerConfigParams_result result = new getSSHAccountProvisionerConfigParams_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -31193,7 +31403,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getUserResourceProfile_result result = new getUserResourceProfile_result();
+ getSSHAccountProvisionerConfigParams_result result = new getSSHAccountProvisionerConfigParams_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31234,27 +31444,26 @@ public class Airavata {
return false;
}
- public void start(I iface, getUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> resultHandler) throws TException {
- iface.getUserResourceProfile(args.authzToken, args.userId, args.gatewayID,resultHandler);
+ public void start(I iface, getSSHAccountProvisionerConfigParams_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam>> resultHandler) throws TException {
+ iface.getSSHAccountProvisionerConfigParams(args.authzToken, args.provisionerName,resultHandler);
}
}
- public static class updateUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserResourceProfile_args, Boolean> {
- public updateUserResourceProfile() {
- super("updateUserResourceProfile");
+ public static class registerUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerUserResourceProfile_args, String> {
+ public registerUserResourceProfile() {
+ super("registerUserResourceProfile");
}
- public updateUserResourceProfile_args getEmptyArgsInstance() {
- return new updateUserResourceProfile_args();
+ public registerUserResourceProfile_args getEmptyArgsInstance() {
+ return new registerUserResourceProfile_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) {
- updateUserResourceProfile_result result = new updateUserResourceProfile_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ registerUserResourceProfile_result result = new registerUserResourceProfile_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -31266,7 +31475,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateUserResourceProfile_result result = new updateUserResourceProfile_result();
+ registerUserResourceProfile_result result = new registerUserResourceProfile_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31307,27 +31516,26 @@ public class Airavata {
return false;
}
- public void start(I iface, updateUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateUserResourceProfile(args.authzToken, args.userId, args.gatewayID, args.userResourceProfile,resultHandler);
+ public void start(I iface, registerUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerUserResourceProfile(args.authzToken, args.userResourceProfile,resultHandler);
}
}
- public static class deleteUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserResourceProfile_args, Boolean> {
- public deleteUserResourceProfile() {
- super("deleteUserResourceProfile");
+ public static class getUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserResourceProfile_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> {
+ public getUserResourceProfile() {
+ super("getUserResourceProfile");
}
- public deleteUserResourceProfile_args getEmptyArgsInstance() {
- return new deleteUserResourceProfile_args();
+ public getUserResourceProfile_args getEmptyArgsInstance() {
+ return new getUserResourceProfile_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- deleteUserResourceProfile_result result = new deleteUserResourceProfile_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile o) {
+ getUserResourceProfile_result result = new getUserResourceProfile_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -31339,7 +31547,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteUserResourceProfile_result result = new deleteUserResourceProfile_result();
+ getUserResourceProfile_result result = new getUserResourceProfile_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31380,25 +31588,25 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteUserResourceProfile(args.authzToken, args.userId, args.gatewayID,resultHandler);
+ public void start(I iface, getUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> resultHandler) throws TException {
+ iface.getUserResourceProfile(args.authzToken, args.userId, args.gatewayID,resultHandler);
}
}
- public static class addUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserComputeResourcePreference_args, Boolean> {
- public addUserComputeResourcePreference() {
- super("addUserComputeResourcePreference");
+ public static class updateUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserResourceProfile_args, Boolean> {
+ public updateUserResourceProfile() {
+ super("updateUserResourceProfile");
}
- public addUserComputeResourcePreference_args getEmptyArgsInstance() {
- return new addUserComputeResourcePreference_args();
+ public updateUserResourceProfile_args getEmptyArgsInstance() {
+ return new updateUserResourceProfile_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) {
- addUserComputeResourcePreference_result result = new addUserComputeResourcePreference_result();
+ updateUserResourceProfile_result result = new updateUserResourceProfile_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -31412,7 +31620,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addUserComputeResourcePreference_result result = new addUserComputeResourcePreference_result();
+ updateUserResourceProfile_result result = new updateUserResourceProfile_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31453,25 +31661,25 @@ public class Airavata {
return false;
}
- public void start(I iface, addUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.addUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId, args.userComputeResourcePreference,resultHandler);
+ public void start(I iface, updateUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateUserResourceProfile(args.authzToken, args.userId, args.gatewayID, args.userResourceProfile,resultHandler);
}
}
- public static class addUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserStoragePreference_args, Boolean> {
- public addUserStoragePreference() {
- super("addUserStoragePreference");
+ public static class deleteUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserResourceProfile_args, Boolean> {
+ public deleteUserResourceProfile() {
+ super("deleteUserResourceProfile");
}
- public addUserStoragePreference_args getEmptyArgsInstance() {
- return new addUserStoragePreference_args();
+ public deleteUserResourceProfile_args getEmptyArgsInstance() {
+ return new deleteUserResourceProfile_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) {
- addUserStoragePreference_result result = new addUserStoragePreference_result();
+ deleteUserResourceProfile_result result = new deleteUserResourceProfile_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -31485,7 +31693,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addUserStoragePreference_result result = new addUserStoragePreference_result();
+ deleteUserResourceProfile_result result = new deleteUserResourceProfile_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31526,26 +31734,27 @@ public class Airavata {
return false;
}
- public void start(I iface, addUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.addUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageResourceId, args.userStoragePreference,resultHandler);
+ public void start(I iface, deleteUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteUserResourceProfile(args.authzToken, args.userId, args.gatewayID,resultHandler);
}
}
- public static class getUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserComputeResourcePreference_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> {
- public getUserComputeResourcePreference() {
- super("getUserComputeResourcePreference");
+ public static class addUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserComputeResourcePreference_args, Boolean> {
+ public addUserComputeResourcePreference() {
+ super("addUserComputeResourcePreference");
}
- public getUserComputeResourcePreference_args getEmptyArgsInstance() {
- return new getUserComputeResourcePreference_args();
+ public addUserComputeResourcePreference_args getEmptyArgsInstance() {
+ return new addUserComputeResourcePreference_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> 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.userresourceprofile.UserComputeResourcePreference>() {
- public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference o) {
- getUserComputeResourcePreference_result result = new getUserComputeResourcePreference_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ addUserComputeResourcePreference_result result = new addUserComputeResourcePreference_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -31557,7 +31766,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getUserComputeResourcePreference_result result = new getUserComputeResourcePreference_result();
+ addUserComputeResourcePreference_result result = new addUserComputeResourcePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31598,26 +31807,27 @@ public class Airavata {
return false;
}
- public void start(I iface, getUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> resultHandler) throws TException {
- iface.getUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId,resultHandler);
+ public void start(I iface, addUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.addUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId, args.userComputeResourcePreference,resultHandler);
}
}
- public static class getUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserStoragePreference_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> {
- public getUserStoragePreference() {
- super("getUserStoragePreference");
+ public static class addUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserStoragePreference_args, Boolean> {
+ public addUserStoragePreference() {
+ super("addUserStoragePreference");
}
- public getUserStoragePreference_args getEmptyArgsInstance() {
- return new getUserStoragePreference_args();
+ public addUserStoragePreference_args getEmptyArgsInstance() {
+ return new addUserStoragePreference_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> 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.userresourceprofile.UserStoragePreference>() {
- public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference o) {
- getUserStoragePreference_result result = new getUserStoragePreference_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ addUserStoragePreference_result result = new addUserStoragePreference_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -31629,7 +31839,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getUserStoragePreference_result result = new getUserStoragePreference_result();
+ addUserStoragePreference_result result = new addUserStoragePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31670,25 +31880,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> resultHandler) throws TException {
- iface.getUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageResourceId,resultHandler);
+ public void start(I iface, addUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.addUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageResourceId, args.userStoragePreference,resultHandler);
}
}
- public static class getAllUserComputeResourcePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserComputeResourcePreferences_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> {
- public getAllUserComputeResourcePreferences() {
- super("getAllUserComputeResourcePreferences");
+ public static class getUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserComputeResourcePreference_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> {
+ public getUserComputeResourcePreference() {
+ super("getUserComputeResourcePreference");
}
- public getAllUserComputeResourcePreferences_args getEmptyArgsInstance() {
- return new getAllUserComputeResourcePreferences_args();
+ public getUserComputeResourcePreference_args getEmptyArgsInstance() {
+ return new getUserComputeResourcePreference_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> o) {
- getAllUserComputeResourcePreferences_result result = new getAllUserComputeResourcePreferences_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference o) {
+ getUserComputeResourcePreference_result result = new getUserComputeResourcePreference_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -31701,7 +31911,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllUserComputeResourcePreferences_result result = new getAllUserComputeResourcePreferences_result();
+ getUserComputeResourcePreference_result result = new getUserComputeResourcePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31742,25 +31952,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllUserComputeResourcePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> resultHandler) throws TException {
- iface.getAllUserComputeResourcePreferences(args.authzToken, args.userId, args.gatewayID,resultHandler);
+ public void start(I iface, getUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> resultHandler) throws TException {
+ iface.getUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId,resultHandler);
}
}
- public static class getAllUserStoragePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserStoragePreferences_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> {
- public getAllUserStoragePreferences() {
- super("getAllUserStoragePreferences");
+ public static class getUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserStoragePreference_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> {
+ public getUserStoragePreference() {
+ super("getUserStoragePreference");
}
- public getAllUserStoragePreferences_args getEmptyArgsInstance() {
- return new getAllUserStoragePreferences_args();
+ public getUserStoragePreference_args getEmptyArgsInstance() {
+ return new getUserStoragePreference_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> o) {
- getAllUserStoragePreferences_result result = new getAllUserStoragePreferences_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference o) {
+ getUserStoragePreference_result result = new getUserStoragePreference_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -31773,7 +31983,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllUserStoragePreferences_result result = new getAllUserStoragePreferences_result();
+ getUserStoragePreference_result result = new getUserStoragePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31814,25 +32024,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllUserStoragePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> resultHandler) throws TException {
- iface.getAllUserStoragePreferences(args.authzToken, args.userId, args.gatewayID,resultHandler);
+ public void start(I iface, getUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> resultHandler) throws TException {
+ iface.getUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageResourceId,resultHandler);
}
}
- public static class getAllUserResourceProfiles<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserResourceProfiles_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> {
- public getAllUserResourceProfiles() {
- super("getAllUserResourceProfiles");
+ public static class getAllUserComputeResourcePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserComputeResourcePreferences_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> {
+ public getAllUserComputeResourcePreferences() {
+ super("getAllUserComputeResourcePreferences");
}
- public getAllUserResourceProfiles_args getEmptyArgsInstance() {
- return new getAllUserResourceProfiles_args();
+ public getAllUserComputeResourcePreferences_args getEmptyArgsInstance() {
+ return new getAllUserComputeResourcePreferences_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> o) {
- getAllUserResourceProfiles_result result = new getAllUserResourceProfiles_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> o) {
+ getAllUserComputeResourcePreferences_result result = new getAllUserComputeResourcePreferences_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -31845,7 +32055,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllUserResourceProfiles_result result = new getAllUserResourceProfiles_result();
+ getAllUserComputeResourcePreferences_result result = new getAllUserComputeResourcePreferences_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31886,27 +32096,26 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllUserResourceProfiles_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> resultHandler) throws TException {
- iface.getAllUserResourceProfiles(args.authzToken,resultHandler);
+ public void start(I iface, getAllUserComputeResourcePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> resultHandler) throws TException {
+ iface.getAllUserComputeResourcePreferences(args.authzToken, args.userId, args.gatewayID,resultHandler);
}
}
- public static class updateUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserComputeResourcePreference_args, Boolean> {
- public updateUserComputeResourcePreference() {
- super("updateUserComputeResourcePreference");
+ public static class getAllUserStoragePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserStoragePreferences_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> {
+ public getAllUserStoragePreferences() {
+ super("getAllUserStoragePreferences");
}
- public updateUserComputeResourcePreference_args getEmptyArgsInstance() {
- return new updateUserComputeResourcePreference_args();
+ public getAllUserStoragePreferences_args getEmptyArgsInstance() {
+ return new getAllUserStoragePreferences_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- updateUserComputeResourcePreference_result result = new updateUserComputeResourcePreference_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> o) {
+ getAllUserStoragePreferences_result result = new getAllUserStoragePreferences_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -31918,7 +32127,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateUserComputeResourcePreference_result result = new updateUserComputeResourcePreference_result();
+ getAllUserStoragePreferences_result result = new getAllUserStoragePreferences_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -31959,27 +32168,26 @@ public class Airavata {
return false;
}
- public void start(I iface, updateUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId, args.userComputeResourcePreference,resultHandler);
+ public void start(I iface, getAllUserStoragePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> resultHandler) throws TException {
+ iface.getAllUserStoragePreferences(args.authzToken, args.userId, args.gatewayID,resultHandler);
}
}
- public static class updateUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserStoragePreference_args, Boolean> {
- public updateUserStoragePreference() {
- super("updateUserStoragePreference");
+ public static class getAllUserResourceProfiles<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserResourceProfiles_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> {
+ public getAllUserResourceProfiles() {
+ super("getAllUserResourceProfiles");
}
- public updateUserStoragePreference_args getEmptyArgsInstance() {
- return new updateUserStoragePreference_args();
+ public getAllUserResourceProfiles_args getEmptyArgsInstance() {
+ return new getAllUserResourceProfiles_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- updateUserStoragePreference_result result = new updateUserStoragePreference_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> o) {
+ getAllUserResourceProfiles_result result = new getAllUserResourceProfiles_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -31991,7 +32199,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateUserStoragePreference_result result = new updateUserStoragePreference_result();
+ getAllUserResourceProfiles_result result = new getAllUserResourceProfiles_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32032,25 +32240,25 @@ public class Airavata {
return false;
}
- public void start(I iface, updateUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageId, args.userStoragePreference,resultHandler);
+ public void start(I iface, getAllUserResourceProfiles_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> resultHandler) throws TException {
+ iface.getAllUserResourceProfiles(args.authzToken,resultHandler);
}
}
- public static class deleteUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserComputeResourcePreference_args, Boolean> {
- public deleteUserComputeResourcePreference() {
- super("deleteUserComputeResourcePreference");
+ public static class updateUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserComputeResourcePreference_args, Boolean> {
+ public updateUserComputeResourcePreference() {
+ super("updateUserComputeResourcePreference");
}
- public deleteUserComputeResourcePreference_args getEmptyArgsInstance() {
- return new deleteUserComputeResourcePreference_args();
+ public updateUserComputeResourcePreference_args getEmptyArgsInstance() {
+ return new updateUserComputeResourcePreference_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) {
- deleteUserComputeResourcePreference_result result = new deleteUserComputeResourcePreference_result();
+ updateUserComputeResourcePreference_result result = new updateUserComputeResourcePreference_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -32064,7 +32272,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteUserComputeResourcePreference_result result = new deleteUserComputeResourcePreference_result();
+ updateUserComputeResourcePreference_result result = new updateUserComputeResourcePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32105,25 +32313,25 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId,resultHandler);
+ public void start(I iface, updateUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId, args.userComputeResourcePreference,resultHandler);
}
}
- public static class deleteUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserStoragePreference_args, Boolean> {
- public deleteUserStoragePreference() {
- super("deleteUserStoragePreference");
+ public static class updateUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserStoragePreference_args, Boolean> {
+ public updateUserStoragePreference() {
+ super("updateUserStoragePreference");
}
- public deleteUserStoragePreference_args getEmptyArgsInstance() {
- return new deleteUserStoragePreference_args();
+ public updateUserStoragePreference_args getEmptyArgsInstance() {
+ return new updateUserStoragePreference_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) {
- deleteUserStoragePreference_result result = new deleteUserStoragePreference_result();
+ updateUserStoragePreference_result result = new updateUserStoragePreference_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -32137,7 +32345,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteUserStoragePreference_result result = new deleteUserStoragePreference_result();
+ updateUserStoragePreference_result result = new updateUserStoragePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32178,26 +32386,27 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageId,resultHandler);
+ public void start(I iface, updateUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageId, args.userStoragePreference,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 deleteUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserComputeResourcePreference_args, Boolean> {
+ public deleteUserComputeResourcePreference() {
+ super("deleteUserComputeResourcePreference");
}
- public getAllWorkflows_args getEmptyArgsInstance() {
- return new getAllWorkflows_args();
+ public deleteUserComputeResourcePreference_args getEmptyArgsInstance() {
+ return new deleteUserComputeResourcePreference_args();
}
- public AsyncMethodCallback<List<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<List<String>>() {
- public void onComplete(List<String> o) {
- getAllWorkflows_result result = new getAllWorkflows_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteUserComputeResourcePreference_result result = new deleteUserComputeResourcePreference_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -32209,7 +32418,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();
+ deleteUserComputeResourcePreference_result result = new deleteUserComputeResourcePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32250,26 +32459,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, deleteUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId,resultHandler);
}
}
- public static class getLatestQueueStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLatestQueueStatuses_args, List<org.apache.airavata.model.status.QueueStatusModel>> {
- public getLatestQueueStatuses() {
- super("getLatestQueueStatuses");
+ public static class deleteUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserStoragePreference_args, Boolean> {
+ public deleteUserStoragePreference() {
+ super("deleteUserStoragePreference");
}
- public getLatestQueueStatuses_args getEmptyArgsInstance() {
- return new getLatestQueueStatuses_args();
+ public deleteUserStoragePreference_args getEmptyArgsInstance() {
+ return new deleteUserStoragePreference_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>> 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.status.QueueStatusModel>>() {
- public void onComplete(List<org.apache.airavata.model.status.QueueStatusModel> o) {
- getLatestQueueStatuses_result result = new getLatestQueueStatuses_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteUserStoragePreference_result result = new deleteUserStoragePreference_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -32281,7 +32491,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getLatestQueueStatuses_result result = new getLatestQueueStatuses_result();
+ deleteUserStoragePreference_result result = new deleteUserStoragePreference_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32322,25 +32532,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getLatestQueueStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>> resultHandler) throws TException {
- iface.getLatestQueueStatuses(args.authzToken,resultHandler);
+ public void start(I iface, deleteUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageId,resultHandler);
}
}
- public static class getWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflow_args, org.apache.airavata.model.WorkflowModel> {
- public getWorkflow() {
- super("getWorkflow");
+ public static class getAllWorkflows<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllWorkflows_args, List<String>> {
+ public getAllWorkflows() {
+ super("getAllWorkflows");
}
- public getWorkflow_args getEmptyArgsInstance() {
- return new getWorkflow_args();
+ public getAllWorkflows_args getEmptyArgsInstance() {
+ return new getAllWorkflows_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.WorkflowModel>() {
- public void onComplete(org.apache.airavata.model.WorkflowModel o) {
- getWorkflow_result result = new getWorkflow_result();
+ return new AsyncMethodCallback<List<String>>() {
+ public void onComplete(List<String> o) {
+ getAllWorkflows_result result = new getAllWorkflows_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -32353,7 +32563,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();
+ getAllWorkflows_result result = new getAllWorkflows_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32394,25 +32604,26 @@ public class Airavata {
return false;
}
- public void start(I iface, getWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> resultHandler) throws TException {
- iface.getWorkflow(args.authzToken, args.workflowTemplateId,resultHandler);
+ 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 static class deleteWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteWorkflow_args, Void> {
- public deleteWorkflow() {
- super("deleteWorkflow");
+ public static class getLatestQueueStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLatestQueueStatuses_args, List<org.apache.airavata.model.status.QueueStatusModel>> {
+ public getLatestQueueStatuses() {
+ super("getLatestQueueStatuses");
}
- public deleteWorkflow_args getEmptyArgsInstance() {
- return new deleteWorkflow_args();
+ public getLatestQueueStatuses_args getEmptyArgsInstance() {
+ return new getLatestQueueStatuses_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>> 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<List<org.apache.airavata.model.status.QueueStatusModel>>() {
+ public void onComplete(List<org.apache.airavata.model.status.QueueStatusModel> o) {
+ getLatestQueueStatuses_result result = new getLatestQueueStatuses_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -32424,7 +32635,7 @@ 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();
+ getLatestQueueStatuses_result result = new getLatestQueueStatuses_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32465,25 +32676,25 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.deleteWorkflow(args.authzToken, args.workflowTemplateId,resultHandler);
+ public void start(I iface, getLatestQueueStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>> resultHandler) throws TException {
+ iface.getLatestQueueStatuses(args.authzToken,resultHandler);
}
}
- public static class registerWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerWorkflow_args, String> {
- public registerWorkflow() {
- super("registerWorkflow");
+ public static class getWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflow_args, org.apache.airavata.model.WorkflowModel> {
+ public getWorkflow() {
+ super("getWorkflow");
}
- public registerWorkflow_args getEmptyArgsInstance() {
- return new registerWorkflow_args();
+ public getWorkflow_args getEmptyArgsInstance() {
+ return new getWorkflow_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- registerWorkflow_result result = new registerWorkflow_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.WorkflowModel>() {
+ public void onComplete(org.apache.airavata.model.WorkflowModel o) {
+ getWorkflow_result result = new getWorkflow_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -32496,7 +32707,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerWorkflow_result result = new registerWorkflow_result();
+ getWorkflow_result result = new getWorkflow_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32537,25 +32748,25 @@ public class Airavata {
return false;
}
- public void start(I iface, registerWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerWorkflow(args.authzToken, args.gatewayId, args.workflow,resultHandler);
+ public void start(I iface, getWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> resultHandler) throws TException {
+ iface.getWorkflow(args.authzToken, args.workflowTemplateId,resultHandler);
}
}
- public static class updateWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateWorkflow_args, Void> {
- public updateWorkflow() {
- super("updateWorkflow");
+ public static class deleteWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteWorkflow_args, Void> {
+ public deleteWorkflow() {
+ super("deleteWorkflow");
}
- public updateWorkflow_args getEmptyArgsInstance() {
- return new updateWorkflow_args();
+ public deleteWorkflow_args getEmptyArgsInstance() {
+ return new deleteWorkflow_args();
}
public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Void>() {
public void onComplete(Void o) {
- updateWorkflow_result result = new updateWorkflow_result();
+ deleteWorkflow_result result = new deleteWorkflow_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -32567,7 +32778,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateWorkflow_result result = new updateWorkflow_result();
+ deleteWorkflow_result result = new deleteWorkflow_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32608,25 +32819,25 @@ public class Airavata {
return false;
}
- public void start(I iface, updateWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.updateWorkflow(args.authzToken, args.workflowTemplateId, args.workflow,resultHandler);
+ public void start(I iface, deleteWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.deleteWorkflow(args.authzToken, args.workflowTemplateId,resultHandler);
}
}
- public static class getWorkflowTemplateId<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflowTemplateId_args, String> {
- public getWorkflowTemplateId() {
- super("getWorkflowTemplateId");
+ public static class registerWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerWorkflow_args, String> {
+ public registerWorkflow() {
+ super("registerWorkflow");
}
- public getWorkflowTemplateId_args getEmptyArgsInstance() {
- return new getWorkflowTemplateId_args();
+ public registerWorkflow_args getEmptyArgsInstance() {
+ return new registerWorkflow_args();
}
public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<String>() {
public void onComplete(String o) {
- getWorkflowTemplateId_result result = new getWorkflowTemplateId_result();
+ registerWorkflow_result result = new registerWorkflow_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -32639,7 +32850,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getWorkflowTemplateId_result result = new getWorkflowTemplateId_result();
+ registerWorkflow_result result = new registerWorkflow_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32680,27 +32891,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getWorkflowTemplateId_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.getWorkflowTemplateId(args.authzToken, args.workflowName,resultHandler);
+ public void start(I iface, registerWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerWorkflow(args.authzToken, args.gatewayId, args.workflow,resultHandler);
}
}
- public static class isWorkflowExistWithName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isWorkflowExistWithName_args, Boolean> {
- public isWorkflowExistWithName() {
- super("isWorkflowExistWithName");
+ public static class updateWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateWorkflow_args, Void> {
+ public updateWorkflow() {
+ super("updateWorkflow");
}
- public isWorkflowExistWithName_args getEmptyArgsInstance() {
- return new isWorkflowExistWithName_args();
+ public updateWorkflow_args getEmptyArgsInstance() {
+ return new updateWorkflow_args();
}
- public AsyncMethodCallback<Boolean> 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<Boolean>() {
- public void onComplete(Boolean o) {
- isWorkflowExistWithName_result result = new isWorkflowExistWithName_result();
- result.success = o;
- result.setSuccessIsSet(true);
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ updateWorkflow_result result = new updateWorkflow_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -32712,7 +32921,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- isWorkflowExistWithName_result result = new isWorkflowExistWithName_result();
+ updateWorkflow_result result = new updateWorkflow_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -32753,25 +32962,25 @@ public class Airavata {
return fal
<TRUNCATED>