pub struct MssqlWriteFailureContext { /* private fields */ }Expand description
Structured context for a one-output SQL Server write failure.
Implementations§
Source§impl MssqlWriteFailureContext
impl MssqlWriteFailureContext
Sourcepub fn to_json_value(&self) -> Value
pub fn to_json_value(&self) -> Value
Returns phase-aware write failure context as a JSON-compatible Python shape.
Source§impl MssqlWriteFailureContext
impl MssqlWriteFailureContext
Sourcepub fn from_output_plan(
output_plan: &MssqlTargetOutputPlan,
phase: MssqlWritePhase,
rows_written: u64,
batches_written: u64,
elapsed_ms: u64,
partial_write_possible: bool,
cleanup: MssqlTargetCleanupStatus,
) -> Self
pub fn from_output_plan( output_plan: &MssqlTargetOutputPlan, phase: MssqlWritePhase, rows_written: u64, batches_written: u64, elapsed_ms: u64, partial_write_possible: bool, cleanup: MssqlTargetCleanupStatus, ) -> Self
Builds failure context from the already planned SQL Server output target.
Sourcepub const fn phase(&self) -> MssqlWritePhase
pub const fn phase(&self) -> MssqlWritePhase
Returns the write phase associated with the failure.
Sourcepub fn output_name(&self) -> &str
pub fn output_name(&self) -> &str
Returns the selected output name.
Sourcepub fn target_table(&self) -> &MssqlTargetTable
pub fn target_table(&self) -> &MssqlTargetTable
Returns the effective target table.
Sourcepub const fn connection_source(&self) -> MssqlConnectionSource
pub const fn connection_source(&self) -> MssqlConnectionSource
Returns where the effective connection came from.
Sourcepub const fn connection(&self) -> &MssqlConnectionSummary
pub const fn connection(&self) -> &MssqlConnectionSummary
Returns the redacted effective connection summary.
Sourcepub const fn stats(&self) -> &MssqlWriteStats
pub const fn stats(&self) -> &MssqlWriteStats
Returns accepted write statistics known at failure time.
Sourcepub const fn output_row_count(&self) -> RowCount
pub const fn output_row_count(&self) -> RowCount
Returns query output row evidence known at failure time.
Sourcepub const fn target_row_count(&self) -> RowCount
pub const fn target_row_count(&self) -> RowCount
Returns target-side row count evidence known at failure time.
Sourcepub const fn target_row_count_before_write(&self) -> RowCount
pub const fn target_row_count_before_write(&self) -> RowCount
Returns target-side row count evidence known before the write.
Sourcepub const fn target_row_count_after_write(&self) -> RowCount
pub const fn target_row_count_after_write(&self) -> RowCount
Returns target-side row count evidence known after the write.
Sourcepub const fn validation_status(&self) -> ValidationStatus
pub const fn validation_status(&self) -> ValidationStatus
Returns target-side validation status known at failure time.
Sourcepub const fn batch_shaping(&self) -> MssqlBatchShapingReport
pub const fn batch_shaping(&self) -> MssqlBatchShapingReport
Returns identity batch-shaping counters known at failure time.
Sourcepub const fn partial_write_possible(&self) -> bool
pub const fn partial_write_possible(&self) -> bool
Returns whether the target may contain a partial write after failure.
Sourcepub const fn cleanup(&self) -> MssqlTargetCleanupStatus
pub const fn cleanup(&self) -> MssqlTargetCleanupStatus
Returns cleanup reporting state for DeltaFunnel-owned target cleanup.
Sourcepub const fn report(&self) -> &MssqlWriteReport
pub const fn report(&self) -> &MssqlWriteReport
Returns the redacted write report associated with the failure.
Sourcepub fn phase_timings(&self) -> &[PhaseTimingReport]
pub fn phase_timings(&self) -> &[PhaseTimingReport]
Returns workflow phase timing reports known at failure time.
Trait Implementations§
Source§impl Clone for MssqlWriteFailureContext
impl Clone for MssqlWriteFailureContext
Source§fn clone(&self) -> MssqlWriteFailureContext
fn clone(&self) -> MssqlWriteFailureContext
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for MssqlWriteFailureContext
impl Debug for MssqlWriteFailureContext
impl Eq for MssqlWriteFailureContext
Source§impl PartialEq for MssqlWriteFailureContext
impl PartialEq for MssqlWriteFailureContext
Source§fn eq(&self, other: &MssqlWriteFailureContext) -> bool
fn eq(&self, other: &MssqlWriteFailureContext) -> bool
self and other values to be equal, and is used by ==.impl StructuralPartialEq for MssqlWriteFailureContext
Auto Trait Implementations§
impl Freeze for MssqlWriteFailureContext
impl RefUnwindSafe for MssqlWriteFailureContext
impl Send for MssqlWriteFailureContext
impl Sync for MssqlWriteFailureContext
impl Unpin for MssqlWriteFailureContext
impl UnsafeUnpin for MssqlWriteFailureContext
impl UnwindSafe for MssqlWriteFailureContext
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> AsAny for T
impl<T> AsAny for T
Source§fn any_ref(&self) -> &(dyn Any + Send + Sync + 'static)
fn any_ref(&self) -> &(dyn Any + Send + Sync + 'static)
dyn Any reference to the object: Read moreSource§fn as_any(self: Arc<T>) -> Arc<dyn Any + Send + Sync> ⓘ
fn as_any(self: Arc<T>) -> Arc<dyn Any + Send + Sync> ⓘ
Arc<dyn Any> reference to the object: Read moreSource§fn into_any(self: Box<T>) -> Box<dyn Any + Send + Sync>
fn into_any(self: Box<T>) -> Box<dyn Any + Send + Sync>
Box<dyn Any>: Read moreSource§fn type_name(&self) -> &'static str
fn type_name(&self) -> &'static str
std::any::type_name, since Any does not provide it and
Any::type_id is useless as a debugging aid (its Debug is just a mess of hex digits).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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> DynPartialEq for T
impl<T> DynPartialEq for T
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more