psycopg/psycopg2
1
1
Fork 0
mirror of https://github.com/psycopg/psycopg2.git synced 2024-11-25 02:13:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Added doc link to replication commands

Browse Source
This commit is contained in:
Daniele Varrazzo 2017-05-10 01:55:01 +01:00
parent 6e5abf33f2
commit 165449c724
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
doc/src/extras.rst
View File

@ -337,7 +337,7 @@ The individual messages in the replication stream are represented by
*This parameter should not be set with physical replication or with *This parameter should not be set with physical replication or with
logical replication plugins that produce binary output.* logical replication plugins that produce binary output.*
This function constructs a ``START_REPLICATION`` command and calls This function constructs a |START_REPLICATION|_ command and calls
`start_replication_expert()` internally. `start_replication_expert()` internally.
After starting the replication, to actually consume the incoming After starting the replication, to actually consume the incoming
@ -345,10 +345,13 @@ The individual messages in the replication stream are represented by
`read_message()` in case of :ref:`asynchronous connection `read_message()` in case of :ref:`asynchronous connection
<async-support>`. <async-support>`.
.. |START_REPLICATION| replace:: :sql:`START_REPLICATION`
.. _START_REPLICATION: https://www.postgresql.org/docs/current/static/protocol-replication.html
.. method:: start_replication_expert(command, decode=False) .. method:: start_replication_expert(command, decode=False)
Start replication on the connection using provided Start replication on the connection using provided
``START_REPLICATION`` command. See `start_replication()` for |START_REPLICATION|_ command. See `start_replication()` for
description of *decode* parameter. description of *decode* parameter.
.. method:: consume_stream(consume, keepalive_interval=10) .. method:: consume_stream(consume, keepalive_interval=10)