package elasticsearch
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- sealed abstract final class ApiVersion extends Enum[ApiVersion]
-
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
- trait RetryLogic extends AnyRef
- final class RetryWithBackoff extends RetryLogic
- 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 RetryWithBackoff
- object StringMessageWriter extends StringMessageWriter
- object WriteMessage