Class: LogStasher::Device::Redis
- Inherits:
-
Object
- Object
- LogStasher::Device::Redis
- Includes:
- LogStasher::Device
- Defined in:
- lib/logstasher/device/redis.rb
Instance Attribute Summary collapse
-
#options ⇒ Object
readonly
Returns the value of attribute options.
-
#redis ⇒ Object
readonly
Returns the value of attribute redis.
Instance Method Summary collapse
- #close ⇒ Object
- #data_type ⇒ Object
-
#initialize(options = {}) ⇒ Redis
constructor
A new instance of Redis.
- #key ⇒ Object
- #redis_options ⇒ Object
- #write(log) ⇒ Object
Methods included from LogStasher::Device
Constructor Details
#initialize(options = {}) ⇒ Redis
Returns a new instance of Redis.
11 12 13 14 15 16 |
# File 'lib/logstasher/device/redis.rb', line 11 def initialize( = {}) @options = .merge(stringify_keys()) configure_redis end |
Instance Attribute Details
#options ⇒ Object (readonly)
Returns the value of attribute options.
9 10 11 |
# File 'lib/logstasher/device/redis.rb', line 9 def @options end |
#redis ⇒ Object (readonly)
Returns the value of attribute redis.
9 10 11 |
# File 'lib/logstasher/device/redis.rb', line 9 def redis @redis end |
Instance Method Details
#close ⇒ Object
46 47 48 |
# File 'lib/logstasher/device/redis.rb', line 46 def close redis.quit end |
#data_type ⇒ Object
18 19 20 |
# File 'lib/logstasher/device/redis.rb', line 18 def data_type ['data_type'] end |
#key ⇒ Object
22 23 24 |
# File 'lib/logstasher/device/redis.rb', line 22 def key ['key'] end |
#redis_options ⇒ Object
26 27 28 29 30 31 32 33 |
# File 'lib/logstasher/device/redis.rb', line 26 def unless @redis_options default_keys = .keys @redis_options = .select { |k, v| !default_keys.include?(k) } end @redis_options end |
#write(log) ⇒ Object
35 36 37 38 39 40 41 42 43 44 |
# File 'lib/logstasher/device/redis.rb', line 35 def write(log) case data_type when 'list' redis.rpush(key, log) when 'channel' redis.publish(key, log) else fail "Unknown data type #{data_type}" end end |