Skip to main content

TableSecondaryIndexCdc

Trait TableSecondaryIndexCdc 

Source
pub trait TableSecondaryIndexCdc<Row, AvailableTypes, SecondaryEvents, AvailableIndexes> {
    // Required methods
    fn save_row_cdc(
        &self,
        row: Row,
        link: Link,
    ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>;
    fn reinsert_row_cdc(
        &self,
        row_old: Row,
        link_old: Link,
        row_new: Row,
        link_new: Link,
    ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>;
    fn delete_row_cdc(
        &self,
        row: Row,
        link: Link,
    ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>;
    fn process_difference_insert_cdc(
        &self,
        link: Link,
        differences: HashMap<&str, Difference<AvailableTypes>>,
    ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>;
    fn process_difference_remove_cdc(
        &self,
        link: Link,
        differences: HashMap<&str, Difference<AvailableTypes>>,
    ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>;
}

Required Methods§

Source

fn save_row_cdc( &self, row: Row, link: Link, ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>

Source

fn reinsert_row_cdc( &self, row_old: Row, link_old: Link, row_new: Row, link_new: Link, ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>

Source

fn delete_row_cdc( &self, row: Row, link: Link, ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>

Source

fn process_difference_insert_cdc( &self, link: Link, differences: HashMap<&str, Difference<AvailableTypes>>, ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>

Source

fn process_difference_remove_cdc( &self, link: Link, differences: HashMap<&str, Difference<AvailableTypes>>, ) -> Result<SecondaryEvents, IndexError<AvailableIndexes>>

Implementors§

Source§

impl<T, Row, AvailableTypes, AvailableIndexes> TableSecondaryIndexCdc<Row, AvailableTypes, (), AvailableIndexes> for T
where T: TableSecondaryIndex<Row, AvailableTypes, AvailableIndexes>,