pmeunier/postrep - Change UEGA35KU63HPNZLXVR5CS2BNMCVOV7HOBTDR4K6YZSPDFWXIKKZQC

Signalling the postgres server when the leader changes, but does not become this node

Created by pmeunier on January 18, 2022

UEGA35KU63HPNZLXVR5CS2BNMCVOV7HOBTDR4K6YZSPDFWXIKKZQC

Dependencies

In channels

main

Change contents

Replacement in src/main.rs at line 261 [3.17]

B:BD[2.2226] → [2.2226:2287]

                rewind(&path, port, &db_name, leader).await;

[2.2226]

[2.2287]

                rewind(&path, port, &db_name, leader, &password).await;
            } else {
                reload(&path).await;

Insertion in src/main.rs at line 265 [3.17]

[2.2301]

[4.3173]

        } else {
            reload(&path).await;

Replacement in src/main.rs at line 287 [3.17]

B:BD[5.3348] → [5.3348:3418]

B:BD[5.3418] → [2.2501:2526]

async fn rewind(path: &str, port: u16, db_name: &str, leader: &str) {
    debug!("rewinding");

[5.3348]

[5.3418]

async fn reload(path: &str) {
    debug!("reload");

Replacement in src/main.rs at line 290 [3.17]

B:BD[5.3451] → [2.2527:2567]

∅:D[2.2567] → [5.3481:3524]

B:BD[5.3481] → [5.3481:3524]

    let out = Command::new("systemctl")
        .args(["stop", "postgresql-repl"])

[5.3451]

[5.3524]

    let out = Command::new("pg_ctl")
        .args(["reload", "-D", path])

Insertion in src/main.rs at line 298 [3.17]

[2.2702]

}
async fn rewind(path: &str, port: u16, db_name: &str, leader: &str, password: &str) {
    debug!("rewinding");
    use std::io::Write;
    use tokio::process::Command;

Insertion in src/main.rs at line 306 [3.17]

[2.2752]

        let out = Command::new("systemctl")
            .args(["stop", "postgresql-repl"])
            .output()
            .await
            .expect("failed to execute process");
        std::io::stdout().write_all(&out.stdout).unwrap();
        std::io::stderr().write_all(&out.stderr).unwrap();
        success = out.status.success();
        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
    }
    let mut success = false;
    while !success {

Replacement in src/main.rs at line 338 [3.17]

B:BD[2.3449] → [2.3449:3489]

∅:D[2.3489] → [5.3989:4112]

B:BD[5.3989] → [5.3989:4112]

B:BD[5.4112] → [2.3490:3600]

    let out = Command::new("systemctl")
        .args(["start", "postgresql-repl"])
        .output()
        .await
        .expect("failed to execute process");
    std::io::stdout().write_all(&out.stdout).unwrap();
    std::io::stderr().write_all(&out.stderr).unwrap();

[2.3449]

[5.4112]


    std::fs::write(
        std::path::Path::new(path).join("postgresql.auto.conf"),
        format!(
            "primary_conninfo = 'host={} port=5432 user=replication password={}'",
            leader, password,
        ),
    )
    .unwrap();
    let mut success = false;
    while !success {
        let out = Command::new("systemctl")
            .args(["start", "postgresql-repl"])
            .output()
            .await
            .expect("failed to execute process");
        std::io::stdout().write_all(&out.stdout).unwrap();
        std::io::stderr().write_all(&out.stderr).unwrap();
        success = out.status.success();
        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
    }