module Sequel::ConnectionExpiration

  1. lib/sequel/extensions/connection_expiration.rb

Attributes

connection_expiration_random_delay [RW]

The maximum number of seconds that will be added as a random delay to the expiration timeout Defaults to 0 seconds (no random delay).
connection_expiration_timeout [RW]

The number of seconds that need to pass since connection creation before expiring a connection. Defaults to 14400 seconds (4 hours).

Public Class methods

extended(pool)

Initialize the data structures used by this extension.

[show source] 
   # File lib/sequel/extensions/connection_expiration.rb
47 def self.extended(pool)
48   case pool.pool_type
49   when :threaded, :sharded_threaded, :timed_queue, :sharded_timed_queue
50     nil
51   else
52     raise Error, "cannot load connection_expiration extension if using single or sharded_single connection pool (or other unsupported connection pool)"
53   end
54 
55   pool.instance_exec do
56     sync do
57       @connection_expiration_timestamps ||= {}
58       @connection_expiration_timeout ||= 14400
59       @connection_expiration_random_delay ||= 0
60 
61       # Record an expiration timestamp for any connections that already
62       # exist in the pool, so that a connection opened before the extension
63       # was loaded (e.g. via Sequel.connect) will eventually be expired.
64       register = method(:register_connection_expiration_time)
65 
66       case pool_type
67       when :timed_queue, :sharded_timed_queue
68         register_queued_connections = lambda do |queue|
69           conns = []
70           while conn = queue.pop(timeout: 0)
71             conns << conn
72           end
73           conns.each do |conn|
74             queue.push(register_connection_expiration_time(conn))
75           end
76         end
77       end
78 
79       case pool_type
80       when :threaded
81         @available_connections.each(&register)
82         @allocated.each_value(&register)
83       when :sharded_threaded
84         @available_connections.each_value{|conns| conns.each(&register)}
85         @allocated.each_value{|threads| threads.each_value(&register)}
86       when :timed_queue
87         register_queued_connections.call(@queue)
88         @allocated.each_value(&register)
89       else # when :sharded_timed_queue
90         @queues.each_value(&register_queued_connections)
91         @allocated.each_value{|threads| threads.each_value(&register)}
92       end
93     end
94   end
95 end