module Sequel::ServerBlock

  1. lib/sequel/extensions/server_block.rb


Public Class

  1. extended

Public Instance

  1. with_server

Public Class methods


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.

[show source]
   # File lib/sequel/extensions/server_block.rb
70 def self.extended(db)
71   pool = db.pool
72   if defined?(ShardedThreadedConnectionPool) && pool.is_a?(ShardedThreadedConnectionPool)
73     pool.extend(ThreadedServerBlock)
74     pool.instance_variable_set(:@default_servers, {})
75   else
76     pool.extend(UnthreadedServerBlock)
77     pool.instance_variable_set(:@default_servers, [])
78   end
79 end

Public Instance methods

with_server(default_server, read_only_server=default_server, &block)

Delegate to the connection pool

[show source]
   # File lib/sequel/extensions/server_block.rb
82 def with_server(default_server, read_only_server=default_server, &block)
83   pool.with_server(default_server, read_only_server, &block)
84 end