diff options
| author |   Piotr Jaszczyk <piotr.jaszczyk@nokia.com> | 2018-06-14 09:48:46 +0200 |
|---|---|---|
| committer | Piotr Jaszczyk <piotr.jaszczyk@nokia.com> | 2018-08-02 09:49:02 +0200 |
| commit | 67689405071acdad2b26d5112b3662605e474ce9 (patch) | |
| tree | 3e945129934d5721922fdabf229b0d61b772dfdb /hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt | |
| parent | e7987b7a660060746d5f49e1ec90b1ff90fcf55a (diff) | |
Various improvements
* Kotlin upgrade
* Monad usage on APIs
* Idle timeout
* Simulator enhancements
Closes ONAP-390
Change-Id: I3c00fcfe38c722caf661ddaad428cf089eeefcaa
Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
Issue-ID: DCAEGEN2-601
Diffstat (limited to 'hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt')
| -rw-r--r-- | hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt b/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt index ed686fe8..d6158481 100644 --- a/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt +++ b/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt @@ -19,6 +19,7 @@ */ package org.onap.dcae.collectors.veshv.boundary +import arrow.effects.IO import io.netty.buffer.ByteBuf import io.netty.buffer.ByteBufAllocator import org.onap.dcae.collectors.veshv.model.ServerConfiguration @@ -32,9 +33,10 @@ interface Collector { typealias CollectorProvider = () -> Collector interface Server { - fun start(): Mono<Void> + fun start(): IO<ServerHandle> } -interface ServerFactory { - fun createServer(serverConfig: ServerConfiguration, collector: CollectorProvider): Server +abstract class ServerHandle(val host: String, val port: Int) { + abstract fun shutdown(): IO<Unit> + abstract fun await(): IO<Unit> } |