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/11/01 00:23:47 UTC
[airavata-sandbox] branch master updated (e76ace3 -> 97c42e1)
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-sandbox.git.
from e76ace3 merge
add 48669ce Initial commit of container based task execution workflow on top of Kubernetes
new 97c42e1 Merge pull request #8 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:
airavata-kubernetes/Design Document.pdf | Bin 0 -> 566742 bytes
airavata-kubernetes/User Guide.pdf | Bin 0 -> 532940 bytes
airavata-kubernetes/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 +
airavata-kubernetes/pom.xml | 85 +
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 +
airavata-kubernetes/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 +
airavata-kubernetes/web-console/.angular-cli.json | 64 +
airavata-kubernetes/web-console/.editorconfig | 13 +
airavata-kubernetes/web-console/.gitignore | 42 +
airavata-kubernetes/web-console/README.md | 32 +
airavata-kubernetes/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 +
airavata-kubernetes/web-console/package-lock.json | 9608 ++++++++++++++++++++
airavata-kubernetes/web-console/package.json | 49 +
airavata-kubernetes/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 +
airavata-kubernetes/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 +
airavata-kubernetes/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 +
airavata-kubernetes/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 airavata-kubernetes/Design Document.pdf
create mode 100644 airavata-kubernetes/User Guide.pdf
create mode 100644 airavata-kubernetes/modules/api-resource/pom.xml
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationDeploymentResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationIfaceResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationInputResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationModuleResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/application/ApplicationOutputResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/compute/ComputeResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/data/DataEntryResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/experiment/ExperimentInputResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/experiment/ExperimentOutputResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/experiment/ExperimentResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/experiment/ExperimentStatusResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/process/ProcessResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/process/ProcessStatusResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/task/TaskParamResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/task/TaskResource.java
create mode 100644 airavata-kubernetes/modules/api-resource/src/main/java/org/apache/airavata/k8s/api/resources/task/TaskStatusResource.java
create mode 100644 airavata-kubernetes/modules/compute-resource-api/pom.xml
create mode 100644 airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/api/ComputeOperations.java
create mode 100644 airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/api/ExecutionResult.java
create mode 100644 airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/impl/MockComputeOperation.java
create mode 100644 airavata-kubernetes/modules/compute-resource-api/src/main/java/org/apache/airavata/k8s/compute/impl/SSHComputeOperations.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/ServerRuntimeException.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ApplicationDeploymentController.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ApplicationInterfaceController.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ApplicationModuleController.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ComputeResourceController.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/DataStoreController.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ExperimentController.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/ProcessController.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/controller/TaskController.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationDeployment.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationInput.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationInterface.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationModule.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/application/ApplicationOutput.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/commons/ErrorModel.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/compute/ComputeResourceModel.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/data/DataStoreModel.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/experiment/Experiment.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/experiment/ExperimentInputData.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/experiment/ExperimentOutputData.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/experiment/ExperimentStatus.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/job/JobModel.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/job/JobStatus.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/process/ProcessModel.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/process/ProcessStatus.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/task/TaskModel.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/task/TaskParam.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/model/task/TaskStatus.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationDeploymentRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationIfaceRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationInputRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationModuleRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ApplicationOutputRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ComputeRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/DataStoreRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ExperimentInputDataRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ExperimentOutputDataRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ExperimentRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ExperimentStatusRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ProcessRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/ProcessStatusRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/TaskParamRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/TaskRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/repository/TaskStatusRepository.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ApplicationDeploymentService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ApplicationIfaceService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ApplicationModuleService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ComputeResourceService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ExperimentService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/ProcessService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/TaskService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/data/DataStoreService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/messaging/MessagingService.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/java/org/apache/airavata/k8s/api/server/service/util/ToResourceUtil.java
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/modules/microservices/api-server/src/main/resources/docker/Dockerfile
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/messaging/KafkaReceiver.java
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/messaging/KafkaSender.java
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/messaging/ReceiverConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/src/main/java/org/apache/airavata/k8s/sink/service/EventPersistingService.java
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/event-sink/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/core/ProcessLifeCycleManager.java
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/KafkaReceiver.java
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/KafkaSender.java
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/ReceiverConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/java/org/apache/airavata/k8s/gfac/service/WorkerService.java
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/task-scheduler/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/messaging/KafkaReceiver.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/messaging/KafkaSender.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/messaging/ReceiverConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/java/org/apacher/airavata/k8s/task/egress/service/TaskExecutionService.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/tasks/egress-staging-task/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/messaging/KafkaReceiver.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/messaging/KafkaSender.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/messaging/ReceiverConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/java/org/apache/airavata/k8s/task/cleanup/service/TaskExecutionService.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-cleanup-task/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/messaging/KafkaReceiver.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/messaging/KafkaSender.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/messaging/ReceiverConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/java/org/apache/airavata/k8s/task/env/setup/service/TaskExecutionService.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/tasks/env-setup-task/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/messaging/KafkaReceiver.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/messaging/KafkaSender.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/messaging/ReceiverConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/java/org/apache/airavata/k8s/task/ingress/service/TaskExecutionService.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/tasks/ingress-staging-task/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/messaging/KafkaReceiver.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/messaging/KafkaSender.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/messaging/ReceiverConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/java/org/apache/airavata/k8s/task/job/service/TaskExecutionService.java
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/tasks/job-submission-task/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/pom.xml
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/Application.java
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/messaging/KafkaReceiver.java
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/messaging/KafkaSender.java
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/messaging/ReceiverConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/messaging/SenderConfig.java
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/src/main/java/org/apache/airavata/k8s/orchestrator/service/ExperimentLaunchService.java
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/src/main/resources/application.properties
create mode 100644 airavata-kubernetes/modules/microservices/workflow-generator/src/main/resources/application.yml
create mode 100644 airavata-kubernetes/pom.xml
create mode 100644 airavata-kubernetes/readme.txt
create mode 100644 airavata-kubernetes/scripts/k8s/api-server/api-server-dep.yml
create mode 100644 airavata-kubernetes/scripts/k8s/api-server/api-server-svc.yml
create mode 100644 airavata-kubernetes/scripts/k8s/db-service.yml
create mode 100644 airavata-kubernetes/scripts/k8s/event-sink/event-sink-dep.yml
create mode 100644 airavata-kubernetes/scripts/k8s/kafka-service.yml
create mode 100644 airavata-kubernetes/scripts/k8s/task-scheduler/task-secheduler-dep.yml
create mode 100644 airavata-kubernetes/scripts/k8s/tasks/egress-staging-task/egress-staging-task-dep.yml
create mode 100644 airavata-kubernetes/scripts/k8s/tasks/env-cleanup-task/env-cleanup-task-dep.yml
create mode 100644 airavata-kubernetes/scripts/k8s/tasks/env-setup-task/env-setup-task-dep.yml
create mode 100644 airavata-kubernetes/scripts/k8s/tasks/ingress-staging-task/ingress-staging-task-dep.yml
create mode 100644 airavata-kubernetes/scripts/k8s/tasks/job-submission-task/job-submission-task-dep.yml
create mode 100644 airavata-kubernetes/scripts/k8s/workflow-generator/workflow-generator-dep.yml
create mode 100644 airavata-kubernetes/web-console/.angular-cli.json
create mode 100644 airavata-kubernetes/web-console/.editorconfig
create mode 100644 airavata-kubernetes/web-console/.gitignore
create mode 100644 airavata-kubernetes/web-console/README.md
create mode 100644 airavata-kubernetes/web-console/docker/Dockerfile
create mode 100644 airavata-kubernetes/web-console/e2e/app.e2e-spec.ts
create mode 100644 airavata-kubernetes/web-console/e2e/app.po.ts
create mode 100644 airavata-kubernetes/web-console/e2e/tsconfig.e2e.json
create mode 100644 airavata-kubernetes/web-console/karma.conf.js
create mode 100644 airavata-kubernetes/web-console/package-lock.json
create mode 100644 airavata-kubernetes/web-console/package.json
create mode 100644 airavata-kubernetes/web-console/protractor.conf.js
copy helix-playground/src/main/resources/ssh/known_hosts => airavata-kubernetes/web-console/src/app/app.component.css (100%)
create mode 100644 airavata-kubernetes/web-console/src/app/app.component.html
create mode 100644 airavata-kubernetes/web-console/src/app/app.component.spec.ts
create mode 100644 airavata-kubernetes/web-console/src/app/app.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/app.module.ts
create mode 100644 airavata-kubernetes/web-console/src/app/app.routing.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/app-dep/list/app.dep.list.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/app-dep/list/list.html
create mode 100644 airavata-kubernetes/web-console/src/app/components/app-iface/list/app.iface.list.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/app-iface/list/list.html
create mode 100644 airavata-kubernetes/web-console/src/app/components/app-module/list/app.module.list.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/app-module/list/list.html
create mode 100644 airavata-kubernetes/web-console/src/app/components/compute/list/compute.list.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/compute/list/list.html
create mode 100644 airavata-kubernetes/web-console/src/app/components/dashboard/dashboard.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/dashboard/dashboard.html
create mode 100644 airavata-kubernetes/web-console/src/app/components/dashboard/dashboard.routes.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/experiment/detail/detail.html
create mode 100644 airavata-kubernetes/web-console/src/app/components/experiment/detail/experiment.detail.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/experiment/list/experiment.list.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/experiment/list/list.html
create mode 100644 airavata-kubernetes/web-console/src/app/components/process/detail/detail.html
create mode 100644 airavata-kubernetes/web-console/src/app/components/process/detail/process.detail.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/setup/setup.component.ts
create mode 100644 airavata-kubernetes/web-console/src/app/components/setup/setup.html
create mode 100644 airavata-kubernetes/web-console/src/app/models/application/application.deployment.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/application/application.iface.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/application/application.ipnput.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/application/application.module.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/application/application.output.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/compute/compute.resource.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/data/data.entry.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/experiment/experiment.input.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/experiment/experiment.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/experiment/experiment.output.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/experiment/experiment.status.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/process/process.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/process/process.status.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/task/task.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/task/task.param.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/models/task/task.status.model.ts
create mode 100644 airavata-kubernetes/web-console/src/app/services/api.service.ts
create mode 100644 airavata-kubernetes/web-console/src/app/services/app.module.service.ts
create mode 100644 airavata-kubernetes/web-console/src/app/services/application.iface.service.ts
create mode 100644 airavata-kubernetes/web-console/src/app/services/compute.service.ts
create mode 100644 airavata-kubernetes/web-console/src/app/services/deployment.service.ts
create mode 100644 airavata-kubernetes/web-console/src/app/services/experiment.service.ts
create mode 100644 airavata-kubernetes/web-console/src/app/services/process.service.ts
create mode 100644 airavata-kubernetes/web-console/src/app/services/task.service.ts
copy helix-playground/src/main/resources/ssh/known_hosts => airavata-kubernetes/web-console/src/assets/.gitkeep (100%)
create mode 100644 airavata-kubernetes/web-console/src/environments/environment.prod.ts
create mode 100644 airavata-kubernetes/web-console/src/environments/environment.ts
create mode 100644 airavata-kubernetes/web-console/src/favicon.ico
create mode 100644 airavata-kubernetes/web-console/src/index.html
create mode 100644 airavata-kubernetes/web-console/src/main.ts
create mode 100644 airavata-kubernetes/web-console/src/polyfills.ts
create mode 100644 airavata-kubernetes/web-console/src/styles.css
create mode 100644 airavata-kubernetes/web-console/src/test.ts
create mode 100644 airavata-kubernetes/web-console/src/tsconfig.app.json
create mode 100644 airavata-kubernetes/web-console/src/tsconfig.spec.json
create mode 100644 airavata-kubernetes/web-console/src/typings.d.ts
create mode 100644 airavata-kubernetes/web-console/tsconfig.json
create mode 100644 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-sandbox] 01/01: Merge pull request #8 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-sandbox.git
commit 97c42e10731277d11668679a68d58f858d225157
Merge: e76ace3 48669ce
Author: Suresh Marru <sm...@apache.org>
AuthorDate: Tue Oct 31 20:23:45 2017 -0400
Merge pull request #8 from DImuthuUpe/master
Container Based Task Execution Workflow for Airavata
airavata-kubernetes/Design Document.pdf | Bin 0 -> 566742 bytes
airavata-kubernetes/User Guide.pdf | Bin 0 -> 532940 bytes
airavata-kubernetes/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 +
airavata-kubernetes/pom.xml | 85 +
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 +
airavata-kubernetes/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 +
airavata-kubernetes/web-console/.angular-cli.json | 64 +
airavata-kubernetes/web-console/.editorconfig | 13 +
airavata-kubernetes/web-console/.gitignore | 42 +
airavata-kubernetes/web-console/README.md | 32 +
airavata-kubernetes/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 +
airavata-kubernetes/web-console/package-lock.json | 9608 ++++++++++++++++++++
airavata-kubernetes/web-console/package.json | 49 +
airavata-kubernetes/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 +
airavata-kubernetes/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 +
airavata-kubernetes/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 +
airavata-kubernetes/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>.