|
|
@@ -31,6 +31,13 @@
|
|
|
(protocol/query e q opts))
|
|
|
(protocol/query e1 q opts)))
|
|
|
|
|
|
+ (query-page [_this q opts]
|
|
|
+ (println "D:Search > Query-page contents:" repo q opts)
|
|
|
+ (let [[e1 e2] (get-registered-engines repo)]
|
|
|
+ (doseq [e e2]
|
|
|
+ (protocol/query-page e q opts))
|
|
|
+ (protocol/query-page e1 q opts)))
|
|
|
+
|
|
|
(rebuild-blocks-indice! [_this]
|
|
|
(println "D:Search > Initial blocks indice!:" repo)
|
|
|
(let [[e1 e2] (get-registered-engines repo)]
|
|
|
@@ -43,6 +50,11 @@
|
|
|
(doseq [e (get-flatten-registered-engines repo)]
|
|
|
(protocol/transact-blocks! e data)))
|
|
|
|
|
|
+ (transact-pages! [_this data]
|
|
|
+ (println "D:Search > Transact pages!:" repo)
|
|
|
+ (doseq [e (get-flatten-registered-engines repo)]
|
|
|
+ (protocol/transact-pages! e data)))
|
|
|
+
|
|
|
(truncate-blocks! [_this]
|
|
|
(println "D:Search > Truncate blocks!" repo)
|
|
|
(doseq [e (get-flatten-registered-engines repo)]
|