mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 14:47:19 -04:00
- remove hacks/testing files that we won't be packaging up
This commit is contained in:
parent
d4459ebf46
commit
c02eb62bcc
5 changed files with 0 additions and 112 deletions
|
@ -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"
|
|
@ -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
|
|
@ -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 }
|
|
@ -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
|
|
@ -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
|
Loading…
Add table
Add a link
Reference in a new issue