privatevoid.net/depot
1
1
Fork 0
Code Issues 23 Pull requests 2 Projects 3 Releases Packages Wiki Activity Actions

WIP: PostgreSQL Cluster Auto-Upgrade #92

Draft
max wants to merge 5 commits from pg-auto-migrations into master
pull from: pg-auto-migrations
merge into: privatevoid.net:master
Conversation 4 Commits 5 Files changed 4 +3
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 9498e87e9c - Show all commits

3
modules/patroni/default.nix
View file

@ -361,6 +361,7 @@ in
print(f"setting system identifier to {sysid}") print(f"setting system identifier to {sysid}")
ctl.dcs.initialize(create_new=False, sysid=str(sysid)) ctl.dcs.initialize(create_new=False, sysid=str(sysid))
pg.stop() pg.stop()
os.system("patronictl resume")
''; '';
migrationScript = pkgs.writeShellScript "patroni-migration-replicate-or-self-upgrade" '' migrationScript = pkgs.writeShellScript "patroni-migration-replicate-or-self-upgrade" ''
if [[ "$(consul catalog nodes --service='${cfg.scope}' 2>/dev/null | wc -l)" -gt 0 ]]; then if [[ "$(consul catalog nodes --service='${cfg.scope}' 2>/dev/null | wc -l)" -gt 0 ]]; then
@ -398,6 +399,7 @@ in
fi fi
done done
echo no other nodes are at the target version, performing self-upgrade echo no other nodes are at the target version, performing self-upgrade
patronictl pause
leaderHost="$(patronictl list -f json | jq -r 'map(select(.Role == "Leader" and .State == "running") | .Host) | .[0]')" leaderHost="$(patronictl list -f json | jq -r 'map(select(.Role == "Leader" and .State == "running") | .Host) | .[0]')"
# this is where it gets spicy # this is where it gets spicy
rm -rf '${cfg.postgresqlDataDir}' rm -rf '${cfg.postgresqlDataDir}'
@ -407,6 +409,7 @@ in
export PATRONIMIGRATOR_LEADER_HOST="$leaderHost" export PATRONIMIGRATOR_LEADER_HOST="$leaderHost"
# HACK: find a way to get the port # HACK: find a way to get the port
export PATRONIMIGRATOR_LEADER_PORT="5432" export PATRONIMIGRATOR_LEADER_PORT="5432"
export PYTHONUNBUFFERED=1
exec ${upgradeScript} exec ${upgradeScript}
fi fi
fi fi