risingwave_connector::connector_common::connection

Function validate_connection

Source 
pub async fn validate_connection(
    connection: &PbConnection,
) -> ConnectorResult<()>