Sha256: 8fc5356062ff06b2f4fb93a95c0af32b4aa31b1900923c2310c84b1cd42d73ed
Contents?: true
Size: 1.92 KB
Versions: 7
Compression:
Stored size: 1.92 KB
Contents
require 'spec_helper'
require 'riak/stamp'
describe Riak::Stamp, test_client: true do
subject { described_class.new test_client }
it "generates always increasing integer identifiers" do
1000.times do
one = subject.next
two = subject.next
expect([one, two]).to be_all {|i| Integer === i }
expect(two).to be > one
end
end
it "delays until the next millisecond when the sequence overflows" do
old = subject.instance_variable_get(:@timestamp) + 0
subject.instance_variable_set(:@sequence, described_class::SEQUENCE_MASK)
count = 0
# Simulate the time_gen method returning the same thing multiple times
allow(subject).to receive(:time_gen) do
count += 1
if count < 10
old
else
old + 1
end
end
expect((subject.next >> described_class::TIMESTAMP_SHIFT) & described_class::TIMESTAMP_MASK).to eq(old + 1)
end
it "raises an exception when the system clock moves backwards" do
old = subject.instance_variable_get(:@timestamp)
expect(subject).to receive(:time_gen).and_return(old - 10)
expect {
subject.next
}.to raise_error(Riak::BackwardsClockError)
end
# The client/worker ID should be used for disambiguation, not for
# primary ordering. This breaks from the Snowflake model where the
# worker ID is in more significant bits.
it "uses the client ID as the bottom component of the identifier" do
expect(subject.next & described_class::CLIENT_ID_MASK).to eq(subject.client.client_id.hash & described_class::CLIENT_ID_MASK)
end
context "using a non-integer client ID" do
subject { described_class.new(Riak::Client.new(:client_id => "ripple")) }
let(:hash) { "ripple".hash }
it "uses the hash of the client ID as the bottom component of the identifier" do
expect(subject.next & described_class::CLIENT_ID_MASK).to eq(subject.client.client_id.hash & described_class::CLIENT_ID_MASK)
end
end
end
Version data entries
7 entries across 7 versions & 2 rubygems