Packages
exq
0.16.1
0.23.0
0.22.0
0.21.0
0.20.0
0.19.0
0.18.0
0.17.0
0.16.2
0.16.1
0.16.0
0.15.0
0.14.0
0.13.5
0.13.4
0.13.3
0.13.2
0.13.1
0.13.0
0.12.2
0.12.1
0.12.0
0.11.0
0.10.1
0.10.0
0.9.1
0.9.0
0.8.7
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.3
0.7.2
0.7.1
0.7.0
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.0
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
0.3.0
0.2.3
0.2.2
0.2.1
0.2.0
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
0.0.2
Exq is a job processing library compatible with Resque / Sidekiq for the Elixir language.
Current section
Files
Jump to
Current section
Files
test/redis_test.exs
defmodule Exq.RedisTest do
use ExUnit.Case
alias Exq.Redis.Connection
setup_all do
ExqTestUtil.reset_config()
TestRedis.setup()
on_exit(fn ->
ExqTestUtil.reset_config()
TestRedis.teardown()
end)
end
setup do
on_exit(fn ->
Connection.flushdb!(:testredis)
end)
:ok
end
test "smembers empty" do
m = Connection.smembers!(:testredis, "bogus")
assert m == []
end
test "sadd" do
r = Connection.sadd!(:testredis, "theset", "amember")
assert r == 1
assert Connection.smembers!(:testredis, "theset") == ["amember"]
end
test "sismember" do
_ = Connection.sadd!(:testredis, "theset", "amember")
_ = Connection.sadd!(:testredis, "theset", "anothermember")
assert 1 == Connection.sismember!(:testredis, "theset", "amember")
assert 1 == Connection.sismember!(:testredis, "theset", "anothermember")
assert 0 == Connection.sismember!(:testredis, "theset", "not_a_member")
end
test "lpop empty" do
assert Connection.lpop(:testredis, "bogus") == {:ok, nil}
end
test "rpush / lpop" do
Connection.rpush!(:testredis, "akey", "avalue")
assert Connection.lpop(:testredis, "akey") == {:ok, "avalue"}
assert Connection.lpop(:testredis, "akey") == {:ok, nil}
end
test "zadd / zcard / zrem" do
assert Connection.zcard!(:testredis, "akey") == 0
assert Connection.zadd!(:testredis, "akey", "1.7", "avalue") == 1
assert Connection.zcard!(:testredis, "akey") == 1
assert Connection.zrem!(:testredis, "akey", "avalue") == 1
assert Connection.zcard!(:testredis, "akey") == 0
end
test "zrangebyscore" do
assert Connection.zcard!(:testredis, "akey") == 0
assert Connection.zadd!(:testredis, "akey", "123456.123455", "avalue") == 1
assert Connection.zadd!(:testredis, "akey", "123456.123456", "bvalue") == 1
assert Connection.zadd!(:testredis, "akey", "123456.123457", "cvalue") == 1
assert Connection.zrangebyscore!(:testredis, "akey", 0, "111111.111111") == []
assert Connection.zrangebyscore!(:testredis, "akey", 0, "123456.123455") == ["avalue"]
assert Connection.zrangebyscore!(:testredis, "akey", 0, "123456.123456") == [
"avalue",
"bvalue"
]
assert Connection.zrangebyscore!(:testredis, "akey", 0, "123456.123457") == [
"avalue",
"bvalue",
"cvalue"
]
assert Connection.zrangebyscore!(:testredis, "akey", 0, "999999.999999") == [
"avalue",
"bvalue",
"cvalue"
]
assert Connection.zrem!(:testredis, "akey", "bvalue") == 1
assert Connection.zrangebyscore!(:testredis, "akey", 0, "123456.123457") == [
"avalue",
"cvalue"
]
assert Connection.zrem!(:testredis, "akey", "avalue") == 1
assert Connection.zrangebyscore!(:testredis, "akey", 0, "123456.123456") == []
assert Connection.zrangebyscore!(:testredis, "akey", 0, "123456.123457") == ["cvalue"]
assert Connection.zrem!(:testredis, "akey", "avalue") == 0
assert Connection.zrem!(:testredis, "akey", "cvalue") == 1
assert Connection.zrangebyscore!(:testredis, "akey", 0, "999999.999999") == []
end
test "zcount" do
assert Connection.zcount!(:testredis, "akey") == Connection.zcard!(:testredis, "akey")
assert Connection.zadd!(:testredis, "akey", "1", "avalue") == 1
assert Connection.zadd!(:testredis, "akey", "1", "bvalue") == 1
assert Connection.zadd!(:testredis, "akey", "2", "cvalue") == 1
assert Connection.zcount!(:testredis, "akey", "0", "1") == 2
assert Connection.zcount!(:testredis, "akey", "1", "1") == 2
assert Connection.zcount!(:testredis, "akey", "-inf", "+inf") == 3
assert Connection.zcount!(:testredis, "akey", "1", "(2") == 2
assert Connection.zcount!(:testredis, "akey", "(1", "2") == 1
end
test "flushdb" do
Connection.sadd!(:testredis, "theset", "amember")
Connection.flushdb!(:testredis)
assert Connection.smembers!(:testredis, "theset") == []
end
end