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/11/08 18:40:05 UTC
[2/9] airavata git commit: Implementing cluster status monitoring
http://git-wip-us.apache.org/repos/asf/airavata/blob/914799c1/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java
----------------------------------------------------------------------
diff --git a/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java b/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java
index d649aeb..9c4ad05 100644
--- a/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java
+++ b/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java
@@ -50,7 +50,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-05")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-11-08")
public class RegistryService {
public interface Iface {
@@ -2081,7 +2081,7 @@ public class RegistryService {
* @param gatewayID
* The identifier to link gateway for the requested User Resource resource.
*
- * @return userResourceProfile
+ * @return userResourceProfile or null if not found
* User Resource Profile Object.
*
*
@@ -2369,6 +2369,14 @@ public class RegistryService {
*/
public boolean deleteUserStoragePreference(String userId, String gatewayID, String userStorageId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException;
+ /**
+ * * Get queue statuses of all compute resources
+ * *
+ */
+ public List<org.apache.airavata.model.status.QueueStatusModel> getLatestQueueStatuses() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException;
+
+ public void registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException;
+
public List<String> getAllWorkflows(String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException;
/**
@@ -2674,6 +2682,10 @@ public class RegistryService {
public void deleteUserStoragePreference(String userId, String gatewayID, String userStorageId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getLatestQueueStatuses(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getAllWorkflows(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getWorkflow(String workflowTemplateId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -6248,6 +6260,54 @@ public class RegistryService {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteUserStoragePreference failed: unknown result");
}
+ public List<org.apache.airavata.model.status.QueueStatusModel> getLatestQueueStatuses() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException
+ {
+ send_getLatestQueueStatuses();
+ return recv_getLatestQueueStatuses();
+ }
+
+ public void send_getLatestQueueStatuses() throws org.apache.thrift.TException
+ {
+ getLatestQueueStatuses_args args = new getLatestQueueStatuses_args();
+ sendBase("getLatestQueueStatuses", args);
+ }
+
+ public List<org.apache.airavata.model.status.QueueStatusModel> recv_getLatestQueueStatuses() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException
+ {
+ getLatestQueueStatuses_result result = new getLatestQueueStatuses_result();
+ receiveBase(result, "getLatestQueueStatuses");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.rse != null) {
+ throw result.rse;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLatestQueueStatuses failed: unknown result");
+ }
+
+ public void registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException
+ {
+ send_registerQueueStatuses(queueStatuses);
+ recv_registerQueueStatuses();
+ }
+
+ public void send_registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) throws org.apache.thrift.TException
+ {
+ registerQueueStatuses_args args = new registerQueueStatuses_args();
+ args.setQueueStatuses(queueStatuses);
+ sendBase("registerQueueStatuses", args);
+ }
+
+ public void recv_registerQueueStatuses() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException
+ {
+ registerQueueStatuses_result result = new registerQueueStatuses_result();
+ receiveBase(result, "registerQueueStatuses");
+ if (result.rse != null) {
+ throw result.rse;
+ }
+ return;
+ }
+
public List<String> getAllWorkflows(String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException
{
send_getAllWorkflows(gatewayId);
@@ -11122,6 +11182,67 @@ public class RegistryService {
}
}
+ public void getLatestQueueStatuses(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getLatestQueueStatuses_call method_call = new getLatestQueueStatuses_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getLatestQueueStatuses_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public getLatestQueueStatuses_call(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);
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getLatestQueueStatuses", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getLatestQueueStatuses_args args = new getLatestQueueStatuses_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<org.apache.airavata.model.status.QueueStatusModel> getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, 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_getLatestQueueStatuses();
+ }
+ }
+
+ public void registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ registerQueueStatuses_call method_call = new registerQueueStatuses_call(queueStatuses, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class registerQueueStatuses_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses;
+ public registerQueueStatuses_call(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses, 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.queueStatuses = queueStatuses;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("registerQueueStatuses", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ registerQueueStatuses_args args = new registerQueueStatuses_args();
+ args.setQueueStatuses(queueStatuses);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, 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);
+ (new Client(prot)).recv_registerQueueStatuses();
+ }
+ }
+
public void getAllWorkflows(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getAllWorkflows_call method_call = new getAllWorkflows_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport);
@@ -11657,6 +11778,8 @@ public class RegistryService {
processMap.put("updateUserStoragePreference", new updateUserStoragePreference());
processMap.put("deleteUserComputeResourcePreference", new deleteUserComputeResourcePreference());
processMap.put("deleteUserStoragePreference", new deleteUserStoragePreference());
+ processMap.put("getLatestQueueStatuses", new getLatestQueueStatuses());
+ processMap.put("registerQueueStatuses", new registerQueueStatuses());
processMap.put("getAllWorkflows", new getAllWorkflows());
processMap.put("getWorkflow", new getWorkflow());
processMap.put("deleteWorkflow", new deleteWorkflow());
@@ -14891,6 +15014,54 @@ public class RegistryService {
}
}
+ public static class getLatestQueueStatuses<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getLatestQueueStatuses_args> {
+ public getLatestQueueStatuses() {
+ super("getLatestQueueStatuses");
+ }
+
+ public getLatestQueueStatuses_args getEmptyArgsInstance() {
+ return new getLatestQueueStatuses_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getLatestQueueStatuses_result getResult(I iface, getLatestQueueStatuses_args args) throws org.apache.thrift.TException {
+ getLatestQueueStatuses_result result = new getLatestQueueStatuses_result();
+ try {
+ result.success = iface.getLatestQueueStatuses();
+ } catch (org.apache.airavata.registry.api.exception.RegistryServiceException rse) {
+ result.rse = rse;
+ }
+ return result;
+ }
+ }
+
+ public static class registerQueueStatuses<I extends Iface> extends org.apache.thrift.ProcessFunction<I, registerQueueStatuses_args> {
+ public registerQueueStatuses() {
+ super("registerQueueStatuses");
+ }
+
+ public registerQueueStatuses_args getEmptyArgsInstance() {
+ return new registerQueueStatuses_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public registerQueueStatuses_result getResult(I iface, registerQueueStatuses_args args) throws org.apache.thrift.TException {
+ registerQueueStatuses_result result = new registerQueueStatuses_result();
+ try {
+ iface.registerQueueStatuses(args.queueStatuses);
+ } catch (org.apache.airavata.registry.api.exception.RegistryServiceException rse) {
+ result.rse = rse;
+ }
+ return result;
+ }
+ }
+
public static class getAllWorkflows<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllWorkflows_args> {
public getAllWorkflows() {
super("getAllWorkflows");
@@ -15325,6 +15496,8 @@ public class RegistryService {
processMap.put("updateUserStoragePreference", new updateUserStoragePreference());
processMap.put("deleteUserComputeResourcePreference", new deleteUserComputeResourcePreference());
processMap.put("deleteUserStoragePreference", new deleteUserStoragePreference());
+ processMap.put("getLatestQueueStatuses", new getLatestQueueStatuses());
+ processMap.put("registerQueueStatuses", new registerQueueStatuses());
processMap.put("getAllWorkflows", new getAllWorkflows());
processMap.put("getWorkflow", new getWorkflow());
processMap.put("deleteWorkflow", new deleteWorkflow());
@@ -22911,20 +23084,20 @@ public class RegistryService {
}
}
- public static class getAllWorkflows<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllWorkflows_args, List<String>> {
- public getAllWorkflows() {
- super("getAllWorkflows");
+ 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 getAllWorkflows_args getEmptyArgsInstance() {
- return new getAllWorkflows_args();
+ public getLatestQueueStatuses_args getEmptyArgsInstance() {
+ return new getLatestQueueStatuses_args();
}
- public AsyncMethodCallback<List<String>> 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<List<String>>() {
- public void onComplete(List<String> o) {
- getAllWorkflows_result result = new getAllWorkflows_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);
@@ -22937,7 +23110,7 @@ public class RegistryService {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllWorkflows_result result = new getAllWorkflows_result();
+ getLatestQueueStatuses_result result = new getLatestQueueStatuses_result();
if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) {
result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
result.setRseIsSet(true);
@@ -22963,26 +23136,25 @@ public class RegistryService {
return false;
}
- public void start(I iface, getAllWorkflows_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
- iface.getAllWorkflows(args.gatewayId,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(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 registerQueueStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerQueueStatuses_args, Void> {
+ public registerQueueStatuses() {
+ super("registerQueueStatuses");
}
- public getWorkflow_args getEmptyArgsInstance() {
- return new getWorkflow_args();
+ public registerQueueStatuses_args getEmptyArgsInstance() {
+ return new registerQueueStatuses_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> 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<org.apache.airavata.model.WorkflowModel>() {
- public void onComplete(org.apache.airavata.model.WorkflowModel o) {
- getWorkflow_result result = new getWorkflow_result();
- result.success = o;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ registerQueueStatuses_result result = new registerQueueStatuses_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22994,7 +23166,7 @@ public class RegistryService {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getWorkflow_result result = new getWorkflow_result();
+ registerQueueStatuses_result result = new registerQueueStatuses_result();
if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) {
result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
result.setRseIsSet(true);
@@ -23020,25 +23192,26 @@ public class RegistryService {
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.workflowTemplateId,resultHandler);
+ public void start(I iface, registerQueueStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.registerQueueStatuses(args.queueStatuses,resultHandler);
}
}
- public static class deleteWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteWorkflow_args, Void> {
- public deleteWorkflow() {
- super("deleteWorkflow");
+ public static class getAllWorkflows<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllWorkflows_args, List<String>> {
+ public getAllWorkflows() {
+ super("getAllWorkflows");
}
- public deleteWorkflow_args getEmptyArgsInstance() {
- return new deleteWorkflow_args();
+ public getAllWorkflows_args getEmptyArgsInstance() {
+ return new getAllWorkflows_args();
}
- public AsyncMethodCallback<Void> 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<Void>() {
- public void onComplete(Void o) {
- deleteWorkflow_result result = new deleteWorkflow_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);
return;
@@ -23050,7 +23223,7 @@ public class RegistryService {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteWorkflow_result result = new deleteWorkflow_result();
+ getAllWorkflows_result result = new getAllWorkflows_result();
if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) {
result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
result.setRseIsSet(true);
@@ -23076,25 +23249,25 @@ public class RegistryService {
return false;
}
- public void start(I iface, deleteWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.deleteWorkflow(args.workflowTemplateId,resultHandler);
+ public void start(I iface, getAllWorkflows_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
+ iface.getAllWorkflows(args.gatewayId,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);
@@ -23107,7 +23280,7 @@ public class RegistryService {
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.registry.api.exception.RegistryServiceException) {
result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
result.setRseIsSet(true);
@@ -23133,25 +23306,25 @@ public class RegistryService {
return false;
}
- public void start(I iface, registerWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerWorkflow(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.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;
@@ -23163,7 +23336,7 @@ public class RegistryService {
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.registry.api.exception.RegistryServiceException) {
result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
result.setRseIsSet(true);
@@ -23189,25 +23362,25 @@ public class RegistryService {
return false;
}
- public void start(I iface, updateWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.updateWorkflow(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.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);
@@ -23220,7 +23393,7 @@ public class RegistryService {
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.registry.api.exception.RegistryServiceException) {
result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
result.setRseIsSet(true);
@@ -23246,27 +23419,25 @@ public class RegistryService {
return false;
}
- public void start(I iface, getWorkflowTemplateId_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.getWorkflowTemplateId(args.workflowName,resultHandler);
+ public void start(I iface, registerWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerWorkflow(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;
@@ -23278,7 +23449,7 @@ public class RegistryService {
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.registry.api.exception.RegistryServiceException) {
result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
result.setRseIsSet(true);
@@ -23304,25 +23475,25 @@ public class RegistryService {
return false;
}
- public void start(I iface, isWorkflowExistWithName_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.isWorkflowExistWithName(args.workflowName,resultHandler);
+ public void start(I iface, updateWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.updateWorkflow(args.workflowTemplateId, args.workflow,resultHandler);
}
}
- public static class registerDataProduct<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerDataProduct_args, String> {
- public registerDataProduct() {
- super("registerDataProduct");
+ public static class getWorkflowTemplateId<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflowTemplateId_args, String> {
+ public getWorkflowTemplateId() {
+ super("getWorkflowTemplateId");
}
- public registerDataProduct_args getEmptyArgsInstance() {
- return new registerDataProduct_args();
+ public getWorkflowTemplateId_args getEmptyArgsInstance() {
+ return new getWorkflowTemplateId_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) {
- registerDataProduct_result result = new registerDataProduct_result();
+ getWorkflowTemplateId_result result = new getWorkflowTemplateId_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -23335,7 +23506,122 @@ public class RegistryService {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerDataProduct_result result = new registerDataProduct_result();
+ getWorkflowTemplateId_result result = new getWorkflowTemplateId_result();
+ if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) {
+ result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
+ result.setRseIsSet(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, getWorkflowTemplateId_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.getWorkflowTemplateId(args.workflowName,resultHandler);
+ }
+ }
+
+ public static class isWorkflowExistWithName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isWorkflowExistWithName_args, Boolean> {
+ public isWorkflowExistWithName() {
+ super("isWorkflowExistWithName");
+ }
+
+ public isWorkflowExistWithName_args getEmptyArgsInstance() {
+ return new isWorkflowExistWithName_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) {
+ isWorkflowExistWithName_result result = new isWorkflowExistWithName_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ isWorkflowExistWithName_result result = new isWorkflowExistWithName_result();
+ if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) {
+ result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
+ result.setRseIsSet(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, isWorkflowExistWithName_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.isWorkflowExistWithName(args.workflowName,resultHandler);
+ }
+ }
+
+ public static class registerDataProduct<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerDataProduct_args, String> {
+ public registerDataProduct() {
+ super("registerDataProduct");
+ }
+
+ public registerDataProduct_args getEmptyArgsInstance() {
+ return new registerDataProduct_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) {
+ registerDataProduct_result result = new registerDataProduct_result();
+ result.success = o;
+ 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;
+ registerDataProduct_result result = new registerDataProduct_result();
if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) {
result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e;
result.setRseIsSet(true);
@@ -144828,22 +145114,20 @@ public class RegistryService {
}
- public static class getAllWorkflows_args implements org.apache.thrift.TBase<getAllWorkflows_args, getAllWorkflows_args._Fields>, java.io.Serializable, Cloneable, Comparable<getAllWorkflows_args> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getAllWorkflows_args");
+ public static class getLatestQueueStatuses_args implements org.apache.thrift.TBase<getLatestQueueStatuses_args, getLatestQueueStatuses_args._Fields>, java.io.Serializable, Cloneable, Comparable<getLatestQueueStatuses_args> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getLatestQueueStatuses_args");
- private static final org.apache.thrift.protocol.TField GATEWAY_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("gatewayId", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
- schemes.put(StandardScheme.class, new getAllWorkflows_argsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new getAllWorkflows_argsTupleSchemeFactory());
+ schemes.put(StandardScheme.class, new getLatestQueueStatuses_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new getLatestQueueStatuses_argsTupleSchemeFactory());
}
- public String gatewayId; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- GATEWAY_ID((short)1, "gatewayId");
+;
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -144858,8 +145142,6 @@ public class RegistryService {
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 1: // GATEWAY_ID
- return GATEWAY_ID;
default:
return null;
}
@@ -144898,87 +145180,37 @@ public class RegistryService {
return _fieldName;
}
}
-
- // isset id assignments
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.GATEWAY_ID, new org.apache.thrift.meta_data.FieldMetaData("gatewayId", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getAllWorkflows_args.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getLatestQueueStatuses_args.class, metaDataMap);
}
- public getAllWorkflows_args() {
- }
-
- public getAllWorkflows_args(
- String gatewayId)
- {
- this();
- this.gatewayId = gatewayId;
+ public getLatestQueueStatuses_args() {
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getAllWorkflows_args(getAllWorkflows_args other) {
- if (other.isSetGatewayId()) {
- this.gatewayId = other.gatewayId;
- }
+ public getLatestQueueStatuses_args(getLatestQueueStatuses_args other) {
}
- public getAllWorkflows_args deepCopy() {
- return new getAllWorkflows_args(this);
+ public getLatestQueueStatuses_args deepCopy() {
+ return new getLatestQueueStatuses_args(this);
}
@Override
public void clear() {
- this.gatewayId = null;
- }
-
- public String getGatewayId() {
- return this.gatewayId;
- }
-
- public getAllWorkflows_args setGatewayId(String gatewayId) {
- this.gatewayId = gatewayId;
- return this;
- }
-
- public void unsetGatewayId() {
- this.gatewayId = null;
- }
-
- /** Returns true if field gatewayId is set (has been assigned a value) and false otherwise */
- public boolean isSetGatewayId() {
- return this.gatewayId != null;
- }
-
- public void setGatewayIdIsSet(boolean value) {
- if (!value) {
- this.gatewayId = null;
- }
}
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case GATEWAY_ID:
- if (value == null) {
- unsetGatewayId();
- } else {
- setGatewayId((String)value);
- }
- break;
-
}
}
public Object getFieldValue(_Fields field) {
switch (field) {
- case GATEWAY_ID:
- return getGatewayId();
-
}
throw new IllegalStateException();
}
@@ -144990,8 +145222,6 @@ public class RegistryService {
}
switch (field) {
- case GATEWAY_ID:
- return isSetGatewayId();
}
throw new IllegalStateException();
}
@@ -145000,24 +145230,15 @@ public class RegistryService {
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof getAllWorkflows_args)
- return this.equals((getAllWorkflows_args)that);
+ if (that instanceof getLatestQueueStatuses_args)
+ return this.equals((getLatestQueueStatuses_args)that);
return false;
}
- public boolean equals(getAllWorkflows_args that) {
+ public boolean equals(getLatestQueueStatuses_args that) {
if (that == null)
return false;
- boolean this_present_gatewayId = true && this.isSetGatewayId();
- boolean that_present_gatewayId = true && that.isSetGatewayId();
- if (this_present_gatewayId || that_present_gatewayId) {
- if (!(this_present_gatewayId && that_present_gatewayId))
- return false;
- if (!this.gatewayId.equals(that.gatewayId))
- return false;
- }
-
return true;
}
@@ -145025,32 +145246,17 @@ public class RegistryService {
public int hashCode() {
List<Object> list = new ArrayList<Object>();
- boolean present_gatewayId = true && (isSetGatewayId());
- list.add(present_gatewayId);
- if (present_gatewayId)
- list.add(gatewayId);
-
return list.hashCode();
}
@Override
- public int compareTo(getAllWorkflows_args other) {
+ public int compareTo(getLatestQueueStatuses_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- lastComparison = Boolean.valueOf(isSetGatewayId()).compareTo(other.isSetGatewayId());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetGatewayId()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gatewayId, other.gatewayId);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
return 0;
}
@@ -145068,25 +145274,15 @@ public class RegistryService {
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("getAllWorkflows_args(");
+ StringBuilder sb = new StringBuilder("getLatestQueueStatuses_args(");
boolean first = true;
- sb.append("gatewayId:");
- if (this.gatewayId == null) {
- sb.append("null");
- } else {
- sb.append(this.gatewayId);
- }
- first = false;
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
- if (gatewayId == null) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString());
- }
// check for sub-struct validity
}
@@ -145106,15 +145302,15 @@ public class RegistryService {
}
}
- private static class getAllWorkflows_argsStandardSchemeFactory implements SchemeFactory {
- public getAllWorkflows_argsStandardScheme getScheme() {
- return new getAllWorkflows_argsStandardScheme();
+ private static class getLatestQueueStatuses_argsStandardSchemeFactory implements SchemeFactory {
+ public getLatestQueueStatuses_argsStandardScheme getScheme() {
+ return new getLatestQueueStatuses_argsStandardScheme();
}
}
- private static class getAllWorkflows_argsStandardScheme extends StandardScheme<getAllWorkflows_args> {
+ private static class getLatestQueueStatuses_argsStandardScheme extends StandardScheme<getLatestQueueStatuses_args> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, getAllWorkflows_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot, getLatestQueueStatuses_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -145124,14 +145320,6 @@ public class RegistryService {
break;
}
switch (schemeField.id) {
- case 1: // GATEWAY_ID
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.gatewayId = iprot.readString();
- struct.setGatewayIdIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -145143,58 +145331,50 @@ public class RegistryService {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, getAllWorkflows_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot, getLatestQueueStatuses_args struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
- if (struct.gatewayId != null) {
- oprot.writeFieldBegin(GATEWAY_ID_FIELD_DESC);
- oprot.writeString(struct.gatewayId);
- oprot.writeFieldEnd();
- }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
- private static class getAllWorkflows_argsTupleSchemeFactory implements SchemeFactory {
- public getAllWorkflows_argsTupleScheme getScheme() {
- return new getAllWorkflows_argsTupleScheme();
+ private static class getLatestQueueStatuses_argsTupleSchemeFactory implements SchemeFactory {
+ public getLatestQueueStatuses_argsTupleScheme getScheme() {
+ return new getLatestQueueStatuses_argsTupleScheme();
}
}
- private static class getAllWorkflows_argsTupleScheme extends TupleScheme<getAllWorkflows_args> {
+ private static class getLatestQueueStatuses_argsTupleScheme extends TupleScheme<getLatestQueueStatuses_args> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, getAllWorkflows_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol prot, getLatestQueueStatuses_args struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeString(struct.gatewayId);
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, getAllWorkflows_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol prot, getLatestQueueStatuses_args struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.gatewayId = iprot.readString();
- struct.setGatewayIdIsSet(true);
}
}
}
- public static class getAllWorkflows_result implements org.apache.thrift.TBase<getAllWorkflows_result, getAllWorkflows_result._Fields>, java.io.Serializable, Cloneable, Comparable<getAllWorkflows_result> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getAllWorkflows_result");
+ public static class getLatestQueueStatuses_result implements org.apache.thrift.TBase<getLatestQueueStatuses_result, getLatestQueueStatuses_result._Fields>, java.io.Serializable, Cloneable, Comparable<getLatestQueueStatuses_result> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getLatestQueueStatuses_result");
private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0);
private static final org.apache.thrift.protocol.TField RSE_FIELD_DESC = new org.apache.thrift.protocol.TField("rse", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
- schemes.put(StandardScheme.class, new getAllWorkflows_resultStandardSchemeFactory());
- schemes.put(TupleScheme.class, new getAllWorkflows_resultTupleSchemeFactory());
+ schemes.put(StandardScheme.class, new getLatestQueueStatuses_resultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new getLatestQueueStatuses_resultTupleSchemeFactory());
}
- public List<String> success; // required
+ public List<org.apache.airavata.model.status.QueueStatusModel> success; // required
public org.apache.airavata.registry.api.exception.RegistryServiceException rse; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -145264,18 +145444,18 @@ public class RegistryService {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.status.QueueStatusModel.class))));
tmpMap.put(_Fields.RSE, new org.apache.thrift.meta_data.FieldMetaData("rse", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getAllWorkflows_result.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getLatestQueueStatuses_result.class, metaDataMap);
}
- public getAllWorkflows_result() {
+ public getLatestQueueStatuses_result() {
}
- public getAllWorkflows_result(
- List<String> success,
+ public getLatestQueueStatuses_result(
+ List<org.apache.airavata.model.status.QueueStatusModel> success,
org.apache.airavata.registry.api.exception.RegistryServiceException rse)
{
this();
@@ -145286,9 +145466,12 @@ public class RegistryService {
/**
* Performs a deep copy on <i>other</i>.
*/
- public getAllWorkflows_result(getAllWorkflows_result other) {
+ public getLatestQueueStatuses_result(getLatestQueueStatuses_result other) {
if (other.isSetSuccess()) {
- List<String> __this__success = new ArrayList<String>(other.success);
+ List<org.apache.airavata.model.status.QueueStatusModel> __this__success = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(other.success.size());
+ for (org.apache.airavata.model.status.QueueStatusModel other_element : other.success) {
+ __this__success.add(new org.apache.airavata.model.status.QueueStatusModel(other_element));
+ }
this.success = __this__success;
}
if (other.isSetRse()) {
@@ -145296,8 +145479,8 @@ public class RegistryService {
}
}
- public getAllWorkflows_result deepCopy() {
- return new getAllWorkflows_result(this);
+ public getLatestQueueStatuses_result deepCopy() {
+ return new getLatestQueueStatuses_result(this);
}
@Override
@@ -145310,22 +145493,22 @@ public class RegistryService {
return (this.success == null) ? 0 : this.success.size();
}
- public java.util.Iterator<String> getSuccessIterator() {
+ public java.util.Iterator<org.apache.airavata.model.status.QueueStatusModel> getSuccessIterator() {
return (this.success == null) ? null : this.success.iterator();
}
- public void addToSuccess(String elem) {
+ public void addToSuccess(org.apache.airavata.model.status.QueueStatusModel elem) {
if (this.success == null) {
- this.success = new ArrayList<String>();
+ this.success = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>();
}
this.success.add(elem);
}
- public List<String> getSuccess() {
+ public List<org.apache.airavata.model.status.QueueStatusModel> getSuccess() {
return this.success;
}
- public getAllWorkflows_result setSuccess(List<String> success) {
+ public getLatestQueueStatuses_result setSuccess(List<org.apache.airavata.model.status.QueueStatusModel> success) {
this.success = success;
return this;
}
@@ -145349,7 +145532,7 @@ public class RegistryService {
return this.rse;
}
- public getAllWorkflows_result setRse(org.apache.airavata.registry.api.exception.RegistryServiceException rse) {
+ public getLatestQueueStatuses_result setRse(org.apache.airavata.registry.api.exception.RegistryServiceException rse) {
this.rse = rse;
return this;
}
@@ -145375,7 +145558,7 @@ public class RegistryService {
if (value == null) {
unsetSuccess();
} else {
- setSuccess((List<String>)value);
+ setSuccess((List<org.apache.airavata.model.status.QueueStatusModel>)value);
}
break;
@@ -145421,12 +145604,12 @@ public class RegistryService {
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof getAllWorkflows_result)
- return this.equals((getAllWorkflows_result)that);
+ if (that instanceof getLatestQueueStatuses_result)
+ return this.equals((getLatestQueueStatuses_result)that);
return false;
}
- public boolean equals(getAllWorkflows_result that) {
+ public boolean equals(getLatestQueueStatuses_result that) {
if (that == null)
return false;
@@ -145469,7 +145652,7 @@ public class RegistryService {
}
@Override
- public int compareTo(getAllWorkflows_result other) {
+ public int compareTo(getLatestQueueStatuses_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
@@ -145513,7 +145696,7 @@ public class RegistryService {
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("getAllWorkflows_result(");
+ StringBuilder sb = new StringBuilder("getLatestQueueStatuses_result(");
boolean first = true;
sb.append("success:");
@@ -145556,15 +145739,15 @@ public class RegistryService {
}
}
- private static class getAllWorkflows_resultStandardSchemeFactory implements SchemeFactory {
- public getAllWorkflows_resultStandardScheme getScheme() {
- return new getAllWorkflows_resultStandardScheme();
+ private static class getLatestQueueStatuses_resultStandardSchemeFactory implements SchemeFactory {
+ public getLatestQueueStatuses_resultStandardScheme getScheme() {
+ return new getLatestQueueStatuses_resultStandardScheme();
}
}
- private static class getAllWorkflows_resultStandardScheme extends StandardScheme<getAllWorkflows_result> {
+ private static class getLatestQueueStatuses_resultStandardScheme extends StandardScheme<getLatestQueueStatuses_result> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, getAllWorkflows_result struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot, getLatestQueueStatuses_result struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -145578,11 +145761,12 @@ public class RegistryService {
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list290 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list290.size);
- String _elem291;
+ struct.success = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(_list290.size);
+ org.apache.airavata.model.status.QueueStatusModel _elem291;
for (int _i292 = 0; _i292 < _list290.size; ++_i292)
{
- _elem291 = iprot.readString();
+ _elem291 = new org.apache.airavata.model.status.QueueStatusModel();
+ _elem291.read(iprot);
struct.success.add(_elem291);
}
iprot.readListEnd();
@@ -145612,17 +145796,17 @@ public class RegistryService {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, getAllWorkflows_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot, getLatestQueueStatuses_result struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.success != null) {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter293 : struct.success)
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
+ for (org.apache.airavata.model.status.QueueStatusModel _iter293 : struct.success)
{
- oprot.writeString(_iter293);
+ _iter293.write(oprot);
}
oprot.writeListEnd();
}
@@ -145639,16 +145823,16 @@ public class RegistryService {
}
- private static class getAllWorkflows_resultTupleSchemeFactory implements SchemeFactory {
- public getAllWorkflows_resultTupleScheme getScheme() {
- return new getAllWorkflows_resultTupleScheme();
+ private static class getLatestQueueStatuses_resultTupleSchemeFactory implements SchemeFactory {
+ public getLatestQueueStatuses_resultTupleScheme getScheme() {
+ return new getLatestQueueStatuses_resultTupleScheme();
}
}
- private static class getAllWorkflows_resultTupleScheme extends TupleScheme<getAllWorkflows_result> {
+ private static class getLatestQueueStatuses_resultTupleScheme extends TupleScheme<getLatestQueueStatuses_result> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, getAllWorkflows_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol prot, getLatestQueueStatuses_result struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
BitSet optionals = new BitSet();
if (struct.isSetSuccess()) {
@@ -145661,9 +145845,9 @@ public class RegistryService {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter294 : struct.success)
+ for (org.apache.airavata.model.status.QueueStatusModel _iter294 : struct.success)
{
- oprot.writeString(_iter294);
+ _iter294.write(oprot);
}
}
}
@@ -145673,17 +145857,18 @@ public class RegistryService {
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, getAllWorkflows_result struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol prot, getLatestQueueStatuses_result struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list295.size);
- String _elem296;
+ org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(_list295.size);
+ org.apache.airavata.model.status.QueueStatusModel _elem296;
for (int _i297 = 0; _i297 < _list295.size; ++_i297)
{
- _elem296 = iprot.readString();
+ _elem296 = new org.apache.airavata.model.status.QueueStatusModel();
+ _elem296.read(iprot);
struct.success.add(_elem296);
}
}
@@ -145699,22 +145884,22 @@ public class RegistryService {
}
- public static class getWorkflow_args implements org.apache.thrift.TBase<getWorkflow_args, getWorkflow_args._Fields>, java.io.Serializable, Cloneable, Comparable<getWorkflow_args> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getWorkflow_args");
+ public static class registerQueueStatuses_args implements org.apache.thrift.TBase<registerQueueStatuses_args, registerQueueStatuses_args._Fields>, java.io.Serializable, Cloneable, Comparable<registerQueueStatuses_args> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("registerQueueStatuses_args");
- private static final org.apache.thrift.protocol.TField WORKFLOW_TEMPLATE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("workflowTemplateId", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField QUEUE_STATUSES_FIELD_DESC = new org.apache.thrift.protocol.TField("queueStatuses", org.apache.thrift.protocol.TType.LIST, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
- schemes.put(StandardScheme.class, new getWorkflow_argsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new getWorkflow_argsTupleSchemeFactory());
+ schemes.put(StandardScheme.class, new registerQueueStatuses_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new registerQueueStatuses_argsTupleSchemeFactory());
}
- public String workflowTemplateId; // required
+ public List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- WORKFLOW_TEMPLATE_ID((short)1, "workflowTemplateId");
+ QUEUE_STATUSES((short)1, "queueStatuses");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -145729,8 +145914,8 @@ public class RegistryService {
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 1: // WORKFLOW_TEMPLATE_ID
- return WORKFLOW_TEMPLATE_ID;
+ case 1: // QUEUE_STATUSES
+ return QUEUE_STATUSES;
default:
return null;
}
@@ -145774,71 +145959,91 @@ public class RegistryService {
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.WORKFLOW_TEMPLATE_ID, new org.apache.thrift.meta_data.FieldMetaData("workflowTemplateId", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.QUEUE_STATUSES, new org.apache.thrift.meta_data.FieldMetaData("queueStatuses", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.status.QueueStatusModel.class))));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getWorkflow_args.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(registerQueueStatuses_args.class, metaDataMap);
}
- public getWorkflow_args() {
+ public registerQueueStatuses_args() {
}
- public getWorkflow_args(
- String workflowTemplateId)
+ public registerQueueStatuses_args(
+ List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses)
{
this();
- this.workflowTemplateId = workflowTemplateId;
+ this.queueStatuses = queueStatuses;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getWorkflow_args(getWorkflow_args other) {
- if (other.isSetWorkflowTemplateId()) {
- this.workflowTemplateId = other.workflowTemplateId;
+ public registerQueueStatuses_args(registerQueueStatuses_args other) {
+ if (other.isSetQueueStatuses()) {
+ List<org.apache.airavata.model.status.QueueStatusModel> __this__queueStatuses = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(other.queueStatuses.size());
+ for (org.apache.airavata.model.status.QueueStatusModel other_element : other.queueStatuses) {
+ __this__queueStatuses.add(new org.apache.airavata.model.status.QueueStatusModel(other_element));
+ }
+ this.queueStatuses = __this__queueStatuses;
}
}
- public getWorkflow_args deepCopy() {
- return new getWorkflow_args(this);
+ public registerQueueStatuses_args deepCopy() {
+ return new registerQueueStatuses_args(this);
}
@Override
public void clear() {
- this.workflowTemplateId = null;
+ this.queueStatuses = null;
}
- public String getWorkflowTemplateId() {
- return this.workflowTemplateId;
+ public int getQueueStatusesSize() {
+ return (this.queueStatuses == null) ? 0 : this.queueStatuses.size();
}
- public getWorkflow_args setWorkflowTemplateId(String workflowTemplateId) {
- this.workflowTemplateId = workflowTemplateId;
+ public java.util.Iterator<org.apache.airavata.model.status.QueueStatusModel> getQueueStatusesIterator() {
+ return (this.queueStatuses == null) ? null : this.queueStatuses.iterator();
+ }
+
+ public void addToQueueStatuses(org.apache.airavata.model.status.QueueStatusModel elem) {
+ if (this.queueStatuses == null) {
+ this.queueStatuses = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>();
+ }
+ this.queueStatuses.add(elem);
+ }
+
+ public List<org.apache.airavata.model.status.QueueStatusModel> getQueueStatuses() {
+ return this.queueStatuses;
+ }
+
+ public registerQueueStatuses_args setQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) {
+ this.queueStatuses = queueStatuses;
return this;
}
- public void unsetWorkflowTemplateId() {
- this.workflowTemplateId = null;
+ public void unsetQueueStatuses() {
+ this.queueStatuses = null;
}
- /** Returns true if field workflowTemplateId is set (has been assigned a value) and false otherwise */
- public boolean isSetWorkflowTemplateId() {
- return this.workflowTemplateId != null;
+ /** Returns true if field queueStatuses is set (has been assigned a value) and false otherwise */
+ public boolean isSetQueueStatuses() {
+ return this.queueStatuses != null;
}
- public void setWorkflowTemplateIdIsSet(boolean value) {
+ public void setQueueStatusesIsSet(boolean value) {
if (!value) {
- this.workflowTemplateId = null;
+ this.queueStatuses = null;
}
}
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case WORKFLOW_TEMPLATE_ID:
+ case QUEUE_STATUSES:
if (value == null) {
- unsetWorkflowTemplateId();
+ unsetQueueStatuses();
} else {
- setWorkflowTemplateId((String)value);
+ setQueueStatuses((List<org.apache.airavata.model.status.QueueStatusModel>)value);
}
break;
@@ -145847,8 +146052,8 @@ public class RegistryService {
public Object getFieldValue(_Fields field) {
switch (field) {
- case WORKFLOW_TEMPLATE_ID:
- return getWorkflowTemplateId();
+ case QUEUE_STATUSES:
+ return getQueueStatuses();
}
throw new IllegalStateException();
@@ -145861,8 +146066,8 @@ public class RegistryService {
}
switch (field) {
- case WORKFLOW_TEMPLATE_ID:
- return isSetWorkflowTemplateId();
+ case QUEUE_STATUSES:
+ return isSetQueueStatuses();
}
throw new IllegalStateException();
}
@@ -145871,21 +146076,21 @@ public class RegistryService {
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof getWorkflow_args)
- return this.equals((getWorkflow_args)that);
+ if (that instanceof registerQueueStatuses_args)
+ return this.equals((registerQueueStatuses_args)that);
return false;
}
- public boolean equals(getWorkflow_args that) {
+ public boolean equals(registerQueueStatuses_args that) {
if (that == null)
return false;
- boolean this_present_workflowTemplateId = true && this.isSetWorkflowTemplateId();
- boolean that_present_workflowTemplateId = true && that.isSetWorkflowTemplateId();
- if (this_present_workflowTemplateId || that_present_workflowTemplateId) {
- if (!(this_present_workflowTemplateId && that_present_workflowTemplateId))
+ boolean this_present_queueStatuses = true && this.isSetQueueStatuses();
+ boolean that_present_queueStatuses = true && that.isSetQueueStatuses();
+ if (this_present_queueStatuses || that_present_queueStatuses) {
+ if (!(this_present_queueStatuses && that_present_queueStatuses))
return false;
- if (!this.workflowTemplateId.equals(that.workflowTemplateId))
+ if (!this.queueStatuses.equals(that.queueStatuses))
return false;
}
@@ -145896,28 +146101,28 @@ public class RegistryService {
public int hashCode() {
List<Object> list = new ArrayList<Object>();
- boolean present_workflowTemplateId = true && (isSetWorkflowTemplateId());
- list.add(present_workflowTemplateId);
- if (present_workflowTemplateId)
- list.add(workflowTemplateId);
+ boolean present_queueStatuses = true && (isSetQueueStatuses());
+ list.add(present_queueStatuses);
+ if (present_queueStatuses)
+ list.add(queueStatuses);
return list.hashCode();
}
@Override
- public int compareTo(getWorkflow_args other) {
+ public int compareTo(registerQueueStatuses_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- lastComparison = Boolean.valueOf(isSetWorkflowTemplateId()).compareTo(other.isSetWorkflowTemplateId());
+ lastComparison = Boolean.valueOf(isSetQueueStatuses()).compareTo(other.isSetQueueStatuses());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetWorkflowTemplateId()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workflowTemplateId, other.workflowTemplateId);
+ if (isSetQueueStatuses()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.queueStatuses, other.queueStatuses);
if (lastComparison != 0) {
return lastComparison;
}
@@ -145939,14 +146144,14 @@ public class RegistryService {
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("getWorkflow_args(");
+ StringBuilder sb = new StringBuilder("registerQueueStatuses_args(");
boolean first = true;
- sb.append("workflowTemplateId:");
- if (this.workflowTemplateId == null) {
+ sb.append("queueStatuses:");
+ if (this.queueStatuses == null) {
sb.append("null");
} else {
- sb.append(this.workflowTemplateId);
+ sb.append(this.queueStatuses);
}
first = false;
sb.append(")");
@@ -145955,8 +146160,8 @@ public class RegistryService {
public void validate() throws org.apache.thrift.TException {
// check for required fields
- if (workflowTemplateId == null) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'workflowTemplateId' was not present! Struct: " + toString());
+ if (queueStatuses == null) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'queueStatuses' was not present! Struct: " + toString());
}
// check for sub-struct validity
}
@@ -145977,15 +146182,15 @@ public class RegistryService {
}
}
- private static class getWorkflow_argsStandardSchemeFactory implements SchemeFactory {
- public getWorkflow_argsStandardScheme getScheme() {
- return new getWorkflow_argsStandardScheme();
+ private static class registerQueueStatuses_argsStandardSchemeFactory implements SchemeFactory {
+ public registerQueueStatuses_argsStandardScheme getScheme() {
+ return new registerQueueStatuses_argsStandardScheme();
}
}
- private static class getWorkflow_argsStandardScheme extends StandardScheme<getWorkflow_args> {
+ private static class registerQueueStatuses_argsStandardScheme extends StandardScheme<registerQueueStatuses_args> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, getWorkflow_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot, registerQueueStatuses_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -145995,10 +146200,21 @@ public class RegistryService {
break;
}
switch (schemeField.id) {
- case 1: // WORKFLOW_TEMPLATE_ID
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.workflowTemplateId = iprot.readString();
- struct.setWorkflowTemplateIdIsSet(true);
+ case 1: // QUEUE_STATUSES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list298 = iprot.readListBegin();
+ struct.queueStatuses = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(_list298.size);
+ org.apache.airavata.model.status.QueueStatusModel _elem299;
+ for (int _i300 = 0; _i300 < _list298.size; ++_i300)
+ {
+ _elem299 = new org.apache.airavata.model.status.QueueStatusModel();
+ _elem299.read(iprot);
+ struct.queueStatuses.add(_elem299);
+ }
+ iprot.readListEnd();
+ }
+ struct.setQueueStatusesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -146014,13 +146230,20 @@ public class RegistryService {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, getWorkflow_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot, registerQueueStatuses_args struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
- if (struct.workflowTemplateId != null) {
- oprot.writeFieldBegin(WORKFLOW_TEMPLATE_ID_FIELD_DESC);
- oprot.writeString(struct.workflowTemplateId);
+ if (struct.queueStatuses != null) {
+ oprot.writeFieldBegin(QUEUE_STATUSES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.queueStatuses.size()));
+ for (org.apache.airavata.model.status.QueueStatusModel _iter301 : struct.queueStatuses)
+ {
+ _iter301.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
@@ -146029,48 +146252,61 @@ public class RegistryService {
}
- private static class getWorkflow_argsTupleSchemeFactory implements SchemeFactory {
- public getWorkflow_argsTupleScheme getScheme() {
- return new getWorkflow_argsTupleScheme();
+ private static class registerQueueStatuses_argsTupleSchemeFactory implements SchemeFactory {
+ public registerQueueStatuses_argsTupleScheme getScheme() {
+ return new registerQueueStatuses_argsTupleScheme();
}
}
- private static class getWorkflow_argsTupleScheme extends TupleScheme<getWorkflow_args> {
+ private static class registerQueueStatuses_argsTupleScheme extends TupleScheme<registerQueueStatuses_args> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, getWorkflow_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol prot, registerQueueStatuses_args struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeString(struct.workflowTemplateId);
+ {
+ oprot.writeI32(struct.queueStatuses.size());
+ for (org.apache.airavata.model.status.QueueStatusModel _iter302 : struct.queueStatuses)
+ {
+ _iter302.write(oprot);
+ }
+ }
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, getWorkflow_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol prot, registerQueueStatuses_args struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.workflowTemplateId = iprot.readString();
- struct.setWorkflowTemplateIdIsSet(true);
+ {
+ org.apache.thrift.protocol.TList _list303 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.queueStatuses = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(_list303.size);
+ org.apache.airavata.model.status.QueueStatusModel _elem304;
+ for (int _i305 = 0; _i305 < _list303.size; ++_i305)
+ {
+ _elem304 = new org.apache.airavata.model.status.QueueStatusModel();
+ _elem304.read(iprot);
+ struct.queueStatuses.add(_elem304);
+ }
+ }
+ struct.setQueueStatusesIsSet(true);
}
}
}
- public static class getWorkflow_result implements org.apache.thrift.TBase<getWorkflow_result, getWorkflow_result._Fields>, java.io.Serializable, Cloneable, Comparable<getWorkflow_result> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getWorkflow_result");
+ public static class registerQueueStatuses_result implements org.apache.thrift.TBase<registerQueueStatuses_result, registerQueueStatuses_result._Fields>, java.io.Serializable, Cloneable, Comparable<registerQueueStatuses_result> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("registerQueueStatuses_result");
- private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0);
private static final org.apache.thrift.protocol.TField RSE_FIELD_DESC = new org.apache.thrift.protocol.TField("rse", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
- schemes.put(StandardScheme.class, new getWorkflow_resultStandardSchemeFactory());
- schemes.put(TupleScheme.class, new getWorkflow_resultTupleSchemeFactory());
+ schemes.put(StandardScheme.class, new registerQueueStatuses_resultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new registerQueueStatuses_resultTupleSchemeFactory());
}
- public org.apache.airavata.model.WorkflowModel success; // required
public org.apache.airavata.registry.api.exception.RegistryServiceException rse; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- SUCCESS((short)0, "success"),
RSE((short)1, "rse");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -146086,8 +146322,6 @@ public class RegistryService {
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 0: // SUCCESS
- return SUCCESS;
case 1: // RSE
return RSE;
default:
@@ -146133,77 +146367,45 @@ public class RegistryService {
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.WorkflowModel.class)));
tmpMap.put(_Fields.RSE, new org.apache.thrift.meta_data.FieldMetaData("rse", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getWorkflow_result.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(registerQueueStatuses_result.class, metaDataMap);
}
- public getWorkflow_result() {
+ public registerQueueStatuses_result() {
}
- public getWorkflow_result(
- org.apache.airavata.model.WorkflowModel success,
+ public registerQueueStatuses_result(
org.apache.airavata.registry.api.exception.RegistryServiceException rse)
{
this();
- this.success = success;
this.rse = rse;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getWorkflow_result(getWorkflow_result other) {
- if (other.isSetSuccess()) {
- this.success = new org.apache.airavata.model.WorkflowModel(other.success);
- }
+ public registerQueueStatuses_result(registerQueueStatuses_result other) {
if (other.isSetRse()) {
this.rse = new org.apache.airavata.registry.api.exception.RegistryServiceException(other.rse);
}
<TRUNCATED>