risingwave_connector::source::base

Function build_connection

source
pub fn build_connection(
    pb_connection_type: PbConnectionType,
    value_secret_filled: BTreeMap<String, String>,
) -> ConnectorResult<Box<dyn Connection>>