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
ivanvc-logstash-input-s3-3.1.1.3 vendor/local/gems/logstash-core-5.1.2.snapshot1-java/lib/logstash/output_delegator_strategies/shared.rb
ivanvc-logstash-input-s3-3.1.1.2 vendor/local/gems/logstash-core-5.1.2.snapshot1-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.2-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.1-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.0-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.0.pre.rc1-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.0.pre.beta1-java lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-delta-1.1.0 vendor/bundle/jruby/2.2.0/gems/logstash-core-5.0.0.alpha6.snapshot5-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-delta-1.0.1 vendor/bundle/jruby/2.2.0/gems/logstash-core-5.0.0.alpha6.snapshot5-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-base64-1.0.4 vendor/bundle/jruby/2.2.0/gems/logstash-core-5.0.0.alpha6.snapshot5-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-base64-1.0.3 vendor/bundle/jruby/2.2.0/gems/logstash-core-5.0.0.alpha6.snapshot5-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-delta-1.0.0 vendor/bundle/jruby/2.2.0/gems/logstash-core-5.0.0.alpha6.snapshot5-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-base64-1.0.2 vendor/bundle/jruby/2.3.0/gems/logstash-core-5.0.0.alpha6.snapshot5-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-base64-1.0.1 vendor/bundle/jruby/2.3.0/gems/logstash-core-5.0.0.alpha6.snapshot5-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-filter-base64-1.0.0 vendor/bundle/jruby/2.3.0/gems/logstash-core-5.0.0.alpha6.snapshot5-java/lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.0.alpha6.snapshot5-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.0.alpha6.snapshot4-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.0.alpha6.snapshot3-java lib/logstash/output_delegator_strategies/shared.rb
logstash-core-5.0.0.alpha6.snapshot2-java lib/logstash/output_delegator_strategies/shared.rb