pub struct TableSourceConfig {
pub table: String,
pub function: Option<String>,
pub propagate_deletes: bool,
pub max_lag: Option<u64>,
}Expand description
@source(table: "OtherType", function:, propagateDeletes:, maxLag:).
Continuous push-on-write subscription from another yeti table.
Fields§
§table: StringSource type name. Resolves to a GraphQL type in the same database. Cross-app references are out of scope for v1.
function: Option<String>Optional projection function. When set, receives the source row and emits zero or more destination rows. When absent, the projection is a field-shape match (drop fields the destination doesn’t have, null-coerce ones the source doesn’t have).
propagate_deletes: boolWhether destination deletes should mirror source deletes.
Default true. Only valid when function is None — when
a transform is in play, the function decides delete
semantics.
max_lag: Option<u64>Maximum acceptable lag (ms) between source writes and destination commits. When set + exceeded, source writes block until the destination catches up. Off by default (background drain, no backpressure).
Trait Implementations§
Source§impl Clone for TableSourceConfig
impl Clone for TableSourceConfig
Source§fn clone(&self) -> TableSourceConfig
fn clone(&self) -> TableSourceConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more