Code Review / dcaegen2 / services / sdk.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 7abe295) | patch
Implement StreamParser 33/82233/7
authorkjaniak <kornel.janiak@nokia.com>
Thu, 14 Mar 2019 09:40:40 +0000 (10:40 +0100)
committerPiotr Jaszczyk <piotr.jaszczyk@nokia.com>
Tue, 19 Mar 2019 12:37:13 +0000 (12:37 +0000)
commit35b114b70ab9da6c519d437dcceafc03da2a88a1
tree6171ef79ded4ccb08c23188654e8655f666091aetree | snapshot
parent7abe2954d3783cb8a6484f012507be95d59c82b9commit | diff
Implement StreamParser

Change-Id: I3ee50ad70bb107fa39f227af7dab67948b7dbe4b
Issue-ID: DCAEGEN2-1342
Signed-off-by: kjaniak <kornel.janiak@nokia.com>
33 files changed:
pom.xml diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/api/streams/StreamFromGsonParsers.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/DataRouterSinkParser.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/DataRouterSourceParser.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/GsonKafka.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/GsonMessageRouter.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/GsonMessageRouterSink.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/GsonMessageRouterSource.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/GsonUtils.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/KafkaSinkParser.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/KafkaSourceParser.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/MessageRouterDmaapInfo.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/MessageRouterSinkParser.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/MessageRouterSourceParser.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/StreamsConstants.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/AafCredentials.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/dmaap/DataRouter.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/dmaap/DataRouterSink.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/dmaap/DataRouterSource.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/dmaap/KafkaSink.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/dmaap/MessageRouter.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/dmaap/MessageRouterSink.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/dmaap/MessageRouterSource.java diff | blob | history
rest-services/cbs-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/DataRouterSinkParserTest.java [new file with mode: 0644] blob
rest-services/cbs-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/DataRouterSourceParserTest.java [new file with mode: 0644] blob
rest-services/cbs-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/MessageRouterSinkParserTest.java [new file with mode: 0644] blob
rest-services/cbs-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/MessageRouterSourceParserTest.java [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/data_router_sink_full.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/data_router_sink_minimal.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/data_router_source_full.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/data_router_source_minimal.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/message_router_full.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/message_router_minimal.json [new file with mode: 0644] blob
Common SDK repo for all DCAE Services (R4)