草庐IT

changefeed

全部标签

Golang RethinkDB ChangeFeed 结构

我想知道是否有人可以解释如何将我的changefeed游标值解码为特定的结构类型。varmessagemap[string]interface{}forchatFeedCursor.Next(&message){fmt.Println(message)}map[new_val:map[club_id:ea2eb6e2-755f-4dad-922d-e3693b6e55c6date:2017-04-0714:48:17.714+0100+01:00id:e389ab54-963e-4b33-9b34-adcb6ec5b17emessage:whatisthemeaningoflife?u

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

我希望使用RethinkDBchangefeeds创建一种“时间触发”:returnr.Table("Checks").Filter(r.Row.Field("ScheduledFor").Le(r.Now())).Changes(r.ChangesOpts{IncludeInitial:true,}).Run(db)但是,虽然它会拾取最初满足Filter谓词的内容,但它似乎不会拾取ScheduledFor从future到现在的记录过去。即r.Now()似乎在被服务器接收时被评估,并且再也不会被评估。有什么方法可以使Now()项动态求值吗?或者我应该只进行表扫描?