diff options
Diffstat (limited to 'sources/hv-collector-configuration/src/test/kotlin/org/onap/dcae/collectors/veshv/config/impl/test_constants.kt')
| -rw-r--r-- | sources/hv-collector-configuration/src/test/kotlin/org/onap/dcae/collectors/veshv/config/impl/test_constants.kt | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/sources/hv-collector-configuration/src/test/kotlin/org/onap/dcae/collectors/veshv/config/impl/test_constants.kt b/sources/hv-collector-configuration/src/test/kotlin/org/onap/dcae/collectors/veshv/config/impl/test_constants.kt index f07af079..d2b56b66 100644 --- a/sources/hv-collector-configuration/src/test/kotlin/org/onap/dcae/collectors/veshv/config/impl/test_constants.kt +++ b/sources/hv-collector-configuration/src/test/kotlin/org/onap/dcae/collectors/veshv/config/impl/test_constants.kt @@ -24,7 +24,9 @@ import com.nhaarman.mockitokotlin2.whenever import org.onap.dcae.collectors.veshv.config.api.model.Route import org.onap.dcae.collectors.veshv.utils.logging.LogLevel import org.onap.dcaegen2.services.sdk.model.streams.dmaap.KafkaSink +import reactor.retry.Retry import java.nio.file.Paths +import java.time.Duration private fun resourcePathAsString(resource: String) = Paths.get(ConfigurationValidatorTest::class.java.getResource(resource).toURI()).toString() @@ -51,4 +53,11 @@ private val sampleSink = mock<KafkaSink>().also { } internal val sampleStreamsDefinition = listOf(sampleSink) -internal val sampleRouting = listOf(Route(sampleSink.name(), sampleSink))
\ No newline at end of file +internal val sampleRouting = listOf(Route(sampleSink.name(), sampleSink)) + +internal val mdc = { mapOf("mdc_key" to "mdc_value") } + +internal fun retry(iterationCount: Long = 1) = Retry + .onlyIf<Any> { it.iteration() <= iterationCount } + .fixedBackoff(Duration.ofNanos(1)) + |