Struct RoutingDecision 

pub struct RoutingDecision {
    pub id: String,
    pub run_id: String,
    pub subtask_id: String,
    pub candidates: Vec<RoutingCandidate>,
    pub chosen: RoutingChoice,
    pub reason: RoutingReason,
    pub content_hash: String,
    pub decided_at: DateTime<Utc>,
    pub anchor: String,
}

The full routing decision recorded per coordination step. Immutable once written; replays compare content_hash to detect drift.

Fields

id: String

rtg_* ULID; unique per record.

run_id: String

Run this decision belongs to.

subtask_id: String

Subtask / DAG step the decision is binding.

candidates: Vec<RoutingCandidate>

Every candidate the orchestrator considered, in the order they were evaluated. Order is preserved verbatim so a replay can attribute a later ordering change.

chosen: RoutingChoice

The candidate that won.

reason: RoutingReason

Why this candidate won.

content_hash: String

SHA-256 over a stable JSON projection of the decision’s structural fields (everything except decided_at and content_hash itself). Equal hashes mean equal decisions; unequal hashes mean a coordination drift that the replay should surface.

decided_at: DateTime<Utc>

Server-generated wall-clock UTC instant.

anchor: String

arXiv anchor of the audit methodology — defaults to ROUTING_ANCHOR.

Implementations

impl RoutingDecision

pub fn new( id: impl Into<String>, run_id: impl Into<String>, subtask_id: impl Into<String>, candidates: Vec<RoutingCandidate>, chosen: RoutingChoice, reason: RoutingReason, decided_at: DateTime<Utc>, ) -> Self

Build a decision from raw inputs. id and decided_at are taken from the caller so the gateway can stamp them at dispatch time; content_hash is computed here so the contract is single-source.

pub fn to_audit_details(&self) -> Value

Serialize the decision into the JSON shape that goes into audit_events.details. Mirrors serde_json::to_value(&self) but kept as a named entry point so call sites read clearly.

pub fn from_audit_details(value: &Value) -> Result<Self, Error>

Parse a decision back out of an audit_events.details blob. Used by the gateway /v1/runs/{id}/routing read endpoint and by the fd-evals replay helper.

pub fn verify_hash(&self) -> bool

Verify that the stored content_hash still matches a re-computation from the structural fields. Used by replays to detect drift.

Trait Implementations

impl Clone for RoutingDecision

fn clone(&self) -> RoutingDecision

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RoutingDecision

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RoutingDecision

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RoutingDecision

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RoutingDecision

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 RoutingDecision