Sha256: ecaeb90f87877ddbf47917905f16b98ed675427270338039493b5b3188505e06
Contents?: true
Size: 796 Bytes
Versions: 1
Compression:
Stored size: 796 Bytes
Contents
# encoding: utf-8 require "logstash/codecs/base" class LogStash::Codecs::Spool < LogStash::Codecs::Base config_name 'spool' milestone 1 config :spool_size, :validate => :number, :default => 50 attr_reader :buffer public def decode(data) data.each do |event| yield event end end # def decode public def encode(data) @buffer = [] if @buffer.nil? #buffer size is hard coded for now until a #better way to pass args into codecs is implemented if @buffer.length >= @spool_size @on_event.call @buffer @buffer = [] else @buffer << data end end # def encode public def teardown if !@buffer.nil? and @buffer.length > 0 @on_event.call @buffer end @buffer = [] end end # class LogStash::Codecs::Spool
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
logstash-lib-1.3.2 | lib/logstash/codecs/spool.rb |