Packages
kvs
8.10.2
13.5.22-aleph
13.4.16
13.4.15
13.4.14
13.4.13
13.3.1
13.2.28
11.9.1
10.8.3
10.8.2
10.3.0
9.9.2
9.9.1
9.9.0
9.8.0
9.7.0
9.4.8
9.4.7
9.4.6
9.4.5
9.4.4
9.4.3
9.4.2
9.4.1
9.4.0
8.12.0
8.11.2
8.11.1
8.10.4
8.10.3
8.10.2
8.10.1
8.10.0
8.5.2
8.5.1
8.5.0
8.4.1
8.4.0
8.3.1
8.3.0
7.11.5
7.9.1
7.7.0
7.1.3
7.1.2
7.1.1
6.12.11
6.12.10
6.12.9
6.12.8
6.12.7
6.12.6
6.12.5
6.12.4
6.12.3
6.12.2
6.12.1
6.12.0
6.11.2
6.11.1
6.11.0
6.10.2
6.10.1
6.10.0
6.9.2
6.9.1
6.9.0
6.7.7
6.7.6
6.7.5
6.7.4
6.7.3
6.7.2
6.7.1
6.7.0
6.6.0
2.1.0
0.12.1
retired
KVS Key-Value Store Abstraction Layer
Current section
Files
Jump to
Current section
Files
test/fd_test.exs
ExUnit.start()
defmodule Fd.Test do
use ExUnit.Case, async: false
require KVS
import Record
test "fd_test", kvs do
assert "//erp" = :kvs_rocks.fd "//erp/orgs"
assert "/erp" = :kvs_rocks.fd "/erp/orgs"
end
test "key_test", kvs do
assert "//erp/orgs" = :kvs_rocks.key "/erp/orgs"
assert "/erp/orgs" = :kvs_rocks.key "erp/orgs"
end
defrecord(:msg, id: [], body: [])
setup do: (on_exit(fn -> :ok = :kvs.leave();:ok = :kvs.destroy() end);:kvs.join())
setup kvs, do: [
id0: :lists.map(fn _ -> :kvs.append(msg(id: :kvs.seq([],[])), "/crm/duck") end, :lists.seq(1,10)),
id1: :lists.map(fn _ -> :kvs.append(msg(id: :kvs.seq([],[])), "/crm/luck") end, :lists.seq(1,10)),
id2: :lists.map(fn _ -> :kvs.append(msg(id: :kvs.seq([],[])), "/crm/truck") end, :lists.seq(1,10))]
test "reader", kvs do
ltop = Enum.at(kvs[:id1],0)
dtop = Enum.at(kvs[:id0],0)
ttop = Enum.at(kvs[:id2],0)
assert KVS.reader(feed: "//crm/luck", count: 10, dir: 0, args: [], cache: {:msg, ^ltop, "//crm/luck"}) = :kvs.reader("/crm/luck")
assert KVS.reader(feed: "//crm/duck", count: 10, dir: 0, args: [], cache: {:msg, ^dtop, "//crm/duck"}) = :kvs.reader("/crm/duck")
assert KVS.reader(feed: "//crm/truck", count: 10, dir: 0, args: [], cache: {:msg, ^ttop, "//crm/truck"}) = :kvs.reader("/crm/truck")
assert KVS.reader(feed: "//crm", count: 0, dir: 0, args: [], cache: {:msg, ^dtop, "//crm/duck"}) = :kvs.reader("/crm")
assert KVS.reader(feed: "//noroute", count: 0, dir: 0, args: []) = :kvs.reader("/noroute")
assert KVS.reader(feed: "//", count: 0, dir: 0, args: [], cache: {:msg, ^dtop, "//crm/duck"}) = :kvs.reader("/")
assert KVS.reader(count: 0, dir: 0, args: []) = :kvs.reader([])
end
test "range", kvs do
ltop = Enum.at(kvs[:id1],0)
dtop = Enum.at(kvs[:id0],0)
lbot = Enum.at(kvs[:id1],9)
assert KVS.reader(feed: "//crm/luck", count: 10, dir: 0, args: [], cache: {:msg, ^ltop, "//crm/luck"}) = :kvs.top(:kvs.reader("/crm/luck"))
assert KVS.reader(feed: "//crm", count: 0, dir: 0, args: [], cache: {:msg, ^dtop, "//crm/duck"}) = :kvs.top(:kvs.reader("/crm"))
assert KVS.reader(feed: "//", count: 0, dir: 0, args: [], cache: {:msg, ^dtop, "//crm/duck"}) = :kvs.top(:kvs.reader("/"))
assert KVS.reader(feed: "//crm/luck", count: 10, dir: 0, args: [], cache: {:msg, ^lbot, "//crm/luck"}) = :kvs.bot(:kvs.reader("/crm/luck"))
assert KVS.reader(feed: "//crm", count: 0, dir: 0, args: [], cache: []) = :kvs.bot(:kvs.reader("/crm"))
assert KVS.reader(feed: "//", count: 0, dir: 0, args: [], cache: []) = :kvs.bot(:kvs.reader("/"))
end
test "next", kvs do
last = msg(id: Enum.at(kvs[:id1],9))
r0 = KVS.reader(id: rid) = :kvs.save(:kvs.top(:kvs.reader("/crm/luck")))
kvs[:id1] |> Enum.with_index
|> Enum.each(fn {id,9} ->
r = :kvs.load_reader(rid)
r01 = :kvs.next(r)
assert r1 = KVS.reader(feed: "//crm/luck", cache: c1, count: 10, dir: 0, args: [^last]) = r01
assert KVS.reader(args: [], feed: "//crm/luck", cache: c1) = :kvs.save(r1)
{id,i} ->
v = msg(id: Enum.at(kvs[:id1],i))
c = Enum.at(kvs[:id1],i+1)
r = :kvs.load_reader(rid)
assert r1 = KVS.reader(feed: "//crm/luck", cache: {:msg,^c,"//crm/luck"}, count: 10, dir: 0, args: [^v]) = :kvs.next(r)
assert KVS.reader(args: [], feed: "//crm/luck", cache: {:msg,^c,"//crm/luck"}) = :kvs.save(r1)
end)
r = :kvs.load_reader(rid)
assert r == :kvs.next(r)
assert r == KVS.reader(:kvs.next(:kvs.bot(r)), args: [])
end
test "prev", kvs do
out = Enum.at(kvs[:id0],9)
KVS.reader(id: rid) = :kvs.save(:kvs.bot(:kvs.reader("/crm/luck")))
ids = kvs[:id1] |> Enum.reverse
ids |> Enum.with_index
|> Enum.each(fn {id,9} ->
r = :kvs.load_reader(rid)
v = msg(id: Enum.at(ids, 9))
assert r1 = KVS.reader(feed: "//crm/luck", cache: {:msg, ^out, "//crm/duck"}, count: 10, args: [^v]) = :kvs.prev(r)
assert KVS.reader(args: [], feed: "//crm/luck", cache: c1) = :kvs.save(r1)
{id,i} ->
r = :kvs.load_reader(rid)
v = msg(id: Enum.at(ids, i))
c = Enum.at(ids, i+1)
assert r1 = KVS.reader(feed: "//crm/luck", cache: {:msg, ^c, "//crm/luck"}, count: 10, args: [^v]) = :kvs.prev(r)
assert KVS.reader(args: [], feed: "//crm/luck", cache: {:msg, ^c, "//crm/luck"}) = :kvs.save(r1)
end)
r = :kvs.load_reader(rid)
assert r = :kvs.prev(r)
assert r = KVS.reader(:kvs.prev(:kvs.top(r)), args: [])
end
test "prev to empty" do
:lists.map(fn _ -> :kvs.append(msg(id: :kvs.seq([],[])), "/aco") end, :lists.seq(1,2))
all = :kvs.all("/aco")
head = Enum.at(all,0)
r = :kvs.bot(:kvs.reader("/aco"))
r1 = KVS.reader(args: args) = :kvs.take(KVS.reader(r, args: 2, dir: 1))
assert all == :lists.reverse(args)
assert KVS.reader(args: [^head]) = :kvs.take(KVS.reader(r1, args: 1000, dir: 1))
end
test "keys with feeds separator" do
:kvs.append(msg(id: "1/1"), "/one/two")
:kvs.append(msg(id: "1/2"), "/one/two")
assert KVS.reader(cache: {:msg, _, "//one/two"}) = :kvs.reader("/one/two")
end
defp log(x), do: IO.puts '#{inspect(x)}'
defp log(m, x), do: IO.puts '#{m} #{inspect(x)}'
end