Contents

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

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

		@writer = LogstashWriter.new(servers, backlog, @metrics)

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

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

		tw = ThreadsWait.new(@metrics.thread, @writer.thread, *(@readers.map { |r| r.thread }))

		dead_thread = tw.next_wait

		if dead_thread == @writer.thread
			$stderr.puts "Writer thread crashed."
		elsif dead_thread == @metrics.thread
			$stderr.puts "Metrics exporter thread crashed."
		else
			reader = @readers.find { |r| r.thread == dead_thread }

			$stderr.puts "Reader thread for #{reader.file} crashed."
		end

		begin
			dead_thread.join
		rescue Exception => ex
			$stderr.puts "Exception in thread was: #{ex.message} (#{ex.class})"
			$stderr.puts ex.backtrace.map { |l| "  #{l}" }.join("\n")
		end

		exit 1
	end
end

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

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
syslogstash-0.4.1	lib/syslogstash.rb
syslogstash-0.4.0	lib/syslogstash.rb