pub struct IngestOptions {
pub table: String,
pub mode: String,
pub schema_override: Option<Map<String, Value>>,
pub merge_key: Option<Vec<String>>,
pub target_db: Option<String>,
}Expand description
Controls how data is loaded into a target table.
Fields§
§table: String§mode: String"replace" drops the existing table first; "append" adds rows to
it; "merge" upserts rows by Self::merge_key.
schema_override: Option<Map<String, Value>>When set, bypasses schema inference and uses these exact column types.
merge_key: Option<Vec<String>>When mode == "merge", the column(s) to match on for upsert. Required
in merge mode; rejected in any other mode (the per-call site validates
up-front so the lower ingest paths can stay format-agnostic).
target_db: Option<String>Resolved database alias for fully-qualified SQL. None means the
primary (ephemeral); Some("persistent") or Some("user_alias")
qualifies table references as "<db>"."public"."<table>".
Must be pre-resolved via Engine::resolve_target_db before setting.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for IngestOptions
impl RefUnwindSafe for IngestOptions
impl Send for IngestOptions
impl Sync for IngestOptions
impl Unpin for IngestOptions
impl UnsafeUnpin for IngestOptions
impl UnwindSafe for IngestOptions
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request