Contents

require 'uri'
require 'socket'
require 'json'

# Read syslog messages from one or more sockets, and send it to a logstash
# server.
#
class Syslogstash
	def initialize(sockets, servers, backlog)
		@writer = LogstashWriter.new(servers, backlog)

		@readers = sockets.map { |f, tags| SyslogReader.new(f, tags, @writer) }
	end

	def run
		@writer.run
		@readers.each { |w| w.run }

		@writer.wait
		@readers.each { |w| w.wait }
	end
end

require_relative 'syslogstash/syslog_reader'
require_relative 'syslogstash/logstash_writer'

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
syslogstash-0.2.0	lib/syslogstash.rb