Class: Terastream::Output::Redis

Inherits:

Object

Object
Terastream::Output::Redis

show all

Defined in:: lib/terastream/middleware/output/redis.rb

Instance Method Summary collapse

#<<(record) ⇒ Object
#initialize(options = {}) ⇒ Redis constructor

A new instance of Redis.

Constructor Details

#initialize(options = {}) ⇒ `Redis`

Returns a new instance of Redis.



6
7
8

# File 'lib/terastream/middleware/output/redis.rb', line 6

def initialize(options = {})
  @connection = ::Redis.new
end

Instance Method Details

#<<(record) ⇒ `Object`



10
11
12

# File 'lib/terastream/middleware/output/redis.rb', line 10

def <<(record)
  @connection.publish(:messages, record)
end