rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-04 12:02:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add test for embedded WAL acceptor

Browse Source
This commit is contained in:
Konstantin Knizhnik
2021-04-29 14:41:13 +03:00
parent 26115818b7
commit f491a22d85
2 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
control_plane/src/storage.rs
View File

@@ -107,14 +107,6 @@ impl TestStorageControlPlane {
.join(",")
}
pub fn get_wal_acceptor_conn_info_quoted(&self) -> String {
self.wal_acceptors
.iter()
.map(|wa| format!("\"{}\"", wa.listen))
.collect::<Vec<String>>()
.join(",")
}
pub fn is_running(&self) -> bool {
self.test_done.load(Ordering::Relaxed)
}

4
integration_tests/tests/test_wal_acceptor.rs
View File

@@ -19,12 +19,12 @@ fn test_embedded_wal_proposer() {
const REDUNDANCY: usize = 3;
let storage_cplane = TestStorageControlPlane::fault_tolerant(&local_env, REDUNDANCY);
let mut compute_cplane = ComputeControlPlane::local(&local_env, &storage_cplane.pageserver);
let wal_acceptors = storage_cplane.get_wal_acceptor_conn_info_quoted();
let wal_acceptors = storage_cplane.get_wal_acceptor_conn_info();
// start postgres
let maintli = storage_cplane.get_branch_timeline("main");
let node = compute_cplane.new_test_master_node(maintli);
node.append_conf("postgresql.conf", &format!("wal_acceptors={}\n", wal_acceptors));
node.append_conf("postgresql.conf", &format!("wal_acceptors='{}'\n", wal_acceptors));
node.start().unwrap();
// check basic work with table