Module: PgHero::Methods::Replication

Included in:
Database
Defined in:
lib/pghero/methods/replication.rb

Instance Method Summary collapse

Instance Method Details

#replica? ⇒ Boolean

Returns:

  • (Boolean) 


4
5
6
7
8
9
 
# File 'lib/pghero/methods/replication.rb', line 4

def replica?
  unless defined?(@replica)
    @replica = select_one("SELECT pg_is_in_recovery()")
  end
  @replica
end

#replicating? ⇒ Boolean

Returns:

  • (Boolean) 


48
49
50
51
52
 
# File 'lib/pghero/methods/replication.rb', line 48

def replicating?
  with_feature_support(:replicating?, false) do
    select_all("SELECT state FROM pg_stat_replication").any?
  end
end

#replication_lag ⇒ Object

www.postgresql.org/message-id/CADKbJJWz9M0swPT3oqe8f9+tfD4-F54uE6Xtkh4nERpVsQnjnw@mail.gmail.com



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/pghero/methods/replication.rb', line 12

def replication_lag
  with_feature_support(:replication_lag) do
    lag_condition =
      if server_version_num >= 100000
        "pg_last_wal_receive_lsn() = pg_last_wal_replay_lsn()"
      else
        "pg_last_xlog_receive_location() = pg_last_xlog_replay_location()"
      end

    select_one "      SELECT\n        CASE\n          WHEN NOT pg_is_in_recovery() OR \#{lag_condition} THEN 0\n          ELSE EXTRACT (EPOCH FROM NOW() - pg_last_xact_replay_timestamp())\n        END\n      AS replication_lag\n    SQL\n  end\nend\n"

#replication_slots ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/pghero/methods/replication.rb', line 32

def replication_slots
  if server_version_num >= 90400
    with_feature_support(:replication_slots, []) do
      select_all "        SELECT\n          slot_name,\n          database,\n          active\n        FROM pg_replication_slots\n      SQL\n    end\n  else\n    []\n  end\nend\n"