go - RethinkDB changefeed 使用 `now()` 过滤

Question

我希望使用 RethinkDB changefeeds 创建一种“时间触发”:

        return r.
            Table("Checks").
            Filter(r.Row.Field("ScheduledFor").Le(r.Now())).
            Changes(r.ChangesOpts{
                    IncludeInitial: true,
            }).Run(db)

但是，虽然它会拾取最初满足 Filter 谓词的内容，但它似乎不会拾取 ScheduledFor 从 future 到现在的记录过去。

即r.Now() 似乎在被服务器接收时被评估，并且再也不会被评估。

有什么方法可以使 Now() 项动态求值吗？或者我应该只进行表扫描？

Answer 1

目前 r.now 始终评估服务器收到查询的时间。最好对安排在上次表扫描和当前时间之间的任何文档重复执行表扫描。