class LogStash::Inputs::Redis
Public Class Methods
new(url, config={}, &block)
click to toggle source
Calls superclass method
LogStash::Inputs::Base::new
# File lib/logstash/inputs/redis.rb, line 7 def initialize(url, config={}, &block) super end
Public Instance Methods
register()
click to toggle source
# File lib/logstash/inputs/redis.rb, line 11 def register _, @db, @queue = @url.path.split('/') puts @url.host, @url.port, @db, @queue EM.run do redis = EM::Protocols::Redis.connect :host => @url.host, :port => @url.port, :db => @db pop = lambda do redis.blpop @queue, 0 do |response| event = LogStash::Event.new({ "@message" => response, "@type" => @type, "@tags" => @tags.clone, }) event.source = @url @callback.call(event) pop.call end end pop.call end end