summaryrefslogtreecommitdiffstats
path: root/sources/hv-collector-test-utils
diff options
context:
space:
mode:
authorIzabela Zawadzka <izabela.zawadzka@nokia.com>2019-07-04 08:59:04 +0200
committerIzabela Zawadzka <izabela.zawadzka@nokia.com>2019-07-04 15:42:08 +0200
commit583bb983ae956f366c034fdad20df79ccef196fd (patch)
treee82e39ea78955e726eb89f32ef8729a685ea2daf /sources/hv-collector-test-utils
parent3a4020ae3e810dad7979597feadc13d8b56b3bb1 (diff)
Measure message travel time
Issue-ID: DCAEGEN2-1654 Signed-off-by: Izabela Zawadzka <izabela.zawadzka@nokia.com> Change-Id: Ifd6597209c5be51d5b4ff5faf7b3b1b1a2871403
Diffstat (limited to 'sources/hv-collector-test-utils')
-rw-r--r--sources/hv-collector-test-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/tests/utils/vesEvents.kt9
1 files changed, 5 insertions, 4 deletions
diff --git a/sources/hv-collector-test-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/tests/utils/vesEvents.kt b/sources/hv-collector-test-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/tests/utils/vesEvents.kt
index ed0cab63..ba60d1b0 100644
--- a/sources/hv-collector-test-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/tests/utils/vesEvents.kt
+++ b/sources/hv-collector-test-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/tests/utils/vesEvents.kt
@@ -37,7 +37,7 @@ fun vesEvent(domain: VesEventDomain = PERF3GPP,
eventFields: ByteString = ByteString.EMPTY,
vesEventListenerVersion: String = "7.0.2"
): VesEventOuterClass.VesEvent = vesEvent(
- commonHeader(domain, id, vesEventListenerVersion),
+ commonHeader(domain, id, vesEventListenerVersion, lastEpochMicrosec = 100000005),
eventFields
)
@@ -51,8 +51,9 @@ fun vesEvent(commonEventHeader: CommonEventHeader,
fun commonHeader(domain: VesEventDomain = PERF3GPP,
id: String = randomUUID().toString(),
vesEventListenerVersion: String = "7.0.2",
- priority: Priority = Priority.NORMAL
-): CommonEventHeader =
+ priority: Priority = Priority.NORMAL,
+ lastEpochMicrosec: Long = 100000005
+ ): CommonEventHeader =
CommonEventHeader.newBuilder()
.setVersion("sample-version")
.setDomain(domain.domainName)
@@ -62,7 +63,7 @@ fun commonHeader(domain: VesEventDomain = PERF3GPP,
.setEventName("sample-event-name")
.setEventType("sample-event-type")
.setStartEpochMicrosec(100000000)
- .setLastEpochMicrosec(100000005)
+ .setLastEpochMicrosec(lastEpochMicrosec)
.setNfNamingCode("sample-nf-naming-code")
.setNfcNamingCode("sample-nfc-naming-code")
.setNfVendorName("vendor-name")