Sha256: 1e5b783767c113fbe4633be8a87391eb96028b5ae61b425c3d619808115a2ff8
Contents?: true
Size: 640 Bytes
Versions: 76
Compression:
Stored size: 640 Bytes
Contents
module LogStash module OutputDelegatorStrategies class Single
def initialize(logger, klass, metric, execution_context, plugin_args)
@output = klass.new(plugin_args)
@output.metric = metric
@output.execution_context = execution_context
@mutex = Mutex.new
end
def register
@output.register
end
def multi_receive(events)
@mutex.synchronize do
@output.multi_receive(events)
end
end
def do_close
# No mutex needed since this is only called when the pipeline is clear
@output.do_close
end
::LogStash::OutputDelegatorStrategyRegistry.instance.register(:single, self)
end; end; end
Version data entries
76 entries across 76 versions & 7 rubygems