Code Review / dcaegen2 / collectors / hv-ves.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 3a4020a) | patch
Measure message travel time 80/90880/4
authorIzabela Zawadzka <izabela.zawadzka@nokia.com>
Thu, 4 Jul 2019 06:59:04 +0000 (08:59 +0200)
committerIzabela Zawadzka <izabela.zawadzka@nokia.com>
Thu, 4 Jul 2019 13:42:08 +0000 (15:42 +0200)
commit583bb983ae956f366c034fdad20df79ccef196fd
treee82e39ea78955e726eb89f32ef8729a685ea2daftree | snapshot
parent3a4020ae3e810dad7979597feadc13d8b56b3bb1commit | diff
Measure message travel time

Issue-ID: DCAEGEN2-1654
Signed-off-by: Izabela Zawadzka <izabela.zawadzka@nokia.com>
Change-Id: Ifd6597209c5be51d5b4ff5faf7b3b1b1a2871403
sources/hv-collector-kafka-consumer/pom.xml diff | blob | history
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/OffsetKafkaConsumer.kt [new file with mode: 0644] blob
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/ProcessingKafkaConsumer.kt [moved from sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/KafkaSource.kt with 58% similarity] diff | blob | history
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/state/OffsetConsumer.kt [deleted file] blob | history
sources/hv-collector-kafka-consumer/src/test/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/OffsetKafkaConsumerTest.kt [moved from sources/hv-collector-kafka-consumer/src/test/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/KafkaSourceTest.kt with 54% similarity] diff | blob | history
sources/hv-collector-kafka-consumer/src/test/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/ProcessingKafkaConsumerTest.kt [new file with mode: 0644] blob
sources/hv-collector-kafka-consumer/src/test/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/state/OffsetConsumerTest.kt [deleted file] blob | history
sources/hv-collector-test-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/tests/utils/vesEvents.kt diff | blob | history
High Volume VES Collector