diff --git a/bin/import.rb b/bin/import.rb deleted file mode 100755 index 524e26618..000000000 --- a/bin/import.rb +++ /dev/null @@ -1,32 +0,0 @@ -#!/usr/bin/ruby - -require 'rubygems' -require 'json' -require 'socket' - - -log_name = ARGV[0] -log_path = ARGV[1] || "/dev/stdin" -source_host = %x(hostname).chomp - -if not log_name - $stderr.puts "usage: import.rb log_name [path]" - exit 1 -end - -sock = TCPSocket.new('127.0.0.1', 12345) -size = 0 -start_t = Time.now.to_f -File.open(log_path).each do |line| - msg = {"log_name" => log_name, - "raw_entry" => line, - "source_host" => source_host, - } - sock.puts msg.to_json - size += line.length -end -end_t = Time.now.to_f -sock.close - -size /= 1024.0 # kB -puts "import rate: #{size/(end_t-start_t)} kB/s" diff --git a/bin/list_json_keys b/bin/list_json_keys deleted file mode 100755 index 6132f84fb..000000000 --- a/bin/list_json_keys +++ /dev/null @@ -1,14 +0,0 @@ -#!/usr/bin/ruby - -require 'rubygems' -require 'json' -require 'lib/util' - -all_keys = {} -$stdin.each do |line| - LogStash::Util.collapse(JSON.parse(line)).keys.each do |k| - all_keys[k] = true - end -end - -puts all_keys.keys.sort diff --git a/bin/list_keys b/bin/list_keys deleted file mode 100755 index e0eef8147..000000000 --- a/bin/list_keys +++ /dev/null @@ -1,9 +0,0 @@ -#!/usr/bin/ruby - -require 'rubygems' -require 'ferret' - -include Ferret - -i = Index::IndexReader.new(ARGV[0]) -puts i.fields.sort { |a, b| a.to_s <=> b.to_s } diff --git a/bin/sendblock.rb b/bin/sendblock.rb deleted file mode 100644 index e8123f683..000000000 --- a/bin/sendblock.rb +++ /dev/null @@ -1,36 +0,0 @@ -#!/usr/bin/ruby -# -require 'rubygems' -require "socket" -require "lib/net/message" -require "lib/net/client" -require "lib/net/messages/directory" -require "lib/net/messages/indexevent" -require "lib/net/messages/search" -require "lib/net/messages/searchhits" -require "lib/net/messages/ping" -require "set" -require "thread" - -Thread::abort_on_exception = true - -class SearchClient < LogStash::Net::MessageClient -end - -def main(args) - client = SearchClient.new - msg = LogStash::Net::Messages::PingRequest.new - op = client.sendmsg("logstash-directory", msg) do |response| - puts response - :finished - end - - op.wait_until_finished - puts "Done!" - - return 0 -end - -if $0 == __FILE__ - exit main(ARGV) -end diff --git a/bin/test_parse_entry b/bin/test_parse_entry deleted file mode 100755 index 85e7ff10f..000000000 --- a/bin/test_parse_entry +++ /dev/null @@ -1,21 +0,0 @@ -#!/usr/bin/ruby - -home = ENV["LOGSTASH_HOME"] || "/opt/logstash" -require "#{home}/config.rb" - -log_type = ARGV[0] -log = $logs[log_type] -if not log - $stderr.puts "invalid log_type=#{log_type} specified" - exit 1 -end - -$stdin.each do |line| - res = log.parse_entry(line) - if res - res.delete("@LINE") - puts res.inspect - else - $stderr.puts "** DID NOT MATCH: #{line}" - end -end