Sha256: eac15f45542bdcf02fe9af53391b7509c2d9cdfcfe9ba369f37c5f329fa121d2
Contents?: true
Size: 1.64 KB
Versions: 17
Compression:
Stored size: 1.64 KB
Contents
# encoding: utf-8
require "logstash/pipeline_action/base"
require "logstash/pipeline"
require "logstash/java_pipeline"
module LogStash module PipelineAction
class Create < Base
include LogStash::Util::Loggable
# We currently pass around the metric object again this
# is needed to correctly create a pipeline, in a future
# PR we could pass a factory to create the pipeline so we pass the logic
# to create the pipeline instead.
def initialize(pipeline_config, metric)
@pipeline_config = pipeline_config
@metric = metric
end
def pipeline_id
@pipeline_config.pipeline_id
end
# Make sure we execution system pipeline like the monitoring
# before any user defined pipelines, system pipeline register hooks into the system that will be
# triggered by the user defined pipeline.
def execution_priority
default_priority = super
@pipeline_config.system? ? default_priority * -1 : default_priority
end
# The execute assume that the thread safety access of the pipeline
# is managed by the caller.
def execute(agent, pipelines_registry)
pipeline_class = @pipeline_config.settings.get_value("pipeline.java_execution") ? LogStash::JavaPipeline : LogStash::Pipeline
new_pipeline = pipeline_class.new(@pipeline_config, @metric, agent)
success = pipelines_registry.create_pipeline(pipeline_id, new_pipeline) do
new_pipeline.start # block until the pipeline is correctly started or crashed
end
LogStash::ConvergeResult::ActionResult.create(self, success)
end
def to_s
"PipelineAction::Create<#{pipeline_id}>"
end
end
end end
Version data entries
17 entries across 17 versions & 1 rubygems