class EventMachine::Hiredis::Client
Public Class Methods
connect(host = 'localhost', port = 6379)
click to toggle source
# File lib/em-hiredis/client.rb, line 3 def self.connect(host = 'localhost', port = 6379) new(host, port).connect end
Public Instance Methods
info() { |info| ... }
click to toggle source
# File lib/em-hiredis/client.rb, line 12 def info df = method_missing(:info) df.callback { |response| info = {} response.each_line do |line| key, value = line.split(":", 2) info[key.to_sym] = value.chomp if value end df.succeed(info) } df.callback { |info| yield info } if block_given? df end
info_commandstats(&blk)
click to toggle source
# File lib/em-hiredis/client.rb, line 26 def info_commandstats(&blk) hash_processor = lambda do |response| commands = {} response.each_line do |line| command, data = line.split(':') if data c = commands[command.sub('cmdstat_', '').to_sym] = {} data.split(',').each do |d| k, v = d.split('=') c[k.to_sym] = v =~ /\./ ? v.to_f : v.to_i end end end blk.call(commands) end method_missing(:info, 'commandstats', &hash_processor) end
monitor(&blk)
click to toggle source
# File lib/em-hiredis/client.rb, line 7 def monitor(&blk) @monitoring = true method_missing(:monitor, &blk) end
psubscribe(channel)
click to toggle source
# File lib/em-hiredis/client.rb, line 61 def psubscribe(channel) raise "Use pubsub client" end
pubsub()
click to toggle source
Gives access to a richer interface for pubsub subscriptions on a separate redis connection
# File lib/em-hiredis/client.rb, line 47 def pubsub @pubsub ||= begin PubsubClient.new(@host, @port, @password, @db).connect end end
punsubscribe(channel)
click to toggle source
# File lib/em-hiredis/client.rb, line 65 def punsubscribe(channel) raise "Use pubsub client" end
subscribe(*channels)
click to toggle source
# File lib/em-hiredis/client.rb, line 53 def subscribe(*channels) raise "Use pubsub client" end
unsubscribe(*channels)
click to toggle source
# File lib/em-hiredis/client.rb, line 57 def unsubscribe(*channels) raise "Use pubsub client" end