mirror of
https://github.com/EnterpriseDB/repmgr.git
synced 2026-03-23 07:06:30 +00:00
Compare commits
77 Commits
REL5_4_STA
...
REL5_3_STA
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
739bbe9a54 | ||
|
|
ba0b8a1692 | ||
|
|
f002ceeae6 | ||
|
|
64228c5a74 | ||
|
|
9264680bdc | ||
|
|
99c3b42921 | ||
|
|
3c0d643466 | ||
|
|
6149e4c7b0 | ||
|
|
5e75707d4e | ||
|
|
8e5698f16e | ||
|
|
3d08800521 | ||
|
|
e64184aff3 | ||
|
|
8c031e2b05 | ||
|
|
3a157465ce | ||
|
|
70da9e8a53 | ||
|
|
6602a98f2e | ||
|
|
b6ba0c3d45 | ||
|
|
e4d6e2cd11 | ||
|
|
a28b6641b8 | ||
|
|
78d2acf204 | ||
|
|
b3d52c4332 | ||
|
|
72ae977d0d | ||
|
|
599351eea8 | ||
|
|
fca2b3ade7 | ||
|
|
89ba005726 | ||
|
|
5ddf450919 | ||
|
|
20342bb8ee | ||
|
|
ea36c5dde3 | ||
|
|
fc72e0bf93 | ||
|
|
b10e9b89dd | ||
|
|
a7d87d5992 | ||
|
|
015c0c8458 | ||
|
|
474d85d647 | ||
|
|
207057a159 | ||
|
|
65d796ee3e | ||
|
|
0fb4c0930a | ||
|
|
cee3b8446a | ||
|
|
90a700c7c0 | ||
|
|
cc4475b8e2 | ||
|
|
9f1c9ef829 | ||
|
|
2a05f495f6 | ||
|
|
d342acfefe | ||
|
|
2f27fec510 | ||
|
|
a80ee17b6c | ||
|
|
595494f8a1 | ||
|
|
3ca4c273fa | ||
|
|
41f0688f69 | ||
|
|
78be15b06c | ||
|
|
f02be50118 | ||
|
|
ac62101dc0 | ||
|
|
78cc278639 | ||
|
|
ceb65027c6 | ||
|
|
e6caa14ea2 | ||
|
|
88a11f36ca | ||
|
|
7f371b11a5 | ||
|
|
349eacd4b7 | ||
|
|
9f2afe9643 | ||
|
|
356f65531f | ||
|
|
2a7579c770 | ||
|
|
820d972d41 | ||
|
|
d0add49c84 | ||
|
|
9a84fa84f9 | ||
|
|
ff2c56f5cb | ||
|
|
3b860bad80 | ||
|
|
70c79aeaec | ||
|
|
afd876377c | ||
|
|
277910cb31 | ||
|
|
9554154677 | ||
|
|
2bbfb5daa0 | ||
|
|
82b0e85a66 | ||
|
|
3320eb0983 | ||
|
|
7862941300 | ||
|
|
f152fc3016 | ||
|
|
9c260e605d | ||
|
|
7ad06530e4 | ||
|
|
c787273f91 | ||
|
|
d40055c8dd |
6
HISTORY
6
HISTORY
@@ -1,9 +1,3 @@
|
|||||||
5.4.1 2023-07-04
|
|
||||||
repmgrd: ensure witness node metadata is updated (Ian)
|
|
||||||
|
|
||||||
5.4.0 2023-03-16
|
|
||||||
Support cloning replicas using pg-backup-api
|
|
||||||
|
|
||||||
5.3.3 2022-10-17
|
5.3.3 2022-10-17
|
||||||
Support for PostgreSQL added
|
Support for PostgreSQL added
|
||||||
repmgrd: ensure event notification script is called for event
|
repmgrd: ensure event notification script is called for event
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ GIT_WORK_TREE=${repmgr_abs_srcdir}
|
|||||||
GIT_DIR=${repmgr_abs_srcdir}/.git
|
GIT_DIR=${repmgr_abs_srcdir}/.git
|
||||||
export GIT_DIR
|
export GIT_DIR
|
||||||
export GIT_WORK_TREE
|
export GIT_WORK_TREE
|
||||||
PG_LDFLAGS=-lcurl -ljson-c
|
|
||||||
include $(PGXS)
|
include $(PGXS)
|
||||||
|
|
||||||
-include ${repmgr_abs_srcdir}/Makefile.custom
|
-include ${repmgr_abs_srcdir}/Makefile.custom
|
||||||
|
|||||||
@@ -30,9 +30,7 @@ DATA = \
|
|||||||
repmgr--5.1--5.2.sql \
|
repmgr--5.1--5.2.sql \
|
||||||
repmgr--5.2.sql \
|
repmgr--5.2.sql \
|
||||||
repmgr--5.2--5.3.sql \
|
repmgr--5.2--5.3.sql \
|
||||||
repmgr--5.3.sql \
|
repmgr--5.3.sql
|
||||||
repmgr--5.3--5.4.sql \
|
|
||||||
repmgr--5.4.sql
|
|
||||||
|
|
||||||
REGRESS = repmgr_extension
|
REGRESS = repmgr_extension
|
||||||
|
|
||||||
@@ -66,7 +64,7 @@ REPMGR_CLIENT_OBJS = repmgr-client.o \
|
|||||||
repmgr-action-primary.o repmgr-action-standby.o repmgr-action-witness.o \
|
repmgr-action-primary.o repmgr-action-standby.o repmgr-action-witness.o \
|
||||||
repmgr-action-cluster.o repmgr-action-node.o repmgr-action-service.o repmgr-action-daemon.o \
|
repmgr-action-cluster.o repmgr-action-node.o repmgr-action-service.o repmgr-action-daemon.o \
|
||||||
configdata.o configfile.o configfile-scan.o log.o strutil.o controldata.o dirutil.o compat.o \
|
configdata.o configfile.o configfile-scan.o log.o strutil.o controldata.o dirutil.o compat.o \
|
||||||
dbutils.o sysutils.o pgbackupapi.o
|
dbutils.o sysutils.o
|
||||||
REPMGRD_OBJS = repmgrd.o repmgrd-physical.o configdata.o configfile.o configfile-scan.o log.o \
|
REPMGRD_OBJS = repmgrd.o repmgrd-physical.o configdata.o configfile.o configfile-scan.o log.o \
|
||||||
dbutils.o strutil.o controldata.o compat.o sysutils.o
|
dbutils.o strutil.o controldata.o compat.o sysutils.o
|
||||||
|
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ replication, and perform administrative tasks such as failover or switchover
|
|||||||
operations.
|
operations.
|
||||||
|
|
||||||
The most recent `repmgr` version (5.3.2) supports all PostgreSQL versions from
|
The most recent `repmgr` version (5.3.2) supports all PostgreSQL versions from
|
||||||
9.5 to 15. PostgreSQL 9.4 is also supported, with some restrictions.
|
9.5 to 14. PostgreSQL 9.4 is also supported, with some restrictions.
|
||||||
|
|
||||||
`repmgr` is distributed under the GNU GPL 3 and maintained by EnterpriseDB.
|
`repmgr` is distributed under the GNU GPL 3 and maintained by EnterpriseDB.
|
||||||
|
|
||||||
@@ -40,6 +40,7 @@ Directories
|
|||||||
- `contrib/`: additional utilities
|
- `contrib/`: additional utilities
|
||||||
- `doc/`: DocBook-based documentation files
|
- `doc/`: DocBook-based documentation files
|
||||||
- `expected/`: expected regression test output
|
- `expected/`: expected regression test output
|
||||||
|
- `scripts/`: example scripts
|
||||||
- `sql/`: regression test input
|
- `sql/`: regression test input
|
||||||
|
|
||||||
|
|
||||||
@@ -69,6 +70,7 @@ news are always welcome.
|
|||||||
|
|
||||||
Thanks from the repmgr core team.
|
Thanks from the repmgr core team.
|
||||||
|
|
||||||
|
* Ian Barwick
|
||||||
* Jaime Casanova
|
* Jaime Casanova
|
||||||
* Abhijit Menon-Sen
|
* Abhijit Menon-Sen
|
||||||
* Simon Riggs
|
* Simon Riggs
|
||||||
|
|||||||
40
configdata.c
40
configdata.c
@@ -291,46 +291,6 @@ struct ConfigFileSetting config_file_settings[] =
|
|||||||
{},
|
{},
|
||||||
{}
|
{}
|
||||||
},
|
},
|
||||||
/* pg_backupapi_backup_id*/
|
|
||||||
{
|
|
||||||
"pg_backupapi_backup_id",
|
|
||||||
CONFIG_STRING,
|
|
||||||
{ .strptr = config_file_options.pg_backupapi_backup_id },
|
|
||||||
{ .strdefault = "" },
|
|
||||||
{},
|
|
||||||
{ .strmaxlen = sizeof(config_file_options.pg_backupapi_backup_id) },
|
|
||||||
{}
|
|
||||||
},
|
|
||||||
/* pg_backupapi_host*/
|
|
||||||
{
|
|
||||||
"pg_backupapi_host",
|
|
||||||
CONFIG_STRING,
|
|
||||||
{ .strptr = config_file_options.pg_backupapi_host },
|
|
||||||
{ .strdefault = "" },
|
|
||||||
{},
|
|
||||||
{ .strmaxlen = sizeof(config_file_options.pg_backupapi_host) },
|
|
||||||
{}
|
|
||||||
},
|
|
||||||
/* pg_backupapi_node_name */
|
|
||||||
{
|
|
||||||
"pg_backupapi_node_name",
|
|
||||||
CONFIG_STRING,
|
|
||||||
{ .strptr = config_file_options.pg_backupapi_node_name },
|
|
||||||
{ .strdefault = "" },
|
|
||||||
{},
|
|
||||||
{ .strmaxlen = sizeof(config_file_options.pg_backupapi_node_name) },
|
|
||||||
{}
|
|
||||||
},
|
|
||||||
/* pg_backupapi_remote_ssh_command */
|
|
||||||
{
|
|
||||||
"pg_backupapi_remote_ssh_command",
|
|
||||||
CONFIG_STRING,
|
|
||||||
{ .strptr = config_file_options.pg_backupapi_remote_ssh_command },
|
|
||||||
{ .strdefault = "" },
|
|
||||||
{},
|
|
||||||
{ .strmaxlen = sizeof(config_file_options.pg_backupapi_remote_ssh_command) },
|
|
||||||
{}
|
|
||||||
},
|
|
||||||
|
|
||||||
/* =======================
|
/* =======================
|
||||||
* standby follow settings
|
* standby follow settings
|
||||||
|
|||||||
@@ -164,10 +164,6 @@ typedef struct
|
|||||||
char archive_cleanup_command[MAXLEN];
|
char archive_cleanup_command[MAXLEN];
|
||||||
bool use_primary_conninfo_password;
|
bool use_primary_conninfo_password;
|
||||||
char passfile[MAXPGPATH];
|
char passfile[MAXPGPATH];
|
||||||
char pg_backupapi_backup_id[NAMEDATALEN];
|
|
||||||
char pg_backupapi_host[NAMEDATALEN];
|
|
||||||
char pg_backupapi_node_name[NAMEDATALEN];
|
|
||||||
char pg_backupapi_remote_ssh_command[MAXLEN];
|
|
||||||
|
|
||||||
/* standby promote settings */
|
/* standby promote settings */
|
||||||
int promote_check_timeout;
|
int promote_check_timeout;
|
||||||
|
|||||||
22
configure
vendored
22
configure
vendored
@@ -1,6 +1,6 @@
|
|||||||
#! /bin/sh
|
#! /bin/sh
|
||||||
# Guess values for system-dependent variables and create Makefiles.
|
# Guess values for system-dependent variables and create Makefiles.
|
||||||
# Generated by GNU Autoconf 2.69 for repmgr 5.4.0.
|
# Generated by GNU Autoconf 2.69 for repmgr 5.3.3.
|
||||||
#
|
#
|
||||||
# Report bugs to <repmgr@googlegroups.com>.
|
# Report bugs to <repmgr@googlegroups.com>.
|
||||||
#
|
#
|
||||||
@@ -11,7 +11,7 @@
|
|||||||
# This configure script is free software; the Free Software Foundation
|
# This configure script is free software; the Free Software Foundation
|
||||||
# gives unlimited permission to copy, distribute and modify it.
|
# gives unlimited permission to copy, distribute and modify it.
|
||||||
#
|
#
|
||||||
# Copyright (c) 2010-2021, EnterpriseDB Corporation
|
# Copyright (c) 2010-2022, EnterpriseDB Corporation
|
||||||
## -------------------- ##
|
## -------------------- ##
|
||||||
## M4sh Initialization. ##
|
## M4sh Initialization. ##
|
||||||
## -------------------- ##
|
## -------------------- ##
|
||||||
@@ -582,8 +582,8 @@ MAKEFLAGS=
|
|||||||
# Identity of this package.
|
# Identity of this package.
|
||||||
PACKAGE_NAME='repmgr'
|
PACKAGE_NAME='repmgr'
|
||||||
PACKAGE_TARNAME='repmgr'
|
PACKAGE_TARNAME='repmgr'
|
||||||
PACKAGE_VERSION='5.4.0'
|
PACKAGE_VERSION='5.3.3'
|
||||||
PACKAGE_STRING='repmgr 5.4.0'
|
PACKAGE_STRING='repmgr 5.3.3'
|
||||||
PACKAGE_BUGREPORT='repmgr@googlegroups.com'
|
PACKAGE_BUGREPORT='repmgr@googlegroups.com'
|
||||||
PACKAGE_URL='https://repmgr.org/'
|
PACKAGE_URL='https://repmgr.org/'
|
||||||
|
|
||||||
@@ -1181,7 +1181,7 @@ if test "$ac_init_help" = "long"; then
|
|||||||
# Omit some internal or obsolete options to make the list less imposing.
|
# Omit some internal or obsolete options to make the list less imposing.
|
||||||
# This message is too long to be a string in the A/UX 3.1 sh.
|
# This message is too long to be a string in the A/UX 3.1 sh.
|
||||||
cat <<_ACEOF
|
cat <<_ACEOF
|
||||||
\`configure' configures repmgr 5.4.0 to adapt to many kinds of systems.
|
\`configure' configures repmgr 5.3.3 to adapt to many kinds of systems.
|
||||||
|
|
||||||
Usage: $0 [OPTION]... [VAR=VALUE]...
|
Usage: $0 [OPTION]... [VAR=VALUE]...
|
||||||
|
|
||||||
@@ -1242,7 +1242,7 @@ fi
|
|||||||
|
|
||||||
if test -n "$ac_init_help"; then
|
if test -n "$ac_init_help"; then
|
||||||
case $ac_init_help in
|
case $ac_init_help in
|
||||||
short | recursive ) echo "Configuration of repmgr 5.4.0:";;
|
short | recursive ) echo "Configuration of repmgr 5.3.3:";;
|
||||||
esac
|
esac
|
||||||
cat <<\_ACEOF
|
cat <<\_ACEOF
|
||||||
|
|
||||||
@@ -1316,14 +1316,14 @@ fi
|
|||||||
test -n "$ac_init_help" && exit $ac_status
|
test -n "$ac_init_help" && exit $ac_status
|
||||||
if $ac_init_version; then
|
if $ac_init_version; then
|
||||||
cat <<\_ACEOF
|
cat <<\_ACEOF
|
||||||
repmgr configure 5.4.0
|
repmgr configure 5.3.3
|
||||||
generated by GNU Autoconf 2.69
|
generated by GNU Autoconf 2.69
|
||||||
|
|
||||||
Copyright (C) 2012 Free Software Foundation, Inc.
|
Copyright (C) 2012 Free Software Foundation, Inc.
|
||||||
This configure script is free software; the Free Software Foundation
|
This configure script is free software; the Free Software Foundation
|
||||||
gives unlimited permission to copy, distribute and modify it.
|
gives unlimited permission to copy, distribute and modify it.
|
||||||
|
|
||||||
Copyright (c) 2010-2021, EnterpriseDB Corporation
|
Copyright (c) 2010-2022, EnterpriseDB Corporation
|
||||||
_ACEOF
|
_ACEOF
|
||||||
exit
|
exit
|
||||||
fi
|
fi
|
||||||
@@ -1335,7 +1335,7 @@ cat >config.log <<_ACEOF
|
|||||||
This file contains any messages produced by compilers while
|
This file contains any messages produced by compilers while
|
||||||
running configure, to aid debugging if configure makes a mistake.
|
running configure, to aid debugging if configure makes a mistake.
|
||||||
|
|
||||||
It was created by repmgr $as_me 5.4.0, which was
|
It was created by repmgr $as_me 5.3.3, which was
|
||||||
generated by GNU Autoconf 2.69. Invocation command line was
|
generated by GNU Autoconf 2.69. Invocation command line was
|
||||||
|
|
||||||
$ $0 $@
|
$ $0 $@
|
||||||
@@ -2487,7 +2487,7 @@ cat >>$CONFIG_STATUS <<\_ACEOF || ac_write_fail=1
|
|||||||
# report actual input values of CONFIG_FILES etc. instead of their
|
# report actual input values of CONFIG_FILES etc. instead of their
|
||||||
# values after options handling.
|
# values after options handling.
|
||||||
ac_log="
|
ac_log="
|
||||||
This file was extended by repmgr $as_me 5.4.0, which was
|
This file was extended by repmgr $as_me 5.3.3, which was
|
||||||
generated by GNU Autoconf 2.69. Invocation command line was
|
generated by GNU Autoconf 2.69. Invocation command line was
|
||||||
|
|
||||||
CONFIG_FILES = $CONFIG_FILES
|
CONFIG_FILES = $CONFIG_FILES
|
||||||
@@ -2550,7 +2550,7 @@ _ACEOF
|
|||||||
cat >>$CONFIG_STATUS <<_ACEOF || ac_write_fail=1
|
cat >>$CONFIG_STATUS <<_ACEOF || ac_write_fail=1
|
||||||
ac_cs_config="`$as_echo "$ac_configure_args" | sed 's/^ //; s/[\\""\`\$]/\\\\&/g'`"
|
ac_cs_config="`$as_echo "$ac_configure_args" | sed 's/^ //; s/[\\""\`\$]/\\\\&/g'`"
|
||||||
ac_cs_version="\\
|
ac_cs_version="\\
|
||||||
repmgr config.status 5.4.0
|
repmgr config.status 5.3.3
|
||||||
configured by $0, generated by GNU Autoconf 2.69,
|
configured by $0, generated by GNU Autoconf 2.69,
|
||||||
with options \\"\$ac_cs_config\\"
|
with options \\"\$ac_cs_config\\"
|
||||||
|
|
||||||
|
|||||||
26
configure.in
26
configure.in
@@ -1,8 +1,8 @@
|
|||||||
AC_INIT([repmgr],[5.4.1],[repmgr@googlegroups.com],[repmgr],[https://www.repmgr.org/])
|
AC_INIT([repmgr], [5.3.3], [repmgr@googlegroups.com], [repmgr], [https://repmgr.org/])
|
||||||
|
|
||||||
AC_COPYRIGHT([Copyright (c) 2010-2021, EnterpriseDB Corporation])
|
AC_COPYRIGHT([Copyright (c) 2010-2022, EnterpriseDB Corporation])
|
||||||
|
|
||||||
AC_CONFIG_HEADERS([config.h])
|
AC_CONFIG_HEADER(config.h)
|
||||||
|
|
||||||
AC_ARG_VAR([PG_CONFIG], [Location to find pg_config for target PostgreSQL (default PATH)])
|
AC_ARG_VAR([PG_CONFIG], [Location to find pg_config for target PostgreSQL (default PATH)])
|
||||||
|
|
||||||
@@ -60,7 +60,6 @@ AC_SUBST(vpath_build)
|
|||||||
AC_CHECK_PROG(HAVE_GNUSED,gnused,yes,no)
|
AC_CHECK_PROG(HAVE_GNUSED,gnused,yes,no)
|
||||||
AC_CHECK_PROG(HAVE_GSED,gsed,yes,no)
|
AC_CHECK_PROG(HAVE_GSED,gsed,yes,no)
|
||||||
AC_CHECK_PROG(HAVE_SED,sed,yes,no)
|
AC_CHECK_PROG(HAVE_SED,sed,yes,no)
|
||||||
AC_CHECK_PROG(HAVE_FLEX,flex,yes,no)
|
|
||||||
|
|
||||||
if test "$HAVE_GNUSED" = yes; then
|
if test "$HAVE_GNUSED" = yes; then
|
||||||
SED=gnused
|
SED=gnused
|
||||||
@@ -73,25 +72,6 @@ else
|
|||||||
fi
|
fi
|
||||||
AC_SUBST(SED)
|
AC_SUBST(SED)
|
||||||
|
|
||||||
AS_IF([test x"$HAVE_FLEX" != x"yes"], AC_MSG_ERROR([flex should be installed first]))
|
|
||||||
|
|
||||||
#Checking libraries
|
|
||||||
GENERIC_LIB_FAILED_MSG="library should be installed"
|
|
||||||
|
|
||||||
AC_CHECK_LIB(selinux, is_selinux_enabled, [],
|
|
||||||
[AC_MSG_ERROR(['selinux' $GENERIC_LIB_FAILED_MSG])])
|
|
||||||
|
|
||||||
AC_CHECK_LIB(lz4, LZ4_compress_default, [],
|
|
||||||
[AC_MSG_ERROR(['Z4' $GENERIC_LIB_FAILED_MSG])])
|
|
||||||
|
|
||||||
AC_CHECK_LIB(xslt, xsltCleanupGlobals, [],
|
|
||||||
[AC_MSG_ERROR(['xslt' $GENERIC_LIB_FAILED_MSG])])
|
|
||||||
|
|
||||||
AC_CHECK_LIB(pam, pam_start, [],
|
|
||||||
[AC_MSG_ERROR(['pam' $GENERIC_LIB_FAILED_MSG])])
|
|
||||||
|
|
||||||
AC_CHECK_LIB(gssapi_krb5, gss_init_sec_context, [],
|
|
||||||
[AC_MSG_ERROR([gssapi_krb5 $GENERIC_LIB_FAILED_MSG])])
|
|
||||||
|
|
||||||
AC_CONFIG_FILES([Makefile])
|
AC_CONFIG_FILES([Makefile])
|
||||||
AC_CONFIG_FILES([Makefile.global])
|
AC_CONFIG_FILES([Makefile.global])
|
||||||
|
|||||||
@@ -16,44 +16,8 @@
|
|||||||
</para>
|
</para>
|
||||||
|
|
||||||
<!-- remember to update the release date in ../repmgr_version.h.in -->
|
<!-- remember to update the release date in ../repmgr_version.h.in -->
|
||||||
<sect1 id="release-5.4.1">
|
|
||||||
<title id="release-current">Release 5.4.1</title>
|
|
||||||
<para><emphasis>Tue 04 July, 2023</emphasis></para>
|
|
||||||
<para>
|
|
||||||
&repmgr; 5.4.1 is a minor release providing a fix for witness metadata update
|
|
||||||
</para>
|
|
||||||
<sect2>
|
|
||||||
<title>Bug fixes</title>
|
|
||||||
<para>
|
|
||||||
<itemizedlist>
|
|
||||||
<listitem>
|
|
||||||
<para>
|
|
||||||
&repmgrd;: ensure witness node metadata is updated if the primary
|
|
||||||
node changed while the witness &repmgrd; was not running.
|
|
||||||
</para>
|
|
||||||
</listitem>
|
|
||||||
</itemizedlist>
|
|
||||||
</para>
|
|
||||||
</sect2>
|
|
||||||
</sect1>
|
|
||||||
|
|
||||||
<sect1 id="release-5.4.0">
|
|
||||||
<title>Release 5.4.0</title>
|
|
||||||
<para><emphasis>Thu 15 March, 2023</emphasis></para>
|
|
||||||
<para>
|
|
||||||
&repmgr; 5.4.0 is a major release.
|
|
||||||
</para>
|
|
||||||
<para>
|
|
||||||
This release provides support for cloning standbys using backups taken with <ulink url="http://www.pgbarman.org">barman</ulink>
|
|
||||||
with the use of <ulink url="https://github.com/EnterpriseDB/pg-backup-api">pg-backup-api</ulink>.
|
|
||||||
</para>
|
|
||||||
<para>
|
|
||||||
Minor fixes to the documentation.
|
|
||||||
</para>
|
|
||||||
</sect1>
|
|
||||||
|
|
||||||
<sect1 id="release-5.3.3">
|
<sect1 id="release-5.3.3">
|
||||||
<title>Release 5.3.3</title>
|
<title id="release-current">Release 5.3.3</title>
|
||||||
<para><emphasis>Mon 17 October, 2022</emphasis></para>
|
<para><emphasis>Mon 17 October, 2022</emphasis></para>
|
||||||
<para>
|
<para>
|
||||||
&repmgr; 5.3.3 is a minor release providing support for
|
&repmgr; 5.3.3 is a minor release providing support for
|
||||||
@@ -279,7 +243,8 @@
|
|||||||
risk of clashes with other shared libraries.
|
risk of clashes with other shared libraries.
|
||||||
</para>
|
</para>
|
||||||
<para>
|
<para>
|
||||||
This does not affect user-facing SQL functions. Howe
|
This does not affect user-facing SQL functions. However an upgrade
|
||||||
|
of the installed extension version is required.
|
||||||
</para>
|
</para>
|
||||||
</listitem>
|
</listitem>
|
||||||
|
|
||||||
|
|||||||
@@ -225,109 +225,6 @@ description = "Main cluster"
|
|||||||
</note>
|
</note>
|
||||||
|
|
||||||
</sect2>
|
</sect2>
|
||||||
|
|
||||||
<sect2 id="cloning-from-barman-pg_backupapi-mode" xreflabel="Using Barman through its API (pg-backup-api)">
|
|
||||||
<title>Using Barman through its API (pg-backup-api)</title>
|
|
||||||
<indexterm>
|
|
||||||
<primary>cloning</primary>
|
|
||||||
<secondary>pg-backup-api</secondary>
|
|
||||||
</indexterm>
|
|
||||||
|
|
||||||
<para>
|
|
||||||
You can find information on how to install and setup pg-backup-api in
|
|
||||||
<ulink url="https://www.enterprisedb.com/docs/supported-open-source/barman/pg-backup-api/">the pg-backup-api
|
|
||||||
documentation</ulink>.
|
|
||||||
</para>
|
|
||||||
|
|
||||||
<para>
|
|
||||||
This mode (`pg-backupapi`) was introduced in v5.4.0 as a way to further integrate with Barman letting Barman
|
|
||||||
handle the restore. This also reduces the ssh keys that need to share between the backup and postgres nodes.
|
|
||||||
As long as you have access to the API service by HTTP calls, you could perform recoveries right away.
|
|
||||||
You just need to instruct Barman through the API which backup you need and on which node the backup needs to
|
|
||||||
to be restored on.
|
|
||||||
</para>
|
|
||||||
|
|
||||||
<para>
|
|
||||||
In order to enable <literal>pg_backupapi mode</literal> support for <command>repmgr standby clone</command>,
|
|
||||||
you need the following lines in repmgr.conf:
|
|
||||||
<itemizedlist spacing="compact" mark="bullet">
|
|
||||||
<listitem><para>pg_backupapi_host: Where pg-backup-api is hosted</para></listitem>
|
|
||||||
<listitem><para>pg_backupapi_node_name: Name of the server as understood by Barman</para></listitem>
|
|
||||||
<listitem><para>pg_backupapi_remote_ssh_command: How Barman will be connecting as to the node</para></listitem>
|
|
||||||
<listitem><para>pg_backupapi_backup_id: ID of the existing backup you need to restore</para></listitem>
|
|
||||||
</itemizedlist>
|
|
||||||
|
|
||||||
This is an example of how repmgr.conf would look like:
|
|
||||||
|
|
||||||
<programlisting>
|
|
||||||
pg_backupapi_host = '192.168.122.154'
|
|
||||||
pg_backupapi_node_name = 'burrito'
|
|
||||||
pg_backupapi_remote_ssh_command = 'ssh john_doe@192.168.122.1'
|
|
||||||
pg_backupapi_backup_id = '20230223T093201'
|
|
||||||
</programlisting>
|
|
||||||
</para>
|
|
||||||
|
|
||||||
<para>
|
|
||||||
<literal>pg_backupapi_host</literal> is the variable name that enables this mode, and when you set it,
|
|
||||||
all the rest of the above variables are required. Also, remember that this service is just an interface
|
|
||||||
between Barman and repmgr, hence if something fails during a recovery, you should check Barman's logs upon
|
|
||||||
why the process couldn't finish properly.
|
|
||||||
</para>
|
|
||||||
|
|
||||||
<note>
|
|
||||||
<simpara>
|
|
||||||
Despite in Barman you can define shortcuts like "lastest" or "oldest", they are not supported for the
|
|
||||||
time being in pg-backup-api. These shortcuts will be supported in a future release.
|
|
||||||
</simpara>
|
|
||||||
</note>
|
|
||||||
|
|
||||||
<para>
|
|
||||||
This is a real example of repmgr's output cloning with the API. Note that during this operation, we stopped
|
|
||||||
the service for a little while and repmgr had to retry but that doesn't affect the final outcome. The primary
|
|
||||||
is listening on localhost's port 6001:
|
|
||||||
|
|
||||||
<programlisting>
|
|
||||||
$ repmgr -f ~/nodes/node_3/repmgr.conf standby clone -U repmgr -p 6001 -h localhost
|
|
||||||
NOTICE: destination directory "/home/mario/nodes/node_3/data" provided
|
|
||||||
INFO: Attempting to use `pg_backupapi` new restore mode
|
|
||||||
INFO: connecting to source node
|
|
||||||
DETAIL: connection string is: user=repmgr port=6001 host=localhost
|
|
||||||
DETAIL: current installation size is 8541 MB
|
|
||||||
DEBUG: 1 node records returned by source node
|
|
||||||
DEBUG: connecting to: "user=repmgr dbname=repmgr host=localhost port=6001 connect_timeout=2 fallback_application_name=repmgr options=-csearch_path="
|
|
||||||
DEBUG: upstream_node_id determined as 1
|
|
||||||
INFO: Attempting to use `pg_backupapi` new restore mode
|
|
||||||
INFO: replication slot usage not requested; no replication slot will be set up for this standby
|
|
||||||
NOTICE: starting backup (using pg_backupapi)...
|
|
||||||
INFO: Success creating the task: operation id '20230309T150647'
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
Incorrect reply received for that operation ID.
|
|
||||||
INFO: Retrying...
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status IN_PROGRESS
|
|
||||||
INFO: status DONE
|
|
||||||
NOTICE: standby clone (from pg_backupapi) complete
|
|
||||||
NOTICE: you can now start your PostgreSQL server
|
|
||||||
HINT: for example: pg_ctl -D /home/mario/nodes/node_3/data start
|
|
||||||
HINT: after starting the server, you need to register this standby with "repmgr standby register"
|
|
||||||
</programlisting>
|
|
||||||
|
|
||||||
</para>
|
|
||||||
</sect2> <!--END cloning-from-barman-pg_backupapi-mode !-->
|
|
||||||
</sect1>
|
</sect1>
|
||||||
|
|
||||||
<sect1 id="cloning-replication-slots" xreflabel="Cloning and replication slots">
|
<sect1 id="cloning-replication-slots" xreflabel="Cloning and replication slots">
|
||||||
|
|||||||
@@ -10,8 +10,8 @@
|
|||||||
<note>
|
<note>
|
||||||
<simpara>
|
<simpara>
|
||||||
This section documents a subset of optional configuration settings; for a full
|
This section documents a subset of optional configuration settings; for a full
|
||||||
and annotated view of all configuration options see the
|
for a full and annotated view of all configuration options see the
|
||||||
<ulink url="https://raw.githubusercontent.com/EnterpriseDB/repmgr/master/repmgr.conf.sample">sample repmgr.conf file</ulink>
|
see the <ulink url="https://raw.githubusercontent.com/EnterpriseDB/repmgr/master/repmgr.conf.sample">sample repmgr.conf file</ulink>
|
||||||
</simpara>
|
</simpara>
|
||||||
</note>
|
</note>
|
||||||
|
|
||||||
|
|||||||
@@ -14,7 +14,7 @@
|
|||||||
</para>
|
</para>
|
||||||
|
|
||||||
<para>
|
<para>
|
||||||
&repmgr; &repmgrversion; is compatible with all PostgreSQL versions from 10. See
|
&repmgr; &repmgrversion; is compatible with all PostgreSQL versions from 9.4. See
|
||||||
section <link linkend="install-compatibility-matrix">&repmgr; compatibility matrix</link>
|
section <link linkend="install-compatibility-matrix">&repmgr; compatibility matrix</link>
|
||||||
for an overview of version compatibility.
|
for an overview of version compatibility.
|
||||||
</para>
|
</para>
|
||||||
@@ -115,24 +115,6 @@
|
|||||||
</thead>
|
</thead>
|
||||||
|
|
||||||
<tbody>
|
<tbody>
|
||||||
<row>
|
|
||||||
<entry>
|
|
||||||
&repmgr; 5.4
|
|
||||||
</entry>
|
|
||||||
<entry>
|
|
||||||
YES
|
|
||||||
</entry>
|
|
||||||
<entry>
|
|
||||||
<link linkend="release-current">&repmgrversion;</link> (&releasedate;)
|
|
||||||
</entry>
|
|
||||||
<entry>
|
|
||||||
10, 11, 12, 13, 14, 15, 16
|
|
||||||
</entry>
|
|
||||||
<entry>
|
|
||||||
|
|
||||||
</entry>
|
|
||||||
</row>
|
|
||||||
|
|
||||||
<row>
|
<row>
|
||||||
<entry>
|
<entry>
|
||||||
&repmgr; 5.3
|
&repmgr; 5.3
|
||||||
|
|||||||
@@ -73,16 +73,16 @@
|
|||||||
</varlistentry>
|
</varlistentry>
|
||||||
|
|
||||||
<varlistentry>
|
<varlistentry>
|
||||||
<term><option>--force-rewind</option></term>
|
<term><option>--force-rewind[=/path/to/pg_rewind]</option></term>
|
||||||
<listitem>
|
<listitem>
|
||||||
<para>
|
<para>
|
||||||
Execute <application>pg_rewind</application>.
|
Execute <application>pg_rewind</application>.
|
||||||
</para>
|
</para>
|
||||||
<para>
|
<para>
|
||||||
See <xref linkend="repmgr-node-rejoin-pg-rewind"/> for more details on using
|
It is only necessary to provide the <application>pg_rewind</application> path
|
||||||
<application>pg_rewind</application>.
|
if using PostgreSQL 9.4, and <application>pg_rewind</application>
|
||||||
|
is not installed in the PostgreSQL <filename>bin</filename> directory.
|
||||||
</para>
|
</para>
|
||||||
|
|
||||||
</listitem>
|
</listitem>
|
||||||
</varlistentry>
|
</varlistentry>
|
||||||
|
|
||||||
@@ -261,6 +261,8 @@
|
|||||||
<para>
|
<para>
|
||||||
<command>repmgr node rejoin</command> can optionally use <command>pg_rewind</command> to re-integrate a
|
<command>repmgr node rejoin</command> can optionally use <command>pg_rewind</command> to re-integrate a
|
||||||
node which has diverged from the rest of the cluster, typically a failed primary.
|
node which has diverged from the rest of the cluster, typically a failed primary.
|
||||||
|
<command>pg_rewind</command> is available in PostgreSQL 9.5 and later as part of the core distribution,
|
||||||
|
and can be installed from external sources for PostgreSQL 9.4.
|
||||||
</para>
|
</para>
|
||||||
<note>
|
<note>
|
||||||
<para>
|
<para>
|
||||||
@@ -384,29 +386,6 @@
|
|||||||
DETAIL: node 2 is now attached to node 3</programlisting>
|
DETAIL: node 2 is now attached to node 3</programlisting>
|
||||||
</para>
|
</para>
|
||||||
</refsect2>
|
</refsect2>
|
||||||
|
|
||||||
<refsect2 id="repmgr-node-rejoin-postgresql-94" xreflabel="pg_rewind and PostgreSQL 9.4">
|
|
||||||
|
|
||||||
<title><command>pg_rewind</command> and PostgreSQL 9.4</title>
|
|
||||||
|
|
||||||
<indexterm>
|
|
||||||
<primary>pg_rewind</primary>
|
|
||||||
<secondary>PostgreSQL 9.4</secondary>
|
|
||||||
</indexterm>
|
|
||||||
|
|
||||||
<para>
|
|
||||||
<application>pg_rewind</application> is available in PostgreSQL 9.5 and later as part of the core distribution.
|
|
||||||
Users of PostgreSQL 9.4 will need to manually install it; the source code is available here:
|
|
||||||
<ulink url="https://github.com/vmware/pg_rewind">https://github.com/vmware/pg_rewind</ulink>.
|
|
||||||
If the <application>pg_rewind</application>
|
|
||||||
binary is not installed in the PostgreSQL <filename>bin</filename> directory, provide
|
|
||||||
its full path on the demotion candidate with <option>--force-rewind</option>.
|
|
||||||
</para>
|
|
||||||
<para>
|
|
||||||
Note that building the 9.4 version of <application>pg_rewind</application> requires the PostgreSQL
|
|
||||||
source code.
|
|
||||||
</para>
|
|
||||||
</refsect2>
|
|
||||||
</refsect1>
|
</refsect1>
|
||||||
|
|
||||||
<refsect1 id="repmgr-node-rejoin-caveats" xreflabel="Caveats">
|
<refsect1 id="repmgr-node-rejoin-caveats" xreflabel="Caveats">
|
||||||
@@ -499,7 +478,7 @@
|
|||||||
<refsect1>
|
<refsect1>
|
||||||
<title>See also</title>
|
<title>See also</title>
|
||||||
<para>
|
<para>
|
||||||
<xref linkend="repmgr-standby-follow"/>, <xref linkend="repmgr-standby-switchover"/>
|
<xref linkend="repmgr-standby-follow"/>
|
||||||
</para>
|
</para>
|
||||||
</refsect1>
|
</refsect1>
|
||||||
</refentry>
|
</refentry>
|
||||||
|
|||||||
@@ -154,12 +154,9 @@
|
|||||||
<para>
|
<para>
|
||||||
Use <application>pg_rewind</application> to reintegrate the old primary if necessary
|
Use <application>pg_rewind</application> to reintegrate the old primary if necessary
|
||||||
(and the prerequisites for using <application>pg_rewind</application> are met).
|
(and the prerequisites for using <application>pg_rewind</application> are met).
|
||||||
</para>
|
|
||||||
<para>
|
|
||||||
If using PostgreSQL 9.4, and the <application>pg_rewind</application>
|
If using PostgreSQL 9.4, and the <application>pg_rewind</application>
|
||||||
binary is not installed in the PostgreSQL <filename>bin</filename> directory,
|
binary is not installed in the PostgreSQL <filename>bin</filename> directory,
|
||||||
provide its full path. For more details see also <xref linkend="switchover-pg-rewind"/>
|
provide its full path. For more details see also <xref linkend="switchover-pg-rewind"/>.
|
||||||
and <xref linkend="repmgr-node-rejoin-pg-rewind"/>.
|
|
||||||
</para>
|
</para>
|
||||||
</listitem>
|
</listitem>
|
||||||
</varlistentry>
|
</varlistentry>
|
||||||
|
|||||||
@@ -26,7 +26,7 @@
|
|||||||
<abstract>
|
<abstract>
|
||||||
<para>
|
<para>
|
||||||
This is the official documentation of &repmgr; &repmgrversion; for
|
This is the official documentation of &repmgr; &repmgrversion; for
|
||||||
use with PostgreSQL 10 - PostgreSQL 16.
|
use with PostgreSQL 9.4 - PostgreSQL 15.
|
||||||
</para>
|
</para>
|
||||||
<para>
|
<para>
|
||||||
&repmgr; is being continually developed and we strongly recommend using the
|
&repmgr; is being continually developed and we strongly recommend using the
|
||||||
|
|||||||
@@ -29,7 +29,7 @@
|
|||||||
|
|
||||||
<listitem>
|
<listitem>
|
||||||
<simpara>
|
<simpara>
|
||||||
option to execute custom scripts ("<link linkend="event-notifications">event notifications</link>")
|
option to execute custom scripts ("<link linkend="event-notifications">event notifications</link>
|
||||||
at different points in the failover sequence
|
at different points in the failover sequence
|
||||||
</simpara>
|
</simpara>
|
||||||
</listitem>
|
</listitem>
|
||||||
|
|||||||
@@ -242,12 +242,21 @@
|
|||||||
</simpara>
|
</simpara>
|
||||||
</note>
|
</note>
|
||||||
<para>
|
<para>
|
||||||
For more details on <application>pg_rewind</application>, see section <xref linkend="repmgr-node-rejoin-pg-rewind"/>
|
For more details on <application>pg_rewind</application>, see:
|
||||||
in the <link linkend="repmgr-node-rejoin"><command>repmgr node rejoin</command></link> documentation and
|
|
||||||
the PostgreSQL documentation at
|
|
||||||
<ulink url="https://www.postgresql.org/docs/current/app-pgrewind.html">https://www.postgresql.org/docs/current/app-pgrewind.html</ulink>.
|
<ulink url="https://www.postgresql.org/docs/current/app-pgrewind.html">https://www.postgresql.org/docs/current/app-pgrewind.html</ulink>.
|
||||||
</para>
|
</para>
|
||||||
|
<para>
|
||||||
|
<application>pg_rewind</application> has been part of the core PostgreSQL distribution since
|
||||||
|
version 9.5. Users of PostgreSQL 9.4 will need to manually install it; the source code is available here:
|
||||||
|
<ulink url="https://github.com/vmware/pg_rewind">https://github.com/vmware/pg_rewind</ulink>.
|
||||||
|
If the <application>pg_rewind</application>
|
||||||
|
binary is not installed in the PostgreSQL <filename>bin</filename> directory, provide
|
||||||
|
its full path on the demotion candidate with <option>--force-rewind</option>.
|
||||||
|
</para>
|
||||||
|
<para>
|
||||||
|
Note that building the 9.4 version of <application>pg_rewind</application> requires the PostgreSQL
|
||||||
|
source code.
|
||||||
|
</para>
|
||||||
</sect2>
|
</sect2>
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -49,6 +49,5 @@
|
|||||||
#define ERR_NODE_STATUS 25
|
#define ERR_NODE_STATUS 25
|
||||||
#define ERR_REPMGRD_PAUSE 26
|
#define ERR_REPMGRD_PAUSE 26
|
||||||
#define ERR_REPMGRD_SERVICE 27
|
#define ERR_REPMGRD_SERVICE 27
|
||||||
#define ERR_PGBACKUPAPI_SERVICE 28
|
|
||||||
|
|
||||||
#endif /* _ERRCODE_H_ */
|
#endif /* _ERRCODE_H_ */
|
||||||
|
|||||||
147
pgbackupapi.c
147
pgbackupapi.c
@@ -1,147 +0,0 @@
|
|||||||
/*
|
|
||||||
* pgbackupapi.c
|
|
||||||
* Copyright (c) EnterpriseDB Corporation, 2010-2021
|
|
||||||
*
|
|
||||||
* This program is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* This program is distributed in the hope that it will be useful,
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
* GNU General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#include <string.h>
|
|
||||||
|
|
||||||
#include <curl/curl.h>
|
|
||||||
#include <json-c/json.h>
|
|
||||||
|
|
||||||
#include "repmgr.h"
|
|
||||||
#include "pgbackupapi.h"
|
|
||||||
|
|
||||||
|
|
||||||
size_t receive_operations_cb(void *content, size_t size, size_t nmemb, char *buffer) {
|
|
||||||
short int max_chars_to_copy = MAX_BUFFER_LENGTH -2;
|
|
||||||
short int i = 0;
|
|
||||||
int operation_length = 0;
|
|
||||||
json_object *value;
|
|
||||||
|
|
||||||
json_object *root = json_tokener_parse(content);
|
|
||||||
json_object *operations = json_object_object_get(root, "operations");
|
|
||||||
|
|
||||||
operation_length = strlen(json_object_get_string(operations));
|
|
||||||
if (operation_length < max_chars_to_copy) {
|
|
||||||
max_chars_to_copy = operation_length;
|
|
||||||
}
|
|
||||||
|
|
||||||
strncpy(buffer, json_object_get_string(operations), max_chars_to_copy);
|
|
||||||
|
|
||||||
fprintf(stdout, "Success! The following operations were found\n");
|
|
||||||
for (i=0; i<json_object_array_length(operations); i++) {
|
|
||||||
value = json_object_array_get_idx(operations, i);
|
|
||||||
printf("%s\n", json_object_get_string(value));
|
|
||||||
}
|
|
||||||
return size * nmemb;
|
|
||||||
}
|
|
||||||
|
|
||||||
char * define_base_url(operation_task *task) {
|
|
||||||
char *format = "http://%s:7480/servers/%s/operations";
|
|
||||||
char *url = malloc(MAX_BUFFER_LENGTH);
|
|
||||||
|
|
||||||
snprintf(url, MAX_BUFFER_LENGTH-1, format, task->host, task->node_name);
|
|
||||||
|
|
||||||
//`url` is freed on the function that called this
|
|
||||||
return url;
|
|
||||||
}
|
|
||||||
|
|
||||||
CURLcode get_operations_on_server(CURL *curl, operation_task *task) {
|
|
||||||
char buffer[MAX_BUFFER_LENGTH];
|
|
||||||
char *url = define_base_url(task);
|
|
||||||
CURLcode ret;
|
|
||||||
|
|
||||||
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, receive_operations_cb);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_WRITEDATA, &buffer);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_URL, url);
|
|
||||||
|
|
||||||
ret = curl_easy_perform(curl);
|
|
||||||
free(url);
|
|
||||||
|
|
||||||
return ret;
|
|
||||||
}
|
|
||||||
|
|
||||||
size_t receive_operation_id(void *content, size_t size, size_t nmemb, char *buffer) {
|
|
||||||
json_object *root = json_tokener_parse(content);
|
|
||||||
json_object *operation = json_object_object_get(root, "operation_id");
|
|
||||||
|
|
||||||
if (operation != NULL) {
|
|
||||||
strncpy(buffer, json_object_get_string(operation), MAX_BUFFER_LENGTH-2);
|
|
||||||
}
|
|
||||||
|
|
||||||
return size * nmemb;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
CURLcode create_new_task(CURL *curl, operation_task *task) {
|
|
||||||
PQExpBufferData payload;
|
|
||||||
char *url = define_base_url(task);
|
|
||||||
CURLcode ret;
|
|
||||||
json_object *root = json_object_new_object();
|
|
||||||
struct curl_slist *chunk = NULL;
|
|
||||||
|
|
||||||
json_object_object_add(root, "operation_type", json_object_new_string(task->operation_type));
|
|
||||||
json_object_object_add(root, "backup_id", json_object_new_string(task->backup_id));
|
|
||||||
json_object_object_add(root, "remote_ssh_command", json_object_new_string(task->remote_ssh_command));
|
|
||||||
json_object_object_add(root, "destination_directory", json_object_new_string(task->destination_directory));
|
|
||||||
|
|
||||||
initPQExpBuffer(&payload);
|
|
||||||
appendPQExpBufferStr(&payload, json_object_to_json_string(root));
|
|
||||||
|
|
||||||
chunk = curl_slist_append(chunk, "Content-type: application/json");
|
|
||||||
curl_easy_setopt(curl, CURLOPT_HTTPHEADER, chunk);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_URL, url);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_POSTFIELDS, payload.data);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_FAILONERROR, 1L);
|
|
||||||
//curl_easy_setopt(curl, CURLOPT_VERBOSE, 1L);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, receive_operation_id);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_WRITEDATA, task->operation_id);
|
|
||||||
ret = curl_easy_perform(curl);
|
|
||||||
free(url);
|
|
||||||
termPQExpBuffer(&payload);
|
|
||||||
|
|
||||||
return ret;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
size_t receive_operation_status(void *content, size_t size, size_t nmemb, char *buffer) {
|
|
||||||
json_object *root = json_tokener_parse(content);
|
|
||||||
json_object *status = json_object_object_get(root, "status");
|
|
||||||
if (status != NULL) {
|
|
||||||
strncpy(buffer, json_object_get_string(status), MAX_BUFFER_LENGTH-2);
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
fprintf(stderr, "Incorrect reply received for that operation ID.\n");
|
|
||||||
strcpy(buffer, "\0");
|
|
||||||
}
|
|
||||||
return size * nmemb;
|
|
||||||
}
|
|
||||||
|
|
||||||
CURLcode get_status_of_operation(CURL *curl, operation_task *task) {
|
|
||||||
CURLcode ret;
|
|
||||||
char *url = define_base_url(task);
|
|
||||||
|
|
||||||
strcat(url, "/");
|
|
||||||
strcat(url, task->operation_id);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_URL, url);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, receive_operation_status);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_WRITEDATA, task->operation_status);
|
|
||||||
|
|
||||||
ret = curl_easy_perform(curl);
|
|
||||||
free(url);
|
|
||||||
|
|
||||||
return ret;
|
|
||||||
}
|
|
||||||
@@ -1,46 +0,0 @@
|
|||||||
/*
|
|
||||||
* pgbackupapi.h
|
|
||||||
* Copyright (c) EnterpriseDB Corporation, 2010-2021
|
|
||||||
*
|
|
||||||
* This program is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* This program is distributed in the hope that it will be useful,
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
* GNU General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
#include <curl/curl.h>
|
|
||||||
#include <json-c/json.h>
|
|
||||||
|
|
||||||
typedef struct operation_task {
|
|
||||||
char *backup_id;
|
|
||||||
char *destination_directory;
|
|
||||||
char *operation_type;
|
|
||||||
char *operation_id;
|
|
||||||
char *operation_status;
|
|
||||||
char *remote_ssh_command;
|
|
||||||
char *host;
|
|
||||||
char *node_name;
|
|
||||||
} operation_task;
|
|
||||||
|
|
||||||
//Default simplebuffer size in most of operations
|
|
||||||
#define MAX_BUFFER_LENGTH 72
|
|
||||||
|
|
||||||
//Callbacks to send/receive data from pg-backup-api endpoints
|
|
||||||
size_t receive_operations_cb(void *content, size_t size, size_t nmemb, char *buffer);
|
|
||||||
size_t receive_operation_id(void *content, size_t size, size_t nmemb, char *buffer);
|
|
||||||
size_t receive_operation_status(void *content, size_t size, size_t nmemb, char *buffer);
|
|
||||||
|
|
||||||
//Functions that implement the logic and know what to do and how to comunnicate wuth the API
|
|
||||||
CURLcode get_operations_on_server(CURL *curl, operation_task *task);
|
|
||||||
CURLcode create_new_task(CURL *curl, operation_task *task);
|
|
||||||
CURLcode get_status_of_operation(CURL *curl, operation_task *task);
|
|
||||||
|
|
||||||
//Helper to make simpler to read the handler where we set the URL
|
|
||||||
char * define_base_url(operation_task *task);
|
|
||||||
@@ -1,2 +0,0 @@
|
|||||||
-- complain if script is sourced in psql, rather than via CREAT EXTENSION
|
|
||||||
\echo Use "CREATE EXTENSION repmgr" to load this file. \quit
|
|
||||||
192
repmgr--5.4.sql
192
repmgr--5.4.sql
@@ -1,192 +0,0 @@
|
|||||||
-- complain if script is sourced in psql, rather than via CREATE EXTENSION
|
|
||||||
\echo Use "CREATE EXTENSION repmgr" to load this file. \quit
|
|
||||||
|
|
||||||
CREATE TABLE repmgr.nodes (
|
|
||||||
node_id INTEGER PRIMARY KEY,
|
|
||||||
upstream_node_id INTEGER NULL REFERENCES nodes (node_id) DEFERRABLE,
|
|
||||||
active BOOLEAN NOT NULL DEFAULT TRUE,
|
|
||||||
node_name TEXT NOT NULL,
|
|
||||||
type TEXT NOT NULL CHECK (type IN('primary','standby','witness','bdr')),
|
|
||||||
location TEXT NOT NULL DEFAULT 'default',
|
|
||||||
priority INT NOT NULL DEFAULT 100,
|
|
||||||
conninfo TEXT NOT NULL,
|
|
||||||
repluser VARCHAR(63) NOT NULL,
|
|
||||||
slot_name TEXT NULL,
|
|
||||||
config_file TEXT NOT NULL
|
|
||||||
);
|
|
||||||
|
|
||||||
SELECT pg_catalog.pg_extension_config_dump('repmgr.nodes', '');
|
|
||||||
|
|
||||||
CREATE TABLE repmgr.events (
|
|
||||||
node_id INTEGER NOT NULL,
|
|
||||||
event TEXT NOT NULL,
|
|
||||||
successful BOOLEAN NOT NULL DEFAULT TRUE,
|
|
||||||
event_timestamp TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
||||||
details TEXT NULL
|
|
||||||
);
|
|
||||||
|
|
||||||
SELECT pg_catalog.pg_extension_config_dump('repmgr.events', '');
|
|
||||||
|
|
||||||
CREATE TABLE repmgr.monitoring_history (
|
|
||||||
primary_node_id INTEGER NOT NULL,
|
|
||||||
standby_node_id INTEGER NOT NULL,
|
|
||||||
last_monitor_time TIMESTAMP WITH TIME ZONE NOT NULL,
|
|
||||||
last_apply_time TIMESTAMP WITH TIME ZONE,
|
|
||||||
last_wal_primary_location PG_LSN NOT NULL,
|
|
||||||
last_wal_standby_location PG_LSN,
|
|
||||||
replication_lag BIGINT NOT NULL,
|
|
||||||
apply_lag BIGINT NOT NULL
|
|
||||||
);
|
|
||||||
|
|
||||||
CREATE INDEX idx_monitoring_history_time
|
|
||||||
ON repmgr.monitoring_history (last_monitor_time, standby_node_id);
|
|
||||||
|
|
||||||
SELECT pg_catalog.pg_extension_config_dump('repmgr.monitoring_history', '');
|
|
||||||
|
|
||||||
CREATE VIEW repmgr.show_nodes AS
|
|
||||||
SELECT n.node_id,
|
|
||||||
n.node_name,
|
|
||||||
n.active,
|
|
||||||
n.upstream_node_id,
|
|
||||||
un.node_name AS upstream_node_name,
|
|
||||||
n.type,
|
|
||||||
n.priority,
|
|
||||||
n.conninfo
|
|
||||||
FROM repmgr.nodes n
|
|
||||||
LEFT JOIN repmgr.nodes un
|
|
||||||
ON un.node_id = n.upstream_node_id;
|
|
||||||
|
|
||||||
CREATE TABLE repmgr.voting_term (
|
|
||||||
term INT NOT NULL
|
|
||||||
);
|
|
||||||
|
|
||||||
CREATE UNIQUE INDEX voting_term_restrict
|
|
||||||
ON repmgr.voting_term ((TRUE));
|
|
||||||
|
|
||||||
CREATE RULE voting_term_delete AS
|
|
||||||
ON DELETE TO repmgr.voting_term
|
|
||||||
DO INSTEAD NOTHING;
|
|
||||||
|
|
||||||
|
|
||||||
/* ================= */
|
|
||||||
/* repmgrd functions */
|
|
||||||
/* ================= */
|
|
||||||
|
|
||||||
/* monitoring functions */
|
|
||||||
|
|
||||||
CREATE FUNCTION set_local_node_id(INT)
|
|
||||||
RETURNS VOID
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_set_local_node_id'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION get_local_node_id()
|
|
||||||
RETURNS INT
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_get_local_node_id'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION standby_set_last_updated()
|
|
||||||
RETURNS TIMESTAMP WITH TIME ZONE
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_standby_set_last_updated'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION standby_get_last_updated()
|
|
||||||
RETURNS TIMESTAMP WITH TIME ZONE
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_standby_get_last_updated'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION set_upstream_last_seen(INT)
|
|
||||||
RETURNS VOID
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_set_upstream_last_seen'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION get_upstream_last_seen()
|
|
||||||
RETURNS INT
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_get_upstream_last_seen'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION get_upstream_node_id()
|
|
||||||
RETURNS INT
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_get_upstream_node_id'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION set_upstream_node_id(INT)
|
|
||||||
RETURNS VOID
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_set_upstream_node_id'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
/* failover functions */
|
|
||||||
|
|
||||||
CREATE FUNCTION notify_follow_primary(INT)
|
|
||||||
RETURNS VOID
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_notify_follow_primary'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION get_new_primary()
|
|
||||||
RETURNS INT
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_get_new_primary'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION reset_voting_status()
|
|
||||||
RETURNS VOID
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_reset_voting_status'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION get_repmgrd_pid()
|
|
||||||
RETURNS INT
|
|
||||||
AS 'MODULE_PATHNAME', 'get_repmgrd_pid'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION get_repmgrd_pidfile()
|
|
||||||
RETURNS TEXT
|
|
||||||
AS 'MODULE_PATHNAME', 'get_repmgrd_pidfile'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION set_repmgrd_pid(INT, TEXT)
|
|
||||||
RETURNS VOID
|
|
||||||
AS 'MODULE_PATHNAME', 'set_repmgrd_pid'
|
|
||||||
LANGUAGE C CALLED ON NULL INPUT;
|
|
||||||
|
|
||||||
CREATE FUNCTION repmgrd_is_running()
|
|
||||||
RETURNS BOOL
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgrd_is_running'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION repmgrd_pause(BOOL)
|
|
||||||
RETURNS VOID
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgrd_pause'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION repmgrd_is_paused()
|
|
||||||
RETURNS BOOL
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgrd_is_paused'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE FUNCTION get_wal_receiver_pid()
|
|
||||||
RETURNS INT
|
|
||||||
AS 'MODULE_PATHNAME', 'repmgr_get_wal_receiver_pid'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/* views */
|
|
||||||
|
|
||||||
CREATE VIEW repmgr.replication_status AS
|
|
||||||
SELECT m.primary_node_id, m.standby_node_id, n.node_name AS standby_name,
|
|
||||||
n.type AS node_type, n.active, last_monitor_time,
|
|
||||||
CASE WHEN n.type='standby' THEN m.last_wal_primary_location ELSE NULL END AS last_wal_primary_location,
|
|
||||||
m.last_wal_standby_location,
|
|
||||||
CASE WHEN n.type='standby' THEN pg_catalog.pg_size_pretty(m.replication_lag) ELSE NULL END AS replication_lag,
|
|
||||||
CASE WHEN n.type='standby' THEN
|
|
||||||
CASE WHEN replication_lag > 0 THEN age(now(), m.last_apply_time) ELSE '0'::INTERVAL END
|
|
||||||
ELSE NULL
|
|
||||||
END AS replication_time_lag,
|
|
||||||
CASE WHEN n.type='standby' THEN pg_catalog.pg_size_pretty(m.apply_lag) ELSE NULL END AS apply_lag,
|
|
||||||
AGE(NOW(), CASE WHEN pg_catalog.pg_is_in_recovery() THEN repmgr.standby_get_last_updated() ELSE m.last_monitor_time END) AS communication_time_lag
|
|
||||||
FROM repmgr.monitoring_history m
|
|
||||||
JOIN repmgr.nodes n ON m.standby_node_id = n.node_id
|
|
||||||
WHERE (m.standby_node_id, m.last_monitor_time) IN (
|
|
||||||
SELECT m1.standby_node_id, MAX(m1.last_monitor_time)
|
|
||||||
FROM repmgr.monitoring_history m1 GROUP BY 1
|
|
||||||
);
|
|
||||||
|
|
||||||
@@ -21,7 +21,6 @@
|
|||||||
|
|
||||||
#include <sys/stat.h>
|
#include <sys/stat.h>
|
||||||
#include <time.h>
|
#include <time.h>
|
||||||
#include <unistd.h>
|
|
||||||
|
|
||||||
#include "repmgr.h"
|
#include "repmgr.h"
|
||||||
#include "dirutil.h"
|
#include "dirutil.h"
|
||||||
@@ -30,7 +29,7 @@
|
|||||||
|
|
||||||
#include "repmgr-client-global.h"
|
#include "repmgr-client-global.h"
|
||||||
#include "repmgr-action-standby.h"
|
#include "repmgr-action-standby.h"
|
||||||
#include "pgbackupapi.h"
|
|
||||||
|
|
||||||
typedef struct TablespaceDataListCell
|
typedef struct TablespaceDataListCell
|
||||||
{
|
{
|
||||||
@@ -114,7 +113,6 @@ static void check_recovery_type(PGconn *conn);
|
|||||||
static void initialise_direct_clone(t_node_info *local_node_record, t_node_info *upstream_node_record);
|
static void initialise_direct_clone(t_node_info *local_node_record, t_node_info *upstream_node_record);
|
||||||
static int run_basebackup(t_node_info *node_record);
|
static int run_basebackup(t_node_info *node_record);
|
||||||
static int run_file_backup(t_node_info *node_record);
|
static int run_file_backup(t_node_info *node_record);
|
||||||
static int run_pg_backupapi(t_node_info *node_record);
|
|
||||||
|
|
||||||
static void copy_configuration_files(bool delete_after_copy);
|
static void copy_configuration_files(bool delete_after_copy);
|
||||||
|
|
||||||
@@ -689,18 +687,19 @@ do_standby_clone(void)
|
|||||||
exit(SUCCESS);
|
exit(SUCCESS);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (mode != barman)
|
||||||
|
{
|
||||||
|
initialise_direct_clone(&local_node_record, &upstream_node_record);
|
||||||
|
}
|
||||||
|
|
||||||
switch (mode)
|
switch (mode)
|
||||||
{
|
{
|
||||||
case pg_basebackup:
|
case pg_basebackup:
|
||||||
initialise_direct_clone(&local_node_record, &upstream_node_record);
|
|
||||||
log_notice(_("starting backup (using pg_basebackup)..."));
|
log_notice(_("starting backup (using pg_basebackup)..."));
|
||||||
break;
|
break;
|
||||||
case barman:
|
case barman:
|
||||||
log_notice(_("retrieving backup from Barman..."));
|
log_notice(_("retrieving backup from Barman..."));
|
||||||
break;
|
break;
|
||||||
case pg_backupapi:
|
|
||||||
log_notice(_("starting backup (using pg_backupapi)..."));
|
|
||||||
break;
|
|
||||||
default:
|
default:
|
||||||
/* should never reach here */
|
/* should never reach here */
|
||||||
log_error(_("unknown clone mode"));
|
log_error(_("unknown clone mode"));
|
||||||
@@ -722,9 +721,6 @@ do_standby_clone(void)
|
|||||||
case barman:
|
case barman:
|
||||||
r = run_file_backup(&local_node_record);
|
r = run_file_backup(&local_node_record);
|
||||||
break;
|
break;
|
||||||
case pg_backupapi:
|
|
||||||
r = run_pg_backupapi(&local_node_record);
|
|
||||||
break;
|
|
||||||
default:
|
default:
|
||||||
/* should never reach here */
|
/* should never reach here */
|
||||||
log_error(_("unknown clone mode"));
|
log_error(_("unknown clone mode"));
|
||||||
@@ -818,6 +814,7 @@ do_standby_clone(void)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Write the recovery.conf file */
|
/* Write the recovery.conf file */
|
||||||
|
|
||||||
if (create_recovery_file(&local_node_record,
|
if (create_recovery_file(&local_node_record,
|
||||||
&recovery_conninfo,
|
&recovery_conninfo,
|
||||||
source_server_version_num,
|
source_server_version_num,
|
||||||
@@ -849,9 +846,6 @@ do_standby_clone(void)
|
|||||||
case barman:
|
case barman:
|
||||||
log_notice(_("standby clone (from Barman) complete"));
|
log_notice(_("standby clone (from Barman) complete"));
|
||||||
break;
|
break;
|
||||||
case pg_backupapi:
|
|
||||||
log_notice(_("standby clone (from pg_backupapi) complete"));
|
|
||||||
break;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -943,9 +937,6 @@ do_standby_clone(void)
|
|||||||
case barman:
|
case barman:
|
||||||
appendPQExpBufferStr(&event_details, "barman");
|
appendPQExpBufferStr(&event_details, "barman");
|
||||||
break;
|
break;
|
||||||
case pg_backupapi:
|
|
||||||
appendPQExpBufferStr(&event_details, "pg_backupapi");
|
|
||||||
break;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
appendPQExpBuffer(&event_details,
|
appendPQExpBuffer(&event_details,
|
||||||
@@ -7779,117 +7770,6 @@ stop_backup:
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Perform a call to pg_backupapi endpoint to ask barman to write the backup
|
|
||||||
* for us. This will ensure that no matter the format on-disk of new backups,
|
|
||||||
* barman will always find a way how to read and write them.
|
|
||||||
* From repmgr 4 this is only used for Barman backups.
|
|
||||||
*/
|
|
||||||
static int
|
|
||||||
run_pg_backupapi(t_node_info *local_node_record)
|
|
||||||
{
|
|
||||||
int r = ERR_PGBACKUPAPI_SERVICE;
|
|
||||||
long http_return_code = 0;
|
|
||||||
short seconds_to_sleep = 3;
|
|
||||||
operation_task *task = malloc(sizeof(operation_task));
|
|
||||||
CURL *curl = curl_easy_init();
|
|
||||||
CURLcode ret;
|
|
||||||
|
|
||||||
check_pg_backupapi_standby_clone_options();
|
|
||||||
|
|
||||||
task->host = malloc(strlen(config_file_options.pg_backupapi_host)+1);
|
|
||||||
task->remote_ssh_command = malloc(strlen(config_file_options.pg_backupapi_remote_ssh_command)+1);
|
|
||||||
task->node_name = malloc(strlen(config_file_options.pg_backupapi_node_name)+1);
|
|
||||||
task->operation_type = malloc(strlen(DEFAULT_STANDBY_PG_BACKUPAPI_OP_TYPE)+1);
|
|
||||||
task->backup_id = malloc(strlen(config_file_options.pg_backupapi_backup_id)+1);
|
|
||||||
task->destination_directory = malloc(strlen(local_data_directory)+1);
|
|
||||||
|
|
||||||
task->operation_id = malloc(MAX_BUFFER_LENGTH);
|
|
||||||
task->operation_status = malloc(MAX_BUFFER_LENGTH);
|
|
||||||
|
|
||||||
strcpy(task->host, config_file_options.pg_backupapi_host);
|
|
||||||
strcpy(task->remote_ssh_command, config_file_options.pg_backupapi_remote_ssh_command);
|
|
||||||
strcpy(task->node_name, config_file_options.pg_backupapi_node_name);
|
|
||||||
strcpy(task->operation_type, DEFAULT_STANDBY_PG_BACKUPAPI_OP_TYPE);
|
|
||||||
strcpy(task->backup_id, config_file_options.pg_backupapi_backup_id);
|
|
||||||
strcpy(task->destination_directory, local_data_directory);
|
|
||||||
strcpy(task->operation_id, "\0");
|
|
||||||
|
|
||||||
ret = create_new_task(curl, task);
|
|
||||||
|
|
||||||
if ((ret != CURLE_OK) || (strlen(task->operation_id) == 0)) {
|
|
||||||
curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &http_return_code);
|
|
||||||
if (499 > http_return_code && http_return_code >= 400) {
|
|
||||||
log_error("Cannot find backup '%s' for node '%s'.", task->backup_id, task->node_name);
|
|
||||||
} else {
|
|
||||||
log_error("whilst reaching out pg_backup service: %s\n", curl_easy_strerror(ret));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
log_info("Success creating the task: operation id '%s'", task->operation_id);
|
|
||||||
|
|
||||||
//We call init again because previous call included POST calls
|
|
||||||
curl_easy_cleanup(curl);
|
|
||||||
curl = curl_easy_init();
|
|
||||||
while (true)
|
|
||||||
{
|
|
||||||
ret = get_status_of_operation(curl, task);
|
|
||||||
if (strlen(task->operation_status) == 0) {
|
|
||||||
log_info("Retrying...");
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
log_info("status %s", task->operation_status);
|
|
||||||
}
|
|
||||||
if (strcmp(task->operation_status, "FAILED") == 0) {
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
if (strcmp(task->operation_status, "DONE") == 0) {
|
|
||||||
r = SUCCESS;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
sleep(seconds_to_sleep);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
curl_easy_cleanup(curl);
|
|
||||||
free(task);
|
|
||||||
return r;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
* pg_backupapi mode is enabled when config_file_options.pg_backupapi_host is set hence, we
|
|
||||||
* should also check the other required variables too.
|
|
||||||
*/
|
|
||||||
|
|
||||||
void check_pg_backupapi_standby_clone_options() {
|
|
||||||
|
|
||||||
bool error = false;
|
|
||||||
|
|
||||||
if (*config_file_options.pg_backupapi_remote_ssh_command == '\0') {
|
|
||||||
log_hint("Check config: remote ssh command is required");
|
|
||||||
error = true;
|
|
||||||
}
|
|
||||||
if (*config_file_options.pg_backupapi_node_name == '\0') {
|
|
||||||
log_hint("Check config: node name is required");
|
|
||||||
error = true;
|
|
||||||
}
|
|
||||||
if (*config_file_options.pg_backupapi_backup_id == '\0') {
|
|
||||||
log_hint("Check config: backup_id is required");
|
|
||||||
error = true;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (error == true) {
|
|
||||||
log_error("Please fix the errors and try again");
|
|
||||||
exit(ERR_BAD_CONFIG);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
static char *
|
static char *
|
||||||
make_barman_ssh_command(char *buf)
|
make_barman_ssh_command(char *buf)
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -30,6 +30,6 @@ extern void do_standby_help(void);
|
|||||||
|
|
||||||
extern bool do_standby_follow_internal(PGconn *primary_conn, PGconn *follow_target_conn, t_node_info *follow_target_node_record, PQExpBufferData *output, int general_error_code, int *error_code);
|
extern bool do_standby_follow_internal(PGconn *primary_conn, PGconn *follow_target_conn, t_node_info *follow_target_node_record, PQExpBufferData *output, int general_error_code, int *error_code);
|
||||||
|
|
||||||
void check_pg_backupapi_standby_clone_options(void);
|
|
||||||
|
|
||||||
#endif /* _REPMGR_ACTION_STANDBY_H_ */
|
#endif /* _REPMGR_ACTION_STANDBY_H_ */
|
||||||
|
|||||||
@@ -193,8 +193,7 @@ typedef struct
|
|||||||
typedef enum
|
typedef enum
|
||||||
{
|
{
|
||||||
barman,
|
barman,
|
||||||
pg_basebackup,
|
pg_basebackup
|
||||||
pg_backupapi
|
|
||||||
} standy_clone_mode;
|
} standy_clone_mode;
|
||||||
|
|
||||||
typedef enum
|
typedef enum
|
||||||
|
|||||||
@@ -3096,14 +3096,9 @@ get_standby_clone_mode(void)
|
|||||||
|
|
||||||
if (*config_file_options.barman_host != '\0' && runtime_options.without_barman == false)
|
if (*config_file_options.barman_host != '\0' && runtime_options.without_barman == false)
|
||||||
mode = barman;
|
mode = barman;
|
||||||
else {
|
else
|
||||||
if (*config_file_options.pg_backupapi_host != '\0') {
|
mode = pg_basebackup;
|
||||||
log_info("Attempting to use `pg_backupapi` new restore mode");
|
|
||||||
mode = pg_backupapi;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
mode = pg_basebackup;
|
|
||||||
}
|
|
||||||
return mode;
|
return mode;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
# repmgr extension
|
# repmgr extension
|
||||||
comment = 'Replication manager for PostgreSQL'
|
comment = 'Replication manager for PostgreSQL'
|
||||||
default_version = '5.4'
|
default_version = '5.3'
|
||||||
module_pathname = '$libdir/repmgr'
|
module_pathname = '$libdir/repmgr'
|
||||||
relocatable = false
|
relocatable = false
|
||||||
schema = repmgr
|
schema = repmgr
|
||||||
|
|||||||
1
repmgr.h
1
repmgr.h
@@ -116,7 +116,6 @@
|
|||||||
#define DEFAULT_STANDBY_FOLLOW_TIMEOUT 30 /* seconds */
|
#define DEFAULT_STANDBY_FOLLOW_TIMEOUT 30 /* seconds */
|
||||||
#define DEFAULT_STANDBY_FOLLOW_RESTART false
|
#define DEFAULT_STANDBY_FOLLOW_RESTART false
|
||||||
#define DEFAULT_SHUTDOWN_CHECK_TIMEOUT 60 /* seconds */
|
#define DEFAULT_SHUTDOWN_CHECK_TIMEOUT 60 /* seconds */
|
||||||
#define DEFAULT_STANDBY_PG_BACKUPAPI_OP_TYPE "recovery"
|
|
||||||
#define DEFAULT_STANDBY_RECONNECT_TIMEOUT 60 /* seconds */
|
#define DEFAULT_STANDBY_RECONNECT_TIMEOUT 60 /* seconds */
|
||||||
#define DEFAULT_NODE_REJOIN_TIMEOUT 60 /* seconds */
|
#define DEFAULT_NODE_REJOIN_TIMEOUT 60 /* seconds */
|
||||||
#define DEFAULT_ARCHIVE_READY_WARNING 16 /* WAL files */
|
#define DEFAULT_ARCHIVE_READY_WARNING 16 /* WAL files */
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
#define REPMGR_VERSION_DATE ""
|
#define REPMGR_VERSION_DATE ""
|
||||||
#define REPMGR_VERSION "5.4.1"
|
#define REPMGR_VERSION "5.3.3"
|
||||||
#define REPMGR_VERSION_NUM 50401
|
#define REPMGR_VERSION_NUM 50303
|
||||||
#define REPMGR_EXTENSION_VERSION "5.4"
|
#define REPMGR_EXTENSION_VERSION "5.3"
|
||||||
#define REPMGR_EXTENSION_NUM 50400
|
#define REPMGR_EXTENSION_NUM 50300
|
||||||
#define REPMGR_RELEASE_DATE "2023-07-04"
|
#define REPMGR_RELEASE_DATE "2022-10-17"
|
||||||
#define PG_ACTUAL_VERSION_NUM
|
#define PG_ACTUAL_VERSION_NUM
|
||||||
|
|||||||
@@ -2394,17 +2394,6 @@ monitor_streaming_witness(void)
|
|||||||
terminate(ERR_BAD_CONFIG);
|
terminate(ERR_BAD_CONFIG);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
|
||||||
* It's possible that the primary changed while the witness repmgrd was not
|
|
||||||
* running. This does not affect the functionality of the witness repmgrd, but
|
|
||||||
* does mean outdated node metadata will be displayed, so update that.
|
|
||||||
*/
|
|
||||||
if (local_node_info.upstream_node_id != primary_node_id)
|
|
||||||
{
|
|
||||||
update_node_record_set_upstream(primary_conn, local_node_info.node_id, primary_node_id);
|
|
||||||
local_node_info.upstream_node_id = primary_node_id;
|
|
||||||
}
|
|
||||||
|
|
||||||
initPQExpBuffer(&event_details);
|
initPQExpBuffer(&event_details);
|
||||||
|
|
||||||
appendPQExpBuffer(&event_details,
|
appendPQExpBuffer(&event_details,
|
||||||
|
|||||||
Reference in New Issue
Block a user