Class: LogStash::Inputs::Reqsample

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/inputs/reqsample.rb

Overview

Generate randomized webserver log strings.

Logs can be generated at once in bulk, or streamed over time.

Instance Method Summary collapse

Instance Method Details

#register ⇒ Object 



43
44
45
46
47
48
49
50
51
52
 
# File 'lib/logstash/inputs/reqsample.rb', line 43

def register
  @host = Socket.gethostname
  @generator = ::ReqSample::Generator.new @stdev
  @production_options = {
    :count => @count,
    :format => @format,
    :truncate => @truncate,
    :peak => Chronic.parse(@peak)
  }
end

#run(queue) ⇒ Object

def register



54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/logstash/inputs/reqsample.rb', line 54

def run(queue)
  if @stream
    @generator.produce(@production_options) do |log|
      break if stop?
      event = LogStash::Event.new('message' => log, 'host' => @host)
      decorate(event)
      queue << event
    end # produce
  else
    @generator.produce(@production_options).each do |log|
      break if stop?
      event = LogStash::Event.new('message' => log, 'host' => @host)
      decorate(event)
      queue << event
    end # produce
  end # if @stream
end