Packages

p

akka.stream.alpakka

elasticsearch

package elasticsearch

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. final class ElasticsearchSourceSettings extends AnyRef

    Configure Elastiscsearch sources.

  2. final class ElasticsearchWriteSettings extends AnyRef

    Configure Elasticsearch sinks and flows.

  3. trait MessageWriter[T] extends AnyRef
  4. final class ReadResult[T] extends AnyRef

    Stream element type emitted by Elasticsearch sources.

    Stream element type emitted by Elasticsearch sources.

    The constructor is INTERNAL API, but you may construct instances for testing by using akka.stream.alpakka.elasticsearch.testkit.MessageFactory.

  5. final class RetryAtFixedRate extends RetryLogic

    Note: If using retries, you will receive messages out of order downstream in cases where elastic returns error one some of the documents in a bulk request.

  6. trait RetryLogic extends AnyRef
  7. sealed class StringMessageWriter extends MessageWriter[String]
  8. final class WriteMessage[T, PT] extends AnyRef
  9. final class WriteResult[T2, C2] extends AnyRef

    Stream element type emitted by Elasticsearch flows.

    Stream element type emitted by Elasticsearch flows.

    The constructor is INTERNAL API, but you may construct instances for testing by using akka.stream.alpakka.elasticsearch.testkit.MessageFactory.

Ungrouped