Code Review / dcaegen2 / services / sdk.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 9eb05b6) | patch
Implement Kafka stream definition parsers 21/82221/6
authorPiotr Jaszczyk <piotr.jaszczyk@nokia.com>
Thu, 14 Mar 2019 07:38:15 +0000 (08:38 +0100)
committerPiotr Jaszczyk <piotr.jaszczyk@nokia.com>
Thu, 14 Mar 2019 12:58:20 +0000 (13:58 +0100)
commitc852448b1e6ca5e28e0b0dab26c2af3d5af3f390
treebf50c6ddbb24eab14f4da96849a74c6088f1e338tree | snapshot
parent9eb05b612d185d00ad6ad9deffc5a3ab5cf91a1ecommit | diff
Implement Kafka stream definition parsers

Change-Id: I43215c1c2494b6036deb004891fb76bfd2b74474
Issue-ID: DCAEGEN2-1341
Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
25 files changed:
rest-services/cbs-client/pom.xml diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/api/exceptions/StreamParserError.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/api/streams/StreamFromGsonParser.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/api/streams/StreamFromGsonParsers.java [new file with mode: 0644] blob
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/api/streams/StreamParser.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/streams/gson/GsonKafka.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/GsonKafkaSink.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/GsonKafkaSource.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 [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/KafkaInfo.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/KafkaSinkParser.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/KafkaSourceParser.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/SinkStream.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/SourceStream.java diff | blob | history
rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/model/streams/dmaap/Kafka.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/dmaap/KafkaSink.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/dmaap/KafkaSource.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/KafkaSinkParserTest.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/KafkaSourceParserTest.java [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/kafka_sink.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/kafka_sink_invalid_type.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/kafka_sink_minimal.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/kafka_sink_missing_child.json [new file with mode: 0644] blob
rest-services/cbs-client/src/test/resources/streams/kafka_source_minimal.json [new file with mode: 0644] blob
Common SDK repo for all DCAE Services (R4)