Struct Receipt 

pub struct Receipt {
    pub id: ReceiptId,
    pub flow_run_id: FlowRunId,
    pub node_id: NodeId,
    pub step_run_id: StepRunId,
    pub connector: String,
    pub timestamp: DateTime<Utc>,
    pub attempt_id_raw: Uuid,
    pub input_hash: String,
    pub output_hash: Option<String>,
    pub status: ReceiptStatus,
    pub error: Option<String>,
    pub duration_ms: u64,
}

Immutable evidence of a single boundary crossing.

Fields

id: ReceiptId

Content-addressed ID (SHA-256 hash of all other fields).

flow_run_id: FlowRunId

Which flow run this crossing belongs to.

node_id: NodeId

Which node performed the crossing.

step_run_id: StepRunId

The step execution that performed the crossing.

connector: String

Name of the connector that was invoked.

timestamp: DateTime<Utc>

When the crossing occurred.

attempt_id_raw: Uuid

The ActionQueue AttemptId (stored as raw UUID to avoid AQ dependency).

input_hash: String

SHA-256 hex digest of the serialized input parameters.

output_hash: Option<String>

SHA-256 hex digest of the output. None if the crossing failed.

status: ReceiptStatus

Whether the crossing succeeded, failed, or timed out.

error: Option<String>

Error message, present when status is Failure or Timeout.

duration_ms: u64

Wall-clock duration of the connector invocation in milliseconds.

Implementations

impl Receipt

pub fn new( flow_run_id: FlowRunId, node_id: NodeId, step_run_id: StepRunId, connector: String, timestamp: DateTime<Utc>, attempt_id_raw: Uuid, input_hash: String, output_hash: Option<String>, status: ReceiptStatus, error: Option<String>, duration_ms: u64, ) -> Self

Construct a new receipt. The content-addressed ID is computed automatically from all fields.

Trait Implementations

impl Clone for Receipt

fn clone(&self) -> Receipt

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Receipt

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Receipt

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Receipt

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Receipt

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 Receipt