Function test_internal_users_cluster

src/environmentd/tests/sql.rs:1973–1989

()

#[mz_ore::test]
#[allow(clippy::disallowed_methods)]
fn test_internal_users_cluster() {
    let server = test_util::TestHarness::default().start_blocking();

    for (user, expected_cluster) in INTERNAL_USER_NAME_TO_DEFAULT_CLUSTER.iter() {
        let mut internal_client = server
            .pg_config_internal()
            .user(user)
            .connect(postgres::NoTls)
            .unwrap();

        let cluster = internal_client
            .query_one("SHOW CLUSTER", &[])
            .unwrap()
            .get::<_, String>(0);
        assert_eq!(expected_cluster, &cluster);
    }
}

// Tests that you can have simultaneous connections on the internal and external ports without
// crashing