Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id E4FE7200D2E for ; Tue, 31 Oct 2017 17:03:38 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id E369A160BF9; Tue, 31 Oct 2017 16:03:38 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id DA5801609EC for ; Tue, 31 Oct 2017 17:03:37 +0100 (CET) Received: (qmail 62528 invoked by uid 500); 31 Oct 2017 16:03:37 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 62519 invoked by uid 99); 31 Oct 2017 16:03:37 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 31 Oct 2017 16:03:37 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 5328B80675; Tue, 31 Oct 2017 16:03:34 +0000 (UTC) Date: Tue, 31 Oct 2017 16:03:35 +0000 To: "commits@airavata.apache.org" Subject: [airavata] 01/01: Merge pull request #135 from DImuthuUpe/master MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit From: smarru@apache.org In-Reply-To: <150946581431.15074.7950936139762153134@gitbox.apache.org> References: <150946581431.15074.7950936139762153134@gitbox.apache.org> X-Git-Host: gitbox.apache.org X-Git-Repo: airavata X-Git-Refname: refs/heads/master X-Git-Reftype: branch X-Git-Rev: 88acdf1220b4e3aa9b8ad09fcb251964034abb21 X-Git-NotificationType: diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated Message-Id: <20171031160335.5328B80675@gitbox.apache.org> archived-at: Tue, 31 Oct 2017 16:03:39 -0000 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 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" .