Struct Checkpoint

Source

pub struct Checkpoint {Show 27 fields
    pub schema_version: String,
    pub run_definition_schema: String,
    pub run_definition: Value,
    pub checkpoint_key: String,
    pub task_id: String,
    pub root_run_id: String,
    pub trace_id: String,
    pub run_definition_digest: String,
    pub resume_attempt: u64,
    pub cycle_index: u64,
    pub status: CheckpointStatus,
    pub messages: Vec<Message>,
    pub cycles: Vec<CycleRecord>,
    pub model_calls: Vec<ModelCallRecord>,
    pub shared_state: BTreeMap<String, Value>,
    pub budget_usage: Option<BudgetUsageSnapshot>,
    pub event_cursor: Option<EventCursor>,
    pub event_outbox: Vec<EventOutboxEntry>,
    pub extension_state: BTreeMap<String, ExtensionStateEntry>,
    pub model_call_journal: Vec<OperationJournalEntry>,
    pub tool_journal: Vec<OperationJournalEntry>,
    pub revision: u64,
    pub claim_token: Option<String>,
    pub claimed_cycle: Option<u64>,
    pub lease_expires_at_ms: Option<u64>,
    pub terminal_result: Option<Value>,
    pub terminal_acknowledged: bool,
}

Fields§

§schema_version: String§run_definition_schema: String§run_definition: Value§checkpoint_key: String§task_id: String§root_run_id: String§trace_id: String§run_definition_digest: String§resume_attempt: u64§cycle_index: u64§status: CheckpointStatus§messages: Vec<Message>§cycles: Vec<CycleRecord>§model_calls: Vec<ModelCallRecord>§shared_state: BTreeMap<String, Value>§budget_usage: Option<BudgetUsageSnapshot>§event_cursor: Option<EventCursor>§event_outbox: Vec<EventOutboxEntry>§extension_state: BTreeMap<String, ExtensionStateEntry>§model_call_journal: Vec<OperationJournalEntry>§tool_journal: Vec<OperationJournalEntry>§revision: u64§claim_token: Option<String>§claimed_cycle: Option<u64>§lease_expires_at_ms: Option<u64>§terminal_result: Option<Value>§terminal_acknowledged: bool

Struct Checkpoint Copy item path

Fields§

Implementations§

impl Checkpoint

pub fn validate(&self) -> CheckpointResult<()>

pub fn active_cycle(&self) -> CheckpointResult<u64>

pub fn has_ambiguous_operation(&self) -> bool

pub fn is_operator_abort_terminal(&self) -> bool

Trait Implementations§

impl Clone for Checkpoint

fn clone(&self) -> Checkpoint

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

impl Debug for Checkpoint

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

impl Default for Checkpoint

fn default() -> Self

impl PartialEq for Checkpoint

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

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

impl StructuralPartialEq for Checkpoint

Auto Trait Implementations§

impl Freeze for Checkpoint

impl RefUnwindSafe for Checkpoint

impl Send for Checkpoint

impl Sync for Checkpoint

impl Unpin for Checkpoint

impl UnsafeUnpin for Checkpoint

impl UnwindSafe for Checkpoint

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

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

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unsharedwhere Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

impl<T> MaybeSend for Twhere T: Send,

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

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

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

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

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

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

type Error = Infallible

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

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

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

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

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct Checkpoint

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

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

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

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

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

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

impl<T> MaybeSend for T
where T: Send,

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

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

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

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

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

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

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

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