#[non_exhaustive]pub struct SqlServerSourceConfig {
pub include_objects: Option<SqlServerRdbms>,
pub exclude_objects: Option<SqlServerRdbms>,
pub max_concurrent_cdc_tasks: i32,
pub max_concurrent_backfill_tasks: i32,
pub cdc_method: Option<CdcMethod>,
/* private fields */
}
Expand description
SQLServer data source configuration
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. }
syntax; cannot be matched against without a wildcard ..
; and struct update syntax will not work.include_objects: Option<SqlServerRdbms>
SQLServer objects to include in the stream.
exclude_objects: Option<SqlServerRdbms>
SQLServer objects to exclude from the stream.
max_concurrent_cdc_tasks: i32
Max concurrent CDC tasks.
max_concurrent_backfill_tasks: i32
Max concurrent backfill tasks.
cdc_method: Option<CdcMethod>
Configuration to select the CDC read method for the stream.
Implementations§
Source§impl SqlServerSourceConfig
impl SqlServerSourceConfig
pub fn new() -> Self
Sourcepub fn set_include_objects<T>(self, v: T) -> Selfwhere
T: Into<SqlServerRdbms>,
pub fn set_include_objects<T>(self, v: T) -> Selfwhere
T: Into<SqlServerRdbms>,
Sets the value of include_objects.
Sourcepub fn set_or_clear_include_objects<T>(self, v: Option<T>) -> Selfwhere
T: Into<SqlServerRdbms>,
pub fn set_or_clear_include_objects<T>(self, v: Option<T>) -> Selfwhere
T: Into<SqlServerRdbms>,
Sets or clears the value of include_objects.
Sourcepub fn set_exclude_objects<T>(self, v: T) -> Selfwhere
T: Into<SqlServerRdbms>,
pub fn set_exclude_objects<T>(self, v: T) -> Selfwhere
T: Into<SqlServerRdbms>,
Sets the value of exclude_objects.
Sourcepub fn set_or_clear_exclude_objects<T>(self, v: Option<T>) -> Selfwhere
T: Into<SqlServerRdbms>,
pub fn set_or_clear_exclude_objects<T>(self, v: Option<T>) -> Selfwhere
T: Into<SqlServerRdbms>,
Sets or clears the value of exclude_objects.
Sourcepub fn set_max_concurrent_cdc_tasks<T: Into<i32>>(self, v: T) -> Self
pub fn set_max_concurrent_cdc_tasks<T: Into<i32>>(self, v: T) -> Self
Sets the value of max_concurrent_cdc_tasks.
Sourcepub fn set_max_concurrent_backfill_tasks<T: Into<i32>>(self, v: T) -> Self
pub fn set_max_concurrent_backfill_tasks<T: Into<i32>>(self, v: T) -> Self
Sets the value of max_concurrent_backfill_tasks.
Sourcepub fn set_cdc_method<T: Into<Option<CdcMethod>>>(self, v: T) -> Self
pub fn set_cdc_method<T: Into<Option<CdcMethod>>>(self, v: T) -> Self
Sets the value of cdc_method.
Note that all the setters affecting cdc_method
are mutually
exclusive.
Sourcepub fn transaction_logs(&self) -> Option<&Box<SqlServerTransactionLogs>>
pub fn transaction_logs(&self) -> Option<&Box<SqlServerTransactionLogs>>
The value of cdc_method
if it holds a TransactionLogs
, None
if the field is not set or
holds a different branch.
Sourcepub fn set_transaction_logs<T: Into<Box<SqlServerTransactionLogs>>>(
self,
v: T,
) -> Self
pub fn set_transaction_logs<T: Into<Box<SqlServerTransactionLogs>>>( self, v: T, ) -> Self
Sets the value of cdc_method
to hold a TransactionLogs
.
Note that all the setters affecting cdc_method
are
mutually exclusive.
Sourcepub fn change_tables(&self) -> Option<&Box<SqlServerChangeTables>>
pub fn change_tables(&self) -> Option<&Box<SqlServerChangeTables>>
The value of cdc_method
if it holds a ChangeTables
, None
if the field is not set or
holds a different branch.
Sourcepub fn set_change_tables<T: Into<Box<SqlServerChangeTables>>>(
self,
v: T,
) -> Self
pub fn set_change_tables<T: Into<Box<SqlServerChangeTables>>>( self, v: T, ) -> Self
Sets the value of cdc_method
to hold a ChangeTables
.
Note that all the setters affecting cdc_method
are
mutually exclusive.
Trait Implementations§
Source§impl Clone for SqlServerSourceConfig
impl Clone for SqlServerSourceConfig
Source§fn clone(&self) -> SqlServerSourceConfig
fn clone(&self) -> SqlServerSourceConfig
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read more