Sha256: e20ee6f89d5c8998f09e03b6a9d44cdec37b50049c530d3d6116266eacade5df
Contents?: true
Size: 1.87 KB
Versions: 11
Compression:
Stored size: 1.87 KB
Contents
# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/outputs/s3/time_rotation_policy"
require "logstash/outputs/s3/temporary_file"
describe LogStash::Outputs::S3::TimeRotationPolicy do
subject { described_class.new(max_time) }
let(:max_time) { 1 }
let(:temporary_directory) { Stud::Temporary.directory }
let(:temporary_file) { Stud::Temporary.file }
let(:name) { "foobar" }
let(:content) { "hello" * 1000 }
let(:file) { LogStash::Outputs::S3::TemporaryFile.new(name, temporary_file, temporary_directory) }
it "raises an exception if the `file_time` is set to 0" do
expect { described_class.new(0) }.to raise_error(LogStash::ConfigurationError, /`time_file` need to be greater than 0/)
end
it "raises an exception if the `file_time` is < 0" do
expect { described_class.new(-100) }.to raise_error(LogStash::ConfigurationError, /`time_file` need to be greater than 0/)
end
context "when the size of the file is superior to 0" do
before :each do
file.write(content)
file.fsync
end
it "returns true if the file old enough" do
allow(file).to receive(:ctime).and_return(Time.now - (max_time * 2 * 60))
expect(subject.rotate?(file)).to be_truthy
end
it "returns false is not old enough" do
expect(subject.rotate?(file)).to be_falsey
end
end
context "When the size of the file is 0" do
it "returns false if the file old enough" do
allow(file).to receive(:ctime).and_return(Time.now - (max_time * 2 * 60))
expect(subject.rotate?(file)).to be_falsey
end
it "returns false is not old enough" do
expect(subject.rotate?(file)).to be_falsey
end
end
context "#needs_periodic?" do
it "return false" do
expect(subject.needs_periodic?).to be_truthy
end
end
it "convert minute into seconds" do
expect(subject.time_file).to eq(60)
end
end
Version data entries
11 entries across 11 versions & 1 rubygems