Sha256: 35aec33666e277769264165f3c3235b16ef079b70561c6da22b9fe46ec331c3c
Contents?: true
Size: 484 Bytes
Versions: 57
Compression:
Stored size: 484 Bytes
Contents
# encoding: utf-8
require "logstash/util/dead_letter_queue_manager"
module LogStash
class ExecutionContext
attr_reader :pipeline, :dlq_writer
def initialize(pipeline, plugin_id, plugin_type, dlq_writer)
@pipeline = pipeline
@plugin_id = plugin_id
@plugin_type = plugin_type
@dlq_writer = LogStash::Util::PluginDeadLetterQueueWriter.new(dlq_writer, @plugin_id, @plugin_type)
end
def pipeline_id
@pipeline.pipeline_id
end
end
end
Version data entries
57 entries across 57 versions & 6 rubygems