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:48 UTC
[airavata-sandbox] 01/01: Merge pull request #8 from
DImuthuUpe/master
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>.