module Norton
Constants
- SUPPORTED_TYPES
- VERSION
Attributes
pools[RW]
redis[RW]
Public Class Methods
mget(objects, fields)
click to toggle source
批量获取多个对象的多个 Norton
字段, 仅仅支持 counter / timestamp
@example
Norton.mget([a_user, another_user], [:followers_count, :profile_updated_at])
@param [Array] names 需要检索的字段
@return [Array] 一组对象
# File lib/norton.rb, line 66 def mget(objects, fields) pools_with_name = fields.each_with_object({}) do |name, hash| pool = objects[0].class.norton_value_redis_pool(name) hash[pool] ||= [] hash[pool] << name end pools_with_name.each do |pool, names| keys = objects.flat_map do |object| names.map { |name| object.norton_value_key(name) } end nested_values = pool.with do |conn| conn.mget(keys) end.each_slice(names.size) objects.zip(nested_values).each do |object, values| object.send(:assign_values, names.zip(values).to_h) end end objects end
setup(options = {})
click to toggle source
Setup your redis connection.
@param options={} [Hash] [Redis connection configuration]
url - Redis connection url pool - Connection pool size timeout - Connection pool timeout
@example
{ "default" => { "url" => "redis://localhost:6379/0", "pool" => 4, "timeout" => 2 }, "norton2" => { "url" => "redis://localhost:6379/3", "pool" => 4, "timeout" => 2 } }
@return [Void]
# File lib/norton.rb, line 42 def setup(options = {}) self.pools = {} options.deep_symbolize_keys! options.each do |name, conn_params| pool_size = (conn_params.delete(:pool) || 1).to_i timeout = (conn_params.delete(:timeout) || 2).to_i Norton.pools[name] = ConnectionPool.new(size: pool_size, timeout: timeout) do Redis.new(conn_params) end end Norton.redis = Norton.pools[:default] end