Sha256: eab88a7bcf640b6acfbdb6e2661e0b1126e09e07dbb8117eaeb82722ead8251c

Contents?: true

Size: 474 Bytes

Versions: 104

Compression:

Stored size: 474 Bytes

Contents

# encoding: utf-8
class LogStash::Codecs::Base
  # This monkey patch add callback based
  # flow to the codec until its shipped with core.
  # This give greater flexibility to the implementation by
  # sending more data to the actual block.
  if !method_defined?(:accept)
    def accept(listener)
      decode(listener.data) do |event|
        listener.process_event(event)
      end
    end
  end
  if !method_defined?(:auto_flush)
    def auto_flush(*)
    end
  end
end

Version data entries

104 entries across 104 versions & 1 rubygems

Version Path
logstash-input-beats-7.0.2-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.9.3-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.9.2-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-7.0.1-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-7.0.0-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.9.1-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.9.0-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.8.4-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.8.3-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.8.2-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.8.1-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.8.0-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.7.2-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.7.1-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.7.0-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.6.4-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.6.3-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.6.2-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.6.1-java lib/logstash/inputs/beats/patch.rb
logstash-input-beats-6.6.0-java lib/logstash/inputs/beats/patch.rb