Sha256: 50c2a9084e3130c7d08ddb1e8a4851d800621389ee10009121eff3db7b44eea1
Contents?: true
Size: 719 Bytes
Versions: 2
Compression:
Stored size: 719 Bytes
Contents
# encoding: utf-8 require "logstash/inputs/beats" module LogStash module Inputs class Beats # Use the new callback based approach instead of using blocks # so we can retain some context of the execution, and make it easier to test class CodecCallbackListener attr_accessor :data # The path acts as the `stream_identity`, # useful when the clients is reading multiples files attr_accessor :path def initialize(data, hash, path, transformer, queue) @data = data @hash = hash @path = path @queue = queue @transformer = transformer end def process_event(event) @transformer.transform(event, @hash) @queue << event end end end; end; end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
logstash-input-beats-6.9.1-java | lib/logstash/inputs/beats/codec_callback_listener.rb |
logstash-input-beats-6.9.0-java | lib/logstash/inputs/beats/codec_callback_listener.rb |