Sha256: 0b8ec0ac1c7aa3eca69e0b509c8754ab5c0a131d1c042b78983ff634de8356f4
Contents?: true
Size: 1.21 KB
Versions: 3
Compression:
Stored size: 1.21 KB
Contents
require 'octoshark/version' require 'active_record' require 'octoshark/active_record_extensions' module Octoshark autoload :ConnectionSwitcher, 'octoshark/connection_switcher' class NotConfiguredError < RuntimeError; end class NoConnectionError < StandardError; end; class NoCurrentConnectionError < StandardError; end; OCTOSHARK = :octoshark class << self delegate :current_connection, :with_connection, :connection, :current_or_default_connection, :connection_pools, :find_connection_pool, :disconnect!, to: :switcher def configure(configs) @configs = configs @switcher = ConnectionSwitcher.new(configs) end def reset! return unless configured? disconnect! @confings = nil @switcher = nil Thread.current[OCTOSHARK] = nil end def reload! raise_not_configured_error unless @configs disconnect! @switcher = ConnectionSwitcher.new(@configs) end def configured? !@switcher.nil? end def switcher @switcher || raise_not_configured_error end private def raise_not_configured_error raise NotConfiguredError, "Octoshark is not configured, use Octoshark.configure" end end end
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
octoshark-0.0.7 | lib/octoshark.rb |
octoshark-0.0.6 | lib/octoshark.rb |
octoshark-0.0.3 | lib/octoshark.rb |