Making storage as first class entity and supporting http transport in the agent
authorDimuthu Wannipurage <dimuthu.upeksha2@gmail.com>
Mon, 18 Jan 2021 23:11:10 +0000 (18:11 -0500)
committerDimuthu Wannipurage <dimuthu.upeksha2@gmail.com>
Mon, 18 Jan 2021 23:11:10 +0000 (18:11 -0500)
commitfe56f1c0962ce48f380db0a491a27a29aa8346e6
tree2306a199d64b5b7995ef305a5d90ac2d3ef1d870
parent774afbc62c80f8a62789f2bb634cb261cfd20935
Making storage as first class entity and supporting http transport in the agent
64 files changed:
admin/src/main/java/org/apache/airavata/mft/admin/models/TransferCommand.java
admin/src/main/java/org/apache/airavata/mft/admin/models/TransferRequest.java
agent/pom.xml
agent/src/main/java/org/apache/airavata/mft/agent/AppConfig.java
agent/src/main/java/org/apache/airavata/mft/agent/MFTAgent.java
agent/src/main/java/org/apache/airavata/mft/agent/TransportMediator.java
agent/src/main/java/org/apache/airavata/mft/agent/http/ConnectorParams.java [new file with mode: 0644]
agent/src/main/java/org/apache/airavata/mft/agent/http/HttpDownloadRequest.java [new file with mode: 0644]
agent/src/main/java/org/apache/airavata/mft/agent/http/HttpServer.java [new file with mode: 0644]
agent/src/main/java/org/apache/airavata/mft/agent/http/HttpServerHandler.java [new file with mode: 0644]
agent/src/main/java/org/apache/airavata/mft/agent/http/HttpServerInitializer.java [new file with mode: 0644]
agent/src/main/java/org/apache/airavata/mft/agent/http/HttpTransferRequest.java [new file with mode: 0644]
agent/src/main/java/org/apache/airavata/mft/agent/http/HttpTransferRequestsStore.java [new file with mode: 0644]
agent/src/main/java/org/apache/airavata/mft/agent/rpc/RPCParser.java
api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java
api/stub/src/main/proto/MFTApi.proto
controller/src/main/java/org/apache/airavata/mft/controller/MFTController.java
core/src/main/java/org/apache/airavata/mft/core/DirectoryResourceMetadata.java
core/src/main/java/org/apache/airavata/mft/core/FileResourceMetadata.java
core/src/main/java/org/apache/airavata/mft/core/TransferTask.java
core/src/main/java/org/apache/airavata/mft/core/api/Connector.java
core/src/main/java/org/apache/airavata/mft/core/api/MetadataCollector.java
examples/src/main/java/org/apache/airavata/mft/examples/http/DownloadExample.java [new file with mode: 0644]
examples/src/main/java/org/apache/airavata/mft/examples/transfer/LocalExample.java
examples/src/main/java/org/apache/airavata/mft/examples/transfer/S3Example.java
examples/src/main/java/org/apache/airavata/mft/examples/transfer/SCPExample.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/backend/ResourceBackend.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/backend/airavata/AiravataResourceBackend.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/backend/file/FileBasedResourceBackend.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/backend/sql/SQLResourceBackend.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/handler/AzureServiceHandler.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/handler/BoxServiceHandler.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/handler/DropboxServiceHandler.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/handler/GCSServiceHandler.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/handler/LocalServiceHandler.java
services/resource-service/server/src/main/java/org/apache/airavata/mft/resource/server/handler/S3ServiceHandler.java
services/resource-service/server/src/main/resources/application.properties
services/resource-service/server/src/main/resources/resources.json
services/resource-service/server/src/main/resources/storages.json [new file with mode: 0644]
transport/azure-transport/src/main/java/org/apache/airavata/mft/transport/azure/AzureMetadataCollector.java
transport/azure-transport/src/main/java/org/apache/airavata/mft/transport/azure/AzureReceiver.java
transport/azure-transport/src/main/java/org/apache/airavata/mft/transport/azure/AzureSender.java
transport/box-transport/src/main/java/org/apache/airavata/mft/transport/box/BoxMetadataCollector.java
transport/box-transport/src/main/java/org/apache/airavata/mft/transport/box/BoxReceiver.java
transport/box-transport/src/main/java/org/apache/airavata/mft/transport/box/BoxSender.java
transport/dropbox-transport/src/main/java/org/apache/airavata/mft/transport/dropbox/DropboxMetadataCollector.java
transport/dropbox-transport/src/main/java/org/apache/airavata/mft/transport/dropbox/DropboxReceiver.java
transport/dropbox-transport/src/main/java/org/apache/airavata/mft/transport/dropbox/DropboxSender.java
transport/ftp-transport/src/main/java/org/apache/airavata/mft/transport/ftp/FTPMetadataCollector.java
transport/ftp-transport/src/main/java/org/apache/airavata/mft/transport/ftp/FTPReceiver.java
transport/ftp-transport/src/main/java/org/apache/airavata/mft/transport/ftp/FTPSender.java
transport/ftp-transport/src/main/java/org/apache/airavata/mft/transport/ftp/FTPTransportUtil.java
transport/gcp-transport/src/main/java/org/apache/airavata/mft/transport/gcp/GCSMetadataCollector.java
transport/gcp-transport/src/main/java/org/apache/airavata/mft/transport/gcp/GCSReceiver.java
transport/gcp-transport/src/main/java/org/apache/airavata/mft/transport/gcp/GCSSender.java
transport/local-transport/src/main/java/org/apache/airavata/mft/transport/local/LocalMetadataCollector.java
transport/local-transport/src/main/java/org/apache/airavata/mft/transport/local/LocalReceiver.java
transport/local-transport/src/main/java/org/apache/airavata/mft/transport/local/LocalSender.java
transport/s3-transport/src/main/java/org/apache/airavata/mft/transport/s3/S3MetadataCollector.java
transport/s3-transport/src/main/java/org/apache/airavata/mft/transport/s3/S3Receiver.java
transport/s3-transport/src/main/java/org/apache/airavata/mft/transport/s3/S3Sender.java
transport/scp-transport/src/main/java/org/apache/airavata/mft/transport/scp/SCPMetadataCollector.java
transport/scp-transport/src/main/java/org/apache/airavata/mft/transport/scp/SCPReceiver.java
transport/scp-transport/src/main/java/org/apache/airavata/mft/transport/scp/SCPSender.java