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)
		@writer = LogstashWriter.new(servers)

		@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

6 entries across 6 versions & 1 rubygems

Version	Path
syslogstash-0.1.5	lib/syslogstash.rb
syslogstash-0.1.4	lib/syslogstash.rb
syslogstash-0.1.3	lib/syslogstash.rb
syslogstash-0.1.2	lib/syslogstash.rb
syslogstash-0.1.1	lib/syslogstash.rb
syslogstash-0.1.0	lib/syslogstash.rb