Sha256: ca6deca1ee78705940552e0e5d709335f9c7e03a9beb800b212107dcb3a86116
Contents?: true
Size: 1.34 KB
Versions: 14
Compression:
Stored size: 1.34 KB
Contents
# encoding: utf-8
require "spec_helper"
describe LogStash::WrappedAckedQueue do
shared_examples "queue tests" do
it "is_empty? on creation" do
expect(queue.is_empty?).to be_truthy
end
it "not is_empty? after pushing an element" do
queue.push(LogStash::Event.new)
expect(queue.is_empty?).to be_falsey
end
it "not is_empty? when all elements are not acked" do
queue.push(LogStash::Event.new)
batch = queue.read_batch(1, 250).to_java
expect(batch.size()).to eq(1)
expect(queue.is_empty?).to be_falsey
end
it "is_empty? when all elements are acked" do
queue.push(LogStash::Event.new)
batch = queue.read_batch(1, 250).to_java
expect(batch.size()).to eq(1)
expect(queue.is_empty?).to be_falsey
batch.close
expect(queue.is_empty?).to be_truthy
end
end
context "persisted" do
let(:page_capacity) { 1024 }
let(:max_events) { 0 }
let(:max_bytes) { 0 }
let(:checkpoint_acks) { 1024 }
let(:checkpoint_writes) { 1024 }
let(:checkpoint_interval) { 0 }
let(:path) { Stud::Temporary.directory }
let(:queue) { LogStash::WrappedAckedQueue.new(path, page_capacity, max_events, checkpoint_acks, checkpoint_writes, checkpoint_interval, max_bytes) }
after do
queue.close
end
include_examples "queue tests"
end
end
Version data entries
14 entries across 14 versions & 1 rubygems