surrealdb_sql/changefeed.rs
1#[derive(Clone, Copy, Debug, Eq, PartialEq, Hash)]
2pub struct ChangeFeed {
3 pub expiry: std::time::Duration,
4 pub store_diff: bool,
5}
6
7impl surrealdb_types::ToSql for ChangeFeed {
8 fn fmt_sql(&self, f: &mut String, sql_fmt: surrealdb_types::SqlFormat) {
9 use surrealdb_types::write_sql;
10 write_sql!(f, sql_fmt, "CHANGEFEED {}", common::fmt::SqlDuration(self.expiry));
11 if self.store_diff {
12 f.push_str(" INCLUDE ORIGINAL");
13 }
14 }
15}