Sha256: f2b7e18e3859297cf6a0044a7f2438d001282e14dd82d59371964d3a378b429a
Contents?: true
Size: 571 Bytes
Versions: 39
Compression:
Stored size: 571 Bytes
Contents
module LogStash module OutputDelegatorStrategies class Single
def initialize(logger, klass, metric, plugin_args)
@output = klass.new(plugin_args)
@output.metric = metric
@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
39 entries across 38 versions & 9 rubygems