Trait TableObserver

pub trait TableObserver: Send + Sync {
    // Required methods
    fn tables(&self) -> Vec<String>;
    fn on_tables_changed(&self, tables: &BTreeSet<String>);
}

Defines an observer for a set of tables.

Required Methods

fn tables(&self) -> Vec<String>

Return the set of tables this observer is interested in.

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.

Implementors