gerrit.onap Code Review - dcaegen2/collectors/hv-ves.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * dcaegen2-collectors-veshv
   4  * ================================================================================
   5  * Copyright (C) 2018 NOKIA
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20 package org.onap.dcae.collectors.veshv.impl.adapters.kafka
  21
  22 import arrow.syntax.collections.tail
  23 import org.assertj.core.api.Assertions.assertThat
  24 import org.jetbrains.spek.api.Spek
  25 import org.jetbrains.spek.api.dsl.describe
  26 import org.jetbrains.spek.api.dsl.given
  27 import org.jetbrains.spek.api.dsl.it
  28 import org.jetbrains.spek.api.dsl.on
  29 import org.onap.dcae.collectors.veshv.model.ClientContext
  30 import org.onap.dcae.collectors.veshv.model.KafkaConfiguration
  31
  32 /**
  33  * @author Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
  34  * @since December 2018
  35  */
  36 internal object KafkaSinkProviderTest : Spek({
  37     describe("non functional requirements") {
  38         given("sample configuration") {
  39             val config = KafkaConfiguration("localhost:9090",
  40                     1024 * 1024)
  41             val cut = KafkaSinkProvider(config)
  42
  43             on("sample clients") {
  44                 val clients = listOf(
  45                         ClientContext(),
  46                         ClientContext(),
  47                         ClientContext(),
  48                         ClientContext())
  49
  50                 it("should create only one instance of KafkaSender") {
  51                     val sinks = clients.map(cut::invoke)
  52                     val firstSink = sinks[0]
  53                     val restOfSinks = sinks.tail()
  54
  55                     assertThat(restOfSinks).isNotEmpty
  56                     assertThat(restOfSinks).allSatisfy { sink ->
  57                         assertThat(firstSink.usesSameSenderAs(sink))
  58                                 .describedAs("$sink.kafkaSender should be same as $firstSink.kafkaSender")
  59                                 .isTrue()
  60                     }
  61                 }
  62             }
  63         }
  64     }
  65 })