pub trait TableObserver: Send + Sync {
// Required methods
fn tables(&self) -> Vec<String>;
fn on_tables_changed(&self, tables: &BTreeSet<String>);
}Expand description
Defines an observer for a set of tables.
Required Methods§
Sourcefn on_tables_changed(&self, tables: &BTreeSet<String>)
fn on_tables_changed(&self, tables: &BTreeSet<String>)
When one or more of the tables return by Self::tables() is modified, this method
will be invoked by the Watcher.
tables contains the set of tables that we modified.
It is recommended that the implementation be as short as possible to not delay/block the execution of other observers.