Skip to main content

SinkFactory

Type Alias SinkFactory 

Source
pub type SinkFactory = Arc<dyn Fn(&ConnectorConfig, Option<&Arc<Registry>>) -> Result<Box<dyn SinkConnector>, ConnectorError> + Send + Sync>;
Expand description

Factory function type for creating sink connectors.

The connector config is available during construction so factories can select a concrete implementation and reject invalid mode-specific options before open() performs external I/O.

The optional shared Prometheus registry allows connectors to register metrics and retain stable registry identity when one is available.

Aliased Typeยง

pub struct SinkFactory { /* private fields */ }