Struct MssqlSourceConfig 

pub struct MssqlSourceConfig {
    pub connection: MssqlConnectionConfig,
    pub query: String,
    pub params: Vec<Value>,
    pub max_connections: u32,
    pub batch_size: usize,
    pub statement_timeout_secs: u64,
    pub replication: MssqlReplication,
    pub state_key: Option<String>,
    pub shard: Option<ShardConfig>,
}

Configuration for MssqlSource.

Fields

connection: MssqlConnectionConfig

Connection + TLS settings (connection_url or connection_string).

query: String

SQL query to run. Use @P1, @P2, … for params, and the literal @bookmark token to bind the incremental cursor server-side.

params: Vec<Value>

Positional bind parameters for the query (@P1…@Pn). Defaults to empty.

max_connections: u32

Maximum pooled connections. Defaults to 10.

batch_size: usize

Records per emitted StreamPage. 0 emits the whole result set as a single page. Defaults to DEFAULT_BATCH_SIZE.

statement_timeout_secs: u64

Per-query timeout in seconds (0 disables). Defaults to 300.

replication: MssqlReplication

Replication mode. Defaults to MssqlReplication::Full.

state_key: Option<String>

Explicit state-store key for the bookmark. When unset, a key is derived from the connection host and a query fingerprint.

shard: Option<ShardConfig>

Optional primary-key range sharding for clustered (Mode B) execution.

When set, the source advertises itself as shardable: the cluster coordinator splits the query’s key range into contiguous slices that different workers process concurrently. Has no effect outside the cluster coordinator (a plain faucet run streams the whole query), so it is fully backward compatible. See ShardConfig.

Implementations

impl MssqlSourceConfig

pub fn new(connection_url: impl Into<String>, query: impl Into<String>) -> Self

Build a config from a connection URL and query, with defaults elsewhere.

pub fn validate(&self) -> Result<(), FaucetError>

Validate connection source, batch size, and replication settings.

Trait Implementations

impl Clone for MssqlSourceConfig

fn clone(&self) -> MssqlSourceConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MssqlSourceConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MssqlSourceConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for MssqlSourceConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for MssqlSourceConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.