Struct OracleCdcSourceConfig 

pub struct OracleCdcSourceConfig {

    pub connection: OracleConnectionConfig,
    pub tables: Vec<String>,
    pub start_position: StartPosition,
    pub poll_interval: Duration,
    pub idle_timeout: Duration,
    pub max_scn_window: u64,
    pub max_staged_records: Option<usize>,
    pub max_staged_records_total: Option<usize>,
    pub batch_size: usize,
    pub max_connections: u32,
    pub statement_timeout_secs: u64,
    pub flush_table: String,
    pub on_unsupported: OnUnsupported,
    pub state_key: Option<String>,
}

Configuration for the Oracle LogMiner CDC source.

Fields

connection: OracleConnectionConfig

Connection settings. Connect to the PDB that owns the tables (Oracle 21c+ mines per PDB), or to a non-CDB / the CDB root.

tables: Vec<String>

Tables to capture as OWNER.TABLE, in data-dictionary case (usually upper case). Required and non-empty.

start_position: StartPosition

Start position on a fresh run. Default current.

poll_interval: Duration

Seconds to wait between polls that find nothing new. Default 1s.

idle_timeout: Duration

End the fetch cycle after this long without a captured change, counted only once mining has reached the current SCN. Default 30s. A long-running runtime re-invokes the source to keep tailing.

max_scn_window: u64

Largest SCN range mined per LogMiner session. Default 500000.

max_staged_records: Option<usize>

Abort when one in-flight transaction buffers more than this many changes (bounded memory). Defaults to 1,000,000; null = unbounded.

max_staged_records_total: Option<usize>

Abort when all open transactions together buffer more than this many changes, counting LOB pieces and folded updates. Unset or null = unbounded.

batch_size: usize

0 aggregates committed transactions into pages of up to 100,000 records, emitted at least every idle_timeout, each with its bookmark; otherwise each committed transaction is its own page. Default DEFAULT_BATCH_SIZE.

max_connections: u32

Maximum pooled sessions. Default 2.

statement_timeout_secs: u64

Per-round-trip call timeout in seconds (0 disables). Default 600.

flush_table: String

Table the source commits to before each mining window, forcing the log writer to flush redo up to the window’s end SCN. Created in the connecting user’s schema when missing. Default FAUCET_LOGMNR_FLUSH.

on_unsupported: OnUnsupported

Handling of changes LogMiner cannot render. Default fail.

state_key: Option<String>

Explicit state-store key. Derived as oracle-cdc:<database>:<table> (or a digest of several tables) when unset.

Implementations

impl OracleCdcSourceConfig

pub fn new(connection: OracleConnectionConfig, tables: Vec<String>) -> Self

A config capturing tables with defaults elsewhere.

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

Validate the fail-fast invariants.

pub fn table_pairs(&self) -> Vec<(String, String)>

(owner, table) pairs of the captured tables.

pub fn resolved_state_key(&self) -> String

The state-store key for the SCN bookmark.

pub fn legacy_state_keys(&self) -> Vec<String>

Keys the SCN bookmark was stored under by releases whose scope did not name the host and port; empty when the key is configured explicitly.

Trait Implementations

impl Clone for OracleCdcSourceConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OracleCdcSourceConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OracleCdcSourceConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for OracleCdcSourceConfig

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 OracleCdcSourceConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.