Struct ReplicationFilter 

pub struct ReplicationFilter { /* private fields */ }

Represents replication filtering rules

Implementations

impl ReplicationFilter

pub fn new( include_databases: Option<Vec<String>>, exclude_databases: Option<Vec<String>>, include_tables: Option<Vec<String>>, exclude_tables: Option<Vec<String>>, ) -> Result<Self>

Creates a filter from CLI arguments

pub fn empty() -> Self

Creates an empty filter (replicate everything)

pub fn is_empty(&self) -> bool

Checks if any filters are active

pub fn fingerprint(&self) -> String

Returns a stable fingerprint for the filter configuration

pub fn table_rules(&self) -> &TableRules

pub fn with_table_rules(self, rules: TableRules) -> Self

pub fn schema_only_tables(&self, database: &str) -> Vec<String>

pub fn predicate_tables(&self, database: &str) -> Vec<(String, String)>

pub fn include_databases(&self) -> Option<&Vec<String>>

Gets the list of databases to include

pub fn exclude_databases(&self) -> Option<&Vec<String>>

Gets the list of databases to exclude

pub fn include_tables(&self) -> Option<&Vec<String>>

Gets the list of tables to include

pub fn exclude_tables(&self) -> Option<&Vec<String>>

Gets the list of tables to exclude

pub fn should_replicate_database(&self, db_name: &str) -> bool

Determines if a database should be replicated

pub fn should_replicate_table(&self, db_name: &str, table_name: &str) -> bool

Determines if a table should be replicated

pub async fn get_databases_to_replicate( &self, source_conn: &Client, ) -> Result<Vec<String>>

Gets list of databases to replicate (queries source if needed)

pub async fn get_tables_to_replicate( &self, source_conn: &Client, db_name: &str, ) -> Result<Vec<String>>

Gets list of tables to replicate for a given database

Trait Implementations

impl Clone for ReplicationFilter

fn clone(&self) -> ReplicationFilter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReplicationFilter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ReplicationFilter

fn default() -> ReplicationFilter

Returns the “default value” for a type.