Function mz_environmentd::test_util::create_postgres_source_with_table
source ยท pub async fn create_postgres_source_with_table<'a>(
server: &TestServer,
mz_client: &Client,
table_name: &str,
table_schema: &str,
source_name: &str,
) -> (Client, impl FnOnce(&'a Client, &'a Client) -> LocalBoxFuture<'a, ()>)
Expand description
Helper function to create a Postgres source.
IMPORTANT: Make sure to call closure that is returned at the end of the test to clean up Postgres state.
WARNING: If multiple tests use this, and the tests are run in parallel, then make sure the test use different postgres tables.