surrealdb_sql/
changefeed.rs1use crate::duration::Duration;
2use revision::revisioned;
3use serde::{Deserialize, Serialize};
4use std::fmt::{self, Display, Formatter};
5use std::str;
6use std::time;
7
8#[derive(Clone, Debug, Eq, PartialEq, PartialOrd, Serialize, Deserialize, Hash)]
9#[revisioned(revision = 1)]
10pub struct ChangeFeed {
11 pub expiry: time::Duration,
12}
13
14impl Display for ChangeFeed {
15 fn fmt(&self, f: &mut Formatter) -> fmt::Result {
16 write!(f, "CHANGEFEED {}", Duration(self.expiry))?;
17 Ok(())
18 }
19}
20
21impl Default for ChangeFeed {
22 fn default() -> Self {
23 Self {
24 expiry: time::Duration::from_secs(0),
25 }
26 }
27}