Class: Makara::Pool
- Inherits:
-
Object
- Object
- Makara::Pool
- Defined in:
- lib/makara/pool.rb
Instance Attribute Summary collapse
-
#blacklist_errors ⇒ Object
readonly
Returns the value of attribute blacklist_errors.
-
#connections ⇒ Object
readonly
Returns the value of attribute connections.
-
#disabled ⇒ Object
there are cases when we understand the pool is busted and we essentially want to skip all execution.
-
#role ⇒ Object
readonly
Returns the value of attribute role.
-
#strategy ⇒ Object
readonly
Returns the value of attribute strategy.
Instance Method Summary collapse
-
#add(config) ⇒ Object
Add a connection to this pool, wrapping the connection with a Makara::ConnectionWrapper.
- #completely_blacklisted? ⇒ Boolean
-
#initialize(role, proxy) ⇒ Pool
constructor
A new instance of Pool.
-
#provide ⇒ Object
Provide a connection that is not blacklisted and connected.
-
#send_to_all(method, *args, &block) ⇒ Object
send this method to all available nodes send nil to just yield with each con if there is block.
Constructor Details
#initialize(role, proxy) ⇒ Pool
Returns a new instance of Pool.
17 18 19 20 21 22 23 24 |
# File 'lib/makara/pool.rb', line 17 def initialize(role, proxy) @role = role @proxy = proxy @connections = [] @blacklist_errors = [] @disabled = false @strategy = proxy.strategy_for(role) end |
Instance Attribute Details
#blacklist_errors ⇒ Object (readonly)
Returns the value of attribute blacklist_errors.
12 13 14 |
# File 'lib/makara/pool.rb', line 12 def blacklist_errors @blacklist_errors end |
#connections ⇒ Object (readonly)
Returns the value of attribute connections.
14 15 16 |
# File 'lib/makara/pool.rb', line 14 def connections @connections end |
#disabled ⇒ Object
there are cases when we understand the pool is busted and we essentially want to skip all execution
11 12 13 |
# File 'lib/makara/pool.rb', line 11 def disabled @disabled end |
#role ⇒ Object (readonly)
Returns the value of attribute role.
13 14 15 |
# File 'lib/makara/pool.rb', line 13 def role @role end |
#strategy ⇒ Object (readonly)
Returns the value of attribute strategy.
15 16 17 |
# File 'lib/makara/pool.rb', line 15 def strategy @strategy end |
Instance Method Details
#add(config) ⇒ Object
Add a connection to this pool, wrapping the connection with a Makara::ConnectionWrapper
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/makara/pool.rb', line 36 def add(config) config[:name] ||= "#{@role}/#{@connections.length + 1}" connection = yield # already wrapped because of initial error if connection.is_a?(Makara::ConnectionWrapper) connection.config = config # to add :name wrapper = connection else wrapper = Makara::ConnectionWrapper.new(@proxy, connection, config) end @connections << wrapper @strategy.connection_added(wrapper) wrapper end |
#completely_blacklisted? ⇒ Boolean
27 28 29 30 31 32 |
# File 'lib/makara/pool.rb', line 27 def completely_blacklisted? @connections.each do |connection| return false unless connection._makara_blacklisted? end true end |
#provide ⇒ Object
Provide a connection that is not blacklisted and connected. Handle any errors that may occur within the block.
93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 |
# File 'lib/makara/pool.rb', line 93 def provide provided_connection = self.next # nil implies that it's blacklisted if provided_connection value = @proxy.error_handler.handle(provided_connection) do yield provided_connection end @blacklist_errors = [] value # if we've made any connections within this pool, we should report the blackout. elsif connection_made? err = Makara::Errors::AllConnectionsBlacklisted.new(self, @blacklist_errors) @blacklist_errors = [] raise err else raise Makara::Errors::NoConnectionsAvailable.new(@role) unless @disabled end # when a connection causes a blacklist error within the provided block, we blacklist it then retry rescue Makara::Errors::BlacklistConnection => e @blacklist_errors.insert(0, e) provided_connection._makara_blacklist! retry end |
#send_to_all(method, *args, &block) ⇒ Object
send this method to all available nodes send nil to just yield with each con if there is block
57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 |
# File 'lib/makara/pool.rb', line 57 def send_to_all(method, *args, &block) ret = nil one_worked = false # actually found one that worked errors = [] @connections.each do |con| next if con._makara_blacklisted? begin ret = @proxy.error_handler.handle(con) do if block yield con else con.send(method, *args) end end one_worked = true rescue Makara::Errors::BlacklistConnection => e errors.insert(0, e) con._makara_blacklist! end end if !one_worked if connection_made? raise Makara::Errors::AllConnectionsBlacklisted.new(self, errors) else raise Makara::Errors::NoConnectionsAvailable.new(@role) unless @disabled end end ret end |