From 90c1a1452158f32c1b1767dd1a6349b4773356a0 Mon Sep 17 00:00:00 2001 From: Ivan Remen Date: Tue, 18 Apr 2017 10:02:23 -0400 Subject: [PATCH] Delfi filters --- delfi.lua | 24 ++++++++++++++++++++++++ 1 file changed, 24 insertions(+) create mode 100644 delfi.lua diff --git a/delfi.lua b/delfi.lua new file mode 100644 index 0000000..2e5b372 --- /dev/null +++ b/delfi.lua @@ -0,0 +1,24 @@ +local space_no = 0 + +function find_filters_by_regex(regex) + if box.cfg.replication_source == nil then error("replica api only") end + + local cnt = 0 + local t = {} + for tpl in box.space[space_no].index[0]:iterator(box.index.ALL) do + + if string.find(tpl[1], regex) then + table.insert(t, tpl) + end + + cnt = cnt + 1 + if cnt == 1000 then + box.fiber.testcancel() + box.fiber.sleep(0) + cnt = 0 + end + + end + + return unpack(t) +end