Библиотека на основе Docker-контейнера для поддержки astic4s

Question

Я использую astic4, а также заинтересован в использовании среды тестирования на основе Docker-контейнера для моего упругого поиска.

Есть несколько библиотек, таких как: https://github.com/dimafeng/testcontainers-scala и docker-it-scala, но я не могу найти, как я интегрирую astic4s в эти библиотеки, кто-нибудь когда-либо использовал env для тестирования на основе контейнера docker?

в настоящее время моя спецификация очень проста:

class ElasticSearchApiServiceSpec extends FreeSpec {

  implicit val defaultPatience = PatienceConfig(timeout = Span(100, Seconds), interval = Span(50, Millis))

  val configuration: Configuration = app.injector.instanceOf[Configuration]

  val elasticSearchApiService = new ElasticSearchApiService(configuration)

  override protected def beforeAll(): Unit = {
    elasticSearchApiService.elasticClient.execute {
      index into s"peopleIndex/person" doc StringDocumentSource(PeopleFactory.rawStringGoodPerson)
    }
    // since ES is eventually
    Thread.sleep(3000)
  }

  override protected def afterAll(): Unit = {
    elasticSearchApiService.elasticClient.execute {
      deleteIndex("peopleIndex")
    }
  }

  "ElasticSearchApiService Tests" - {

    "elastic search service should retrieve person info properly - case existing person" in {
      val personInfo = elasticSearchApiService.getPersonInfo("2324").futureValue

      personInfo.get.name shouldBe "john"
    }
  }

}

и когда я запускаю его, я запускаю эластичный поиск в фоновом режиме из своего терминала, но теперь я хочу использовать контейнеры, чтобы он был менее зависимым.

Answer 1

Я думаю, вы не хотите зависеть от ES-сервера, работающего на вашем локальном компьютере в тестах. Тогда самый простой подход будет использовать testcontainers-scala"s GenericContainer запустить официальный образ ES Docker следующим образом:

class GenericContainerSpec extends FlatSpec with ForAllTestContainer {
    override val container = GenericContainer("docker.elastic.co/elasticsearch/elasticsearch:5.5.1",
        exposedPorts = Seq(9200),
        waitStrategy = Wait.forHttp("/")
    )

    "GenericContainer" should "start ES and expose 9200 port" in {
       assert(Source.fromInputStream(
          new URL(
            s"http://${container.containerIpAddress}:${container.mappedPort(9200)}/_status")
            .openConnection()
            .getInputStream)
           .mkString
           .contains("ES server is successfully installed"))
    }
}