module PgFailover::SequelAdapter

Public Class Methods

enable(databases = Sequel::DATABASES) click to toggle source
# File lib/pg_failover/sequel_adapter.rb, line 12
def enable(databases = Sequel::DATABASES)
  register_extension

  databases.each do |db|
    db.extension :postgres_failover_validator if db.adapter_scheme == :postgres
  end
end
register_extension() click to toggle source
# File lib/pg_failover/sequel_adapter.rb, line 6
def register_extension
  ::Sequel::Database.register_extension(:postgres_failover_validator) do |db|
    db.pool.extend(PgFailover::SequelAdapter::ConnectionValidator)
  end
end