Delivery

pub struct RuntimeRoute {
    pub route_key: String,
    pub recipient: String,
    pub channel: Option<String>,
    pub sink: String,
    pub target_module: String,
    pub retry_max: Option<u32>,
    pub backoff_ms: Option<u64>,
    pub rate_limit_per_minute: Option<u32>,
}

pub struct RoutingResolution {
    pub route_id: String,
    pub recipient: String,
    pub channel: String,
    pub sink: String,
    pub target_module: String,
    pub retry_max: u32,
    pub backoff_ms: u64,
    pub rate_limit_per_minute: u32,
}

RuntimeRoute {
    route_key: format!("mob.member.{member_id}"),
    recipient: member_id,
    channel: Some("notification".to_string()),
    sink: "mob_member".to_string(),
    target_module: "delivery".to_string(),
    retry_max: None,
    backoff_ms: None,
    rate_limit_per_minute: None,
}

DeliverySendRequest {
    resolution,
    payload: serde_json::json!({
        "subject": "Update",
        "body": "The work is complete"
    }),
    idempotency_key: Some("customer-update-42".to_string()),
}