Sha256: 383fae0214240cd7df140a75703e7c54fc4cf613b088e27649c33c21458c63cf
Contents?: true
Size: 1.11 KB
Versions: 7
Compression:
Stored size: 1.11 KB
Contents
require 'spec_helper'
require 'riak'
describe Riak::Counter, test_server: true, integration: true do
before :all do
opts = {
http_port: test_server.http_port,
pb_port: test_server.pb_port,
protocol: 'pbc'
}
test_server.start
@client = Riak::Client.new opts
@bucket = @client['counter_spec']
@bucket.allow_mult = true
@counter = Riak::Counter.new @bucket, 'counter_spec'
end
['pbc', 'http'].each do |protocol|
describe protocol do
before :all do
@client.protocol = protocol
end
it 'should read and update' do
initial = @counter.value
@counter.increment
@counter.increment
@counter.value.should == (initial + 2)
@counter.decrement 2
@counter.value.should == initial
5.times do
amt = rand(10_000)
@counter.increment amt
@counter.value.should == (initial + amt)
@counter.decrement (amt * 2)
@counter.value.should == (initial - amt)
@counter.increment_and_return(amt).should == initial
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems