Sha256: 813184a7ea75ac921360300038bc2b673299b728f2cce38fab5a94044979dd1b
Contents?: true
Size: 520 Bytes
Versions: 20
Compression:
Stored size: 520 Bytes
Contents
# encoding: utf-8
require "logstash/util/dead_letter_queue_manager"
module LogStash
class ExecutionContext
attr_reader :pipeline, :agent, :dlq_writer
def initialize(pipeline, agent, plugin_id, plugin_type, dlq_writer)
@pipeline = pipeline
@agent = agent
@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
20 entries across 20 versions & 1 rubygems