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 */ }