diff options
Diffstat (limited to 'hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt')
| -rw-r--r-- | hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt b/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt index bc030587..e9cd5f3f 100644 --- a/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt +++ b/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt @@ -19,12 +19,14 @@ */ package org.onap.dcae.collectors.veshv.model +import arrow.core.Option import org.onap.ves.VesEventV5.VesEvent.CommonEventHeader import org.onap.ves.VesEventV5.VesEvent.CommonEventHeader.Domain data class Routing(val routes: List<Route>) { - fun routeFor(commonHeader: CommonEventHeader): Route? = routes.find { it.applies(commonHeader) } + fun routeFor(commonHeader: CommonEventHeader): Option<Route> = + Option.fromNullable(routes.find { it.applies(commonHeader) }) } data class Route(val domain: Domain, val targetTopic: String, val partitioning: (CommonEventHeader) -> Int) { |