class ActiveRecord::Slave::ReplicationRouter

Public Class Methods

new(replication_config) click to toggle source
# File lib/active_record/slave/replication_router.rb, line 6
def initialize(replication_config)
  fail "Not ActiveRecord::Slave::ReplicationConfig object." unless replication_config.is_a? ActiveRecord::Slave::ReplicationConfig
  @replication_config = replication_config
end

Public Instance Methods

master_connection_name() click to toggle source
# File lib/active_record/slave/replication_router.rb, line 11
def master_connection_name
  @replication_config.master_connection_name
end
slave_connection_name() click to toggle source
# File lib/active_record/slave/replication_router.rb, line 15
def slave_connection_name
  slaves = Pickup.new(@replication_config.slave_connection_names)
  slaves.pick(1)
end