Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Smart replication feedback #913

Merged
merged 4 commits into from
May 12, 2019
Merged

Smart replication feedback #913

Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift click to select a range
6cff5a3
Smart replication feedback
May 6, 2019
f827e49
Change the default value of keepalive_interval parameter to None
May 6, 2019
5eec11f
Improve docs
May 6, 2019
90755e6
Address code-review
May 7, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Improve docs
  • Loading branch information
Alexander Kukushkin committed May 6, 2019
commit 5eec11f2322a2c0cc772d8edee71f02d67040f0a
14 changes: 14 additions & 0 deletions doc/src/extras.rst
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -345,6 345,9 @@ The individual messages in the replication stream are represented by
`read_message()` in case of :ref:`asynchronous connection
<async-support>`.

.. versionchanged:: 2.8.3
added the *status_interval* parameter.

.. |START_REPLICATION| replace:: :sql:`START_REPLICATION`
.. _START_REPLICATION: https://www.postgresql.org/docs/current/static/protocol-replication.html

Expand All @@ -359,6 362,9 @@ The individual messages in the replication stream are represented by
performed on messages received from the server.
:param status_interval: time between feedback packets sent to the server

.. versionchanged:: 2.8.3
added the *status_interval* parameter.


.. method:: consume_stream(consume, keepalive_interval=None)

Expand Down Expand Up @@ -417,6 423,9 @@ The individual messages in the replication stream are represented by
retains all the WAL segments that might be needed to stream the
changes via all of the currently open replication slots.

.. versionchanged:: 2.8.3
changed the default value of the *keepalive_interval* parameter to `!None`.

.. method:: send_feedback(write_lsn=0, flush_lsn=0, apply_lsn=0, reply=False, force=False)

:param write_lsn: a LSN position up to which the client has written the data locally
Expand All @@ -438,6 447,9 @@ The individual messages in the replication stream are represented by
to the server. The library sends feedback message automatically
when *status_interval* timeout is reached.

.. versionchanged:: 2.8.3
added the *force* parameter.

Low-level replication cursor methods for :ref:`asynchronous connection
<async-support>` operation.

Expand Down Expand Up @@ -493,6 505,8 @@ The individual messages in the replication stream are represented by
A `~datetime` object representing the timestamp at the moment when
the last feedback message sent to the server.

.. versionadded:: 2.8.3

.. attribute:: wal_end

LSN position of the current end of WAL on the server at the
Expand Down