Packages

p

akka.stream.alpakka

elasticsearch

package elasticsearch

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. sealed abstract final class ApiVersion extends Enum[ApiVersion]
  2. final class ElasticsearchSourceSettings extends AnyRef

    Configure Elastiscsearch sources.

  3. final class ElasticsearchWriteSettings extends AnyRef

    Configure Elasticsearch sinks and flows.

  4. trait MessageWriter[T] extends AnyRef
  5. 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.

  6. final class RetryAtFixedRate extends RetryLogic
  7. trait RetryLogic extends AnyRef
  8. final class RetryWithBackoff extends RetryLogic
  9. sealed class StringMessageWriter extends MessageWriter[String]
  10. final class WriteMessage[T, PT] extends AnyRef
  11. 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