Sha256: f1cfd70bb6af94508fb78d1094bdf99655705e7368a2d214b4e7684e2e39577e

Contents?: true

Size: 444 Bytes

Versions: 39

Compression:

Stored size: 444 Bytes

Contents

module LogStash module OutputDelegatorStrategies class Shared
  def initialize(logger, klass, metric, plugin_args)
    @output = klass.new(plugin_args)
    @output.metric = metric
  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

39 entries across 38 versions & 9 rubygems

Version Path
logstash-filter-csharp-0.2.1 vendor/bundle/jruby/2.3.0/gems/logstash-core-5.2.1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-csharp-0.2.0 vendor/bundle/jruby/2.3.0/gems/logstash-core-5.2.1-java/lib/logstash/output_delegator_strategies/shared.rb
mrcooper-logstash-output-azuresearch-0.2.2 vendor/jruby/2.5.0/gems/logstash-core-5.0.0-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-output-icinga-1.1.0 vendor/jruby/1.9/gems/logstash-core-5.2.1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-output-icinga-1.1.0 vendor/jruby/2.3.0/gems/logstash-core-5.2.1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-csharp-0.1.0 vendor/bundle/jruby/2.3.0/gems/logstash-core-5.2.1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.3.3-java lib/logstash/output_delegator_strategies/shared.rb
logstash-output-icinga-1.0.0 vendor/jruby/1.9/gems/logstash-core-5.2.1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.3.2-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.3.1-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.3.0-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.2.2-java lib/logstash/output_delegator_strategies/shared.rb
logstash-input-fifo-0.9.1 vendor/bundle/jruby/1.9/gems/logstash-core-5.1.1.1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-input-fifo-0.9.0 vendor/bundle/jruby/1.9/gems/logstash-core-5.1.1.1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.2.1-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.2.0-java lib/logstash/output_delegator_strategies/shared.rb
logstash-input-salesforce-3.0.0 vendor/jruby/1.9/gems/logstash-core-5.1.1.1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.1.2-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.1.1.1-java lib/logstash/output_delegator_strategies/shared.rb
ivanvc-logstash-input-s3-3.1.1.4 vendor/local/gems/logstash-core-5.1.2.snapshot1-java/lib/logstash/output_delegator_strategies/shared.rb