rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-07 05:22:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

[WIP] Implement CLI pg part

Browse Source
This commit is contained in:
Stas Kelvich
2021-04-13 09:47:16 +03:00
committed by Stas Kelvich
parent 39ebec51d1
commit c5f379bff3
8 changed files with 327 additions and 241 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
integration_tests/tests/test_pageserver.rs
View File

@@ -15,8 +15,8 @@ fn test_redo_cases() {
let mut compute_cplane = ComputeControlPlane::local(&storage_cplane.pageserver);
// start postgres
let node = compute_cplane.new_node();
node.start();
let node = compute_cplane.new_test_node();
node.start().unwrap();
// check basic work with table
node.safe_psql(
@@ -55,8 +55,8 @@ fn test_regress() {
let mut compute_cplane = ComputeControlPlane::local(&storage_cplane.pageserver);
// start postgres
let node = compute_cplane.new_node();
node.start();
let node = compute_cplane.new_test_node();
node.start().unwrap();
control_plane::storage::regress_check(&node);
}
@@ -69,10 +69,10 @@ fn test_pageserver_multitenancy() {
let mut compute_cplane = ComputeControlPlane::local(&storage_cplane.pageserver);
// Allocate postgres instance, but don't start
let node1 = compute_cplane.new_node();
let node2 = compute_cplane.new_node();
node1.start();
node2.start();
let node1 = compute_cplane.new_test_node();
let node2 = compute_cplane.new_test_node();
node1.start().unwrap();
node2.start().unwrap();
// check node1
node1.safe_psql(

16
integration_tests/tests/test_wal_acceptor.rs
View File

@@ -16,8 +16,8 @@ fn test_acceptors_normal_work() {
let wal_acceptors = storage_cplane.get_wal_acceptor_conn_info();
// start postgres
let node = compute_cplane.new_master_node();
node.start();
let node = compute_cplane.new_test_master_node();
node.start().unwrap();
// start proxy
let _proxy = node.start_proxy(wal_acceptors);
@@ -54,8 +54,8 @@ fn test_acceptors_restarts() {
let mut rng = rand::thread_rng();
// start postgres
let node = compute_cplane.new_master_node();
node.start();
let node = compute_cplane.new_test_master_node();
node.start().unwrap();
// start proxy
let _proxy = node.start_proxy(wal_acceptors);
@@ -112,8 +112,8 @@ fn test_acceptors_unavalability() {
let wal_acceptors = storage_cplane.get_wal_acceptor_conn_info();
// start postgres
let node = compute_cplane.new_master_node();
node.start();
let node = compute_cplane.new_test_master_node();
node.start().unwrap();
// start proxy
let _proxy = node.start_proxy(wal_acceptors);
@@ -187,8 +187,8 @@ fn test_race_conditions() {
let wal_acceptors = storage_cplane.get_wal_acceptor_conn_info();
// start postgres
let node = compute_cplane.new_master_node();
node.start();
let node = compute_cplane.new_test_master_node();
node.start().unwrap();
// start proxy
let _proxy = node.start_proxy(wal_acceptors);