module RedisClient::Common
def initialize(
def initialize( config, id: config.id, connect_timeout: config.connect_timeout, read_timeout: config.read_timeout, write_timeout: config.write_timeout ) @config = config @id = id&.to_s @connect_timeout = connect_timeout @read_timeout = read_timeout @write_timeout = write_timeout @command_builder = config.command_builder @pid = PIDCache.pid @nodes = [self].freeze end
def node_for(_key)
def node_for(_key) self end
def nodes_for(*keys)
def nodes_for(*keys) keys.flatten! { self => keys } end
def timeout=(timeout)
def timeout=(timeout) @connect_timeout = @read_timeout = @write_timeout = timeout end