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