airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sma...@apache.org
Subject [airavata] 01/01: Merge pull request #135 from DImuthuUpe/master
Date Tue, 31 Oct 2017 16:03:35 GMT
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 <smarru@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" <commits@airavata.apache.org>.

Mime
View raw message