Sha256: 88c6a5887b63847a95672f8b746a576300cecf8b2abc9a33e0160dca917e7df0
Contents?: true
Size: 1.88 KB
Versions: 9
Compression:
Stored size: 1.88 KB
Contents
require_relative "../../../spec/es_spec_helper"
shared_examples "an indexer" do
let(:index) { 10.times.collect { rand(10).to_s }.join("") }
let(:type) { 10.times.collect { rand(10).to_s }.join("") }
let(:event_count) { 10000 + rand(500) }
let(:flush_size) { rand(200) + 1 }
let(:config) { "not implemented" }
subject { LogStash::Outputs::ElasticSearch.new(config) }
before do
subject.register
event_count.times do
subject.multi_receive([LogStash::Event.new("message" => "Hello World!", "type" => type)])
end
end
it "ships events" do
index_url = "http://#{get_host_port}/#{index}"
ftw = FTW::Agent.new
ftw.post!("#{index_url}/_refresh")
# Wait until all events are available.
Stud::try(10.times) do
data = ""
response = ftw.get!("#{index_url}/_count?q=*")
response.read_body { |chunk| data << chunk }
result = LogStash::Json.load(data)
cur_count = result["count"]
insist { cur_count } == event_count
end
response = ftw.get!("#{index_url}/_search?q=*&size=1000")
data = ""
response.read_body { |chunk| data << chunk }
result = LogStash::Json.load(data)
result["hits"]["hits"].each do |doc|
insist { doc["_type"] } == type
insist { doc["_index"] } == index
end
end
end
describe "an indexer with custom index_type", :integration => true do
it_behaves_like "an indexer" do
let(:config) {
{
"hosts" => get_host_port,
"index" => index,
"flush_size" => flush_size
}
}
end
end
describe "an indexer with no type value set (default to logs)", :integration => true do
it_behaves_like "an indexer" do
let(:type) { "logs" }
let(:config) {
{
"hosts" => get_host_port,
"index" => index,
"flush_size" => flush_size
}
}
end
end
Version data entries
9 entries across 9 versions & 1 rubygems