class

PG::Replication::Connection

Inherits Reference / Object

Instance methods

Source

closed?

Source

handler

Source

keepalive_interval

How often the backstop fiber sends a standby status update to keep the server from tripping its wal_sender_timeout. Ideally set to less than half of that timeout to avoid being disconnected by the Postgres server. Defaults to 10 seconds.

Source

last_wal_byte_applied

Source

last_wal_byte_applied=(last_wal_byte_applied : Int64)

Source

last_wal_byte_flushed

Source

last_wal_byte_flushed=(last_wal_byte_flushed : Int64)

Source

last_wal_byte_received

Source

publication_name

Source

received(frame : ErrorFrame)

Source

received(data : XLogData)

Handle the XLogData message that wraps WALMessages

Source

received(response : KeepAliveResponse)

This shouldn't ever be received, but it can be represented in memory so we need to include it for completeness.

Source

send_keepalive

Source

slot_name

Source