class LogStash::Outputs::Redis
Public Instance Methods
receive(event)
click to toggle source
# File lib/logstash/outputs/redis.rb, line 22 def receive(event) @redis.rpush(event.sprintf(@queue), { :source_host => @hostname, :source => event.source, :message => event.message }.to_json) end
register()
click to toggle source
# File lib/logstash/outputs/redis.rb, line 7 def register @port = nil @password = nil @host = @url.host _, @db, @queue = @url.path.split('/') require 'socket' @hostname = Socket.gethostname @work = [] @redis = EM::Protocols::Redis.connect({ :host => @host, :port => @port, :db => @db }) end