pub fn parse_source(
    conn: &str,
    protocol: Option<&str>
) -> Result<SourceConn, ConnectorXError>