Skip to main content

DataMigrationRunDetail

Struct DataMigrationRunDetail 

Source
pub struct DataMigrationRunDetail {
Show 21 fields pub id: i64, pub job_id: Option<Option<String>>, pub created_by: String, pub created_at: String, pub started_at: String, pub updated_at: String, pub completed_at: Option<Option<String>>, pub status: Status, pub source_resource_path: String, pub target_resource_path: String, pub source_table: String, pub target_table: String, pub rows_migrated: i64, pub batches: i32, pub conflict_mode: ConflictMode, pub resume_count: i32, pub has_checkpoint: bool, pub has_pending_batch: bool, pub failed: bool, pub mapping: Vec<ColumnMapping>, pub error: Option<Option<String>>,
}
Expand description

DataMigrationRunDetail : One run in full. The handler flattens DataMigrationRunSummary into this object, so the wire shape is the summary’s fields plus mapping and error.

Fields§

§id: i64§job_id: Option<Option<String>>

The queue job this run belongs to, once #1212 moves execution onto the job queue. null for a run executed inline in the API request task – the one case with no SSE stream to watch and no job to cancel.

§created_by: String§created_at: String§started_at: String§updated_at: String

Last write of any kind to the row. For a running run this is the liveness signal: a stale updated_at with no live job is how a crashed run is visible as crashed rather than simply absent.

§completed_at: Option<Option<String>>§status: Status§source_resource_path: String§target_resource_path: String§source_table: String§target_table: String§rows_migrated: i64

Cumulative across attempts when the run was resumed: "how much of this migration is done", not "how much did the last attempt do".

§batches: i32§conflict_mode: ConflictMode§resume_count: i32

how many times this run has been picked up again after stopping.

§has_checkpoint: bool

A batch has committed, so a resume has a checkpoint to start from. The cursor itself is not returned – it is a list of source primary-key values, i.e. customer data.

§has_pending_batch: bool

A batch was handed to the target and its outcome was never recorded. Resume across it is only safe under conflict_mode = skip.

§failed: bool

The run recorded an error. The text is deliberately not here: it is on the per-run route only, so a history listing cannot carry it (see #1406).

§mapping: Vec<ColumnMapping>

The mapping this run was configured with. Returned because a resume is a fresh POST /run and the engine re-validates the mapping rather than trusting stored configuration – so the caller has to send it back, and the run row is the only place it is kept.

§error: Option<Option<String>>

Backend-authored failure text. Render as escaped text, never as HTML: until #1406 is fixed this can still contain target row values.

Implementations§

Source§

impl DataMigrationRunDetail

Source

pub fn new( id: i64, created_by: String, created_at: String, started_at: String, updated_at: String, status: Status, source_resource_path: String, target_resource_path: String, source_table: String, target_table: String, rows_migrated: i64, batches: i32, conflict_mode: ConflictMode, resume_count: i32, has_checkpoint: bool, has_pending_batch: bool, failed: bool, mapping: Vec<ColumnMapping>, ) -> DataMigrationRunDetail

One run in full. The handler flattens DataMigrationRunSummary into this object, so the wire shape is the summary’s fields plus mapping and error.

Trait Implementations§

Source§

impl Clone for DataMigrationRunDetail

Source§

fn clone(&self) -> DataMigrationRunDetail

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for DataMigrationRunDetail

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for DataMigrationRunDetail

Source§

fn default() -> DataMigrationRunDetail

Returns the “default value” for a type. Read more
Source§

impl<'de> Deserialize<'de> for DataMigrationRunDetail

Source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
Source§

impl PartialEq for DataMigrationRunDetail

Source§

fn eq(&self, other: &DataMigrationRunDetail) -> bool

Equality operator ==. Read more
1.0.0 (const: unstable) · Source§

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=. Read more
Source§

impl Serialize for DataMigrationRunDetail

Source§

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

Serialize this value into the given Serde serializer. Read more
Source§

impl StructuralPartialEq for DataMigrationRunDetail

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more