http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigStandardSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigStandardSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigStandardSchemeFactory.class new file mode 100644 index 0000000..b2b5b3c Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigStandardSchemeFactory.class differ
http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigTupleScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigTupleScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigTupleScheme.class new file mode 100644 index 0000000..978be7d Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigTupleScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigTupleSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigTupleSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigTupleSchemeFactory.class new file mode 100644 index 0000000..a14303a Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$TaskConfigTupleSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$_Fields.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$_Fields.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$_Fields.class new file mode 100644 index 0000000..f39f47d Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig$_Fields.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig.class new file mode 100644 index 0000000..132eb8a Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConfig.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConstraint$_Fields.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConstraint$_Fields.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConstraint$_Fields.class new file mode 100644 index 0000000..54e13a2 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConstraint$_Fields.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConstraint.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConstraint.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConstraint.class new file mode 100644 index 0000000..06dc014 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskConstraint.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventStandardScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventStandardScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventStandardScheme.class new file mode 100644 index 0000000..65908f2 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventStandardScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventStandardSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventStandardSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventStandardSchemeFactory.class new file mode 100644 index 0000000..be83467 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventStandardSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventTupleScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventTupleScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventTupleScheme.class new file mode 100644 index 0000000..4f704a8 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventTupleScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventTupleSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventTupleSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventTupleSchemeFactory.class new file mode 100644 index 0000000..6661d00 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$TaskEventTupleSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$_Fields.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$_Fields.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$_Fields.class new file mode 100644 index 0000000..dddcc89 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent$_Fields.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent.class new file mode 100644 index 0000000..a17498d Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskEvent.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryStandardScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryStandardScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryStandardScheme.class new file mode 100644 index 0000000..971add3 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryStandardScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryStandardSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryStandardSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryStandardSchemeFactory.class new file mode 100644 index 0000000..92efb45 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryStandardSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryTupleScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryTupleScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryTupleScheme.class new file mode 100644 index 0000000..b0cf659 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryTupleScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryTupleSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryTupleSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryTupleSchemeFactory.class new file mode 100644 index 0000000..ad40665 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$TaskQueryTupleSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$_Fields.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$_Fields.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$_Fields.class new file mode 100644 index 0000000..f4d3aed Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery$_Fields.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery.class new file mode 100644 index 0000000..1808fd4 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigStandardScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigStandardScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigStandardScheme.class new file mode 100644 index 0000000..cdf0273 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigStandardScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigStandardSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigStandardSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigStandardSchemeFactory.class new file mode 100644 index 0000000..d030f57 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigStandardSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigTupleScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigTupleScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigTupleScheme.class new file mode 100644 index 0000000..3b1db7b Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigTupleScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigTupleSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigTupleSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigTupleSchemeFactory.class new file mode 100644 index 0000000..5515a49 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$TierConfigTupleSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$_Fields.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$_Fields.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$_Fields.class new file mode 100644 index 0000000..a0e7797 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig$_Fields.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig.class new file mode 100644 index 0000000..641599f Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/TierConfig.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintStandardScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintStandardScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintStandardScheme.class new file mode 100644 index 0000000..afbbea9 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintStandardScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintStandardSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintStandardSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintStandardSchemeFactory.class new file mode 100644 index 0000000..ae03e36 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintStandardSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintTupleScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintTupleScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintTupleScheme.class new file mode 100644 index 0000000..d5060b3 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintTupleScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintTupleSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintTupleSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintTupleSchemeFactory.class new file mode 100644 index 0000000..80ca8bd Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$ValueConstraintTupleSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$_Fields.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$_Fields.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$_Fields.class new file mode 100644 index 0000000..6b9b77f Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint$_Fields.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint.class new file mode 100644 index 0000000..b5ee579 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/ValueConstraint.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeStandardScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeStandardScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeStandardScheme.class new file mode 100644 index 0000000..7161585 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeStandardScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeStandardSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeStandardSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeStandardSchemeFactory.class new file mode 100644 index 0000000..7ddcaa2 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeStandardSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeTupleScheme.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeTupleScheme.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeTupleScheme.class new file mode 100644 index 0000000..84ea6f7 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeTupleScheme.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeTupleSchemeFactory.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeTupleSchemeFactory.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeTupleSchemeFactory.class new file mode 100644 index 0000000..33686e1 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$VolumeTupleSchemeFactory.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$_Fields.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$_Fields.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$_Fields.class new file mode 100644 index 0000000..13ec487 Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume$_Fields.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume.class new file mode 100644 index 0000000..9d7e24a Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/Volume.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/aurora_apiConstants.class ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/aurora_apiConstants.class b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/aurora_apiConstants.class new file mode 100644 index 0000000..d9fc8ef Binary files /dev/null and b/modules/cloud/aurora-client/bin/org/apache/airavata/cloud/aurora/client/sdk/aurora_apiConstants.class differ http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/pom.xml ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/pom.xml b/modules/cloud/aurora-client/pom.xml new file mode 100644 index 0000000..22797e2 --- /dev/null +++ b/modules/cloud/aurora-client/pom.xml @@ -0,0 +1,55 @@ +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>org.apache.airavata</groupId> + <artifactId>airavata-cloud</artifactId> + <version>0.17-SNAPSHOT</version> + <relativePath>../pom.xml</relativePath> + </parent> + + <artifactId>aurora-client</artifactId> + <packaging>jar</packaging> + <name>Thrift client for Apache Aurora</name> + <version>0.17-SNAPSHOT</version> + <url>http://airavata.apache.org/</url> + + <dependencies> + <dependency> + <groupId>org.apache.thrift</groupId> + <artifactId>libthrift</artifactId> + <version>0.9.3</version> + </dependency> + <dependency> + <groupId>org.json</groupId> + <artifactId>json</artifactId> + <version>20160212</version> + </dependency> + <dependency> + <groupId>commons-io</groupId> + <artifactId>commons-io</artifactId> + <version>2.5</version> + </dependency> + </dependencies> + + <build> + <directory>target</directory> + <outputDirectory>target/classes</outputDirectory> + <finalName>${project.artifactId}-${project.version}</finalName> + <testOutputDirectory>target/test-classes</testOutputDirectory> + <sourceDirectory>src/main/java</sourceDirectory> + <testSourceDirectory>src/test/java</testSourceDirectory> + <resources> + <resource> + <directory>src/main/resources</directory> + </resource> + </resources> + <testResources> + <testResource> + <directory>src/test/resources</directory> + </testResource> + </testResources> + <plugins> + </plugins> + </build> +</project> http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/AuroraSchedulerClientFactory.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/AuroraSchedulerClientFactory.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/AuroraSchedulerClientFactory.java new file mode 100644 index 0000000..a727c36 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/AuroraSchedulerClientFactory.java @@ -0,0 +1,50 @@ +package org.apache.airavata.cloud.aurora.client; + +import org.apache.airavata.cloud.aurora.client.sdk.AuroraSchedulerManager; +import org.apache.airavata.cloud.aurora.client.sdk.ReadOnlyScheduler; +import org.apache.thrift.protocol.TJSONProtocol; +import org.apache.thrift.protocol.TProtocol; +import org.apache.thrift.transport.THttpClient; +import org.apache.thrift.transport.TTransport; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * A factory for creating AuroraSchedulerClient objects. + */ +public class AuroraSchedulerClientFactory { + + /** The Constant logger. */ + private final static Logger logger = LoggerFactory.getLogger(AuroraSchedulerClientFactory.class); + + /** + * Creates a new AuroraSchedulerClient object. + * + * @param connectionUrl the connection url + * @return the client + * @throws Exception the exception + */ + public static ReadOnlyScheduler.Client createReadOnlySchedulerClient(String connectionUrl) throws Exception { + try { + TTransport transport = new THttpClient(connectionUrl); + transport.open(); + TProtocol protocol = new TJSONProtocol(transport); + return new ReadOnlyScheduler.Client(protocol); + } catch(Exception ex) { + logger.error(ex.getMessage(), ex); + throw ex; + } + } + + public static AuroraSchedulerManager.Client createSchedulerManagerClient(String connectionUrl) throws Exception { + try { + TTransport transport = new THttpClient(connectionUrl); + transport.open(); + TProtocol protocol = new TJSONProtocol(transport); + return new AuroraSchedulerManager.Client(protocol); + } catch(Exception ex) { + logger.error(ex.getMessage(), ex); + throw ex; + } + } +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/AuroraThriftClient.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/AuroraThriftClient.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/AuroraThriftClient.java new file mode 100644 index 0000000..f933abe --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/AuroraThriftClient.java @@ -0,0 +1,197 @@ +package org.apache.airavata.cloud.aurora.client; + +import java.text.MessageFormat; +import java.util.HashSet; +import java.util.Properties; +import java.util.Set; + +import org.apache.airavata.cloud.aurora.client.bean.GetJobsResponseBean; +import org.apache.airavata.cloud.aurora.client.bean.JobConfigBean; +import org.apache.airavata.cloud.aurora.client.bean.JobDetailsResponseBean; +import org.apache.airavata.cloud.aurora.client.bean.JobKeyBean; +import org.apache.airavata.cloud.aurora.client.bean.PendingJobReasonBean; +import org.apache.airavata.cloud.aurora.client.bean.ResponseBean; +import org.apache.airavata.cloud.aurora.client.sdk.AuroraSchedulerManager; +import org.apache.airavata.cloud.aurora.client.sdk.JobConfiguration; +import org.apache.airavata.cloud.aurora.client.sdk.JobKey; +import org.apache.airavata.cloud.aurora.client.sdk.ReadOnlyScheduler; +import org.apache.airavata.cloud.aurora.client.sdk.Response; +import org.apache.airavata.cloud.aurora.client.sdk.TaskQuery; +import org.apache.airavata.cloud.aurora.sample.AuroraClientSample; +import org.apache.airavata.cloud.aurora.util.AuroraThriftClientUtil; +import org.apache.airavata.cloud.aurora.util.Constants; +import org.apache.airavata.cloud.aurora.util.ResponseResultType; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * The Class AuroraThriftClient. + */ +public class AuroraThriftClient { + + /** The Constant logger. */ + private final static Logger logger = LoggerFactory.getLogger(AuroraThriftClient.class); + + /** The properties. */ + private static Properties properties = new Properties(); + + /** The read only scheduler client. */ + private ReadOnlyScheduler.Client readOnlySchedulerClient = null; + + /** The aurora scheduler manager client. */ + private AuroraSchedulerManager.Client auroraSchedulerManagerClient = null; + + /** The thrift client. */ + private static AuroraThriftClient thriftClient = null; + + /** + * Instantiates a new aurora thrift client. + */ + private AuroraThriftClient() {} + + /** + * Gets the aurora thrift client. + * + * @param auroraSchedulerPropFile the aurora scheduler prop file + * @return the aurora thrift client + * @throws Exception the exception + */ + public static AuroraThriftClient getAuroraThriftClient(String auroraSchedulerPropFile) throws Exception { + try { + if(thriftClient == null) { + thriftClient = new AuroraThriftClient(); + + // construct connection url for scheduler + properties.load(AuroraClientSample.class.getClassLoader().getResourceAsStream(auroraSchedulerPropFile)); + String auroraHost = properties.getProperty(Constants.AURORA_SCHEDULER_HOST); + String auroraPort = properties.getProperty(Constants.AURORA_SCHEDULER_PORT); + String connectionUrl = MessageFormat.format(Constants.AURORA_SCHEDULER_CONNECTION_URL, auroraHost, auroraPort); + + thriftClient.readOnlySchedulerClient = AuroraSchedulerClientFactory.createReadOnlySchedulerClient(connectionUrl); + thriftClient.auroraSchedulerManagerClient = AuroraSchedulerClientFactory.createSchedulerManagerClient(connectionUrl); + } + } catch(Exception ex) { + logger.error(ex.getMessage(), ex); + throw ex; + } + return thriftClient; + } + + /** + * Creates the job. + * + * @param jobConfigBean the job config bean + * @return the response bean + * @throws Exception the exception + */ + public ResponseBean createJob(JobConfigBean jobConfigBean) throws Exception { + ResponseBean response = null; + try { + if(jobConfigBean != null) { + JobConfiguration jobConfig = AuroraThriftClientUtil.getAuroraJobConfig(jobConfigBean); + Response createJobResponse = this.auroraSchedulerManagerClient.createJob(jobConfig); + response = AuroraThriftClientUtil.getResponseBean(createJobResponse, ResponseResultType.CREATE_JOB); + } + } catch(Exception ex) { + logger.error(ex.getMessage(), ex); + throw ex; + } + return response; + } + + /** + * Kill tasks. + * + * @param jobKeyBean the job key bean + * @param instances the instances + * @return the response bean + * @throws Exception the exception + */ + public ResponseBean killTasks(JobKeyBean jobKeyBean, Set<Integer> instances) throws Exception { + ResponseBean response = null; + try { + if(jobKeyBean != null) { + JobKey jobKey = AuroraThriftClientUtil.getAuroraJobKey(jobKeyBean); + Response killTaskResponse = this.auroraSchedulerManagerClient.killTasks(jobKey, instances); + response = AuroraThriftClientUtil.getResponseBean(killTaskResponse, ResponseResultType.KILL_TASKS); + } + } catch(Exception ex) { + logger.error(ex.getMessage(), ex); + throw ex; + } + return response; + } + + /** + * Gets the job list. + * + * @param ownerRole the owner role + * @return the job list + * @throws Exception the exception + */ + public GetJobsResponseBean getJobList(String ownerRole) throws Exception { + GetJobsResponseBean response = null; + try { + Response jobListResponse = this.readOnlySchedulerClient.getJobs(ownerRole); + response = (GetJobsResponseBean) AuroraThriftClientUtil.getResponseBean(jobListResponse, ResponseResultType.GET_JOBS); + } catch(Exception ex) { + logger.error(ex.getMessage(), ex); + throw ex; + } + return response; + } + + /** + * Gets the pending reason for job. + * + * @param jobKeyBean the job key bean + * @return the pending reason for job + * @throws Exception the exception + */ + public PendingJobReasonBean getPendingReasonForJob(JobKeyBean jobKeyBean) throws Exception { + PendingJobReasonBean response = null; + try { + JobKey jobKey = AuroraThriftClientUtil.getAuroraJobKey(jobKeyBean); + Set<JobKey> jobKeySet = new HashSet<>(); + jobKeySet.add(jobKey); + + TaskQuery query = new TaskQuery(); + query.setJobKeys(jobKeySet); + + Response pendingReasonResponse = this.readOnlySchedulerClient.getPendingReason(query); + response = (PendingJobReasonBean) AuroraThriftClientUtil.getResponseBean(pendingReasonResponse, ResponseResultType.GET_PENDING_JOB_REASON); + } catch(Exception ex) { + logger.error(ex.getMessage(), ex); + throw ex; + } + return response; + } + + /** + * Gets the job details. + * + * @param jobKeyBean the job key bean + * @return the job details + * @throws Exception the exception + */ + public ResponseBean getJobDetails(JobKeyBean jobKeyBean) throws Exception { + JobDetailsResponseBean response = null; + try { + if(jobKeyBean != null) { + JobKey jobKey = AuroraThriftClientUtil.getAuroraJobKey(jobKeyBean); + Set<JobKey> jobKeySet = new HashSet<>(); + jobKeySet.add(jobKey); + + TaskQuery query = new TaskQuery(); + query.setJobKeys(jobKeySet); + + Response jobDetailsResponse = this.readOnlySchedulerClient.getTasksStatus(query); + response = (JobDetailsResponseBean) AuroraThriftClientUtil.getResponseBean(jobDetailsResponse, ResponseResultType.GET_JOB_DETAILS); + } + } catch(Exception ex) { + logger.error(ex.getMessage(), ex); + throw ex; + } + return response; + } +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/GetJobsResponseBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/GetJobsResponseBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/GetJobsResponseBean.java new file mode 100644 index 0000000..30df8da --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/GetJobsResponseBean.java @@ -0,0 +1,34 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +import java.util.HashSet; +import java.util.Set; + +/** + * The Class GetJobsResponseBean. + */ +public class GetJobsResponseBean extends ResponseBean { + + /** The job configs. */ + private Set<JobConfigBean> jobConfigs; + + /** + * Gets the job configs. + * + * @return the job configs + */ + public Set<JobConfigBean> getJobConfigs() { + if(jobConfigs == null) { + jobConfigs = new HashSet<>(); + } + return jobConfigs; + } + + /** + * Sets the job configs. + * + * @param jobConfigs the new job configs + */ + public void setJobConfigs(Set<JobConfigBean> jobConfigs) { + this.jobConfigs = jobConfigs; + } +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/IdentityBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/IdentityBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/IdentityBean.java new file mode 100644 index 0000000..cd16f09 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/IdentityBean.java @@ -0,0 +1,39 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +// TODO: Auto-generated Javadoc +/** + * The Class IdentityBean. + */ +public class IdentityBean { + + /** The user. */ + private String user; + + /** + * Instantiates a new identity bean. + * + * @param user the user + */ + public IdentityBean(String user) { + this.user = user; + } + + /** + * Gets the user. + * + * @return the user + */ + public String getUser() { + return user; + } + + /** + * Sets the user. + * + * @param user the new user + */ + public void setUser(String user) { + this.user = user; + } + +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobConfigBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobConfigBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobConfigBean.java new file mode 100644 index 0000000..1eda52c --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobConfigBean.java @@ -0,0 +1,217 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +// TODO: Auto-generated Javadoc +/** + * The Class JobConfigBean. + */ +public class JobConfigBean { + + /** The job. */ + private JobKeyBean job; + + /** The owner. */ + private IdentityBean owner; + + /** The task config. */ + private TaskConfigBean taskConfig; + + /** The is service. */ + private boolean isService; + + /** The priority. */ + private int priority; + + /** The production. */ + private boolean production; + + /** The max task failures. */ + private int maxTaskFailures; + + /** The instances. */ + private int instances; + + /** The cluster. */ + private String cluster; + + /** + * Instantiates a new job config bean. + * + * @param job the job + * @param owner the owner + * @param taskConfig the task config + * @param cluster the cluster + */ + public JobConfigBean(JobKeyBean job, IdentityBean owner, TaskConfigBean taskConfig, String cluster) { + this.job = job; + this.owner = owner; + this.taskConfig = taskConfig; + this.cluster = cluster; + + // set defaults + this.isService = false; + this.maxTaskFailures = 1; + this.instances = 1; + } + + /** + * Gets the job. + * + * @return the job + */ + public JobKeyBean getJob() { + return job; + } + + /** + * Sets the job. + * + * @param job the new job + */ + public void setJob(JobKeyBean job) { + this.job = job; + } + + /** + * Gets the owner. + * + * @return the owner + */ + public IdentityBean getOwner() { + return owner; + } + + /** + * Sets the owner. + * + * @param owner the new owner + */ + public void setOwner(IdentityBean owner) { + this.owner = owner; + } + + /** + * Checks if is service. + * + * @return true, if is service + */ + public boolean isService() { + return isService; + } + + /** + * Sets the service. + * + * @param isService the new service + */ + public void setService(boolean isService) { + this.isService = isService; + } + + /** + * Gets the priority. + * + * @return the priority + */ + public int getPriority() { + return priority; + } + + /** + * Sets the priority. + * + * @param priority the new priority + */ + public void setPriority(int priority) { + this.priority = priority; + } + + /** + * Checks if is production. + * + * @return true, if is production + */ + public boolean isProduction() { + return production; + } + + /** + * Sets the production. + * + * @param production the new production + */ + public void setProduction(boolean production) { + this.production = production; + } + + /** + * Gets the task config. + * + * @return the task config + */ + public TaskConfigBean getTaskConfig() { + return taskConfig; + } + + /** + * Sets the task config. + * + * @param taskConfig the new task config + */ + public void setTaskConfig(TaskConfigBean taskConfig) { + this.taskConfig = taskConfig; + } + + /** + * Gets the max task failures. + * + * @return the max task failures + */ + public int getMaxTaskFailures() { + return maxTaskFailures; + } + + /** + * Sets the max task failures. + * + * @param maxTaskFailures the new max task failures + */ + public void setMaxTaskFailures(int maxTaskFailures) { + this.maxTaskFailures = maxTaskFailures; + } + + /** + * Gets the instances. + * + * @return the instances + */ + public int getInstances() { + return instances; + } + + /** + * Sets the instances. + * + * @param instances the new instances + */ + public void setInstances(int instances) { + this.instances = instances; + } + + /** + * Gets the cluster. + * + * @return the cluster + */ + public String getCluster() { + return cluster; + } + + /** + * Sets the cluster. + * + * @param cluster the new cluster + */ + public void setCluster(String cluster) { + this.cluster = cluster; + } +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobDetailsResponseBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobDetailsResponseBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobDetailsResponseBean.java new file mode 100644 index 0000000..780e986 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobDetailsResponseBean.java @@ -0,0 +1,50 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +import java.util.List; + +import org.apache.airavata.cloud.aurora.client.sdk.ScheduledTask; + +/** + * The Class JobDetailsResponseBean. + */ +public class JobDetailsResponseBean extends ResponseBean { + + /** + * Instantiates a new job details response bean. + * + * @param responseBean the response bean + */ + public JobDetailsResponseBean(ResponseBean responseBean) { + this.setResponseCode(responseBean.getResponseCode()); + this.setServerInfo(responseBean.getServerInfo()); + } + + /** The tasks. */ + private List<ScheduledTask> tasks; + + /** + * Gets the tasks. + * + * @return the tasks + */ + public List<ScheduledTask> getTasks() { + return tasks; + } + + /** + * Sets the tasks. + * + * @param tasks the new tasks + */ + public void setTasks(List<ScheduledTask> tasks) { + this.tasks = tasks; + } + + /* (non-Javadoc) + * @see org.apache.airavata.cloud.aurora.client.bean.ResponseBean#toString() + */ + @Override + public String toString() { + return "JobDetailsResponseBean [tasks=" + tasks + "]"; + } +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobKeyBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobKeyBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobKeyBean.java new file mode 100644 index 0000000..6ec3f11 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/JobKeyBean.java @@ -0,0 +1,85 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +// TODO: Auto-generated Javadoc +/** + * The Class JobKeyBean. + */ +public class JobKeyBean { + + /** The environment. */ + private String environment; + + /** The role. */ + private String role; + + /** The name. */ + private String name; + + /** + * Instantiates a new job key bean. + * + * @param environment the environment + * @param role the role + * @param name the name + */ + public JobKeyBean(String environment, String role, String name) { + this.environment = environment; + this.role = role; + this.name = name; + } + + /** + * Gets the environment. + * + * @return the environment + */ + public String getEnvironment() { + return environment; + } + + /** + * Sets the environment. + * + * @param environment the new environment + */ + public void setEnvironment(String environment) { + this.environment = environment; + } + + /** + * Gets the role. + * + * @return the role + */ + public String getRole() { + return role; + } + + /** + * Sets the role. + * + * @param role the new role + */ + public void setRole(String role) { + this.role = role; + } + + /** + * Gets the name. + * + * @return the name + */ + public String getName() { + return name; + } + + /** + * Sets the name. + * + * @param name the new name + */ + public void setName(String name) { + this.name = name; + } + +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/PendingJobReasonBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/PendingJobReasonBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/PendingJobReasonBean.java new file mode 100644 index 0000000..169fa27 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/PendingJobReasonBean.java @@ -0,0 +1,51 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +import java.util.Set; + +import org.apache.airavata.cloud.aurora.client.sdk.PendingReason; + +/** + * The Class PendingJobResponseBean. + */ +public class PendingJobReasonBean extends ResponseBean { + + /** The reasons. */ + private Set<PendingReason> reasons; + + /** + * Instantiates a new pending job response bean. + * + * @param responseBean the response bean + */ + public PendingJobReasonBean(ResponseBean responseBean) { + this.setResponseCode(responseBean.getResponseCode()); + this.setServerInfo(responseBean.getServerInfo()); + } + + /** + * Gets the reasons. + * + * @return the reasons + */ + public Set<PendingReason> getReasons() { + return reasons; + } + + /** + * Sets the reasons. + * + * @param reasons the new reasons + */ + public void setReasons(Set<PendingReason> reasons) { + this.reasons = reasons; + } + + /* (non-Javadoc) + * @see org.apache.airavata.cloud.aurora.client.bean.ResponseBean#toString() + */ + @Override + public String toString() { + return "PendingJobResponseBean [reasons=" + reasons + "]"; + } + +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ProcessBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ProcessBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ProcessBean.java new file mode 100644 index 0000000..4994a60 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ProcessBean.java @@ -0,0 +1,174 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +/** + * The Class ProcessBean. + */ +public class ProcessBean { + + /** The name. */ + private String name; + + /** The cmd line. */ + private String cmdLine; + + /** The is daemon. */ + private boolean isDaemon; + + /** The is ephemeral. */ + private boolean isEphemeral; + + /** The is final. */ + private boolean isFinal; + + /** The max failures. */ + private int max_failures; + + /** The min duration. */ + private int min_duration; + + /** + * Instantiates a new process bean. + * + * @param name the name + * @param cmdLine the cmd line + * @param isDaemon the is daemon + */ + public ProcessBean(String name, String cmdLine, boolean isDaemon) { + this.name = name; + this.cmdLine = cmdLine; + this.isDaemon = isDaemon; + + // set defaults + this.isEphemeral = false; + this.isFinal = false; + this.max_failures = 1; + this.min_duration = 5; + } + + /** + * Gets the name. + * + * @return the name + */ + public String getName() { + return name; + } + + /** + * Sets the name. + * + * @param name the new name + */ + public void setName(String name) { + this.name = name; + } + + /** + * Gets the cmd line. + * + * @return the cmd line + */ + public String getCmdLine() { + return cmdLine; + } + + /** + * Sets the cmd line. + * + * @param cmdLine the new cmd line + */ + public void setCmdLine(String cmdLine) { + this.cmdLine = cmdLine; + } + + /** + * Checks if is daemon. + * + * @return true, if is daemon + */ + public boolean isDaemon() { + return isDaemon; + } + + /** + * Sets the daemon. + * + * @param isDaemon the new daemon + */ + public void setDaemon(boolean isDaemon) { + this.isDaemon = isDaemon; + } + + /** + * Checks if is ephemeral. + * + * @return true, if is ephemeral + */ + public boolean isEphemeral() { + return isEphemeral; + } + + /** + * Sets the ephemeral. + * + * @param isEphemeral the new ephemeral + */ + public void setEphemeral(boolean isEphemeral) { + this.isEphemeral = isEphemeral; + } + + /** + * Checks if is final. + * + * @return true, if is final + */ + public boolean isFinal() { + return isFinal; + } + + /** + * Sets the final. + * + * @param isFinal the new final + */ + public void setFinal(boolean isFinal) { + this.isFinal = isFinal; + } + + /** + * Gets the max failures. + * + * @return the max failures + */ + public int getMax_failures() { + return max_failures; + } + + /** + * Sets the max failures. + * + * @param max_failures the new max failures + */ + public void setMax_failures(int max_failures) { + this.max_failures = max_failures; + } + + /** + * Gets the min duration. + * + * @return the min duration + */ + public int getMin_duration() { + return min_duration; + } + + /** + * Sets the min duration. + * + * @param min_duration the new min duration + */ + public void setMin_duration(int min_duration) { + this.min_duration = min_duration; + } + +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ResourceBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ResourceBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ResourceBean.java new file mode 100644 index 0000000..f4e3746 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ResourceBean.java @@ -0,0 +1,85 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +/** + * The Class ResourceBean. + */ +public class ResourceBean { + + /** The num cpus. */ + private double numCpus; + + /** The disk mb. */ + private long diskMb; + + /** The ram mb. */ + private long ramMb; + + /** + * Instantiates a new resource bean. + * + * @param numCpus the num cpus + * @param diskMb the disk mb + * @param ramMb the ram mb + */ + public ResourceBean(double numCpus, long diskMb, long ramMb) { + this.numCpus = numCpus; + this.diskMb = diskMb; + this.ramMb = ramMb; + } + + /** + * Gets the num cpus. + * + * @return the num cpus + */ + public double getNumCpus() { + return numCpus; + } + + /** + * Sets the num cpus. + * + * @param numCpus the new num cpus + */ + public void setNumCpus(double numCpus) { + this.numCpus = numCpus; + } + + /** + * Gets the disk mb. + * + * @return the disk mb + */ + public long getDiskMb() { + return diskMb; + } + + /** + * Sets the disk mb. + * + * @param diskMb the new disk mb + */ + public void setDiskMb(long diskMb) { + this.diskMb = diskMb; + } + + /** + * Gets the ram mb. + * + * @return the ram mb + */ + public long getRamMb() { + return ramMb; + } + + /** + * Sets the ram mb. + * + * @param ramMb the new ram mb + */ + public void setRamMb(long ramMb) { + this.ramMb = ramMb; + } + + +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ResponseBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ResponseBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ResponseBean.java new file mode 100644 index 0000000..37422bb --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ResponseBean.java @@ -0,0 +1,60 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +import org.apache.airavata.cloud.aurora.util.ResponseCodeEnum; + +/** + * The Class ResponseBean. + */ +public class ResponseBean { + + /** The response code. */ + private ResponseCodeEnum responseCode; + + /** The server info. */ + private ServerInfoBean serverInfo; + + /** + * Gets the response code. + * + * @return the response code + */ + public ResponseCodeEnum getResponseCode() { + return responseCode; + } + + /** + * Sets the response code. + * + * @param responseCode the new response code + */ + public void setResponseCode(ResponseCodeEnum responseCode) { + this.responseCode = responseCode; + } + + /** + * Gets the server info. + * + * @return the server info + */ + public ServerInfoBean getServerInfo() { + return serverInfo; + } + + /** + * Sets the server info. + * + * @param serverInfo the new server info + */ + public void setServerInfo(ServerInfoBean serverInfo) { + this.serverInfo = serverInfo; + } + + /* (non-Javadoc) + * @see java.lang.Object#toString() + */ + @Override + public String toString() { + return "ResponseBean [responseCode=" + responseCode + ", serverInfo=" + serverInfo + "]"; + } + +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ServerInfoBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ServerInfoBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ServerInfoBean.java new file mode 100644 index 0000000..5de28f4 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/ServerInfoBean.java @@ -0,0 +1,68 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +/** + * The Class ServerInfoBean. + */ +public class ServerInfoBean { + + /** The cluster name. */ + private String clusterName; + + /** The stats url prefix. */ + private String statsUrlPrefix; + + /** + * Instantiates a new server info bean. + * + * @param clusterName the cluster name + * @param statsUrlPrefix the stats url prefix + */ + public ServerInfoBean(String clusterName, String statsUrlPrefix) { + this.clusterName = clusterName; + this.statsUrlPrefix = statsUrlPrefix; + } + + /** + * Gets the cluster name. + * + * @return the cluster name + */ + public String getClusterName() { + return clusterName; + } + + /** + * Sets the cluster name. + * + * @param clusterName the new cluster name + */ + public void setClusterName(String clusterName) { + this.clusterName = clusterName; + } + + /** + * Gets the stats url prefix. + * + * @return the stats url prefix + */ + public String getStatsUrlPrefix() { + return statsUrlPrefix; + } + + /** + * Sets the stats url prefix. + * + * @param statsUrlPrefix the new stats url prefix + */ + public void setStatsUrlPrefix(String statsUrlPrefix) { + this.statsUrlPrefix = statsUrlPrefix; + } + + /* (non-Javadoc) + * @see java.lang.Object#toString() + */ + @Override + public String toString() { + return "ServerInfoBean [clusterName=" + clusterName + ", statsUrlPrefix=" + statsUrlPrefix + "]"; + } +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/TaskConfigBean.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/TaskConfigBean.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/TaskConfigBean.java new file mode 100644 index 0000000..c49e7c4 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/bean/TaskConfigBean.java @@ -0,0 +1,117 @@ +package org.apache.airavata.cloud.aurora.client.bean; + +import java.util.HashSet; +import java.util.Set; + +/** + * The Class TaskConfigBean. + */ +public class TaskConfigBean { + + /** The task name. */ + private String taskName; + + /** The resources. */ + private ResourceBean resources; + + /** The max failures. */ + private int maxFailures; + + /** The processes. */ + private Set<ProcessBean> processes; + + /** + * Instantiates a new task config bean. + * + * @param taskName the task name + * @param processes the processes + * @param resources the resources + */ + public TaskConfigBean(String taskName, Set<ProcessBean> processes, ResourceBean resources) { + this.taskName = taskName; + this.processes = processes; + this.resources = resources; + + // set default value + this.maxFailures = 1; + } + + /** + * Gets the task name. + * + * @return the task name + */ + public String getTaskName() { + return taskName; + } + + /** + * Sets the task name. + * + * @param taskName the new task name + */ + public void setTaskName(String taskName) { + this.taskName = taskName; + } + + + + /** + * Gets the resources. + * + * @return the resources + */ + public ResourceBean getResources() { + return resources; + } + + /** + * Sets the resources. + * + * @param resources the new resources + */ + public void setResources(ResourceBean resources) { + this.resources = resources; + } + + /** + * Gets the max failures. + * + * @return the max failures + */ + public int getMaxFailures() { + return maxFailures; + } + + /** + * Sets the max failures. + * + * @param maxFailures the new max failures + */ + public void setMaxFailures(int maxFailures) { + this.maxFailures = maxFailures; + } + + /** + * Gets the processes. + * + * @return the processes + */ + public Set<ProcessBean> getProcesses() { + if(processes == null) { + processes = new HashSet<>(); + } + + return processes; + } + + /** + * Sets the processes. + * + * @param processes the new processes + */ + public void setProcesses(Set<ProcessBean> processes) { + this.processes = processes; + } + +} 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/AppcImage.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AppcImage.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AppcImage.java new file mode 100644 index 0000000..d6c59e1 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AppcImage.java @@ -0,0 +1,530 @@ +/** + * 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 an image for use with the Mesos unified containerizer in the AppC format + */ +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") +public class AppcImage implements org.apache.thrift.TBase<AppcImage, AppcImage._Fields>, java.io.Serializable, Cloneable, Comparable<AppcImage> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AppcImage"); + + private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField IMAGE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("imageId", org.apache.thrift.protocol.TType.STRING, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AppcImageStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AppcImageTupleSchemeFactory()); + } + + /** + * The name of the image to run + */ + public String name; // required + /** + * The appc image id identifying the image + */ + public String imageId; // 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 { + /** + * The name of the image to run + */ + NAME((short)1, "name"), + /** + * The appc image id identifying the image + */ + IMAGE_ID((short)2, "imageId"); + + 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: // NAME + return NAME; + case 2: // IMAGE_ID + return IMAGE_ID; + 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.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.IMAGE_ID, new org.apache.thrift.meta_data.FieldMetaData("imageId", 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(AppcImage.class, metaDataMap); + } + + public AppcImage() { + } + + public AppcImage( + String name, + String imageId) + { + this(); + this.name = name; + this.imageId = imageId; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AppcImage(AppcImage other) { + if (other.isSetName()) { + this.name = other.name; + } + if (other.isSetImageId()) { + this.imageId = other.imageId; + } + } + + public AppcImage deepCopy() { + return new AppcImage(this); + } + + @Override + public void clear() { + this.name = null; + this.imageId = null; + } + + /** + * The name of the image to run + */ + public String getName() { + return this.name; + } + + /** + * The name of the image to run + */ + public AppcImage setName(String name) { + this.name = name; + return this; + } + + public void unsetName() { + this.name = null; + } + + /** Returns true if field name is set (has been assigned a value) and false otherwise */ + public boolean isSetName() { + return this.name != null; + } + + public void setNameIsSet(boolean value) { + if (!value) { + this.name = null; + } + } + + /** + * The appc image id identifying the image + */ + public String getImageId() { + return this.imageId; + } + + /** + * The appc image id identifying the image + */ + public AppcImage setImageId(String imageId) { + this.imageId = imageId; + return this; + } + + public void unsetImageId() { + this.imageId = null; + } + + /** Returns true if field imageId is set (has been assigned a value) and false otherwise */ + public boolean isSetImageId() { + return this.imageId != null; + } + + public void setImageIdIsSet(boolean value) { + if (!value) { + this.imageId = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case NAME: + if (value == null) { + unsetName(); + } else { + setName((String)value); + } + break; + + case IMAGE_ID: + if (value == null) { + unsetImageId(); + } else { + setImageId((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case NAME: + return getName(); + + case IMAGE_ID: + return getImageId(); + + } + 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 NAME: + return isSetName(); + case IMAGE_ID: + return isSetImageId(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AppcImage) + return this.equals((AppcImage)that); + return false; + } + + public boolean equals(AppcImage that) { + if (that == null) + return false; + + boolean this_present_name = true && this.isSetName(); + boolean that_present_name = true && that.isSetName(); + if (this_present_name || that_present_name) { + if (!(this_present_name && that_present_name)) + return false; + if (!this.name.equals(that.name)) + return false; + } + + boolean this_present_imageId = true && this.isSetImageId(); + boolean that_present_imageId = true && that.isSetImageId(); + if (this_present_imageId || that_present_imageId) { + if (!(this_present_imageId && that_present_imageId)) + return false; + if (!this.imageId.equals(that.imageId)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_name = true && (isSetName()); + list.add(present_name); + if (present_name) + list.add(name); + + boolean present_imageId = true && (isSetImageId()); + list.add(present_imageId); + if (present_imageId) + list.add(imageId); + + return list.hashCode(); + } + + @Override + public int compareTo(AppcImage other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetImageId()).compareTo(other.isSetImageId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetImageId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.imageId, other.imageId); + 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("AppcImage("); + boolean first = true; + + sb.append("name:"); + if (this.name == null) { + sb.append("null"); + } else { + sb.append(this.name); + } + first = false; + if (!first) sb.append(", "); + sb.append("imageId:"); + if (this.imageId == null) { + sb.append("null"); + } else { + sb.append(this.imageId); + } + 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 AppcImageStandardSchemeFactory implements SchemeFactory { + public AppcImageStandardScheme getScheme() { + return new AppcImageStandardScheme(); + } + } + + private static class AppcImageStandardScheme extends StandardScheme<AppcImage> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AppcImage 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: // NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.name = iprot.readString(); + struct.setNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // IMAGE_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.imageId = iprot.readString(); + struct.setImageIdIsSet(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, AppcImage struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.name != null) { + oprot.writeFieldBegin(NAME_FIELD_DESC); + oprot.writeString(struct.name); + oprot.writeFieldEnd(); + } + if (struct.imageId != null) { + oprot.writeFieldBegin(IMAGE_ID_FIELD_DESC); + oprot.writeString(struct.imageId); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AppcImageTupleSchemeFactory implements SchemeFactory { + public AppcImageTupleScheme getScheme() { + return new AppcImageTupleScheme(); + } + } + + private static class AppcImageTupleScheme extends TupleScheme<AppcImage> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AppcImage struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetName()) { + optionals.set(0); + } + if (struct.isSetImageId()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetName()) { + oprot.writeString(struct.name); + } + if (struct.isSetImageId()) { + oprot.writeString(struct.imageId); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AppcImage struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + struct.name = iprot.readString(); + struct.setNameIsSet(true); + } + if (incoming.get(1)) { + struct.imageId = iprot.readString(); + struct.setImageIdIsSet(true); + } + } + } + +} +
