Sha256: 1e1979ef028bc8c0659af5bccb1721f21019825d2aa117c8f68e15aa55a1bca7
Contents?: true
Size: 1.52 KB
Versions: 7
Compression:
Stored size: 1.52 KB
Contents
# encoding: utf-8
require "logstash/pipeline_action/base"
require "logstash/pipeline"
require "logstash/converge_result"
require "logstash/util/loggable"
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)
pipeline = LogStash::Pipeline.new(@pipeline_config, @metric, agent)
status = pipeline.start # block until the pipeline is correctly started or crashed
if status
pipelines[pipeline_id] = pipeline # The pipeline is successfully started we can add it to the hash
end
LogStash::ConvergeResult::ActionResult.create(self, status)
end
end
end end
Version data entries
7 entries across 7 versions & 1 rubygems