Sha256: ba025f7161eeeda8b85b6e07240a0c63d3e64f7a4992202a996582c70904f121
Contents?: true
Size: 513 Bytes
Versions: 76
Compression:
Stored size: 513 Bytes
Contents
module LogStash module OutputDelegatorStrategies class Shared
def initialize(logger, klass, metric, execution_context, plugin_args)
@output = klass.new(plugin_args)
@output.metric = metric
@output.execution_context = execution_context
end
def register
@output.register
end
def multi_receive(events)
@output.multi_receive(events)
end
def do_close
@output.do_close
end
::LogStash::OutputDelegatorStrategyRegistry.instance.register(:shared, self)
end; end; end
Version data entries
76 entries across 76 versions & 7 rubygems