Class: LogStash::ExecutionContext

Inherits:
Object
  • Object
show all
Defined in:
lib/logstash/execution_context.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(pipeline, agent, plugin_id, plugin_type, dlq_writer) ⇒ ExecutionContext

Returns a new instance of ExecutionContext.



7
8
9
10
11
12
13
 
# File 'lib/logstash/execution_context.rb', line 7

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

Instance Attribute Details

#agent ⇒ Object (readonly)

Returns the value of attribute agent.



5
6
7
 
# File 'lib/logstash/execution_context.rb', line 5

def agent
  @agent
end

#dlq_writer ⇒ Object (readonly)

Returns the value of attribute dlq_writer.



5
6
7
 
# File 'lib/logstash/execution_context.rb', line 5

def dlq_writer
  @dlq_writer
end

#pipeline ⇒ Object (readonly)

Returns the value of attribute pipeline.



5
6
7
 
# File 'lib/logstash/execution_context.rb', line 5

def pipeline
  @pipeline
end

Instance Method Details

#pipeline_id ⇒ Object 



15
16
17
 
# File 'lib/logstash/execution_context.rb', line 15

def pipeline_id
  @pipeline.pipeline_id
end