Contents

# encoding: utf-8
module LogStash
  class ExecutionContext
    attr_reader :pipeline, :agent

    def initialize(pipeline, agent)
      @pipeline = pipeline
      @agent = agent
    end
    
    def pipeline_id
      @pipeline.pipeline_id
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logstash-core-6.0.0.alpha1-java	lib/logstash/execution_context.rb