Class: TokyoMessenger::Balancer::Table

Inherits:
Base
  • Object
show all
Defined in:
lib/tokyo_messenger/balancer.rb

Instance Method Summary collapse

Methods inherited from Base

#add_double, #add_int, #check, #close, #db_for_key, #delete_keys_with_prefix, #empty?, #fetch, #fwmkeys, #get, #get_double, #get_int, #initialize, #keys, #optimize, #out, #put, #putcat, #putkeep, #putnr, #putshl, #ring, #rnum, #servers, #set_index, #sync, #values, #vanish, #vsiz

Constructor Details

This class inherits a constructor from TokyoMessenger::Balancer::Base

Instance Method Details

#find(&block) ⇒ Object 



180
181
182
183
184
185
 
# File 'lib/tokyo_messenger/balancer.rb', line 180

def find(&block)
  queries = @servers.collect{ |server|
    server.prepare_query(&block)
  }
  TokyoMessenger::Query.parallel_search(*queries)
end

#klass ⇒ Object 



176
177
178
 
# File 'lib/tokyo_messenger/balancer.rb', line 176

def klass
  TokyoMessenger::Table
end