Sha256: cbe712ce07a78624ca2de2268189b464f0272b6312e4f00f662fefc947e4407f
Contents?: true
Size: 1.46 KB
Versions: 5
Compression:
Stored size: 1.46 KB
Contents
# encoding: utf-8
require "logstash/outputs/base"
require "logstash/namespace"
# A simple output which prints to the STDOUT of the shell running
# Logstash. This output can be quite convenient when debugging
# plugin configurations, by allowing instant access to the event
# data after it has passed through the inputs and filters.
#
# For example, the following output configuration, in conjunction with the
# Logstash `-e` command-line flag, will allow you to see the results
# of your event pipeline for quick iteration.
# [source,ruby]
# output {
# stdout {}
# }
#
# Useful codecs include:
#
# `rubydebug`: outputs event data using the ruby "awesome_print"
# http://rubygems.org/gems/awesome_print[library]
#
# [source,ruby]
# output {
# stdout { codec => rubydebug }
# }
#
# `json`: outputs event data in structured JSON format
# [source,ruby]
# output {
# stdout { codec => json }
# }
#
class LogStash::Outputs::Stdout < LogStash::Outputs::Base
config_name "stdout"
default :codec, "line"
if self.respond_to?(:workers_not_supported!) # Check for v2.2+ API
declare_workers_not_supported!("Stdout only supports one worker to prevent text overlap!")
end
public
def register
workers_not_supported # < v2.2 API
@codec.on_event do |event, data|
$stdout.write(data)
end
end
def receive(event)
return if event == LogStash::SHUTDOWN
@codec.encode(event)
end
end # class LogStash::Outputs::Stdout
Version data entries
5 entries across 5 versions & 1 rubygems