Crate faucet_source_elasticsearch 

faucet-source-elasticsearch

Elasticsearch search source connector for the faucet-stream ecosystem.

Uses the scroll API to paginate through large result sets efficiently.

Re-exports

pub use config::ElasticsearchSourceConfig;

pub use stream::ElasticsearchSource;

Modules

config

Elasticsearch source configuration.

stream

Elasticsearch scroll-based search source.

Enums

AuthSpec

A connector’s auth: field: either an inline auth definition A (the { type, config } shape), or a { ref: <name> } reference to a shared provider defined in the top-level auth: catalog.

ElasticsearchAuth

Authentication method for Elasticsearch.

FaucetError

All possible errors returned by faucet-stream.

Traits

Source

A source fetches records from an external system.

Type Aliases

SharedAuthProvider

A shared AuthProvider handle. Cloning it shares the one live provider (and its single token cache) across connectors.