package elasticsearch
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
final
class
ElasticsearchSourceSettings extends AnyRef
Configure Elastiscsearch sources.
-
final
class
ElasticsearchWriteSettings extends AnyRef
Configure Elasticsearch sinks and flows.
- trait MessageWriter[T] extends AnyRef
-
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.
-
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.
- trait RetryLogic extends AnyRef
- sealed class StringMessageWriter extends MessageWriter[String]
- final class WriteMessage[T, PT] extends AnyRef
-
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.
Value Members
- object ElasticsearchSourceSettings
- object ElasticsearchWriteSettings
- object RetryAtFixedRate
- object RetryNever extends RetryLogic
- object StringMessageWriter extends StringMessageWriter
- object WriteMessage