Struct RuntimeConfig 

pub struct RuntimeConfig {
    pub source: RuntimeSourceConfig,
    pub snapshot_tables: Vec<String>,
    pub incremental_snapshot: Option<IncrementalSnapshotConfig>,
    pub checkpoint: Box<dyn Checkpoint>,
    pub schema_history: Box<dyn SchemaHistory>,
    pub options: RuntimeOptions,
}

Runtime configuration for embedded execution.

Fields

source: RuntimeSourceConfig

Source configuration used by the runtime.

snapshot_tables: Vec<String>

Snapshot table list used on first run when no checkpoint exists.

incremental_snapshot: Option<IncrementalSnapshotConfig>

Optional incremental (non-blocking) snapshot configuration.

When set, runtime startup initializes stream ingestion through the connector’s watermark-based incremental snapshot handle instead of the classic snapshot + handoff path.

checkpoint: Box<dyn Checkpoint>

Checkpoint backend owned by the runtime.

schema_history: Box<dyn SchemaHistory>

Schema history backend owned by the runtime.

options: RuntimeOptions

Explicit runtime options including observability and tuning defaults.

Implementations

impl RuntimeConfig

pub fn new<C, H>( source: RuntimeSourceConfig, checkpoint: C, schema_history: H, ) -> Self

where C: Checkpoint + 'static, H: SchemaHistory + 'static,

Create a config boxing the provided checkpoint and schema history implementations.

pub fn with_options(self, options: RuntimeOptions) -> Self

Replace the full runtime options surface.

pub fn with_observability(self, observability: RuntimeObservability) -> Self

Replace the observability configuration.

pub fn with_metrics(self, metrics: Arc<dyn MetricsCollector>) -> Self

Override the metrics collector.

pub fn with_tracer(self, tracer: Arc<dyn EventTracer>) -> Self

Override the tracer.

pub fn with_max_buffer_size(self, max_buffer_size: usize) -> Self

Override the maximum buffer size.

pub fn with_max_poll_wait_ms(self, max_poll_wait_ms: u64) -> Self

Override the poll wait budget in milliseconds.

pub fn with_transform_error_policy(self, policy: TransformErrorPolicy) -> Self

Configure transform failure behavior. Defaults to TransformErrorPolicy::Halt.

Operational Guidance

• Production: Use Halt (default) to fail fast on data corruption.
• Staging/Testing: Use Skip for tolerant evaluation (e.g., optional enrichment).
• Change at Runtime: Policy is set at config time; to change behavior, recreate runtime.

Error Context

Errors during transform execution include the transform’s name and the event ID, enabling quick diagnosis. All failed events are logged regardless of policy.

pub fn with_post_commit_source_confirm_policy( self, policy: PostCommitSourceConfirmPolicy, ) -> Self

Configure post-commit source confirmation behavior.

pub fn with_idempotency(self, idempotency: IdempotencyOptions) -> Self

Configure runtime-level idempotency guard options.

Duplicate detection runs before transform stages, so dedupe decisions are stable even when downstream transforms are nondeterministic.

pub fn with_idempotency_disabled(self) -> Self

Explicitly disable runtime-level duplicate suppression.

pub fn with_event_validation(self, enabled: bool) -> Self

Enable or disable canonical event-envelope validation at runtime ingress.

pub fn with_schema_history_retention( self, retention: SchemaHistoryRetention, ) -> Self

Configure runtime-managed schema-history retention after DDL persistence.

pub fn with_snapshot_tables(self, snapshot_tables: Vec<String>) -> Self

Configure snapshot tables for initial snapshot mode.

pub fn with_incremental_snapshot( self, config: IncrementalSnapshotConfig, ) -> Self

Configure runtime startup to use incremental (non-blocking) snapshot mode.

This supersedes the classic with_snapshot_tables bootstrapping path. Do not set both at once.