module Replicat::Replicable::ClassMethods

Public Instance Methods

configuration() click to toggle source
# File lib/replicat/replicable.rb, line 38
def configuration
  connection_name && configurations[connection_name]
end
connection_with_proxy() click to toggle source
# File lib/replicat/replicable.rb, line 22
def connection_with_proxy
  if has_any_replication?
    proxy
  else
    connection_without_proxy
  end
end
has_any_replication?() click to toggle source
# File lib/replicat/replicable.rb, line 30
def has_any_replication?
  has_configuration? && replications.present?
end
has_configuration?() click to toggle source
# File lib/replicat/replicable.rb, line 34
def has_configuration?
  !!configuration
end
replications() click to toggle source
# File lib/replicat/replicable.rb, line 42
def replications
  configuration["replications"]
end
using(connection_name) { || ... } click to toggle source
# File lib/replicat/replicable.rb, line 46
def using(connection_name)
  if block_given?
    proxy.current_connection_name = connection_name
    yield
  else
    ScopeProxy.new(klass: self, connection_name: connection_name)
  end
ensure
  proxy.current_connection_name = nil if block_given?
end