Struct LedgerRow 

pub struct LedgerRow {

    pub msg_id: String,
    pub op_id: Option<String>,
    pub fingerprint: Option<String>,
    pub kind: MsgKind,
    pub from_json: String,
    pub to_json: String,
    pub task: Option<String>,
    pub parent_task: Option<String>,
    pub attempt: i64,
    pub state: LedgerState,
    pub out_head: Option<String>,
    pub reason: Option<String>,
    pub enqueued_at: String,
    pub acked_at: Option<String>,
    pub body_json: Option<String>,
    pub hop: i64,
    pub expires_at: Option<String>,
    pub requeued: i64,
    pub family: Option<String>,
    pub hop_budget: Option<i64>,
    pub origin: Option<String>,
    pub deadline: Option<String>,
    pub labels_json: Option<String>,
}

Fields

msg_id: String

op_id: Option<String>

fingerprint: Option<String>

kind: MsgKind

from_json: String

to_json: String

task: Option<String>

parent_task: Option<String>

attempt: i64

state: LedgerState

out_head: Option<String>

reason: Option<String>

enqueued_at: String

acked_at: Option<String>

body_json: Option<String>

hop: i64

Causality’s hop count from the root task, which is what turns the parent_task links into a measurable depth.

expires_at: Option<String>

The persisted expiry deadline of a ttl note, so a restarted server can re-arm its sweep.

requeued: i64

Times this row has moved from in_flight back to queued.

family: Option<String>

The family’s root task id, read off the envelope’s causality. Every row of one run carries it unchanged, and onlyne handoff reads it back to mint the next hop into the same family.

hop_budget: Option<i64>

The hops the family may spend, carried on every row of the run.

origin: Option<String>

The role the family reports home to, carried on every row of the run.

deadline: Option<String>

Wall-clock bound for the whole family, in the RFC 3339 text this crate’s helpers produce.

labels_json: Option<String>

The causality’s labels as JSON text, so the column keeps whatever map the sender attached.

Implementations

impl LedgerRow

pub fn from_envelope( envelope: &Envelope, fingerprint: &str, ) -> StoreResult<Self>

impl LedgerRow

pub fn sender(&self) -> Result<Principal, Error>

The sender principal this row recorded.

The sender column carries the principal beside the admin marker, so a row states whether an admin-surface send wrote it (plan §8 line 320) without a second column. A column holding a bare principal decodes too.

pub fn sender_is_admin(&self) -> bool

Whether the send behind this row arrived on the admin surface.

Trait Implementations

impl Clone for LedgerRow

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LedgerRow

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LedgerRow

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for LedgerRow

impl PartialEq for LedgerRow

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for LedgerRow

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for LedgerRow