Sha256: a6ef80c270961bcbf7ac0d9c56719c3a1df4bb2901edfd4975515ddb57f257d9
Contents?: true
Size: 719 Bytes
Versions: 113
Compression:
Stored size: 719 Bytes
Contents
# encoding: utf-8
require "logstash/inputs/beats"
module LogStash module Inputs class Beats
# Use the new callback based approch 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`,
# usefull 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
113 entries across 113 versions & 1 rubygems