You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2017/10/31 16:03:34 UTC
[airavata] branch master updated (2a3302c -> 88acdf1)
This is an automated email from the ASF dual-hosted git repository.
smarru pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git.
from 2a3302c Added a new test gateway with develop airavata server for SGA class student project
add a68ff57 Initial API server framework
add c3644ef Implementing Experiment and Application creation APIs
add 98afe91 Implemented Orchestrator to accept messages from launch queue and create tasks and processes for experiments
add c4a3a05 Adding task microservices for each task type
add e96bced Adding task microservices for each task type - v2
add f800a63 Support to async task execution to avoid task being executed by the kafka consumer thread
add 04f88bc Publishing events of a task to a single partition to achieve ordered delivery
add 14a62f9 Implementing the event sink to perisit task states to the database
add 56bb2fa Compute resource operations to decouple the communication between tasks and compute resources
add fa3a242 Restructuring modules and fixing docker builds
add 4268067 Exposing port 8080 of api-server container
add da921e9 Adding kubernetes scripts to deploy microservices on kubernetes
add 549ae48 Adding API server endpoint to accept process status
add 4e27cb5 Adding get all method to API server resources
add e1e09b8 Web console initial commit
add 2d18e15 Adding Experiment and App Interface creation functionality to Web Console
add e1d73b5 Adding Experiment detail pages
add 95fb8d4 Added task event view console
add 4f19f5c Adding setup page to configure API Server endpoint
add 9b8c097 Fixing bugs in task execution processes
add cb4438f Uploading experiment outputs to Data Store
add 421fd4a Docker file to build console docker image
add 7b16ba6 Externalizing db username and password
add 67de113 Minor improvements
add 70076aa Adding dependency management
add 35ef652 Adding license headers
add 3077522 Updated readme
new 88acdf1 Merge pull request #135 from DImuthuUpe/master
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
sandbox/airavata-kubernetes/Design Document.pdf | Bin 0 -> 566742 bytes
sandbox/airavata-kubernetes/User Guide.pdf | Bin 0 -> 532940 bytes
.../modules/api-resource/pom.xml | 49 +
.../application/ApplicationDeploymentResource.java | 100 +
.../application/ApplicationIfaceResource.java | 92 +
.../application/ApplicationInputResource.java | 79 +
.../application/ApplicationModuleResource.java | 70 +
.../application/ApplicationOutputResource.java | 68 +
.../k8s/api/resources/compute/ComputeResource.java | 90 +
.../k8s/api/resources/data/DataEntryResource.java | 60 +
.../experiment/ExperimentInputResource.java | 90 +
.../experiment/ExperimentOutputResource.java | 80 +
.../resources/experiment/ExperimentResource.java | 168 +
.../experiment/ExperimentStatusResource.java | 79 +
.../k8s/api/resources/process/ProcessResource.java | 125 +
.../resources/process/ProcessStatusResource.java | 107 +
.../k8s/api/resources/task/TaskParamResource.java | 60 +
.../k8s/api/resources/task/TaskResource.java | 163 +
.../k8s/api/resources/task/TaskStatusResource.java | 99 +
.../modules/compute-resource-api/pom.xml | 61 +
.../k8s/compute/api/ComputeOperations.java | 32 +
.../airavata/k8s/compute/api/ExecutionResult.java | 60 +
.../k8s/compute/impl/MockComputeOperation.java | 68 +
.../k8s/compute/impl/SSHComputeOperations.java | 302 +
.../modules/microservices/api-server/pom.xml | 162 +
.../airavata/k8s/api/server/Application.java | 66 +
.../k8s/api/server/ServerRuntimeException.java | 40 +
.../ApplicationDeploymentController.java | 60 +
.../controller/ApplicationInterfaceController.java | 59 +
.../controller/ApplicationModuleController.java | 60 +
.../controller/ComputeResourceController.java | 59 +
.../api/server/controller/DataStoreController.java | 71 +
.../server/controller/ExperimentController.java | 64 +
.../api/server/controller/ProcessController.java | 59 +
.../k8s/api/server/controller/TaskController.java | 65 +
.../model/application/ApplicationDeployment.java | 109 +
.../server/model/application/ApplicationInput.java | 116 +
.../model/application/ApplicationInterface.java | 100 +
.../model/application/ApplicationModule.java | 73 +
.../model/application/ApplicationOutput.java | 108 +
.../k8s/api/server/model/commons/ErrorModel.java | 108 +
.../server/model/compute/ComputeResourceModel.java | 96 +
.../k8s/api/server/model/data/DataStoreModel.java | 88 +
.../api/server/model/experiment/Experiment.java | 168 +
.../model/experiment/ExperimentInputData.java | 114 +
.../model/experiment/ExperimentOutputData.java | 106 +
.../server/model/experiment/ExperimentStatus.java | 99 +
.../k8s/api/server/model/job/JobModel.java | 168 +
.../k8s/api/server/model/job/JobStatus.java | 109 +
.../k8s/api/server/model/process/ProcessModel.java | 135 +
.../api/server/model/process/ProcessStatus.java | 124 +
.../k8s/api/server/model/task/TaskModel.java | 190 +
.../k8s/api/server/model/task/TaskParam.java | 82 +
.../k8s/api/server/model/task/TaskStatus.java | 121 +
.../ApplicationDeploymentRepository.java | 36 +
.../repository/ApplicationIfaceRepository.java | 36 +
.../repository/ApplicationInputRepository.java | 32 +
.../repository/ApplicationModuleRepository.java | 36 +
.../repository/ApplicationOutputRepository.java | 32 +
.../api/server/repository/ComputeRepository.java | 36 +
.../api/server/repository/DataStoreRepository.java | 36 +
.../repository/ExperimentInputDataRepository.java | 32 +
.../repository/ExperimentOutputDataRepository.java | 35 +
.../server/repository/ExperimentRepository.java | 35 +
.../repository/ExperimentStatusRepository.java | 32 +
.../api/server/repository/ProcessRepository.java | 35 +
.../server/repository/ProcessStatusRepository.java | 32 +
.../api/server/repository/TaskParamRepository.java | 32 +
.../k8s/api/server/repository/TaskRepository.java | 35 +
.../server/repository/TaskStatusRepository.java | 36 +
.../service/ApplicationDeploymentService.java | 87 +
.../server/service/ApplicationIfaceService.java | 109 +
.../server/service/ApplicationModuleService.java | 69 +
.../api/server/service/ComputeResourceService.java | 70 +
.../k8s/api/server/service/ExperimentService.java | 149 +
.../k8s/api/server/service/ProcessService.java | 99 +
.../k8s/api/server/service/TaskService.java | 109 +
.../api/server/service/data/DataStoreService.java | 71 +
.../server/service/messaging/MessagingService.java | 42 +
.../api/server/service/messaging/SenderConfig.java | 64 +
.../api/server/service/util/ToResourceUtil.java | 305 +
.../src/main/resources/application.properties | 5 +
.../api-server/src/main/resources/application.yml | 4 +
.../src/main/resources/docker/Dockerfile | 6 +
.../modules/microservices/event-sink/pom.xml | 151 +
.../org/apache/airavata/k8s/sink/Application.java | 49 +
.../airavata/k8s/sink/messaging/KafkaReceiver.java | 53 +
.../airavata/k8s/sink/messaging/KafkaSender.java | 43 +
.../k8s/sink/messaging/ReceiverConfig.java | 85 +
.../airavata/k8s/sink/messaging/SenderConfig.java | 69 +
.../k8s/sink/service/EventPersistingService.java | 56 +
.../src/main/resources/application.properties | 4 +
.../event-sink/src/main/resources/application.yml | 4 +
.../modules/microservices/task-scheduler/pom.xml | 151 +
.../org/apache/airavata/k8s/gfac/Application.java | 49 +
.../k8s/gfac/core/ProcessLifeCycleManager.java | 124 +
.../airavata/k8s/gfac/messaging/KafkaReceiver.java | 53 +
.../airavata/k8s/gfac/messaging/KafkaSender.java | 39 +
.../k8s/gfac/messaging/ReceiverConfig.java | 109 +
.../airavata/k8s/gfac/messaging/SenderConfig.java | 69 +
.../airavata/k8s/gfac/service/WorkerService.java | 88 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../tasks/egress-staging-task/pom.xml | 156 +
.../airavata/k8s/task/egress/Application.java | 49 +
.../k8s/task/egress/messaging/KafkaReceiver.java | 45 +
.../k8s/task/egress/messaging/KafkaSender.java | 43 +
.../k8s/task/egress/messaging/ReceiverConfig.java | 85 +
.../k8s/task/egress/messaging/SenderConfig.java | 69 +
.../task/egress/service/TaskExecutionService.java | 183 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../microservices/tasks/env-cleanup-task/pom.xml | 156 +
.../airavata/k8s/task/cleanup/Application.java | 49 +
.../k8s/task/cleanup/messaging/KafkaReceiver.java | 45 +
.../k8s/task/cleanup/messaging/KafkaSender.java | 43 +
.../k8s/task/cleanup/messaging/ReceiverConfig.java | 85 +
.../k8s/task/cleanup/messaging/SenderConfig.java | 69 +
.../task/cleanup/service/TaskExecutionService.java | 153 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../microservices/tasks/env-setup-task/pom.xml | 157 +
.../airavata/k8s/task/env/setup/Application.java | 49 +
.../task/env/setup/messaging/KafkaReceiver.java | 45 +
.../k8s/task/env/setup/messaging/KafkaSender.java | 43 +
.../task/env/setup/messaging/ReceiverConfig.java | 85 +
.../k8s/task/env/setup/messaging/SenderConfig.java | 69 +
.../env/setup/service/TaskExecutionService.java | 153 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../tasks/ingress-staging-task/pom.xml | 156 +
.../airavata/k8s/task/ingress/Application.java | 49 +
.../k8s/task/ingress/messaging/KafkaReceiver.java | 45 +
.../k8s/task/ingress/messaging/KafkaSender.java | 43 +
.../k8s/task/ingress/messaging/ReceiverConfig.java | 85 +
.../k8s/task/ingress/messaging/SenderConfig.java | 69 +
.../task/ingress/service/TaskExecutionService.java | 126 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../tasks/job-submission-task/pom.xml | 156 +
.../apache/airavata/k8s/task/job/Application.java | 49 +
.../k8s/task/job/messaging/KafkaReceiver.java | 45 +
.../k8s/task/job/messaging/KafkaSender.java | 43 +
.../k8s/task/job/messaging/ReceiverConfig.java | 85 +
.../k8s/task/job/messaging/SenderConfig.java | 69 +
.../k8s/task/job/service/TaskExecutionService.java | 160 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../microservices/workflow-generator/pom.xml | 153 +
.../airavata/k8s/orchestrator/Application.java | 49 +
.../k8s/orchestrator/messaging/KafkaReceiver.java | 46 +
.../k8s/orchestrator/messaging/KafkaSender.java | 39 +
.../k8s/orchestrator/messaging/ReceiverConfig.java | 81 +
.../k8s/orchestrator/messaging/SenderConfig.java | 69 +
.../service/ExperimentLaunchService.java | 259 +
.../src/main/resources/application.properties | 4 +
.../src/main/resources/application.yml | 4 +
sandbox/airavata-kubernetes/pom.xml | 85 +
sandbox/airavata-kubernetes/readme.txt | 21 +
.../scripts/k8s/api-server/api-server-dep.yml | 26 +
.../scripts/k8s/api-server/api-server-svc.yml | 14 +
.../airavata-kubernetes/scripts/k8s/db-service.yml | 30 +
.../scripts/k8s/event-sink/event-sink-dep.yml | 21 +
.../scripts/k8s/kafka-service.yml | 30 +
.../k8s/task-scheduler/task-secheduler-dep.yml | 21 +
.../egress-staging-task-dep.yml | 21 +
.../env-cleanup-task/env-cleanup-task-dep.yml | 21 +
.../tasks/env-setup-task/env-setup-task-dep.yml | 21 +
.../ingress-staging-task-dep.yml | 21 +
.../job-submission-task-dep.yml | 21 +
.../workflow-generator/workflow-generator-dep.yml | 21 +
.../web-console/.angular-cli.json | 64 +
.../airavata-kubernetes/web-console/.editorconfig | 13 +
sandbox/airavata-kubernetes/web-console/.gitignore | 42 +
sandbox/airavata-kubernetes/web-console/README.md | 32 +
.../web-console/docker/Dockerfile | 2 +
.../web-console/e2e/app.e2e-spec.ts | 14 +
.../airavata-kubernetes/web-console/e2e/app.po.ts | 11 +
.../web-console/e2e/tsconfig.e2e.json | 14 +
.../airavata-kubernetes/web-console/karma.conf.js | 33 +
.../web-console/package-lock.json | 9608 ++++++++++++++++++++
.../airavata-kubernetes/web-console/package.json | 49 +
.../web-console/protractor.conf.js | 28 +
.../web-console/src/app/app.component.css} | 0
.../web-console/src/app/app.component.html | 20 +
.../web-console/src/app/app.component.spec.ts | 27 +
.../web-console/src/app/app.component.ts | 13 +
.../web-console/src/app/app.module.ts | 42 +
.../web-console/src/app/app.routing.ts | 14 +
.../app-dep/list/app.dep.list.component.ts | 90 +
.../src/app/components/app-dep/list/list.html | 77 +
.../app-iface/list/app.iface.list.component.ts | 88 +
.../src/app/components/app-iface/list/list.html | 111 +
.../app-module/list/app.module.list.component.ts | 64 +
.../src/app/components/app-module/list/list.html | 56 +
.../compute/list/compute.list.component.ts | 66 +
.../src/app/components/compute/list/list.html | 69 +
.../components/dashboard/dashboard.component.ts | 12 +
.../src/app/components/dashboard/dashboard.html | 45 +
.../app/components/dashboard/dashboard.routes.ts | 50 +
.../app/components/experiment/detail/detail.html | 124 +
.../experiment/detail/experiment.detail.ts | 64 +
.../experiment/list/experiment.list.component.ts | 141 +
.../src/app/components/experiment/list/list.html | 117 +
.../src/app/components/process/detail/detail.html | 107 +
.../process/detail/process.detail.component.ts | 47 +
.../src/app/components/setup/setup.component.ts | 25 +
.../src/app/components/setup/setup.html | 13 +
.../application/application.deployment.model.ts | 27 +
.../models/application/application.iface.model.ts | 29 +
.../models/application/application.ipnput.model.ts | 22 +
.../models/application/application.module.model.ts | 21 +
.../models/application/application.output.model.ts | 21 +
.../app/models/compute/compute.resource.model.ts | 30 +
.../src/app/models/data/data.entry.model.ts | 9 +
.../models/experiment/experiment.input.model.ts | 22 +
.../src/app/models/experiment/experiment.model.ts | 44 +
.../models/experiment/experiment.output.model.ts | 20 +
.../models/experiment/experiment.status.model.ts | 10 +
.../src/app/models/process/process.model.ts | 20 +
.../src/app/models/process/process.status.model.ts | 15 +
.../web-console/src/app/models/task/task.model.ts | 41 +
.../src/app/models/task/task.param.model.ts | 18 +
.../src/app/models/task/task.status.model.ts | 24 +
.../web-console/src/app/services/api.service.ts | 46 +
.../src/app/services/app.module.service.ts | 23 +
.../src/app/services/application.iface.service.ts | 23 +
.../src/app/services/compute.service.ts | 22 +
.../src/app/services/deployment.service.ts | 21 +
.../src/app/services/experiment.service.ts | 31 +
.../src/app/services/process.service.ts | 28 +
.../web-console/src/app/services/task.service.ts | 25 +
.../web-console/src/assets/.gitkeep} | 0
.../src/environments/environment.prod.ts | 3 +
.../web-console/src/environments/environment.ts | 8 +
.../web-console/src/favicon.ico | Bin 0 -> 5430 bytes
.../airavata-kubernetes/web-console/src/index.html | 16 +
.../airavata-kubernetes/web-console/src/main.ts | 12 +
.../web-console/src/polyfills.ts | 76 +
.../airavata-kubernetes/web-console/src/styles.css | 1 +
.../airavata-kubernetes/web-console/src/test.ts | 32 +
.../web-console/src/tsconfig.app.json | 13 +
.../web-console/src/tsconfig.spec.json | 20 +
.../web-console/src/typings.d.ts | 5 +
.../airavata-kubernetes/web-console/tsconfig.json | 19 +
.../airavata-kubernetes/web-console/tslint.json | 141 +
246 files changed, 24487 insertions(+)
create mode 100644 sandbox/airavata-kubernetes/Design Document.pdf
create mode 100644 sandbox/airavata-kubernetes/User Guide.pdf
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationDeploymentResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationIfaceResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationInputResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationModuleResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationOutputResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/compute/ComputeResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/data/DataEntryResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/experiment/ExperimentInputResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/experiment/ExperimentOutputResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/experiment/ExperimentResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/experiment/ExperimentStatusResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/process/ProcessResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/process/ProcessStatusResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/task/TaskParamResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/task/TaskResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/task/TaskStatusResource.java
create mode 100644 sandbox/airavata-kubernetes/modules/compute-resource-api/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/api/ComputeOperations.java
create mode 100644 sandbox/airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/api/ExecutionResult.java
create mode 100644 sandbox/airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/impl/MockComputeOperation.java
create mode 100644 sandbox/airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/impl/SSHComputeOperations.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/ServerRuntimeException.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ApplicationDeploymentController.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ApplicationInterfaceController.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ApplicationModuleController.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ComputeResourceController.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/DataStoreController.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ExperimentController.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ProcessController.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/TaskController.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationDeployment.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationInput.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationInterface.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationModule.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationOutput.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/commons/ErrorModel.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/compute/ComputeResourceModel.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/data/DataStoreModel.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/experiment/Experiment.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/experiment/ExperimentInputData.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/experiment/ExperimentOutputData.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/experiment/ExperimentStatus.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/job/JobModel.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/job/JobStatus.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/process/ProcessModel.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/process/ProcessStatus.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/task/TaskModel.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/task/TaskParam.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/task/TaskStatus.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationDeploymentRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationIfaceRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationInputRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationModuleRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationOutputRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ComputeRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/DataStoreRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ExperimentInputDataRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ExperimentOutputDataRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ExperimentRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ExperimentStatusRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ProcessRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ProcessStatusRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/TaskParamRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/TaskRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/TaskStatusRepository.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ApplicationDeploymentService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ApplicationIfaceService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ApplicationModuleService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ComputeResourceService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ExperimentService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ProcessService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/TaskService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/data/DataStoreService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/messaging/MessagingService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/util/ToResourceUtil.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/api-server/src/main/resources/docker/Dockerfile
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/messaging/KafkaReceiver.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/messaging/KafkaSender.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/messaging/ReceiverConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/service/EventPersistingService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/event-sink/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/core/ProcessLifeCycleManager.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/KafkaReceiver.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/KafkaSender.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/ReceiverConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/service/WorkerService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/task-scheduler/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/messaging/KafkaReceiver.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/messaging/KafkaSender.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/messaging/ReceiverConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/service/TaskExecutionService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/messaging/KafkaReceiver.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/messaging/KafkaSender.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/messaging/ReceiverConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/service/TaskExecutionService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/messaging/KafkaReceiver.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/messaging/KafkaSender.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/messaging/ReceiverConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/service/TaskExecutionService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/messaging/KafkaReceiver.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/messaging/KafkaSender.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/messaging/ReceiverConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/service/TaskExecutionService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/messaging/KafkaReceiver.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/messaging/KafkaSender.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/messaging/ReceiverConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/service/TaskExecutionService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/pom.xml
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/Application.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/messaging/KafkaReceiver.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/messaging/KafkaSender.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/messaging/ReceiverConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/messaging/SenderConfig.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/service/ExperimentLaunchService.java
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/src/main/resources/application.properties
create mode 100644 sandbox/airavata-kubernetes/modules/microservices/workflow-generator/src/main/resources/application.yml
create mode 100644 sandbox/airavata-kubernetes/pom.xml
create mode 100644 sandbox/airavata-kubernetes/readme.txt
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/api-server/api-server-dep.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/api-server/api-server-svc.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/db-service.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/event-sink/event-sink-dep.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/kafka-service.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/task-scheduler/task-secheduler-dep.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/tasks/egress-staging-task/egress-staging-task-dep.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/tasks/env-cleanup-task/env-cleanup-task-dep.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/tasks/env-setup-task/env-setup-task-dep.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/tasks/ingress-staging-task/ingress-staging-task-dep.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/tasks/job-submission-task/job-submission-task-dep.yml
create mode 100644 sandbox/airavata-kubernetes/scripts/k8s/workflow-generator/workflow-generator-dep.yml
create mode 100644 sandbox/airavata-kubernetes/web-console/.angular-cli.json
create mode 100644 sandbox/airavata-kubernetes/web-console/.editorconfig
create mode 100644 sandbox/airavata-kubernetes/web-console/.gitignore
create mode 100644 sandbox/airavata-kubernetes/web-console/README.md
create mode 100644 sandbox/airavata-kubernetes/web-console/docker/Dockerfile
create mode 100644 sandbox/airavata-kubernetes/web-console/e2e/app.e2e-spec.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/e2e/app.po.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/e2e/tsconfig.e2e.json
create mode 100644 sandbox/airavata-kubernetes/web-console/karma.conf.js
create mode 100644 sandbox/airavata-kubernetes/web-console/package-lock.json
create mode 100644 sandbox/airavata-kubernetes/web-console/package.json
create mode 100644 sandbox/airavata-kubernetes/web-console/protractor.conf.js
copy sandbox/{simstream/example/openmm_example/application/trajectory.dcd => airavata-kubernetes/web-console/src/app/app.component.css} (100%)
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/app.component.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/app.component.spec.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/app.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/app.module.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/app.routing.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/app-dep/list/app.dep.list.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/app-dep/list/list.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/app-iface/list/app.iface.list.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/app-iface/list/list.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/app-module/list/app.module.list.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/app-module/list/list.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/compute/list/compute.list.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/compute/list/list.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/dashboard/dashboard.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/dashboard/dashboard.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/dashboard/dashboard.routes.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/experiment/detail/detail.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/experiment/detail/experiment.detail.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/experiment/list/experiment.list.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/experiment/list/list.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/process/detail/detail.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/process/detail/process.detail.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/setup/setup.component.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/components/setup/setup.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/application/application.deployment.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/application/application.iface.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/application/application.ipnput.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/application/application.module.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/application/application.output.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/compute/compute.resource.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/data/data.entry.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/experiment/experiment.input.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/experiment/experiment.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/experiment/experiment.output.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/experiment/experiment.status.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/process/process.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/process/process.status.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/task/task.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/task/task.param.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/models/task/task.status.model.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/services/api.service.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/services/app.module.service.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/services/application.iface.service.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/services/compute.service.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/services/deployment.service.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/services/experiment.service.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/services/process.service.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/app/services/task.service.ts
copy sandbox/{simstream/example/openmm_example/application/trajectory.dcd => airavata-kubernetes/web-console/src/assets/.gitkeep} (100%)
create mode 100644 sandbox/airavata-kubernetes/web-console/src/environments/environment.prod.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/environments/environment.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/favicon.ico
create mode 100644 sandbox/airavata-kubernetes/web-console/src/index.html
create mode 100644 sandbox/airavata-kubernetes/web-console/src/main.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/polyfills.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/styles.css
create mode 100644 sandbox/airavata-kubernetes/web-console/src/test.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/src/tsconfig.app.json
create mode 100644 sandbox/airavata-kubernetes/web-console/src/tsconfig.spec.json
create mode 100644 sandbox/airavata-kubernetes/web-console/src/typings.d.ts
create mode 100644 sandbox/airavata-kubernetes/web-console/tsconfig.json
create mode 100644 sandbox/airavata-kubernetes/web-console/tslint.json
--
To stop receiving notification emails like this one, please contact
['"commits@airavata.apache.org" <co...@airavata.apache.org>'].
[airavata] 01/01: Merge pull request #135 from DImuthuUpe/master
Posted by sm...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
smarru pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git
commit 88acdf1220b4e3aa9b8ad09fcb251964034abb21
Merge: 2a3302c 3077522
Author: Suresh Marru <sm...@apache.org>
AuthorDate: Tue Oct 31 12:03:32 2017 -0400
Merge pull request #135 from DImuthuUpe/master
Container Based Task Execution Workflow for Airavata
sandbox/airavata-kubernetes/Design Document.pdf | Bin 0 -> 566742 bytes
sandbox/airavata-kubernetes/User Guide.pdf | Bin 0 -> 532940 bytes
.../modules/api-resource/pom.xml | 49 +
.../application/ApplicationDeploymentResource.java | 100 +
.../application/ApplicationIfaceResource.java | 92 +
.../application/ApplicationInputResource.java | 79 +
.../application/ApplicationModuleResource.java | 70 +
.../application/ApplicationOutputResource.java | 68 +
.../k8s/api/resources/compute/ComputeResource.java | 90 +
.../k8s/api/resources/data/DataEntryResource.java | 60 +
.../experiment/ExperimentInputResource.java | 90 +
.../experiment/ExperimentOutputResource.java | 80 +
.../resources/experiment/ExperimentResource.java | 168 +
.../experiment/ExperimentStatusResource.java | 79 +
.../k8s/api/resources/process/ProcessResource.java | 125 +
.../resources/process/ProcessStatusResource.java | 107 +
.../k8s/api/resources/task/TaskParamResource.java | 60 +
.../k8s/api/resources/task/TaskResource.java | 163 +
.../k8s/api/resources/task/TaskStatusResource.java | 99 +
.../modules/compute-resource-api/pom.xml | 61 +
.../k8s/compute/api/ComputeOperations.java | 32 +
.../airavata/k8s/compute/api/ExecutionResult.java | 60 +
.../k8s/compute/impl/MockComputeOperation.java | 68 +
.../k8s/compute/impl/SSHComputeOperations.java | 302 +
.../modules/microservices/api-server/pom.xml | 162 +
.../airavata/k8s/api/server/Application.java | 66 +
.../k8s/api/server/ServerRuntimeException.java | 40 +
.../ApplicationDeploymentController.java | 60 +
.../controller/ApplicationInterfaceController.java | 59 +
.../controller/ApplicationModuleController.java | 60 +
.../controller/ComputeResourceController.java | 59 +
.../api/server/controller/DataStoreController.java | 71 +
.../server/controller/ExperimentController.java | 64 +
.../api/server/controller/ProcessController.java | 59 +
.../k8s/api/server/controller/TaskController.java | 65 +
.../model/application/ApplicationDeployment.java | 109 +
.../server/model/application/ApplicationInput.java | 116 +
.../model/application/ApplicationInterface.java | 100 +
.../model/application/ApplicationModule.java | 73 +
.../model/application/ApplicationOutput.java | 108 +
.../k8s/api/server/model/commons/ErrorModel.java | 108 +
.../server/model/compute/ComputeResourceModel.java | 96 +
.../k8s/api/server/model/data/DataStoreModel.java | 88 +
.../api/server/model/experiment/Experiment.java | 168 +
.../model/experiment/ExperimentInputData.java | 114 +
.../model/experiment/ExperimentOutputData.java | 106 +
.../server/model/experiment/ExperimentStatus.java | 99 +
.../k8s/api/server/model/job/JobModel.java | 168 +
.../k8s/api/server/model/job/JobStatus.java | 109 +
.../k8s/api/server/model/process/ProcessModel.java | 135 +
.../api/server/model/process/ProcessStatus.java | 124 +
.../k8s/api/server/model/task/TaskModel.java | 190 +
.../k8s/api/server/model/task/TaskParam.java | 82 +
.../k8s/api/server/model/task/TaskStatus.java | 121 +
.../ApplicationDeploymentRepository.java | 36 +
.../repository/ApplicationIfaceRepository.java | 36 +
.../repository/ApplicationInputRepository.java | 32 +
.../repository/ApplicationModuleRepository.java | 36 +
.../repository/ApplicationOutputRepository.java | 32 +
.../api/server/repository/ComputeRepository.java | 36 +
.../api/server/repository/DataStoreRepository.java | 36 +
.../repository/ExperimentInputDataRepository.java | 32 +
.../repository/ExperimentOutputDataRepository.java | 35 +
.../server/repository/ExperimentRepository.java | 35 +
.../repository/ExperimentStatusRepository.java | 32 +
.../api/server/repository/ProcessRepository.java | 35 +
.../server/repository/ProcessStatusRepository.java | 32 +
.../api/server/repository/TaskParamRepository.java | 32 +
.../k8s/api/server/repository/TaskRepository.java | 35 +
.../server/repository/TaskStatusRepository.java | 36 +
.../service/ApplicationDeploymentService.java | 87 +
.../server/service/ApplicationIfaceService.java | 109 +
.../server/service/ApplicationModuleService.java | 69 +
.../api/server/service/ComputeResourceService.java | 70 +
.../k8s/api/server/service/ExperimentService.java | 149 +
.../k8s/api/server/service/ProcessService.java | 99 +
.../k8s/api/server/service/TaskService.java | 109 +
.../api/server/service/data/DataStoreService.java | 71 +
.../server/service/messaging/MessagingService.java | 42 +
.../api/server/service/messaging/SenderConfig.java | 64 +
.../api/server/service/util/ToResourceUtil.java | 305 +
.../src/main/resources/application.properties | 5 +
.../api-server/src/main/resources/application.yml | 4 +
.../src/main/resources/docker/Dockerfile | 6 +
.../modules/microservices/event-sink/pom.xml | 151 +
.../org/apache/airavata/k8s/sink/Application.java | 49 +
.../airavata/k8s/sink/messaging/KafkaReceiver.java | 53 +
.../airavata/k8s/sink/messaging/KafkaSender.java | 43 +
.../k8s/sink/messaging/ReceiverConfig.java | 85 +
.../airavata/k8s/sink/messaging/SenderConfig.java | 69 +
.../k8s/sink/service/EventPersistingService.java | 56 +
.../src/main/resources/application.properties | 4 +
.../event-sink/src/main/resources/application.yml | 4 +
.../modules/microservices/task-scheduler/pom.xml | 151 +
.../org/apache/airavata/k8s/gfac/Application.java | 49 +
.../k8s/gfac/core/ProcessLifeCycleManager.java | 124 +
.../airavata/k8s/gfac/messaging/KafkaReceiver.java | 53 +
.../airavata/k8s/gfac/messaging/KafkaSender.java | 39 +
.../k8s/gfac/messaging/ReceiverConfig.java | 109 +
.../airavata/k8s/gfac/messaging/SenderConfig.java | 69 +
.../airavata/k8s/gfac/service/WorkerService.java | 88 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../tasks/egress-staging-task/pom.xml | 156 +
.../airavata/k8s/task/egress/Application.java | 49 +
.../k8s/task/egress/messaging/KafkaReceiver.java | 45 +
.../k8s/task/egress/messaging/KafkaSender.java | 43 +
.../k8s/task/egress/messaging/ReceiverConfig.java | 85 +
.../k8s/task/egress/messaging/SenderConfig.java | 69 +
.../task/egress/service/TaskExecutionService.java | 183 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../microservices/tasks/env-cleanup-task/pom.xml | 156 +
.../airavata/k8s/task/cleanup/Application.java | 49 +
.../k8s/task/cleanup/messaging/KafkaReceiver.java | 45 +
.../k8s/task/cleanup/messaging/KafkaSender.java | 43 +
.../k8s/task/cleanup/messaging/ReceiverConfig.java | 85 +
.../k8s/task/cleanup/messaging/SenderConfig.java | 69 +
.../task/cleanup/service/TaskExecutionService.java | 153 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../microservices/tasks/env-setup-task/pom.xml | 157 +
.../airavata/k8s/task/env/setup/Application.java | 49 +
.../task/env/setup/messaging/KafkaReceiver.java | 45 +
.../k8s/task/env/setup/messaging/KafkaSender.java | 43 +
.../task/env/setup/messaging/ReceiverConfig.java | 85 +
.../k8s/task/env/setup/messaging/SenderConfig.java | 69 +
.../env/setup/service/TaskExecutionService.java | 153 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../tasks/ingress-staging-task/pom.xml | 156 +
.../airavata/k8s/task/ingress/Application.java | 49 +
.../k8s/task/ingress/messaging/KafkaReceiver.java | 45 +
.../k8s/task/ingress/messaging/KafkaSender.java | 43 +
.../k8s/task/ingress/messaging/ReceiverConfig.java | 85 +
.../k8s/task/ingress/messaging/SenderConfig.java | 69 +
.../task/ingress/service/TaskExecutionService.java | 126 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../tasks/job-submission-task/pom.xml | 156 +
.../apache/airavata/k8s/task/job/Application.java | 49 +
.../k8s/task/job/messaging/KafkaReceiver.java | 45 +
.../k8s/task/job/messaging/KafkaSender.java | 43 +
.../k8s/task/job/messaging/ReceiverConfig.java | 85 +
.../k8s/task/job/messaging/SenderConfig.java | 69 +
.../k8s/task/job/service/TaskExecutionService.java | 160 +
.../src/main/resources/application.properties | 5 +
.../src/main/resources/application.yml | 4 +
.../microservices/workflow-generator/pom.xml | 153 +
.../airavata/k8s/orchestrator/Application.java | 49 +
.../k8s/orchestrator/messaging/KafkaReceiver.java | 46 +
.../k8s/orchestrator/messaging/KafkaSender.java | 39 +
.../k8s/orchestrator/messaging/ReceiverConfig.java | 81 +
.../k8s/orchestrator/messaging/SenderConfig.java | 69 +
.../service/ExperimentLaunchService.java | 259 +
.../src/main/resources/application.properties | 4 +
.../src/main/resources/application.yml | 4 +
sandbox/airavata-kubernetes/pom.xml | 85 +
sandbox/airavata-kubernetes/readme.txt | 21 +
.../scripts/k8s/api-server/api-server-dep.yml | 26 +
.../scripts/k8s/api-server/api-server-svc.yml | 14 +
.../airavata-kubernetes/scripts/k8s/db-service.yml | 30 +
.../scripts/k8s/event-sink/event-sink-dep.yml | 21 +
.../scripts/k8s/kafka-service.yml | 30 +
.../k8s/task-scheduler/task-secheduler-dep.yml | 21 +
.../egress-staging-task-dep.yml | 21 +
.../env-cleanup-task/env-cleanup-task-dep.yml | 21 +
.../tasks/env-setup-task/env-setup-task-dep.yml | 21 +
.../ingress-staging-task-dep.yml | 21 +
.../job-submission-task-dep.yml | 21 +
.../workflow-generator/workflow-generator-dep.yml | 21 +
.../web-console/.angular-cli.json | 64 +
.../airavata-kubernetes/web-console/.editorconfig | 13 +
sandbox/airavata-kubernetes/web-console/.gitignore | 42 +
sandbox/airavata-kubernetes/web-console/README.md | 32 +
.../web-console/docker/Dockerfile | 2 +
.../web-console/e2e/app.e2e-spec.ts | 14 +
.../airavata-kubernetes/web-console/e2e/app.po.ts | 11 +
.../web-console/e2e/tsconfig.e2e.json | 14 +
.../airavata-kubernetes/web-console/karma.conf.js | 33 +
.../web-console/package-lock.json | 9608 ++++++++++++++++++++
.../airavata-kubernetes/web-console/package.json | 49 +
.../web-console/protractor.conf.js | 28 +
.../web-console/src/app/app.component.css | 0
.../web-console/src/app/app.component.html | 20 +
.../web-console/src/app/app.component.spec.ts | 27 +
.../web-console/src/app/app.component.ts | 13 +
.../web-console/src/app/app.module.ts | 42 +
.../web-console/src/app/app.routing.ts | 14 +
.../app-dep/list/app.dep.list.component.ts | 90 +
.../src/app/components/app-dep/list/list.html | 77 +
.../app-iface/list/app.iface.list.component.ts | 88 +
.../src/app/components/app-iface/list/list.html | 111 +
.../app-module/list/app.module.list.component.ts | 64 +
.../src/app/components/app-module/list/list.html | 56 +
.../compute/list/compute.list.component.ts | 66 +
.../src/app/components/compute/list/list.html | 69 +
.../components/dashboard/dashboard.component.ts | 12 +
.../src/app/components/dashboard/dashboard.html | 45 +
.../app/components/dashboard/dashboard.routes.ts | 50 +
.../app/components/experiment/detail/detail.html | 124 +
.../experiment/detail/experiment.detail.ts | 64 +
.../experiment/list/experiment.list.component.ts | 141 +
.../src/app/components/experiment/list/list.html | 117 +
.../src/app/components/process/detail/detail.html | 107 +
.../process/detail/process.detail.component.ts | 47 +
.../src/app/components/setup/setup.component.ts | 25 +
.../src/app/components/setup/setup.html | 13 +
.../application/application.deployment.model.ts | 27 +
.../models/application/application.iface.model.ts | 29 +
.../models/application/application.ipnput.model.ts | 22 +
.../models/application/application.module.model.ts | 21 +
.../models/application/application.output.model.ts | 21 +
.../app/models/compute/compute.resource.model.ts | 30 +
.../src/app/models/data/data.entry.model.ts | 9 +
.../models/experiment/experiment.input.model.ts | 22 +
.../src/app/models/experiment/experiment.model.ts | 44 +
.../models/experiment/experiment.output.model.ts | 20 +
.../models/experiment/experiment.status.model.ts | 10 +
.../src/app/models/process/process.model.ts | 20 +
.../src/app/models/process/process.status.model.ts | 15 +
.../web-console/src/app/models/task/task.model.ts | 41 +
.../src/app/models/task/task.param.model.ts | 18 +
.../src/app/models/task/task.status.model.ts | 24 +
.../web-console/src/app/services/api.service.ts | 46 +
.../src/app/services/app.module.service.ts | 23 +
.../src/app/services/application.iface.service.ts | 23 +
.../src/app/services/compute.service.ts | 22 +
.../src/app/services/deployment.service.ts | 21 +
.../src/app/services/experiment.service.ts | 31 +
.../src/app/services/process.service.ts | 28 +
.../web-console/src/app/services/task.service.ts | 25 +
.../web-console/src/assets/.gitkeep | 0
.../src/environments/environment.prod.ts | 3 +
.../web-console/src/environments/environment.ts | 8 +
.../web-console/src/favicon.ico | Bin 0 -> 5430 bytes
.../airavata-kubernetes/web-console/src/index.html | 16 +
.../airavata-kubernetes/web-console/src/main.ts | 12 +
.../web-console/src/polyfills.ts | 76 +
.../airavata-kubernetes/web-console/src/styles.css | 1 +
.../airavata-kubernetes/web-console/src/test.ts | 32 +
.../web-console/src/tsconfig.app.json | 13 +
.../web-console/src/tsconfig.spec.json | 20 +
.../web-console/src/typings.d.ts | 5 +
.../airavata-kubernetes/web-console/tsconfig.json | 19 +
.../airavata-kubernetes/web-console/tslint.json | 141 +
246 files changed, 24487 insertions(+)
--
To stop receiving notification emails like this one, please contact
"commits@airavata.apache.org" <co...@airavata.apache.org>.
Re: [airavata] branch master updated (2a3302c -> 88acdf1)
Posted by Suresh Marru <sm...@apache.org>.
Hi Marcus,
My bad, I was trying the new GitHub based merge/comment. You are right, this should go to sandbox, I will revert this now.
Suresh
> On Oct 31, 2017, at 4:27 PM, Christie, Marcus Aaron <ma...@iu.edu> wrote:
>
> Suresh,
>
> Just curious. Why is this committed to *airavata* instead of *airavata-sandbox* repo?
>
>> On Oct 31, 2017, at 12:03 PM, smarru@apache.org wrote:
>>
>> This is an automated email from the ASF dual-hosted git repository.
>>
>> smarru pushed a change to branch master
>> in repository https://gitbox.apache.org/repos/asf/airavata.git.
>>
>>
>> from 2a3302c Added a new test gateway with develop airavata server for SGA class student project
>> add a68ff57 Initial API server framework
>> add c3644ef Implementing Experiment and Application creation APIs
>> add 98afe91 Implemented Orchestrator to accept messages from launch queue and create tasks and processes for experiments
>> add c4a3a05 Adding task microservices for each task type
>> add e96bced Adding task microservices for each task type - v2
>> add f800a63 Support to async task execution to avoid task being executed by the kafka consumer thread
>> add 04f88bc Publishing events of a task to a single partition to achieve ordered delivery
>> add 14a62f9 Implementing the event sink to perisit task states to the database
>> add 56bb2fa Compute resource operations to decouple the communication between tasks and compute resources
>> add fa3a242 Restructuring modules and fixing docker builds
>> add 4268067 Exposing port 8080 of api-server container
>> add da921e9 Adding kubernetes scripts to deploy microservices on kubernetes
>> add 549ae48 Adding API server endpoint to accept process status
>> add 4e27cb5 Adding get all method to API server resources
>> add e1e09b8 Web console initial commit
>> add 2d18e15 Adding Experiment and App Interface creation functionality to Web Console
>> add e1d73b5 Adding Experiment detail pages
>> add 95fb8d4 Added task event view console
>> add 4f19f5c Adding setup page to configure API Server endpoint
>> add 9b8c097 Fixing bugs in task execution processes
>> add cb4438f Uploading experiment outputs to Data Store
>> add 421fd4a Docker file to build console docker image
>> add 7b16ba6 Externalizing db username and password
>> add 67de113 Minor improvements
>> add 70076aa Adding dependency management
>> add 35ef652 Adding license headers
>> add 3077522 Updated readme
>> new 88acdf1 Merge pull request #135 from DImuthuUpe/master
>>
> ...
>
Re: [airavata] branch master updated (2a3302c -> 88acdf1)
Posted by "Christie, Marcus Aaron" <ma...@iu.edu>.
Suresh,
Just curious. Why is this committed to *airavata* instead of *airavata-sandbox* repo?
> On Oct 31, 2017, at 12:03 PM, smarru@apache.org wrote:
>
> This is an automated email from the ASF dual-hosted git repository.
>
> smarru pushed a change to branch master
> in repository https://gitbox.apache.org/repos/asf/airavata.git.
>
>
> from 2a3302c Added a new test gateway with develop airavata server for SGA class student project
> add a68ff57 Initial API server framework
> add c3644ef Implementing Experiment and Application creation APIs
> add 98afe91 Implemented Orchestrator to accept messages from launch queue and create tasks and processes for experiments
> add c4a3a05 Adding task microservices for each task type
> add e96bced Adding task microservices for each task type - v2
> add f800a63 Support to async task execution to avoid task being executed by the kafka consumer thread
> add 04f88bc Publishing events of a task to a single partition to achieve ordered delivery
> add 14a62f9 Implementing the event sink to perisit task states to the database
> add 56bb2fa Compute resource operations to decouple the communication between tasks and compute resources
> add fa3a242 Restructuring modules and fixing docker builds
> add 4268067 Exposing port 8080 of api-server container
> add da921e9 Adding kubernetes scripts to deploy microservices on kubernetes
> add 549ae48 Adding API server endpoint to accept process status
> add 4e27cb5 Adding get all method to API server resources
> add e1e09b8 Web console initial commit
> add 2d18e15 Adding Experiment and App Interface creation functionality to Web Console
> add e1d73b5 Adding Experiment detail pages
> add 95fb8d4 Added task event view console
> add 4f19f5c Adding setup page to configure API Server endpoint
> add 9b8c097 Fixing bugs in task execution processes
> add cb4438f Uploading experiment outputs to Data Store
> add 421fd4a Docker file to build console docker image
> add 7b16ba6 Externalizing db username and password
> add 67de113 Minor improvements
> add 70076aa Adding dependency management
> add 35ef652 Adding license headers
> add 3077522 Updated readme
> new 88acdf1 Merge pull request #135 from DImuthuUpe/master
>
...