airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shame...@apache.org
Subject [22/53] airavata git commit: Adding aurora-client project
Date Thu, 27 Oct 2016 21:32:15 GMT
http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Resource.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Resource.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Resource.java
new file mode 100644
index 0000000..3e8319d
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Resource.java
@@ -0,0 +1,542 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+/**
+ * Describes resource value required to run a task.
+ */
+public class Resource extends org.apache.thrift.TUnion<Resource, Resource._Fields> {
+  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Resource");
+  private static final org.apache.thrift.protocol.TField NUM_CPUS_FIELD_DESC = new org.apache.thrift.protocol.TField("numCpus", org.apache.thrift.protocol.TType.DOUBLE, (short)1);
+  private static final org.apache.thrift.protocol.TField RAM_MB_FIELD_DESC = new org.apache.thrift.protocol.TField("ramMb", org.apache.thrift.protocol.TType.I64, (short)2);
+  private static final org.apache.thrift.protocol.TField DISK_MB_FIELD_DESC = new org.apache.thrift.protocol.TField("diskMb", org.apache.thrift.protocol.TType.I64, (short)3);
+  private static final org.apache.thrift.protocol.TField NAMED_PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("namedPort", org.apache.thrift.protocol.TType.STRING, (short)4);
+  private static final org.apache.thrift.protocol.TField NUM_GPUS_FIELD_DESC = new org.apache.thrift.protocol.TField("numGpus", org.apache.thrift.protocol.TType.I64, (short)5);
+
+  /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+  public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+    NUM_CPUS((short)1, "numCpus"),
+    RAM_MB((short)2, "ramMb"),
+    DISK_MB((short)3, "diskMb"),
+    NAMED_PORT((short)4, "namedPort"),
+    NUM_GPUS((short)5, "numGpus");
+
+    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+    static {
+      for (_Fields field : EnumSet.allOf(_Fields.class)) {
+        byName.put(field.getFieldName(), field);
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, or null if its not found.
+     */
+    public static _Fields findByThriftId(int fieldId) {
+      switch(fieldId) {
+        case 1: // NUM_CPUS
+          return NUM_CPUS;
+        case 2: // RAM_MB
+          return RAM_MB;
+        case 3: // DISK_MB
+          return DISK_MB;
+        case 4: // NAMED_PORT
+          return NAMED_PORT;
+        case 5: // NUM_GPUS
+          return NUM_GPUS;
+        default:
+          return null;
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, throwing an exception
+     * if it is not found.
+     */
+    public static _Fields findByThriftIdOrThrow(int fieldId) {
+      _Fields fields = findByThriftId(fieldId);
+      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+      return fields;
+    }
+
+    /**
+     * Find the _Fields constant that matches name, or null if its not found.
+     */
+    public static _Fields findByName(String name) {
+      return byName.get(name);
+    }
+
+    private final short _thriftId;
+    private final String _fieldName;
+
+    _Fields(short thriftId, String fieldName) {
+      _thriftId = thriftId;
+      _fieldName = fieldName;
+    }
+
+    public short getThriftFieldId() {
+      return _thriftId;
+    }
+
+    public String getFieldName() {
+      return _fieldName;
+    }
+  }
+
+  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.NUM_CPUS, new org.apache.thrift.meta_data.FieldMetaData("numCpus", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+    tmpMap.put(_Fields.RAM_MB, new org.apache.thrift.meta_data.FieldMetaData("ramMb", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+    tmpMap.put(_Fields.DISK_MB, new org.apache.thrift.meta_data.FieldMetaData("diskMb", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+    tmpMap.put(_Fields.NAMED_PORT, new org.apache.thrift.meta_data.FieldMetaData("namedPort", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+    tmpMap.put(_Fields.NUM_GPUS, new org.apache.thrift.meta_data.FieldMetaData("numGpus", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+    metaDataMap = Collections.unmodifiableMap(tmpMap);
+    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Resource.class, metaDataMap);
+  }
+
+  public Resource() {
+    super();
+  }
+
+  public Resource(_Fields setField, Object value) {
+    super(setField, value);
+  }
+
+  public Resource(Resource other) {
+    super(other);
+  }
+  public Resource deepCopy() {
+    return new Resource(this);
+  }
+
+  public static Resource numCpus(double value) {
+    Resource x = new Resource();
+    x.setNumCpus(value);
+    return x;
+  }
+
+  public static Resource ramMb(long value) {
+    Resource x = new Resource();
+    x.setRamMb(value);
+    return x;
+  }
+
+  public static Resource diskMb(long value) {
+    Resource x = new Resource();
+    x.setDiskMb(value);
+    return x;
+  }
+
+  public static Resource namedPort(String value) {
+    Resource x = new Resource();
+    x.setNamedPort(value);
+    return x;
+  }
+
+  public static Resource numGpus(long value) {
+    Resource x = new Resource();
+    x.setNumGpus(value);
+    return x;
+  }
+
+
+  @Override
+  protected void checkType(_Fields setField, Object value) throws ClassCastException {
+    switch (setField) {
+      case NUM_CPUS:
+        if (value instanceof Double) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Double for field 'numCpus', but got " + value.getClass().getSimpleName());
+      case RAM_MB:
+        if (value instanceof Long) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Long for field 'ramMb', but got " + value.getClass().getSimpleName());
+      case DISK_MB:
+        if (value instanceof Long) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Long for field 'diskMb', but got " + value.getClass().getSimpleName());
+      case NAMED_PORT:
+        if (value instanceof String) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type String for field 'namedPort', but got " + value.getClass().getSimpleName());
+      case NUM_GPUS:
+        if (value instanceof Long) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Long for field 'numGpus', but got " + value.getClass().getSimpleName());
+      default:
+        throw new IllegalArgumentException("Unknown field id " + setField);
+    }
+  }
+
+  @Override
+  protected Object standardSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TField field) throws org.apache.thrift.TException {
+    _Fields setField = _Fields.findByThriftId(field.id);
+    if (setField != null) {
+      switch (setField) {
+        case NUM_CPUS:
+          if (field.type == NUM_CPUS_FIELD_DESC.type) {
+            Double numCpus;
+            numCpus = iprot.readDouble();
+            return numCpus;
+          } else {
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case RAM_MB:
+          if (field.type == RAM_MB_FIELD_DESC.type) {
+            Long ramMb;
+            ramMb = iprot.readI64();
+            return ramMb;
+          } else {
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case DISK_MB:
+          if (field.type == DISK_MB_FIELD_DESC.type) {
+            Long diskMb;
+            diskMb = iprot.readI64();
+            return diskMb;
+          } else {
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case NAMED_PORT:
+          if (field.type == NAMED_PORT_FIELD_DESC.type) {
+            String namedPort;
+            namedPort = iprot.readString();
+            return namedPort;
+          } else {
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case NUM_GPUS:
+          if (field.type == NUM_GPUS_FIELD_DESC.type) {
+            Long numGpus;
+            numGpus = iprot.readI64();
+            return numGpus;
+          } else {
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        default:
+          throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
+      }
+    } else {
+      org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+      return null;
+    }
+  }
+
+  @Override
+  protected void standardSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+    switch (setField_) {
+      case NUM_CPUS:
+        Double numCpus = (Double)value_;
+        oprot.writeDouble(numCpus);
+        return;
+      case RAM_MB:
+        Long ramMb = (Long)value_;
+        oprot.writeI64(ramMb);
+        return;
+      case DISK_MB:
+        Long diskMb = (Long)value_;
+        oprot.writeI64(diskMb);
+        return;
+      case NAMED_PORT:
+        String namedPort = (String)value_;
+        oprot.writeString(namedPort);
+        return;
+      case NUM_GPUS:
+        Long numGpus = (Long)value_;
+        oprot.writeI64(numGpus);
+        return;
+      default:
+        throw new IllegalStateException("Cannot write union with unknown field " + setField_);
+    }
+  }
+
+  @Override
+  protected Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, short fieldID) throws org.apache.thrift.TException {
+    _Fields setField = _Fields.findByThriftId(fieldID);
+    if (setField != null) {
+      switch (setField) {
+        case NUM_CPUS:
+          Double numCpus;
+          numCpus = iprot.readDouble();
+          return numCpus;
+        case RAM_MB:
+          Long ramMb;
+          ramMb = iprot.readI64();
+          return ramMb;
+        case DISK_MB:
+          Long diskMb;
+          diskMb = iprot.readI64();
+          return diskMb;
+        case NAMED_PORT:
+          String namedPort;
+          namedPort = iprot.readString();
+          return namedPort;
+        case NUM_GPUS:
+          Long numGpus;
+          numGpus = iprot.readI64();
+          return numGpus;
+        default:
+          throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
+      }
+    } else {
+      throw new TProtocolException("Couldn't find a field with field id " + fieldID);
+    }
+  }
+
+  @Override
+  protected void tupleSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+    switch (setField_) {
+      case NUM_CPUS:
+        Double numCpus = (Double)value_;
+        oprot.writeDouble(numCpus);
+        return;
+      case RAM_MB:
+        Long ramMb = (Long)value_;
+        oprot.writeI64(ramMb);
+        return;
+      case DISK_MB:
+        Long diskMb = (Long)value_;
+        oprot.writeI64(diskMb);
+        return;
+      case NAMED_PORT:
+        String namedPort = (String)value_;
+        oprot.writeString(namedPort);
+        return;
+      case NUM_GPUS:
+        Long numGpus = (Long)value_;
+        oprot.writeI64(numGpus);
+        return;
+      default:
+        throw new IllegalStateException("Cannot write union with unknown field " + setField_);
+    }
+  }
+
+  @Override
+  protected org.apache.thrift.protocol.TField getFieldDesc(_Fields setField) {
+    switch (setField) {
+      case NUM_CPUS:
+        return NUM_CPUS_FIELD_DESC;
+      case RAM_MB:
+        return RAM_MB_FIELD_DESC;
+      case DISK_MB:
+        return DISK_MB_FIELD_DESC;
+      case NAMED_PORT:
+        return NAMED_PORT_FIELD_DESC;
+      case NUM_GPUS:
+        return NUM_GPUS_FIELD_DESC;
+      default:
+        throw new IllegalArgumentException("Unknown field id " + setField);
+    }
+  }
+
+  @Override
+  protected org.apache.thrift.protocol.TStruct getStructDesc() {
+    return STRUCT_DESC;
+  }
+
+  @Override
+  protected _Fields enumForId(short id) {
+    return _Fields.findByThriftIdOrThrow(id);
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+
+  public double getNumCpus() {
+    if (getSetField() == _Fields.NUM_CPUS) {
+      return (Double)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'numCpus' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setNumCpus(double value) {
+    setField_ = _Fields.NUM_CPUS;
+    value_ = value;
+  }
+
+  public long getRamMb() {
+    if (getSetField() == _Fields.RAM_MB) {
+      return (Long)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'ramMb' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setRamMb(long value) {
+    setField_ = _Fields.RAM_MB;
+    value_ = value;
+  }
+
+  public long getDiskMb() {
+    if (getSetField() == _Fields.DISK_MB) {
+      return (Long)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'diskMb' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setDiskMb(long value) {
+    setField_ = _Fields.DISK_MB;
+    value_ = value;
+  }
+
+  public String getNamedPort() {
+    if (getSetField() == _Fields.NAMED_PORT) {
+      return (String)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'namedPort' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setNamedPort(String value) {
+    if (value == null) throw new NullPointerException();
+    setField_ = _Fields.NAMED_PORT;
+    value_ = value;
+  }
+
+  public long getNumGpus() {
+    if (getSetField() == _Fields.NUM_GPUS) {
+      return (Long)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'numGpus' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setNumGpus(long value) {
+    setField_ = _Fields.NUM_GPUS;
+    value_ = value;
+  }
+
+  public boolean isSetNumCpus() {
+    return setField_ == _Fields.NUM_CPUS;
+  }
+
+
+  public boolean isSetRamMb() {
+    return setField_ == _Fields.RAM_MB;
+  }
+
+
+  public boolean isSetDiskMb() {
+    return setField_ == _Fields.DISK_MB;
+  }
+
+
+  public boolean isSetNamedPort() {
+    return setField_ == _Fields.NAMED_PORT;
+  }
+
+
+  public boolean isSetNumGpus() {
+    return setField_ == _Fields.NUM_GPUS;
+  }
+
+
+  public boolean equals(Object other) {
+    if (other instanceof Resource) {
+      return equals((Resource)other);
+    } else {
+      return false;
+    }
+  }
+
+  public boolean equals(Resource other) {
+    return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue());
+  }
+
+  @Override
+  public int compareTo(Resource other) {
+    int lastComparison = org.apache.thrift.TBaseHelper.compareTo(getSetField(), other.getSetField());
+    if (lastComparison == 0) {
+      return org.apache.thrift.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue());
+    }
+    return lastComparison;
+  }
+
+
+  @Override
+  public int hashCode() {
+    List<Object> list = new ArrayList<Object>();
+    list.add(this.getClass().getName());
+    org.apache.thrift.TFieldIdEnum setField = getSetField();
+    if (setField != null) {
+      list.add(setField.getThriftFieldId());
+      Object value = getFieldValue();
+      if (value instanceof org.apache.thrift.TEnum) {
+        list.add(((org.apache.thrift.TEnum)getFieldValue()).getValue());
+      } else {
+        list.add(value);
+      }
+    }
+    return list.hashCode();
+  }
+  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+    try {
+      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+
+  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+    try {
+      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+
+}

http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResourceAggregate.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResourceAggregate.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResourceAggregate.java
new file mode 100644
index 0000000..d288c1c
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResourceAggregate.java
@@ -0,0 +1,801 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21")
+public class ResourceAggregate implements org.apache.thrift.TBase<ResourceAggregate, ResourceAggregate._Fields>, java.io.Serializable, Cloneable, Comparable<ResourceAggregate> {
+  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ResourceAggregate");
+
+  private static final org.apache.thrift.protocol.TField NUM_CPUS_FIELD_DESC = new org.apache.thrift.protocol.TField("numCpus", org.apache.thrift.protocol.TType.DOUBLE, (short)1);
+  private static final org.apache.thrift.protocol.TField RAM_MB_FIELD_DESC = new org.apache.thrift.protocol.TField("ramMb", org.apache.thrift.protocol.TType.I64, (short)2);
+  private static final org.apache.thrift.protocol.TField DISK_MB_FIELD_DESC = new org.apache.thrift.protocol.TField("diskMb", org.apache.thrift.protocol.TType.I64, (short)3);
+  private static final org.apache.thrift.protocol.TField RESOURCES_FIELD_DESC = new org.apache.thrift.protocol.TField("resources", org.apache.thrift.protocol.TType.SET, (short)4);
+
+  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+  static {
+    schemes.put(StandardScheme.class, new ResourceAggregateStandardSchemeFactory());
+    schemes.put(TupleScheme.class, new ResourceAggregateTupleSchemeFactory());
+  }
+
+  /**
+   * Number of CPU cores allotted.
+   */
+  public double numCpus; // required
+  /**
+   * Megabytes of RAM allotted.
+   */
+  public long ramMb; // required
+  /**
+   * Megabytes of disk space allotted.
+   */
+  public long diskMb; // required
+  /**
+   * Aggregated resource values.
+   */
+  public Set<Resource> resources; // 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 {
+    /**
+     * Number of CPU cores allotted.
+     */
+    NUM_CPUS((short)1, "numCpus"),
+    /**
+     * Megabytes of RAM allotted.
+     */
+    RAM_MB((short)2, "ramMb"),
+    /**
+     * Megabytes of disk space allotted.
+     */
+    DISK_MB((short)3, "diskMb"),
+    /**
+     * Aggregated resource values.
+     */
+    RESOURCES((short)4, "resources");
+
+    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+    static {
+      for (_Fields field : EnumSet.allOf(_Fields.class)) {
+        byName.put(field.getFieldName(), field);
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, or null if its not found.
+     */
+    public static _Fields findByThriftId(int fieldId) {
+      switch(fieldId) {
+        case 1: // NUM_CPUS
+          return NUM_CPUS;
+        case 2: // RAM_MB
+          return RAM_MB;
+        case 3: // DISK_MB
+          return DISK_MB;
+        case 4: // RESOURCES
+          return RESOURCES;
+        default:
+          return null;
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, throwing an exception
+     * if it is not found.
+     */
+    public static _Fields findByThriftIdOrThrow(int fieldId) {
+      _Fields fields = findByThriftId(fieldId);
+      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+      return fields;
+    }
+
+    /**
+     * Find the _Fields constant that matches name, or null if its not found.
+     */
+    public static _Fields findByName(String name) {
+      return byName.get(name);
+    }
+
+    private final short _thriftId;
+    private final String _fieldName;
+
+    _Fields(short thriftId, String fieldName) {
+      _thriftId = thriftId;
+      _fieldName = fieldName;
+    }
+
+    public short getThriftFieldId() {
+      return _thriftId;
+    }
+
+    public String getFieldName() {
+      return _fieldName;
+    }
+  }
+
+  // isset id assignments
+  private static final int __NUMCPUS_ISSET_ID = 0;
+  private static final int __RAMMB_ISSET_ID = 1;
+  private static final int __DISKMB_ISSET_ID = 2;
+  private byte __isset_bitfield = 0;
+  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.NUM_CPUS, new org.apache.thrift.meta_data.FieldMetaData("numCpus", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+    tmpMap.put(_Fields.RAM_MB, new org.apache.thrift.meta_data.FieldMetaData("ramMb", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+    tmpMap.put(_Fields.DISK_MB, new org.apache.thrift.meta_data.FieldMetaData("diskMb", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+    tmpMap.put(_Fields.RESOURCES, new org.apache.thrift.meta_data.FieldMetaData("resources", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET, 
+            new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Resource.class))));
+    metaDataMap = Collections.unmodifiableMap(tmpMap);
+    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ResourceAggregate.class, metaDataMap);
+  }
+
+  public ResourceAggregate() {
+  }
+
+  public ResourceAggregate(
+    double numCpus,
+    long ramMb,
+    long diskMb,
+    Set<Resource> resources)
+  {
+    this();
+    this.numCpus = numCpus;
+    setNumCpusIsSet(true);
+    this.ramMb = ramMb;
+    setRamMbIsSet(true);
+    this.diskMb = diskMb;
+    setDiskMbIsSet(true);
+    this.resources = resources;
+  }
+
+  /**
+   * Performs a deep copy on <i>other</i>.
+   */
+  public ResourceAggregate(ResourceAggregate other) {
+    __isset_bitfield = other.__isset_bitfield;
+    this.numCpus = other.numCpus;
+    this.ramMb = other.ramMb;
+    this.diskMb = other.diskMb;
+    if (other.isSetResources()) {
+      Set<Resource> __this__resources = new HashSet<Resource>(other.resources.size());
+      for (Resource other_element : other.resources) {
+        __this__resources.add(new Resource(other_element));
+      }
+      this.resources = __this__resources;
+    }
+  }
+
+  public ResourceAggregate deepCopy() {
+    return new ResourceAggregate(this);
+  }
+
+  @Override
+  public void clear() {
+    setNumCpusIsSet(false);
+    this.numCpus = 0.0;
+    setRamMbIsSet(false);
+    this.ramMb = 0;
+    setDiskMbIsSet(false);
+    this.diskMb = 0;
+    this.resources = null;
+  }
+
+  /**
+   * Number of CPU cores allotted.
+   */
+  public double getNumCpus() {
+    return this.numCpus;
+  }
+
+  /**
+   * Number of CPU cores allotted.
+   */
+  public ResourceAggregate setNumCpus(double numCpus) {
+    this.numCpus = numCpus;
+    setNumCpusIsSet(true);
+    return this;
+  }
+
+  public void unsetNumCpus() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMCPUS_ISSET_ID);
+  }
+
+  /** Returns true if field numCpus is set (has been assigned a value) and false otherwise */
+  public boolean isSetNumCpus() {
+    return EncodingUtils.testBit(__isset_bitfield, __NUMCPUS_ISSET_ID);
+  }
+
+  public void setNumCpusIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMCPUS_ISSET_ID, value);
+  }
+
+  /**
+   * Megabytes of RAM allotted.
+   */
+  public long getRamMb() {
+    return this.ramMb;
+  }
+
+  /**
+   * Megabytes of RAM allotted.
+   */
+  public ResourceAggregate setRamMb(long ramMb) {
+    this.ramMb = ramMb;
+    setRamMbIsSet(true);
+    return this;
+  }
+
+  public void unsetRamMb() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __RAMMB_ISSET_ID);
+  }
+
+  /** Returns true if field ramMb is set (has been assigned a value) and false otherwise */
+  public boolean isSetRamMb() {
+    return EncodingUtils.testBit(__isset_bitfield, __RAMMB_ISSET_ID);
+  }
+
+  public void setRamMbIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __RAMMB_ISSET_ID, value);
+  }
+
+  /**
+   * Megabytes of disk space allotted.
+   */
+  public long getDiskMb() {
+    return this.diskMb;
+  }
+
+  /**
+   * Megabytes of disk space allotted.
+   */
+  public ResourceAggregate setDiskMb(long diskMb) {
+    this.diskMb = diskMb;
+    setDiskMbIsSet(true);
+    return this;
+  }
+
+  public void unsetDiskMb() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __DISKMB_ISSET_ID);
+  }
+
+  /** Returns true if field diskMb is set (has been assigned a value) and false otherwise */
+  public boolean isSetDiskMb() {
+    return EncodingUtils.testBit(__isset_bitfield, __DISKMB_ISSET_ID);
+  }
+
+  public void setDiskMbIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __DISKMB_ISSET_ID, value);
+  }
+
+  public int getResourcesSize() {
+    return (this.resources == null) ? 0 : this.resources.size();
+  }
+
+  public java.util.Iterator<Resource> getResourcesIterator() {
+    return (this.resources == null) ? null : this.resources.iterator();
+  }
+
+  public void addToResources(Resource elem) {
+    if (this.resources == null) {
+      this.resources = new HashSet<Resource>();
+    }
+    this.resources.add(elem);
+  }
+
+  /**
+   * Aggregated resource values.
+   */
+  public Set<Resource> getResources() {
+    return this.resources;
+  }
+
+  /**
+   * Aggregated resource values.
+   */
+  public ResourceAggregate setResources(Set<Resource> resources) {
+    this.resources = resources;
+    return this;
+  }
+
+  public void unsetResources() {
+    this.resources = null;
+  }
+
+  /** Returns true if field resources is set (has been assigned a value) and false otherwise */
+  public boolean isSetResources() {
+    return this.resources != null;
+  }
+
+  public void setResourcesIsSet(boolean value) {
+    if (!value) {
+      this.resources = null;
+    }
+  }
+
+  public void setFieldValue(_Fields field, Object value) {
+    switch (field) {
+    case NUM_CPUS:
+      if (value == null) {
+        unsetNumCpus();
+      } else {
+        setNumCpus((Double)value);
+      }
+      break;
+
+    case RAM_MB:
+      if (value == null) {
+        unsetRamMb();
+      } else {
+        setRamMb((Long)value);
+      }
+      break;
+
+    case DISK_MB:
+      if (value == null) {
+        unsetDiskMb();
+      } else {
+        setDiskMb((Long)value);
+      }
+      break;
+
+    case RESOURCES:
+      if (value == null) {
+        unsetResources();
+      } else {
+        setResources((Set<Resource>)value);
+      }
+      break;
+
+    }
+  }
+
+  public Object getFieldValue(_Fields field) {
+    switch (field) {
+    case NUM_CPUS:
+      return getNumCpus();
+
+    case RAM_MB:
+      return getRamMb();
+
+    case DISK_MB:
+      return getDiskMb();
+
+    case RESOURCES:
+      return getResources();
+
+    }
+    throw new IllegalStateException();
+  }
+
+  /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+  public boolean isSet(_Fields field) {
+    if (field == null) {
+      throw new IllegalArgumentException();
+    }
+
+    switch (field) {
+    case NUM_CPUS:
+      return isSetNumCpus();
+    case RAM_MB:
+      return isSetRamMb();
+    case DISK_MB:
+      return isSetDiskMb();
+    case RESOURCES:
+      return isSetResources();
+    }
+    throw new IllegalStateException();
+  }
+
+  @Override
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof ResourceAggregate)
+      return this.equals((ResourceAggregate)that);
+    return false;
+  }
+
+  public boolean equals(ResourceAggregate that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_numCpus = true;
+    boolean that_present_numCpus = true;
+    if (this_present_numCpus || that_present_numCpus) {
+      if (!(this_present_numCpus && that_present_numCpus))
+        return false;
+      if (this.numCpus != that.numCpus)
+        return false;
+    }
+
+    boolean this_present_ramMb = true;
+    boolean that_present_ramMb = true;
+    if (this_present_ramMb || that_present_ramMb) {
+      if (!(this_present_ramMb && that_present_ramMb))
+        return false;
+      if (this.ramMb != that.ramMb)
+        return false;
+    }
+
+    boolean this_present_diskMb = true;
+    boolean that_present_diskMb = true;
+    if (this_present_diskMb || that_present_diskMb) {
+      if (!(this_present_diskMb && that_present_diskMb))
+        return false;
+      if (this.diskMb != that.diskMb)
+        return false;
+    }
+
+    boolean this_present_resources = true && this.isSetResources();
+    boolean that_present_resources = true && that.isSetResources();
+    if (this_present_resources || that_present_resources) {
+      if (!(this_present_resources && that_present_resources))
+        return false;
+      if (!this.resources.equals(that.resources))
+        return false;
+    }
+
+    return true;
+  }
+
+  @Override
+  public int hashCode() {
+    List<Object> list = new ArrayList<Object>();
+
+    boolean present_numCpus = true;
+    list.add(present_numCpus);
+    if (present_numCpus)
+      list.add(numCpus);
+
+    boolean present_ramMb = true;
+    list.add(present_ramMb);
+    if (present_ramMb)
+      list.add(ramMb);
+
+    boolean present_diskMb = true;
+    list.add(present_diskMb);
+    if (present_diskMb)
+      list.add(diskMb);
+
+    boolean present_resources = true && (isSetResources());
+    list.add(present_resources);
+    if (present_resources)
+      list.add(resources);
+
+    return list.hashCode();
+  }
+
+  @Override
+  public int compareTo(ResourceAggregate other) {
+    if (!getClass().equals(other.getClass())) {
+      return getClass().getName().compareTo(other.getClass().getName());
+    }
+
+    int lastComparison = 0;
+
+    lastComparison = Boolean.valueOf(isSetNumCpus()).compareTo(other.isSetNumCpus());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetNumCpus()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.numCpus, other.numCpus);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetRamMb()).compareTo(other.isSetRamMb());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetRamMb()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ramMb, other.ramMb);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetDiskMb()).compareTo(other.isSetDiskMb());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetDiskMb()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.diskMb, other.diskMb);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetResources()).compareTo(other.isSetResources());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetResources()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.resources, other.resources);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    return 0;
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+  public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+    schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+  }
+
+  public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+    schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder("ResourceAggregate(");
+    boolean first = true;
+
+    sb.append("numCpus:");
+    sb.append(this.numCpus);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("ramMb:");
+    sb.append(this.ramMb);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("diskMb:");
+    sb.append(this.diskMb);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("resources:");
+    if (this.resources == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.resources);
+    }
+    first = false;
+    sb.append(")");
+    return sb.toString();
+  }
+
+  public void validate() throws org.apache.thrift.TException {
+    // check for required fields
+    // check for sub-struct validity
+  }
+
+  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+    try {
+      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+    try {
+      // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+      __isset_bitfield = 0;
+      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private static class ResourceAggregateStandardSchemeFactory implements SchemeFactory {
+    public ResourceAggregateStandardScheme getScheme() {
+      return new ResourceAggregateStandardScheme();
+    }
+  }
+
+  private static class ResourceAggregateStandardScheme extends StandardScheme<ResourceAggregate> {
+
+    public void read(org.apache.thrift.protocol.TProtocol iprot, ResourceAggregate struct) throws org.apache.thrift.TException {
+      org.apache.thrift.protocol.TField schemeField;
+      iprot.readStructBegin();
+      while (true)
+      {
+        schemeField = iprot.readFieldBegin();
+        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+          break;
+        }
+        switch (schemeField.id) {
+          case 1: // NUM_CPUS
+            if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+              struct.numCpus = iprot.readDouble();
+              struct.setNumCpusIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 2: // RAM_MB
+            if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+              struct.ramMb = iprot.readI64();
+              struct.setRamMbIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 3: // DISK_MB
+            if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+              struct.diskMb = iprot.readI64();
+              struct.setDiskMbIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 4: // RESOURCES
+            if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
+              {
+                org.apache.thrift.protocol.TSet _set84 = iprot.readSetBegin();
+                struct.resources = new HashSet<Resource>(2*_set84.size);
+                Resource _elem85;
+                for (int _i86 = 0; _i86 < _set84.size; ++_i86)
+                {
+                  _elem85 = new Resource();
+                  _elem85.read(iprot);
+                  struct.resources.add(_elem85);
+                }
+                iprot.readSetEnd();
+              }
+              struct.setResourcesIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          default:
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+
+      // check for required fields of primitive type, which can't be checked in the validate method
+      struct.validate();
+    }
+
+    public void write(org.apache.thrift.protocol.TProtocol oprot, ResourceAggregate struct) throws org.apache.thrift.TException {
+      struct.validate();
+
+      oprot.writeStructBegin(STRUCT_DESC);
+      oprot.writeFieldBegin(NUM_CPUS_FIELD_DESC);
+      oprot.writeDouble(struct.numCpus);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(RAM_MB_FIELD_DESC);
+      oprot.writeI64(struct.ramMb);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(DISK_MB_FIELD_DESC);
+      oprot.writeI64(struct.diskMb);
+      oprot.writeFieldEnd();
+      if (struct.resources != null) {
+        oprot.writeFieldBegin(RESOURCES_FIELD_DESC);
+        {
+          oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.resources.size()));
+          for (Resource _iter87 : struct.resources)
+          {
+            _iter87.write(oprot);
+          }
+          oprot.writeSetEnd();
+        }
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+  }
+
+  private static class ResourceAggregateTupleSchemeFactory implements SchemeFactory {
+    public ResourceAggregateTupleScheme getScheme() {
+      return new ResourceAggregateTupleScheme();
+    }
+  }
+
+  private static class ResourceAggregateTupleScheme extends TupleScheme<ResourceAggregate> {
+
+    @Override
+    public void write(org.apache.thrift.protocol.TProtocol prot, ResourceAggregate struct) throws org.apache.thrift.TException {
+      TTupleProtocol oprot = (TTupleProtocol) prot;
+      BitSet optionals = new BitSet();
+      if (struct.isSetNumCpus()) {
+        optionals.set(0);
+      }
+      if (struct.isSetRamMb()) {
+        optionals.set(1);
+      }
+      if (struct.isSetDiskMb()) {
+        optionals.set(2);
+      }
+      if (struct.isSetResources()) {
+        optionals.set(3);
+      }
+      oprot.writeBitSet(optionals, 4);
+      if (struct.isSetNumCpus()) {
+        oprot.writeDouble(struct.numCpus);
+      }
+      if (struct.isSetRamMb()) {
+        oprot.writeI64(struct.ramMb);
+      }
+      if (struct.isSetDiskMb()) {
+        oprot.writeI64(struct.diskMb);
+      }
+      if (struct.isSetResources()) {
+        {
+          oprot.writeI32(struct.resources.size());
+          for (Resource _iter88 : struct.resources)
+          {
+            _iter88.write(oprot);
+          }
+        }
+      }
+    }
+
+    @Override
+    public void read(org.apache.thrift.protocol.TProtocol prot, ResourceAggregate struct) throws org.apache.thrift.TException {
+      TTupleProtocol iprot = (TTupleProtocol) prot;
+      BitSet incoming = iprot.readBitSet(4);
+      if (incoming.get(0)) {
+        struct.numCpus = iprot.readDouble();
+        struct.setNumCpusIsSet(true);
+      }
+      if (incoming.get(1)) {
+        struct.ramMb = iprot.readI64();
+        struct.setRamMbIsSet(true);
+      }
+      if (incoming.get(2)) {
+        struct.diskMb = iprot.readI64();
+        struct.setDiskMbIsSet(true);
+      }
+      if (incoming.get(3)) {
+        {
+          org.apache.thrift.protocol.TSet _set89 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.resources = new HashSet<Resource>(2*_set89.size);
+          Resource _elem90;
+          for (int _i91 = 0; _i91 < _set89.size; ++_i91)
+          {
+            _elem90 = new Resource();
+            _elem90.read(iprot);
+            struct.resources.add(_elem90);
+          }
+        }
+        struct.setResourcesIsSet(true);
+      }
+    }
+  }
+
+}
+

http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Response.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Response.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Response.java
new file mode 100644
index 0000000..3f974c0
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Response.java
@@ -0,0 +1,821 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21")
+public class Response implements org.apache.thrift.TBase<Response, Response._Fields>, java.io.Serializable, Cloneable, Comparable<Response> {
+  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Response");
+
+  private static final org.apache.thrift.protocol.TField RESPONSE_CODE_FIELD_DESC = new org.apache.thrift.protocol.TField("responseCode", org.apache.thrift.protocol.TType.I32, (short)1);
+  private static final org.apache.thrift.protocol.TField SERVER_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("serverInfo", org.apache.thrift.protocol.TType.STRUCT, (short)5);
+  private static final org.apache.thrift.protocol.TField RESULT_FIELD_DESC = new org.apache.thrift.protocol.TField("result", org.apache.thrift.protocol.TType.STRUCT, (short)3);
+  private static final org.apache.thrift.protocol.TField DETAILS_FIELD_DESC = new org.apache.thrift.protocol.TField("details", org.apache.thrift.protocol.TType.LIST, (short)6);
+
+  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+  static {
+    schemes.put(StandardScheme.class, new ResponseStandardSchemeFactory());
+    schemes.put(TupleScheme.class, new ResponseTupleSchemeFactory());
+  }
+
+  /**
+   * 
+   * @see ResponseCode
+   */
+  public ResponseCode responseCode; // required
+  public ServerInfo serverInfo; // required
+  /**
+   * Payload from the invoked RPC.
+   */
+  public Result result; // optional
+  /**
+   * Messages from the server relevant to the request, such as warnings or use of deprecated
+   * features.
+   */
+  public List<ResponseDetail> details; // 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 {
+    /**
+     * 
+     * @see ResponseCode
+     */
+    RESPONSE_CODE((short)1, "responseCode"),
+    SERVER_INFO((short)5, "serverInfo"),
+    /**
+     * Payload from the invoked RPC.
+     */
+    RESULT((short)3, "result"),
+    /**
+     * Messages from the server relevant to the request, such as warnings or use of deprecated
+     * features.
+     */
+    DETAILS((short)6, "details");
+
+    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+    static {
+      for (_Fields field : EnumSet.allOf(_Fields.class)) {
+        byName.put(field.getFieldName(), field);
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, or null if its not found.
+     */
+    public static _Fields findByThriftId(int fieldId) {
+      switch(fieldId) {
+        case 1: // RESPONSE_CODE
+          return RESPONSE_CODE;
+        case 5: // SERVER_INFO
+          return SERVER_INFO;
+        case 3: // RESULT
+          return RESULT;
+        case 6: // DETAILS
+          return DETAILS;
+        default:
+          return null;
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, throwing an exception
+     * if it is not found.
+     */
+    public static _Fields findByThriftIdOrThrow(int fieldId) {
+      _Fields fields = findByThriftId(fieldId);
+      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+      return fields;
+    }
+
+    /**
+     * Find the _Fields constant that matches name, or null if its not found.
+     */
+    public static _Fields findByName(String name) {
+      return byName.get(name);
+    }
+
+    private final short _thriftId;
+    private final String _fieldName;
+
+    _Fields(short thriftId, String fieldName) {
+      _thriftId = thriftId;
+      _fieldName = fieldName;
+    }
+
+    public short getThriftFieldId() {
+      return _thriftId;
+    }
+
+    public String getFieldName() {
+      return _fieldName;
+    }
+  }
+
+  // isset id assignments
+  private static final _Fields optionals[] = {_Fields.RESULT};
+  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.RESPONSE_CODE, new org.apache.thrift.meta_data.FieldMetaData("responseCode", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ResponseCode.class)));
+    tmpMap.put(_Fields.SERVER_INFO, new org.apache.thrift.meta_data.FieldMetaData("serverInfo", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ServerInfo.class)));
+    tmpMap.put(_Fields.RESULT, new org.apache.thrift.meta_data.FieldMetaData("result", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
+        new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Result.class)));
+    tmpMap.put(_Fields.DETAILS, new org.apache.thrift.meta_data.FieldMetaData("details", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        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, ResponseDetail.class))));
+    metaDataMap = Collections.unmodifiableMap(tmpMap);
+    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Response.class, metaDataMap);
+  }
+
+  public Response() {
+  }
+
+  public Response(
+    ResponseCode responseCode,
+    ServerInfo serverInfo,
+    List<ResponseDetail> details)
+  {
+    this();
+    this.responseCode = responseCode;
+    this.serverInfo = serverInfo;
+    this.details = details;
+  }
+
+  /**
+   * Performs a deep copy on <i>other</i>.
+   */
+  public Response(Response other) {
+    if (other.isSetResponseCode()) {
+      this.responseCode = other.responseCode;
+    }
+    if (other.isSetServerInfo()) {
+      this.serverInfo = new ServerInfo(other.serverInfo);
+    }
+    if (other.isSetResult()) {
+      this.result = new Result(other.result);
+    }
+    if (other.isSetDetails()) {
+      List<ResponseDetail> __this__details = new ArrayList<ResponseDetail>(other.details.size());
+      for (ResponseDetail other_element : other.details) {
+        __this__details.add(new ResponseDetail(other_element));
+      }
+      this.details = __this__details;
+    }
+  }
+
+  public Response deepCopy() {
+    return new Response(this);
+  }
+
+  @Override
+  public void clear() {
+    this.responseCode = null;
+    this.serverInfo = null;
+    this.result = null;
+    this.details = null;
+  }
+
+  /**
+   * 
+   * @see ResponseCode
+   */
+  public ResponseCode getResponseCode() {
+    return this.responseCode;
+  }
+
+  /**
+   * 
+   * @see ResponseCode
+   */
+  public Response setResponseCode(ResponseCode responseCode) {
+    this.responseCode = responseCode;
+    return this;
+  }
+
+  public void unsetResponseCode() {
+    this.responseCode = null;
+  }
+
+  /** Returns true if field responseCode is set (has been assigned a value) and false otherwise */
+  public boolean isSetResponseCode() {
+    return this.responseCode != null;
+  }
+
+  public void setResponseCodeIsSet(boolean value) {
+    if (!value) {
+      this.responseCode = null;
+    }
+  }
+
+  public ServerInfo getServerInfo() {
+    return this.serverInfo;
+  }
+
+  public Response setServerInfo(ServerInfo serverInfo) {
+    this.serverInfo = serverInfo;
+    return this;
+  }
+
+  public void unsetServerInfo() {
+    this.serverInfo = null;
+  }
+
+  /** Returns true if field serverInfo is set (has been assigned a value) and false otherwise */
+  public boolean isSetServerInfo() {
+    return this.serverInfo != null;
+  }
+
+  public void setServerInfoIsSet(boolean value) {
+    if (!value) {
+      this.serverInfo = null;
+    }
+  }
+
+  /**
+   * Payload from the invoked RPC.
+   */
+  public Result getResult() {
+    return this.result;
+  }
+
+  /**
+   * Payload from the invoked RPC.
+   */
+  public Response setResult(Result result) {
+    this.result = result;
+    return this;
+  }
+
+  public void unsetResult() {
+    this.result = null;
+  }
+
+  /** Returns true if field result is set (has been assigned a value) and false otherwise */
+  public boolean isSetResult() {
+    return this.result != null;
+  }
+
+  public void setResultIsSet(boolean value) {
+    if (!value) {
+      this.result = null;
+    }
+  }
+
+  public int getDetailsSize() {
+    return (this.details == null) ? 0 : this.details.size();
+  }
+
+  public java.util.Iterator<ResponseDetail> getDetailsIterator() {
+    return (this.details == null) ? null : this.details.iterator();
+  }
+
+  public void addToDetails(ResponseDetail elem) {
+    if (this.details == null) {
+      this.details = new ArrayList<ResponseDetail>();
+    }
+    this.details.add(elem);
+  }
+
+  /**
+   * Messages from the server relevant to the request, such as warnings or use of deprecated
+   * features.
+   */
+  public List<ResponseDetail> getDetails() {
+    return this.details;
+  }
+
+  /**
+   * Messages from the server relevant to the request, such as warnings or use of deprecated
+   * features.
+   */
+  public Response setDetails(List<ResponseDetail> details) {
+    this.details = details;
+    return this;
+  }
+
+  public void unsetDetails() {
+    this.details = null;
+  }
+
+  /** Returns true if field details is set (has been assigned a value) and false otherwise */
+  public boolean isSetDetails() {
+    return this.details != null;
+  }
+
+  public void setDetailsIsSet(boolean value) {
+    if (!value) {
+      this.details = null;
+    }
+  }
+
+  public void setFieldValue(_Fields field, Object value) {
+    switch (field) {
+    case RESPONSE_CODE:
+      if (value == null) {
+        unsetResponseCode();
+      } else {
+        setResponseCode((ResponseCode)value);
+      }
+      break;
+
+    case SERVER_INFO:
+      if (value == null) {
+        unsetServerInfo();
+      } else {
+        setServerInfo((ServerInfo)value);
+      }
+      break;
+
+    case RESULT:
+      if (value == null) {
+        unsetResult();
+      } else {
+        setResult((Result)value);
+      }
+      break;
+
+    case DETAILS:
+      if (value == null) {
+        unsetDetails();
+      } else {
+        setDetails((List<ResponseDetail>)value);
+      }
+      break;
+
+    }
+  }
+
+  public Object getFieldValue(_Fields field) {
+    switch (field) {
+    case RESPONSE_CODE:
+      return getResponseCode();
+
+    case SERVER_INFO:
+      return getServerInfo();
+
+    case RESULT:
+      return getResult();
+
+    case DETAILS:
+      return getDetails();
+
+    }
+    throw new IllegalStateException();
+  }
+
+  /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+  public boolean isSet(_Fields field) {
+    if (field == null) {
+      throw new IllegalArgumentException();
+    }
+
+    switch (field) {
+    case RESPONSE_CODE:
+      return isSetResponseCode();
+    case SERVER_INFO:
+      return isSetServerInfo();
+    case RESULT:
+      return isSetResult();
+    case DETAILS:
+      return isSetDetails();
+    }
+    throw new IllegalStateException();
+  }
+
+  @Override
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof Response)
+      return this.equals((Response)that);
+    return false;
+  }
+
+  public boolean equals(Response that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_responseCode = true && this.isSetResponseCode();
+    boolean that_present_responseCode = true && that.isSetResponseCode();
+    if (this_present_responseCode || that_present_responseCode) {
+      if (!(this_present_responseCode && that_present_responseCode))
+        return false;
+      if (!this.responseCode.equals(that.responseCode))
+        return false;
+    }
+
+    boolean this_present_serverInfo = true && this.isSetServerInfo();
+    boolean that_present_serverInfo = true && that.isSetServerInfo();
+    if (this_present_serverInfo || that_present_serverInfo) {
+      if (!(this_present_serverInfo && that_present_serverInfo))
+        return false;
+      if (!this.serverInfo.equals(that.serverInfo))
+        return false;
+    }
+
+    boolean this_present_result = true && this.isSetResult();
+    boolean that_present_result = true && that.isSetResult();
+    if (this_present_result || that_present_result) {
+      if (!(this_present_result && that_present_result))
+        return false;
+      if (!this.result.equals(that.result))
+        return false;
+    }
+
+    boolean this_present_details = true && this.isSetDetails();
+    boolean that_present_details = true && that.isSetDetails();
+    if (this_present_details || that_present_details) {
+      if (!(this_present_details && that_present_details))
+        return false;
+      if (!this.details.equals(that.details))
+        return false;
+    }
+
+    return true;
+  }
+
+  @Override
+  public int hashCode() {
+    List<Object> list = new ArrayList<Object>();
+
+    boolean present_responseCode = true && (isSetResponseCode());
+    list.add(present_responseCode);
+    if (present_responseCode)
+      list.add(responseCode.getValue());
+
+    boolean present_serverInfo = true && (isSetServerInfo());
+    list.add(present_serverInfo);
+    if (present_serverInfo)
+      list.add(serverInfo);
+
+    boolean present_result = true && (isSetResult());
+    list.add(present_result);
+    if (present_result)
+      list.add(result);
+
+    boolean present_details = true && (isSetDetails());
+    list.add(present_details);
+    if (present_details)
+      list.add(details);
+
+    return list.hashCode();
+  }
+
+  @Override
+  public int compareTo(Response other) {
+    if (!getClass().equals(other.getClass())) {
+      return getClass().getName().compareTo(other.getClass().getName());
+    }
+
+    int lastComparison = 0;
+
+    lastComparison = Boolean.valueOf(isSetResponseCode()).compareTo(other.isSetResponseCode());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetResponseCode()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.responseCode, other.responseCode);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetServerInfo()).compareTo(other.isSetServerInfo());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetServerInfo()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.serverInfo, other.serverInfo);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetResult()).compareTo(other.isSetResult());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetResult()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.result, other.result);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetDetails()).compareTo(other.isSetDetails());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetDetails()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.details, other.details);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    return 0;
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+  public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+    schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+  }
+
+  public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+    schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder("Response(");
+    boolean first = true;
+
+    sb.append("responseCode:");
+    if (this.responseCode == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.responseCode);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("serverInfo:");
+    if (this.serverInfo == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.serverInfo);
+    }
+    first = false;
+    if (isSetResult()) {
+      if (!first) sb.append(", ");
+      sb.append("result:");
+      if (this.result == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.result);
+      }
+      first = false;
+    }
+    if (!first) sb.append(", ");
+    sb.append("details:");
+    if (this.details == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.details);
+    }
+    first = false;
+    sb.append(")");
+    return sb.toString();
+  }
+
+  public void validate() throws org.apache.thrift.TException {
+    // check for required fields
+    // check for sub-struct validity
+    if (serverInfo != null) {
+      serverInfo.validate();
+    }
+  }
+
+  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+    try {
+      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+    try {
+      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private static class ResponseStandardSchemeFactory implements SchemeFactory {
+    public ResponseStandardScheme getScheme() {
+      return new ResponseStandardScheme();
+    }
+  }
+
+  private static class ResponseStandardScheme extends StandardScheme<Response> {
+
+    public void read(org.apache.thrift.protocol.TProtocol iprot, Response struct) throws org.apache.thrift.TException {
+      org.apache.thrift.protocol.TField schemeField;
+      iprot.readStructBegin();
+      while (true)
+      {
+        schemeField = iprot.readFieldBegin();
+        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+          break;
+        }
+        switch (schemeField.id) {
+          case 1: // RESPONSE_CODE
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.responseCode = org.apache.airavata.cloud.aurora.client.sdk.ResponseCode.findByValue(iprot.readI32());
+              struct.setResponseCodeIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 5: // SERVER_INFO
+            if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+              struct.serverInfo = new ServerInfo();
+              struct.serverInfo.read(iprot);
+              struct.setServerInfoIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 3: // RESULT
+            if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+              struct.result = new Result();
+              struct.result.read(iprot);
+              struct.setResultIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 6: // DETAILS
+            if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+              {
+                org.apache.thrift.protocol.TList _list392 = iprot.readListBegin();
+                struct.details = new ArrayList<ResponseDetail>(_list392.size);
+                ResponseDetail _elem393;
+                for (int _i394 = 0; _i394 < _list392.size; ++_i394)
+                {
+                  _elem393 = new ResponseDetail();
+                  _elem393.read(iprot);
+                  struct.details.add(_elem393);
+                }
+                iprot.readListEnd();
+              }
+              struct.setDetailsIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          default:
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+
+      // check for required fields of primitive type, which can't be checked in the validate method
+      struct.validate();
+    }
+
+    public void write(org.apache.thrift.protocol.TProtocol oprot, Response struct) throws org.apache.thrift.TException {
+      struct.validate();
+
+      oprot.writeStructBegin(STRUCT_DESC);
+      if (struct.responseCode != null) {
+        oprot.writeFieldBegin(RESPONSE_CODE_FIELD_DESC);
+        oprot.writeI32(struct.responseCode.getValue());
+        oprot.writeFieldEnd();
+      }
+      if (struct.result != null) {
+        if (struct.isSetResult()) {
+          oprot.writeFieldBegin(RESULT_FIELD_DESC);
+          struct.result.write(oprot);
+          oprot.writeFieldEnd();
+        }
+      }
+      if (struct.serverInfo != null) {
+        oprot.writeFieldBegin(SERVER_INFO_FIELD_DESC);
+        struct.serverInfo.write(oprot);
+        oprot.writeFieldEnd();
+      }
+      if (struct.details != null) {
+        oprot.writeFieldBegin(DETAILS_FIELD_DESC);
+        {
+          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.details.size()));
+          for (ResponseDetail _iter395 : struct.details)
+          {
+            _iter395.write(oprot);
+          }
+          oprot.writeListEnd();
+        }
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+  }
+
+  private static class ResponseTupleSchemeFactory implements SchemeFactory {
+    public ResponseTupleScheme getScheme() {
+      return new ResponseTupleScheme();
+    }
+  }
+
+  private static class ResponseTupleScheme extends TupleScheme<Response> {
+
+    @Override
+    public void write(org.apache.thrift.protocol.TProtocol prot, Response struct) throws org.apache.thrift.TException {
+      TTupleProtocol oprot = (TTupleProtocol) prot;
+      BitSet optionals = new BitSet();
+      if (struct.isSetResponseCode()) {
+        optionals.set(0);
+      }
+      if (struct.isSetServerInfo()) {
+        optionals.set(1);
+      }
+      if (struct.isSetResult()) {
+        optionals.set(2);
+      }
+      if (struct.isSetDetails()) {
+        optionals.set(3);
+      }
+      oprot.writeBitSet(optionals, 4);
+      if (struct.isSetResponseCode()) {
+        oprot.writeI32(struct.responseCode.getValue());
+      }
+      if (struct.isSetServerInfo()) {
+        struct.serverInfo.write(oprot);
+      }
+      if (struct.isSetResult()) {
+        struct.result.write(oprot);
+      }
+      if (struct.isSetDetails()) {
+        {
+          oprot.writeI32(struct.details.size());
+          for (ResponseDetail _iter396 : struct.details)
+          {
+            _iter396.write(oprot);
+          }
+        }
+      }
+    }
+
+    @Override
+    public void read(org.apache.thrift.protocol.TProtocol prot, Response struct) throws org.apache.thrift.TException {
+      TTupleProtocol iprot = (TTupleProtocol) prot;
+      BitSet incoming = iprot.readBitSet(4);
+      if (incoming.get(0)) {
+        struct.responseCode = org.apache.airavata.cloud.aurora.client.sdk.ResponseCode.findByValue(iprot.readI32());
+        struct.setResponseCodeIsSet(true);
+      }
+      if (incoming.get(1)) {
+        struct.serverInfo = new ServerInfo();
+        struct.serverInfo.read(iprot);
+        struct.setServerInfoIsSet(true);
+      }
+      if (incoming.get(2)) {
+        struct.result = new Result();
+        struct.result.read(iprot);
+        struct.setResultIsSet(true);
+      }
+      if (incoming.get(3)) {
+        {
+          org.apache.thrift.protocol.TList _list397 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.details = new ArrayList<ResponseDetail>(_list397.size);
+          ResponseDetail _elem398;
+          for (int _i399 = 0; _i399 < _list397.size; ++_i399)
+          {
+            _elem398 = new ResponseDetail();
+            _elem398.read(iprot);
+            struct.details.add(_elem398);
+          }
+        }
+        struct.setDetailsIsSet(true);
+      }
+    }
+  }
+
+}
+

http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseCode.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseCode.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseCode.java
new file mode 100644
index 0000000..afee9e3
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseCode.java
@@ -0,0 +1,66 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+
+import java.util.Map;
+import java.util.HashMap;
+import org.apache.thrift.TEnum;
+
+public enum ResponseCode implements org.apache.thrift.TEnum {
+  INVALID_REQUEST(0),
+  OK(1),
+  ERROR(2),
+  WARNING(3),
+  AUTH_FAILED(4),
+  /**
+   * Raised when a Lock-protected operation failed due to lock validation.
+   */
+  LOCK_ERROR(5),
+  /**
+   * Raised when a scheduler is transiently unavailable and later retry is recommended.
+   */
+  ERROR_TRANSIENT(6);
+
+  private final int value;
+
+  private ResponseCode(int value) {
+    this.value = value;
+  }
+
+  /**
+   * Get the integer value of this enum value, as defined in the Thrift IDL.
+   */
+  public int getValue() {
+    return value;
+  }
+
+  /**
+   * Find a the enum type by its integer value, as defined in the Thrift IDL.
+   * @return null if the value is not found.
+   */
+  public static ResponseCode findByValue(int value) { 
+    switch (value) {
+      case 0:
+        return INVALID_REQUEST;
+      case 1:
+        return OK;
+      case 2:
+        return ERROR;
+      case 3:
+        return WARNING;
+      case 4:
+        return AUTH_FAILED;
+      case 5:
+        return LOCK_ERROR;
+      case 6:
+        return ERROR_TRANSIENT;
+      default:
+        return null;
+    }
+  }
+}

http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseDetail.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseDetail.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseDetail.java
new file mode 100644
index 0000000..43ec385
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseDetail.java
@@ -0,0 +1,398 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21")
+public class ResponseDetail implements org.apache.thrift.TBase<ResponseDetail, ResponseDetail._Fields>, java.io.Serializable, Cloneable, Comparable<ResponseDetail> {
+  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ResponseDetail");
+
+  private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", 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 ResponseDetailStandardSchemeFactory());
+    schemes.put(TupleScheme.class, new ResponseDetailTupleSchemeFactory());
+  }
+
+  public String message; // 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 {
+    MESSAGE((short)1, "message");
+
+    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+    static {
+      for (_Fields field : EnumSet.allOf(_Fields.class)) {
+        byName.put(field.getFieldName(), field);
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, or null if its not found.
+     */
+    public static _Fields findByThriftId(int fieldId) {
+      switch(fieldId) {
+        case 1: // MESSAGE
+          return MESSAGE;
+        default:
+          return null;
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, throwing an exception
+     * if it is not found.
+     */
+    public static _Fields findByThriftIdOrThrow(int fieldId) {
+      _Fields fields = findByThriftId(fieldId);
+      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+      return fields;
+    }
+
+    /**
+     * Find the _Fields constant that matches name, or null if its not found.
+     */
+    public static _Fields findByName(String name) {
+      return byName.get(name);
+    }
+
+    private final short _thriftId;
+    private final String _fieldName;
+
+    _Fields(short thriftId, String fieldName) {
+      _thriftId = thriftId;
+      _fieldName = fieldName;
+    }
+
+    public short getThriftFieldId() {
+      return _thriftId;
+    }
+
+    public String getFieldName() {
+      return _fieldName;
+    }
+  }
+
+  // isset id assignments
+  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.MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("message", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+    metaDataMap = Collections.unmodifiableMap(tmpMap);
+    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ResponseDetail.class, metaDataMap);
+  }
+
+  public ResponseDetail() {
+  }
+
+  public ResponseDetail(
+    String message)
+  {
+    this();
+    this.message = message;
+  }
+
+  /**
+   * Performs a deep copy on <i>other</i>.
+   */
+  public ResponseDetail(ResponseDetail other) {
+    if (other.isSetMessage()) {
+      this.message = other.message;
+    }
+  }
+
+  public ResponseDetail deepCopy() {
+    return new ResponseDetail(this);
+  }
+
+  @Override
+  public void clear() {
+    this.message = null;
+  }
+
+  public String getMessage() {
+    return this.message;
+  }
+
+  public ResponseDetail setMessage(String message) {
+    this.message = message;
+    return this;
+  }
+
+  public void unsetMessage() {
+    this.message = null;
+  }
+
+  /** Returns true if field message is set (has been assigned a value) and false otherwise */
+  public boolean isSetMessage() {
+    return this.message != null;
+  }
+
+  public void setMessageIsSet(boolean value) {
+    if (!value) {
+      this.message = null;
+    }
+  }
+
+  public void setFieldValue(_Fields field, Object value) {
+    switch (field) {
+    case MESSAGE:
+      if (value == null) {
+        unsetMessage();
+      } else {
+        setMessage((String)value);
+      }
+      break;
+
+    }
+  }
+
+  public Object getFieldValue(_Fields field) {
+    switch (field) {
+    case MESSAGE:
+      return getMessage();
+
+    }
+    throw new IllegalStateException();
+  }
+
+  /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+  public boolean isSet(_Fields field) {
+    if (field == null) {
+      throw new IllegalArgumentException();
+    }
+
+    switch (field) {
+    case MESSAGE:
+      return isSetMessage();
+    }
+    throw new IllegalStateException();
+  }
+
+  @Override
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof ResponseDetail)
+      return this.equals((ResponseDetail)that);
+    return false;
+  }
+
+  public boolean equals(ResponseDetail that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_message = true && this.isSetMessage();
+    boolean that_present_message = true && that.isSetMessage();
+    if (this_present_message || that_present_message) {
+      if (!(this_present_message && that_present_message))
+        return false;
+      if (!this.message.equals(that.message))
+        return false;
+    }
+
+    return true;
+  }
+
+  @Override
+  public int hashCode() {
+    List<Object> list = new ArrayList<Object>();
+
+    boolean present_message = true && (isSetMessage());
+    list.add(present_message);
+    if (present_message)
+      list.add(message);
+
+    return list.hashCode();
+  }
+
+  @Override
+  public int compareTo(ResponseDetail other) {
+    if (!getClass().equals(other.getClass())) {
+      return getClass().getName().compareTo(other.getClass().getName());
+    }
+
+    int lastComparison = 0;
+
+    lastComparison = Boolean.valueOf(isSetMessage()).compareTo(other.isSetMessage());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetMessage()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message, other.message);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    return 0;
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+  public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+    schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+  }
+
+  public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+    schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder("ResponseDetail(");
+    boolean first = true;
+
+    sb.append("message:");
+    if (this.message == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.message);
+    }
+    first = false;
+    sb.append(")");
+    return sb.toString();
+  }
+
+  public void validate() throws org.apache.thrift.TException {
+    // check for required fields
+    // check for sub-struct validity
+  }
+
+  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+    try {
+      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+    try {
+      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private static class ResponseDetailStandardSchemeFactory implements SchemeFactory {
+    public ResponseDetailStandardScheme getScheme() {
+      return new ResponseDetailStandardScheme();
+    }
+  }
+
+  private static class ResponseDetailStandardScheme extends StandardScheme<ResponseDetail> {
+
+    public void read(org.apache.thrift.protocol.TProtocol iprot, ResponseDetail struct) throws org.apache.thrift.TException {
+      org.apache.thrift.protocol.TField schemeField;
+      iprot.readStructBegin();
+      while (true)
+      {
+        schemeField = iprot.readFieldBegin();
+        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+          break;
+        }
+        switch (schemeField.id) {
+          case 1: // MESSAGE
+            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+              struct.message = iprot.readString();
+              struct.setMessageIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          default:
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+
+      // check for required fields of primitive type, which can't be checked in the validate method
+      struct.validate();
+    }
+
+    public void write(org.apache.thrift.protocol.TProtocol oprot, ResponseDetail struct) throws org.apache.thrift.TException {
+      struct.validate();
+
+      oprot.writeStructBegin(STRUCT_DESC);
+      if (struct.message != null) {
+        oprot.writeFieldBegin(MESSAGE_FIELD_DESC);
+        oprot.writeString(struct.message);
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+  }
+
+  private static class ResponseDetailTupleSchemeFactory implements SchemeFactory {
+    public ResponseDetailTupleScheme getScheme() {
+      return new ResponseDetailTupleScheme();
+    }
+  }
+
+  private static class ResponseDetailTupleScheme extends TupleScheme<ResponseDetail> {
+
+    @Override
+    public void write(org.apache.thrift.protocol.TProtocol prot, ResponseDetail struct) throws org.apache.thrift.TException {
+      TTupleProtocol oprot = (TTupleProtocol) prot;
+      BitSet optionals = new BitSet();
+      if (struct.isSetMessage()) {
+        optionals.set(0);
+      }
+      oprot.writeBitSet(optionals, 1);
+      if (struct.isSetMessage()) {
+        oprot.writeString(struct.message);
+      }
+    }
+
+    @Override
+    public void read(org.apache.thrift.protocol.TProtocol prot, ResponseDetail struct) throws org.apache.thrift.TException {
+      TTupleProtocol iprot = (TTupleProtocol) prot;
+      BitSet incoming = iprot.readBitSet(1);
+      if (incoming.get(0)) {
+        struct.message = iprot.readString();
+        struct.setMessageIsSet(true);
+      }
+    }
+  }
+
+}
+


Mime
View raw message