gerrit.onap Code Review - dcaegen2/collectors/datafile.git/commit

Code Review / dcaegen2 / collectors / datafile.git / commit

author	PatrikBuhr <patrik.buhr@est.tech>
	Wed, 29 May 2019 09:39:53 +0000 (09:39 +0000)
committer	PatrikBuhr <patrik.buhr@est.tech>
	Wed, 29 May 2019 09:39:53 +0000 (09:39 +0000)
commit	4229afc64d82cbd1ea1e43c92fcd6c9bed9e5137
tree	6c5c6efecb383a439f27cd163b20edfa364b6ce2	tree \| snapshot
parent	2187fc6e6b4b4783389289fb87bd6a3676ad2c72	commit \| diff

Generalizing Data File Collection to handle any type of file

Extension of the DFC to be able to handle any file types types, which are published on different DR feeds.
This association between file type and DR feed is defined by configuration.
The file type is defined by the changeIdentifier in the fileReady VES message reported from the PNF.

The creation of DR feeds and configuration will be done by the DMAAP plugin, but that is
not tested yet.

Change-Id: I13b36acd926a6941ee733e6b37922049fb54a5d9
Issue-ID: DCAEGEN2-1532
Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>

43 files changed:

datafile-app-server/config/datafile_endpoints.json		diff \| blob \| history
datafile-app-server/pom.xml		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/AppConfig.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/CloudConfigParser.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/CloudConfiguration.java	[deleted file]	blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/ConsumerConfiguration.java	[new file with mode: 0644]	blob
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/EnvironmentProcessor.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/FtpesConfig.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/PublisherConfiguration.java	[new file with mode: 0644]	blob
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/SchedulerConfig.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/SwaggerConfig.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/configuration/TomcatHttpConfig.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/controllers/ScheduleController.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FileServerData.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClient.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/SftpClient.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FileData.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/model/FilePublishInformation.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/model/JsonSerializer.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/JsonMessageParser.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/PublishedFileCache.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/producer/DmaapProducerHttpClient.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DMaaPMessageConsumer.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisher.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollector.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/PublishedChecker.java		diff \| blob \| history
datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/ScheduledTasks.java		diff \| blob \| history
datafile-app-server/src/main/resources/datafile_endpoints.json	[deleted file]	blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/configuration/AppConfigTest.java		diff \| blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/configuration/CloudConfigParserTest.java	[deleted file]	blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/configuration/SchedulerConfigTest.java		diff \| blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/integration/ScheduledXmlContextITest.java	[deleted file]	blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/model/FilePublishInformationTest.java	[deleted file]	blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/service/JsonMessageParserTest.java		diff \| blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/service/producer/DmaapProducerHttpClientTest.java		diff \| blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/DMaaPMessageConsumerTest.java		diff \| blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisherTest.java		diff \| blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/FileCollectorTest.java		diff \| blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/PublishedCheckerTest.java		diff \| blob \| history
datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/tasks/ScheduledTasksTest.java		diff \| blob \| history
datafile-app-server/src/test/resources/datafile_endpoints.json	[deleted file]	blob \| history
datafile-app-server/src/test/resources/datafile_endpoints_test.json	[new file with mode: 0644]	blob
datafile-app-server/src/test/resources/datafile_endpoints_test_2producers.json	[new file with mode: 0644]	blob

Data File collector

RSS Atom