[COMMITTERS] pgsql: Logical replication - Mailing list pgsql-committers

Logical replication

- Add PUBLICATION catalogs and DDL
- Add SUBSCRIPTION catalog and DDL
- Define logical replication protocol and output plugin
- Add logical replication workers

From: Petr Jelinek <petr@2ndquadrant.com>
Reviewed-by: Steve Singer <steve@ssinger.info>
Reviewed-by: Andres Freund <andres@anarazel.de>
Reviewed-by: Erik Rijkers <er@xs4all.nl>
Reviewed-by: Peter Eisentraut <peter.eisentraut@2ndquadrant.com>

Branch
------
master

Details
-------
http://git.postgresql.org/pg/commitdiff/665d1fad99e7b11678b0d5fa24d2898424243cd6

Modified Files
--------------
doc/src/sgml/catalogs.sgml                         |  309 +++++
doc/src/sgml/config.sgml                           |   41 +
doc/src/sgml/filelist.sgml                         |    1 +
doc/src/sgml/func.sgml                             |    2 +-
doc/src/sgml/logical-replication.sgml              |  396 ++++++
doc/src/sgml/monitoring.sgml                       |   74 +
doc/src/sgml/postgres.sgml                         |    1 +
doc/src/sgml/protocol.sgml                         |  721 ++++++++++
doc/src/sgml/ref/allfiles.sgml                     |    6 +
doc/src/sgml/ref/alter_publication.sgml            |  139 ++
doc/src/sgml/ref/alter_subscription.sgml           |  139 ++
doc/src/sgml/ref/create_publication.sgml           |  206 +++
doc/src/sgml/ref/create_subscription.sgml          |  176 +++
doc/src/sgml/ref/drop_publication.sgml             |  107 ++
doc/src/sgml/ref/drop_subscription.sgml            |  110 ++
doc/src/sgml/ref/pg_dump.sgml                      |   21 +
doc/src/sgml/ref/psql-ref.sgml                     |   28 +
doc/src/sgml/reference.sgml                        |    6 +
src/Makefile                                       |    1 +
src/backend/access/transam/xact.c                  |    2 +
src/backend/catalog/Makefile                       |    7 +-
src/backend/catalog/aclchk.c                       |   57 +
src/backend/catalog/catalog.c                      |    8 +-
src/backend/catalog/dependency.c                   |   24 +
src/backend/catalog/objectaddress.c                |  219 +++
src/backend/catalog/pg_publication.c               |  457 +++++++
src/backend/catalog/pg_shdepend.c                  |   11 +
src/backend/catalog/pg_subscription.c              |  207 +++
src/backend/catalog/system_views.sql               |   25 +
src/backend/commands/Makefile                      |    8 +-
src/backend/commands/alter.c                       |   10 +
src/backend/commands/dbcommands.c                  |   17 +
src/backend/commands/define.c                      |   28 +
src/backend/commands/dropcmds.c                    |    4 +
src/backend/commands/event_trigger.c               |    8 +
src/backend/commands/publicationcmds.c             |  754 +++++++++++
src/backend/commands/subscriptioncmds.c            |  643 +++++++++
src/backend/commands/tablecmds.c                   |   12 +
src/backend/executor/Makefile                      |    2 +-
src/backend/executor/execMain.c                    |    3 +-
src/backend/executor/execReplication.c             |  553 ++++++++
src/backend/nodes/copyfuncs.c                      |   78 ++
src/backend/nodes/equalfuncs.c                     |   73 +
src/backend/parser/gram.y                          |  262 +++-
src/backend/postmaster/bgworker.c                  |   23 +-
src/backend/postmaster/pgstat.c                    |    6 +
src/backend/postmaster/postmaster.c                |    9 +
.../libpqwalreceiver/libpqwalreceiver.c            |  217 ++-
src/backend/replication/logical/Makefile           |    4 +-
src/backend/replication/logical/launcher.c         |  759 +++++++++++
src/backend/replication/logical/proto.c            |  637 +++++++++
src/backend/replication/logical/relation.c         |  489 +++++++
src/backend/replication/logical/worker.c           | 1429 ++++++++++++++++++++
src/backend/replication/pgoutput/Makefile          |   32 +
src/backend/replication/pgoutput/pgoutput.c        |  596 ++++++++
src/backend/replication/walreceiver.c              |   20 +-
src/backend/storage/ipc/ipci.c                     |    3 +
src/backend/storage/lmgr/lwlocknames.txt           |    2 +
src/backend/tcop/utility.c                         |   83 ++
src/backend/utils/cache/inval.c                    |   35 +-
src/backend/utils/cache/relcache.c                 |  136 +-
src/backend/utils/cache/syscache.c                 |   69 +
src/backend/utils/misc/guc.c                       |   13 +
src/backend/utils/misc/postgresql.conf.sample      |    1 +
src/bin/pg_dump/common.c                           |   12 +
src/bin/pg_dump/pg_backup.h                        |    3 +
src/bin/pg_dump/pg_backup_archiver.c               |    7 +-
src/bin/pg_dump/pg_dump.c                          |  464 +++++++
src/bin/pg_dump/pg_dump.h                          |   46 +-
src/bin/pg_dump/pg_dump_sort.c                     |   20 +-
src/bin/pg_dump/pg_restore.c                       |    3 +
src/bin/pg_dump/t/002_pg_dump.pl                   |   76 +-
src/bin/psql/command.c                             |   16 +
src/bin/psql/describe.c                            |  292 ++++
src/bin/psql/describe.h                            |    9 +
src/bin/psql/help.c                                |    2 +
src/bin/psql/tab-complete.c                        |   53 +-
src/include/catalog/dependency.h                   |    3 +
src/include/catalog/indexing.h                     |   18 +
src/include/catalog/pg_proc.h                      |    6 +
src/include/catalog/pg_publication.h               |  104 ++
src/include/catalog/pg_publication_rel.h           |   52 +
src/include/catalog/pg_subscription.h              |   83 ++
src/include/commands/defrem.h                      |    1 +
src/include/commands/publicationcmds.h             |   28 +
src/include/commands/subscriptioncmds.h            |   27 +
src/include/executor/executor.h                    |   17 +
src/include/nodes/nodes.h                          |    5 +
src/include/nodes/parsenodes.h                     |   51 +
src/include/parser/kwlist.h                        |    3 +
src/include/pgstat.h                               |    4 +-
src/include/replication/logicallauncher.h          |   27 +
src/include/replication/logicalproto.h             |  104 ++
src/include/replication/logicalrelation.h          |   43 +
src/include/replication/logicalworker.h            |   17 +
src/include/replication/pgoutput.h                 |   29 +
src/include/replication/walreceiver.h              |   60 +-
src/include/replication/worker_internal.h          |   62 +
src/include/storage/sinval.h                       |    3 +-
src/include/utils/acl.h                            |    4 +
src/include/utils/inval.h                          |    2 +
src/include/utils/rel.h                            |    6 +
src/include/utils/relcache.h                       |    6 +
src/include/utils/syscache.h                       |    6 +
src/test/Makefile                                  |    2 +-
src/test/perl/PostgresNode.pm                      |   13 +-
src/test/regress/expected/publication.out          |  156 +++
src/test/regress/expected/rules.out                |   18 +
src/test/regress/expected/sanity_check.out         |    3 +
src/test/regress/expected/subscription.out         |   66 +
src/test/regress/parallel_schedule                 |    3 +
src/test/regress/serial_schedule                   |    2 +
src/test/regress/sql/publication.sql               |   82 ++
src/test/regress/sql/subscription.sql              |   44 +
src/test/subscription/.gitignore                   |    2 +
src/test/subscription/Makefile                     |   22 +
src/test/subscription/README                       |   16 +
src/test/subscription/t/001_rep_changes.pl         |  188 +++
src/test/subscription/t/002_types.pl               |  539 ++++++++
119 files changed, 13354 insertions(+), 95 deletions(-)


pgsql-committers by date:

Previous
From: Tom Lane
Date:
Subject: [COMMITTERS] pgsql: Avoid core dump for empty prepared statement in an abortedtrans
Next
From: Peter Eisentraut
Date:
Subject: [COMMITTERS] pgsql: Bump catversion