Struct MsSqlSource 

pub struct MsSqlSource { /* private fields */ }

MS SQL CDC Source

Monitors MS SQL Server CDC change tables and emits source change events.

Implementations

impl MsSqlSource

pub fn new(id: impl Into<String>, config: MsSqlSourceConfig) -> Result<Self>

Create a new MS SQL source with configuration

Arguments

• id - Unique identifier for this source
• config - MS SQL source configuration

pub fn builder(id: impl Into<String>) -> MsSqlSourceBuilder

Create a builder for configuring the MS SQL source

Arguments

• id - Unique identifier for this source

Example

use drasi_source_mssql::MsSqlSource;

let source = MsSqlSource::builder("my-source")
    .with_host("localhost")
    .with_database("mydb")
    .with_user("user")
    .with_password("password")
    .build()?;

Trait Implementations

impl Source for MsSqlSource

fn id(&self) -> &str

Get the source’s unique identifier

fn type_name(&self) -> &str

Get the source type name (e.g., “postgres”, “http”, “mock”)

fn properties(&self) -> HashMap<String, Value>

Get the source’s configuration properties for inspection

fn auto_start(&self) -> bool

Whether this source should auto-start when DrasiLib starts

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ComponentStatus> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the current status of the source

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start the source

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop the source

fn subscribe<'life0, 'async_trait>( &'life0 self, settings: SourceSubscriptionSettings, ) -> Pin<Box<dyn Future<Output = Result<SubscriptionResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribe to this source for change events

fn as_any(&self) -> &dyn Any

Downcast helper for testing - allows access to concrete types

fn initialize<'life0, 'async_trait>( &'life0 self, context: SourceRuntimeContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initialize the source with runtime context.

fn set_bootstrap_provider<'life0, 'async_trait>( &'life0 self, provider: Box<dyn BootstrapProvider + 'static>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Set the bootstrap provider for this source

fn dispatch_mode(&self) -> DispatchMode

Get the dispatch mode for this source (Channel or Broadcast)

fn supports_replay(&self) -> bool

Whether this source supports positional replay via resume_from.

fn deprovision<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Permanently clean up internal state when the source is being removed.