pub struct TuneMvActuationRow {Show 15 fields
pub id: i64,
pub run_id: i64,
pub sequence: i64,
pub kind: MvActuationKind,
pub commanded_at: DateTime<Utc>,
pub target_mv: f32,
pub previous_commanded_mv: Option<f32>,
pub tolerance: f32,
pub confirmation_due_at: DateTime<Utc>,
pub last_checked_at: Option<DateTime<Utc>>,
pub readback_mv: Option<f32>,
pub readback_quality: Option<SampleQuality>,
pub attempt_count: i64,
pub status: MvActuationStatus,
pub detail: Option<String>,
}Expand description
One row of tune_mv_actuations: durable evidence for an accepted OPC DA MV write.
These rows are separate from TuneSampleRow, whose MV remains the engine’s commanded
series for trend/export compatibility. readback_mv and readback_quality are the most
recent physical observation made by the verifier; attempt_count counts every persisted
observation, including attempts where no numeric value or trustworthy quality could be
obtained.
Fields§
§id: i64§run_id: i64§sequence: i64Monotonic command order within one run. Unique together with run_id.
kind: MvActuationKind§commanded_at: DateTime<Utc>UTC projection of the instant at which the driver accepted the MV write.
target_mv: f32§previous_commanded_mv: Option<f32>§tolerance: f32Exact absolute target/readback tolerance applied to this command.
confirmation_due_at: DateTime<Utc>Exact time at which the command must have terminal evidence under the active policy.
last_checked_at: Option<DateTime<Utc>>§readback_mv: Option<f32>§readback_quality: Option<SampleQuality>§attempt_count: i64§status: MvActuationStatus§detail: Option<String>Operator-facing explanation, primarily for failed/unverified/superseded rows.
Implementations§
Source§impl TuneMvActuationRow
impl TuneMvActuationRow
Sourcepub async fn insert_pending(
pool: &SqlitePool,
run_id: i64,
new: NewTuneMvActuation,
) -> DbResult<TuneMvActuationRow>
pub async fn insert_pending( pool: &SqlitePool, run_id: i64, new: NewTuneMvActuation, ) -> DbResult<TuneMvActuationRow>
Inserts one accepted command in MvActuationStatus::Pending state. Observation
fields are empty and attempt_count is zero until Self::record_observation or
Self::record_final_observation is called.
Sourcepub async fn record_observation(
pool: &SqlitePool,
id: i64,
checked_at: DateTime<Utc>,
readback_mv: Option<f32>,
readback_quality: Option<SampleQuality>,
) -> DbResult<TuneMvActuationRow>
pub async fn record_observation( pool: &SqlitePool, id: i64, checked_at: DateTime<Utc>, readback_mv: Option<f32>, readback_quality: Option<SampleQuality>, ) -> DbResult<TuneMvActuationRow>
Records the latest verification attempt while leaving the command pending. Both observation values are optional so a caller can still persist that an attempted check produced no usable numeric value and/or no quality classification.
Sourcepub async fn record_final_observation(
pool: &SqlitePool,
id: i64,
checked_at: DateTime<Utc>,
readback_mv: Option<f32>,
readback_quality: Option<SampleQuality>,
status: MvActuationStatus,
detail: Option<&str>,
) -> DbResult<TuneMvActuationRow>
pub async fn record_final_observation( pool: &SqlitePool, id: i64, checked_at: DateTime<Utc>, readback_mv: Option<f32>, readback_quality: Option<SampleQuality>, status: MvActuationStatus, detail: Option<&str>, ) -> DbResult<TuneMvActuationRow>
Atomically records the final observation and terminal status. This is preferable to
separate Self::record_observation and Self::finalize calls when one read
conclusively confirms or rejects the target, because readers can never observe that
final evidence while the row still misleadingly says pending.
Sourcepub async fn finalize(
pool: &SqlitePool,
id: i64,
status: MvActuationStatus,
detail: Option<&str>,
) -> DbResult<TuneMvActuationRow>
pub async fn finalize( pool: &SqlitePool, id: i64, status: MvActuationStatus, detail: Option<&str>, ) -> DbResult<TuneMvActuationRow>
Finalizes a pending command without inventing an observation. Used for terminal paths
such as interruption (Unverified) or deliberate handoff (Superseded).
Sourcepub async fn finalize_pending_for_run(
pool: &SqlitePool,
run_id: i64,
status: MvActuationStatus,
detail: Option<&str>,
) -> DbResult<u64>
pub async fn finalize_pending_for_run( pool: &SqlitePool, run_id: i64, status: MvActuationStatus, detail: Option<&str>, ) -> DbResult<u64>
Finalizes every still-pending command belonging to run_id, returning the number of
rows changed. Already-terminal rows and rows for other runs are never modified. This
is the terminal-path backstop that prevents a completed/failed/aborted run from
retaining misleading pending audit records.
Sourcepub async fn list_for_run(
pool: &SqlitePool,
run_id: i64,
) -> DbResult<Vec<TuneMvActuationRow>>
pub async fn list_for_run( pool: &SqlitePool, run_id: i64, ) -> DbResult<Vec<TuneMvActuationRow>>
Lists every accepted MV command for run_id in command-sequence order.
Trait Implementations§
Source§impl Clone for TuneMvActuationRow
impl Clone for TuneMvActuationRow
Source§fn clone(&self) -> TuneMvActuationRow
fn clone(&self) -> TuneMvActuationRow
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 TuneMvActuationRow
impl Debug for TuneMvActuationRow
Source§impl PartialEq for TuneMvActuationRow
impl PartialEq for TuneMvActuationRow
Source§fn eq(&self, other: &TuneMvActuationRow) -> bool
fn eq(&self, other: &TuneMvActuationRow) -> bool
self and other values to be equal, and is used by ==.impl StructuralPartialEq for TuneMvActuationRow
Auto Trait Implementations§
impl Freeze for TuneMvActuationRow
impl RefUnwindSafe for TuneMvActuationRow
impl Send for TuneMvActuationRow
impl Sync for TuneMvActuationRow
impl Unpin for TuneMvActuationRow
impl UnsafeUnpin for TuneMvActuationRow
impl UnwindSafe for TuneMvActuationRow
Blanket Implementations§
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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