Sha256: 5db5f6288a2d0cb43cf5b351829517e11815a71241a8b528e99559dad430df92
Contents?: true
Size: 589 Bytes
Versions: 47
Compression:
Stored size: 589 Bytes
Contents
# encoding: utf-8
require "logstash/pipeline_action/base"
module LogStash module PipelineAction
class Stop < Base
attr_reader :pipeline_id
def initialize(pipeline_id)
@pipeline_id = pipeline_id
end
def execute(agent, pipelines_registry)
pipelines_registry.terminate_pipeline(pipeline_id) do |pipeline|
pipeline.shutdown { LogStash::ShutdownWatcher.start(pipeline) }
pipeline.thread.join
end
LogStash::ConvergeResult::SuccessfulAction.new
end
def to_s
"PipelineAction::Stop<#{pipeline_id}>"
end
end
end end
Version data entries
47 entries across 47 versions & 1 rubygems