class ManageIQ::PostgresHaAdmin::LogicalReplicationConfigHandler

Attributes

conn_info[R]
subscription[R]

Public Class Methods

new(options = {}) click to toggle source
# File lib/manageiq/postgres_ha_admin/config_handler/logical_replication_config_handler.rb, line 9
def initialize(options = {})
  @subscription = options[:subscription]
  @conn_info    = options[:conn_info]
end

Public Instance Methods

name() click to toggle source
# File lib/manageiq/postgres_ha_admin/config_handler/logical_replication_config_handler.rb, line 14
def name
  "Logical Replication subscription #{subscription} Config Handler"
end
read() click to toggle source
# File lib/manageiq/postgres_ha_admin/config_handler/logical_replication_config_handler.rb, line 18
    def read
      conn = PG::Connection.open(@conn_info)
      dsn = conn.exec_params(<<~SQL, [@subscription]).first["subconninfo"]
        SELECT subconninfo
        FROM pg_subscription
        WHERE subname = $1
      SQL
      PG::DSNParser.new.parse(dsn)
    end
write(_params) click to toggle source
# File lib/manageiq/postgres_ha_admin/config_handler/logical_replication_config_handler.rb, line 28
def write(_params)
  # Nothing to do here as the expectation is that the user will
  # remove and re-add the subscription in the after failover callback
end