module Sequel::ConnectionCheckoutEventCallbacks::ShardedTimedQueue

Attributes

on_checkout_event[RW]

The callback that is called with connection checkout events.

Private Instance Methods

available(queue, server) click to toggle source

Calls superclass method

    # File lib/sequel/extensions/connection_checkout_event_callback.rb
114 def available(queue, server)
115   conn = super
116   @on_checkout_event.call(conn ? :immediately_available : :not_immediately_available, server)
117   conn
118 end

try_make_new(server) click to toggle source

Calls superclass method

    # File lib/sequel/extensions/connection_checkout_event_callback.rb
120 def try_make_new(server)
121   conn = super
122   @on_checkout_event.call(:new_connection, server) if conn
123   conn
124 end

wait_until_available(queue, server) click to toggle source

Calls superclass method

    # File lib/sequel/extensions/connection_checkout_event_callback.rb
126 def wait_until_available(queue, server)
127   timer = Sequel.start_timer
128   conn = super
129   @on_checkout_event.call(Sequel.elapsed_seconds_since(timer), server)
130   conn
131 end