mirror of
https://github.com/elastic/logstash.git
synced 2025-04-21 21:27:20 -04:00
76286b4f0e
Work done by @guyboertje and @ph Since JRuby 1.7.25 is now EOL we are migrating Logstash to use JRuby 9k and JDK8 only, Not much needed updating to make this work, its was mostly a drop in replacement from the previous version. The major point was the change in the implementation of Time in JRuby, JRuby now use `java.time` instead of joda time, this allow JRuby to have nanoseconds precision on time object.
73 lines
2.2 KiB
Ruby
73 lines
2.2 KiB
Ruby
# encoding: utf-8
|
|
require_relative 'coverage_helper'
|
|
# In order to archive an expected coverage analysis we need to eager load
|
|
# all logstash code base, otherwise it will not get a good analysis.
|
|
CoverageHelper.eager_load if ENV['COVERAGE']
|
|
|
|
require "logstash/devutils/rspec/spec_helper"
|
|
|
|
require "flores/rspec"
|
|
require "flores/random"
|
|
require "pathname"
|
|
require "stud/task"
|
|
require "logstash/devutils/rspec/spec_helper"
|
|
require "support/resource_dsl_methods"
|
|
require "support/mocks_classes"
|
|
require "support/helpers"
|
|
require "support/shared_contexts"
|
|
require "support/shared_examples"
|
|
require 'rspec/expectations'
|
|
require "logstash/settings"
|
|
require 'rack/test'
|
|
require 'rspec'
|
|
require "json"
|
|
|
|
|
|
class JSONIOThingy < IO
|
|
def initialize; end
|
|
def flush; end
|
|
|
|
def puts(payload)
|
|
# Ensure that all log payloads are valid json.
|
|
LogStash::Json.load(payload)
|
|
end
|
|
end
|
|
|
|
# Refactor the suite to https://github.com/elastic/logstash/issues/7148
|
|
RSpec::Expectations.configuration.on_potential_false_positives = :nothing
|
|
|
|
RSpec.configure do |c|
|
|
Flores::RSpec.configure(c)
|
|
c.include LogStashHelper
|
|
c.extend LogStashHelper
|
|
|
|
c.before(:each) do
|
|
# TODO: commented out on post-merged in master - the logger has moved to log4j
|
|
#
|
|
#
|
|
# Force Cabin to always have a JSON subscriber. The main purpose of this
|
|
# is to catch crashes in json serialization for our logs. JSONIOThingy
|
|
# exists to validate taht what LogStash::Logging::JSON emits is always
|
|
# valid JSON.
|
|
# jsonvalidator = JSONIOThingy.new
|
|
# allow(Cabin::Channel).to receive(:new).and_wrap_original do |m, *args|
|
|
# logger = m.call(*args)
|
|
# logger.level = :debug
|
|
# logger.subscribe(LogStash::Logging::JSON.new(jsonvalidator))
|
|
#
|
|
# logger
|
|
# end
|
|
|
|
# Some tests mess with the settings. This ensures one test cannot pollute another
|
|
LogStash::SETTINGS.reset
|
|
|
|
LogStash::SETTINGS.set("queue.type", "memory_acked")
|
|
LogStash::SETTINGS.set("queue.page_capacity", 1024 * 1024)
|
|
LogStash::SETTINGS.set("queue.max_events", 250)
|
|
end
|
|
end
|
|
|
|
def installed_plugins
|
|
Gem::Specification.find_all.select { |spec| spec.metadata["logstash_plugin"] }.map { |plugin| plugin.name }
|
|
end
|
|
|