diff options
| -rw-r--r-- | doc/src/extras.rst | 10 | ||||
| -rw-r--r-- | lib/extras.py | 9 |
2 files changed, 1 insertions, 18 deletions
diff --git a/doc/src/extras.rst b/doc/src/extras.rst index bdf8fc1..356e10e 100644 --- a/doc/src/extras.rst +++ b/doc/src/extras.rst @@ -222,16 +222,6 @@ The individual messages in the replication stream are presented by .. autoclass:: ReplicationCursor - .. method:: identify_system() - - Execute ``IDENTIFY_SYSTEM`` command of the streaming replication - protocol and return the result as a dictionary. - - Example:: - - >>> cur.identify_system() - {'timeline': 1, 'systemid': '1234567890123456789', 'dbname': 'test', 'xlogpos': '0/1ABCDEF'} - .. method:: create_replication_slot(slot_name, slot_type=None, output_plugin=None) Create streaming replication slot. diff --git a/lib/extras.py b/lib/extras.py index c05536a..913a6aa 100644 --- a/lib/extras.py +++ b/lib/extras.py @@ -506,13 +506,6 @@ class PhysicalReplicationConnection(ReplicationConnectionBase): class ReplicationCursor(_cursor): """A cursor used for communication on the replication protocol.""" - def identify_system(self): - """Get information about the cluster status.""" - - self.execute("IDENTIFY_SYSTEM") - return dict(zip([_.name for _ in self.description], - self.fetchall()[0])) - def create_replication_slot(self, slot_name, slot_type=None, output_plugin=None): """Create streaming replication slot.""" @@ -594,7 +587,7 @@ class ReplicationCursor(_cursor): command += "%s %s" % (self.connection.quote_ident(k), _A(str(v))) command += ")" - return self.start_replication_expert(command) + self.start_replication_expert(command) def send_feedback_message(self, written_lsn=0, sync_lsn=0, apply_lsn=0, reply_requested=False): return self.send_replication_feedback(written_lsn, sync_lsn, apply_lsn, reply_requested) |