Class: LogStasher::Device::Redis
- Inherits:
-
Object
- Object
- LogStasher::Device::Redis
- 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
Constructor Details
#initialize(options = {}) ⇒ Redis
Returns a new instance of Redis.
9 10 11 12 13 |
# File 'lib/logstasher/device/redis.rb', line 9 def initialize( = {}) @options = .merge() configure_redis end |
Instance Attribute Details
#options ⇒ Object (readonly)
Returns the value of attribute options.
7 8 9 |
# File 'lib/logstasher/device/redis.rb', line 7 def @options end |
#redis ⇒ Object (readonly)
Returns the value of attribute redis.
7 8 9 |
# File 'lib/logstasher/device/redis.rb', line 7 def redis @redis end |
Instance Method Details
#close ⇒ Object
43 44 45 |
# File 'lib/logstasher/device/redis.rb', line 43 def close redis.quit end |
#data_type ⇒ Object
15 16 17 |
# File 'lib/logstasher/device/redis.rb', line 15 def data_type [:data_type] end |
#key ⇒ Object
19 20 21 |
# File 'lib/logstasher/device/redis.rb', line 19 def key [:key] end |
#redis_options ⇒ Object
23 24 25 26 27 28 29 30 |
# File 'lib/logstasher/device/redis.rb', line 23 def unless @redis_options default_keys = .keys @redis_options = .select { |k, v| !default_keys.include?(k) } end @redis_options end |
#write(log) ⇒ Object
32 33 34 35 36 37 38 39 40 41 |
# File 'lib/logstasher/device/redis.rb', line 32 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 |