Crate faucet_sink_elasticsearch 

faucet-sink-elasticsearch

Elasticsearch bulk index sink connector for the faucet-stream ecosystem.

Writes JSON records to an Elasticsearch index using the _bulk API.

Re-exports

pub use config::ElasticsearchSinkAuth;Deprecated

pub use config::ElasticsearchOpType;

pub use config::ElasticsearchSinkConfig;

pub use sink::ElasticsearchSink;

Modules

config

Elasticsearch sink configuration.

sink

Elasticsearch bulk index sink.

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.

Constants

DESCRIPTOR

The connector’s static descriptor (RFC 0013): its capabilities, answered from config alone.

Traits

Sink

A sink writes records to an external system.

Type Aliases

ElasticsearchTls

The tls: block of the Elasticsearch source and sink: a CA that signed the cluster’s certificate (ca_cert_path / ca_cert_pem, used in place of the platform roots — self-managed Elasticsearch 8 ships a self-signed CA), a client certificate for mutual TLS, and insecure_skip_verify.

SharedAuthProvider

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