package elasticsearch
- Alphabetic
- Public
- Protected
Type Members
- sealed final class ApiVersion extends Enum[ApiVersion] with ApiVersionBase
- trait ApiVersionBase extends AnyRef
Common interface to represent Opensearch / Elasticsearch versions.
- final class ElasticsearchConnectionSettings extends AnyRef
- final class ElasticsearchParams extends AnyRef
- final class ElasticsearchSourceSettings extends SourceSettingsBase[ApiVersion, ElasticsearchSourceSettings]
Configure Elastiscsearch sources.
- final class ElasticsearchWriteSettings extends WriteSettingsBase[ApiVersion, ElasticsearchWriteSettings]
Configure Elasticsearch sinks and flows.
- trait MessageWriter[T] extends AnyRef
- sealed final class OpensearchApiVersion extends Enum[OpensearchApiVersion] with ApiVersionBase
- final class OpensearchSourceSettings extends SourceSettingsBase[OpensearchApiVersion, OpensearchSourceSettings]
Configure Opensearch sources.
- final class OpensearchWriteSettings extends WriteSettingsBase[OpensearchApiVersion, OpensearchWriteSettings]
Configure Opensearch sinks and flows.
- 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 pekko.stream.connectors.elasticsearch.testkit.MessageFactory.
- final class RetryAtFixedRate extends RetryLogic
- trait RetryLogic extends AnyRef
- final class RetryWithBackoff extends RetryLogic
- abstract class SourceSettingsBase[Version <: ApiVersionBase, S <: SourceSettingsBase[Version, S]] extends AnyRef
Configure Elastiscsearch/OpenSearch sources.
- 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 org.apache.pekko.stream.connectors.elasticsearch.testkit.MessageFactory.
- abstract class WriteSettingsBase[Version <: ApiVersionBase, W <: WriteSettingsBase[Version, W]] extends AnyRef
Configure Elasticsearch/OpenSearch sinks and flows.
Value Members
- object ElasticsearchConnectionSettings
- object ElasticsearchParams
- object ElasticsearchSourceSettings
- object ElasticsearchWriteSettings
- object OpensearchConnectionSettings
Opensearch 1.x is fully compatible with Elasticsearch 7.x with respect to connection parameters.
- object OpensearchParams
Opensearch 1.x is fully compatible with Elasticsearch 7.x release line, so we could reuse the Elasticsearch V7 compatibile implementation.
- object OpensearchSourceSettings
- object OpensearchWriteSettings
- object RetryAtFixedRate
- object RetryNever extends RetryLogic
- object RetryWithBackoff
- object StringMessageWriter extends StringMessageWriter
- object WriteMessage