Initial implementation of task execution engine on top of helix
authordimuthu.upeksha2@gmail.com <Dimu@1234>
Sat, 18 Nov 2017 19:49:04 +0000 (01:19 +0530)
committerSuresh Marru <smarru@apache.org>
Wed, 6 Dec 2017 03:13:42 +0000 (22:13 -0500)
commit23b761ec3813f6db12ad2d851924d40021017fd9
treee0656080465b626c76b2bcd7cd68b89ef8a3b6b6
parent7ee67aa756c3961bafc9573cd2c6a6b2f60e9bae
Initial implementation of task execution engine on top of helix
29 files changed:
airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/impl/SSHComputeOperations.java
airavata-kubernetes/modules/helix-tasks/pom.xml [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/HelixCluster.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/HelixController.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/HelixManager.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/HelixParticipant.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/WorkflowManager.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/AbstractTask.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/DataCollectingTask.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/DataPushingTask.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/command/CommandTask.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/command/Participant.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/datain/DataInputTask.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/datain/Participant.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/dataout/DataOutputTask.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/java/org/apache/airavata/helix/tasks/dataout/Participant.java [new file with mode: 0644]
airavata-kubernetes/modules/helix-tasks/src/main/resources/log4j.properties [new file with mode: 0644]
airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/DataStoreController.java
airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/data/DataStoreModel.java
airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/WorkflowService.java
airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/data/DataStoreService.java
airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/util/ToResourceUtil.java
airavata-kubernetes/modules/microservices/task-scheduler/pom.xml
airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/core/HelixWorkflowManager.java [new file with mode: 0644]
airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/KafkaReceiver.java
airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/service/HelixWorkflowService.java [new file with mode: 0644]
airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/service/WorkerService.java
airavata-kubernetes/modules/microservices/task-scheduler/src/main/resources/log4j.properties [new file with mode: 0644]
airavata-kubernetes/pom.xml