-
Notifications
You must be signed in to change notification settings - Fork 17
/
glob-tail.rb
47 lines (41 loc) · 1.09 KB
/
glob-tail.rb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
#!/usr/bin/env ruby
#
# Sample that uses eventmachine-tail to watch a file or set of files.
# Basically, this example implements 'tail -f' but can accept globs
# that are also watched.
#
# For example, '/var/log/*.log' will be periodically watched for new
# matching files which will additionally be watched.
#
# Usage example:
# glob-tail.rb "/var/log/*.log" "/var/log/httpd/*.log"
#
# (Important to use quotes or otherwise escape the '*' chars, otherwise
# your shell will interpret them)
require "rubygems"
require "eventmachine"
require "eventmachine-tail"
class Reader < EventMachine::FileTail
def initialize(path, startpos=-1)
super(path, startpos)
puts "Tailing #{path}"
@buffer = BufferedTokenizer.new
end
def receive_data(data)
@buffer.extract(data).each do |line|
puts "#{path}: #{line}"
end
end
end
def main(args)
if args.length == 0
puts "Usage: #{$0} <path_or_glob> [path_or_glob2] [...]"
return 1
end
EventMachine.run do
args.each do |path|
EventMachine::FileGlobWatchTail.new(path, Reader)
end
end
end # def main
exit(main(ARGV))