foreachByFilter feature

This commit is contained in:
Doug Hoyte
2023-06-05 11:36:31 -04:00
parent d9048acb64
commit e2816f6bd5

View File

@ -382,3 +382,12 @@ struct DBQuery : NonCopyable {
return true;
}
};
inline void foreachByFilter(lmdb::txn &txn, const tao::json::value &filter, std::function<void(uint64_t, std::string_view)> cb) {
DBQuery query(filter);
query.process(txn, [&](const auto &, uint64_t levId, std::string_view eventPayload){
cb(levId, eventPayload);
});
}