Method: Sequel::ServerBlock.extended

Defined in:
lib/sequel/extensions/server_block.rb

.extended(db) ⇒ Object

Enable the server block on the connection pool, choosing the correct extension depending on whether the connection pool is threaded or not. Also defines the with_server method on the receiver for easy use.



70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/sequel/extensions/server_block.rb', line 70

def self.extended(db)
  pool = db.pool
  case pool.pool_type
  when :sharded_threaded, :sharded_timed_queue
    pool.extend(ThreadedServerBlock)
    pool.instance_variable_set(:@default_servers, {})
  else
    pool.extend(UnthreadedServerBlock)
    pool.instance_variable_set(:@default_servers, [])
  end
end