class EventsEmitter::Redis

Public Class Methods

config() click to toggle source
# File lib/events_emitter/redis.rb, line 28
def self.config
  @config ||= { host: "127.0.0.1", port: 6379, db: 1 }
end

Public Instance Methods

get(key) click to toggle source
# File lib/events_emitter/redis.rb, line 22
def get(key)
  storage.smembers(key).map do |e|
    JSON.parse(e)
  end
end
record(key, value) click to toggle source
# File lib/events_emitter/redis.rb, line 18
def record(key, value)
  storage.sadd(key, value.to_json)
end
storage() click to toggle source
# File lib/events_emitter/redis.rb, line 6
def storage
  return @storage if @storage

  opts = {
    :host => self.class.config[:host],
    :port => self.class.config[:port],
    :db   => self.class.config[:db]
  }

  @storage = ::Redis.new(opts)
end