class
PG::Replication::Connection
- PG::Replication::Connection
- Reference
- Object
Defined in:
pg/replication.crInstance Method Summary
- #close
- #closed? : Bool
- #handler : Handler
-
#keepalive_interval : Time::Span
How often the backstop fiber sends a standby status update to keep the server from tripping its
wal_sender_timeout. - #last_wal_byte_applied : Int64
- #last_wal_byte_applied=(last_wal_byte_applied : Int64)
- #last_wal_byte_flushed : Int64
- #last_wal_byte_flushed=(last_wal_byte_flushed : Int64)
- #last_wal_byte_received : Int64
- #publication_name : String
- #received(frame : ErrorFrame)
-
#received(data : XLogData)
Handle the
XLogDatamessage that wrapsWALMessages -
#received(response : KeepAliveResponse)
This shouldn't ever be received, but it can be represented in memory so we need to include it for completeness.
- #send_keepalive
- #slot_name : String
Instance Method Detail
def keepalive_interval : Time::Span
#
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.
def received(response : KeepAliveResponse)
#
This shouldn't ever be received, but it can be represented in memory so we need to include it for completeness.