Struct RequestContext 

pub struct RequestContext {
    pub tx: Arc<str>,
    pub client_id: Option<ClientId>,
    pub lineage: Vec<Arc<str>>,
    pub host_id: Uuid,
    pub created_at: String,
    pub windback: Option<Arc<str>>,
}

Context that propagates through request processing.

Created when a request arrives via WebSocket and flows through command execution, query subscriptions, and report generation.

Fields

tx: Arc<str>

Transaction ID - same across all operations in one request. Used to correlate logs, events, and responses.

client_id: Option<ClientId>

Client ID of the WebSocket connection that initiated this request. None for internal operations (sagas, startup tasks).

lineage: Vec<Arc<str>>

Call chain tracking the path of execution. Starts with ["client"] for WebSocket requests or ["saga", "SagaName"] for sagas. Extended via child() for nested operations.

host_id: Uuid

Server that received the original request.

created_at: String

ISO timestamp when the request started.

windback: Option<Arc<str>>

Windback timestamp for historical state viewing. When set, queries should return state as of this ISO timestamp. None means the client is viewing live state.

Implementations

impl RequestContext

pub fn new( tx: Arc<str>, client_id: Option<Arc<str>>, lineage: Vec<Arc<str>>, host_id: Uuid, created_at: String, ) -> Self

Create a new RequestContext with explicit values.

pub fn from_client(tx: Arc<str>, client_id: Arc<str>, host_id: Uuid) -> Self

Create a context for a client-initiated request.

Sets lineage to ["client"] and created_at to current time. Use from_client_with_windback to include windback state.

pub fn from_client_with_windback( tx: Arc<str>, client_id: Arc<str>, host_id: Uuid, windback: Option<Arc<str>>, ) -> Self

Create a context for a client-initiated request with windback state.

Sets lineage to ["client"] and created_at to current time.

pub fn internal(tx: Arc<str>, host_id: Uuid, origin: &str) -> Self

Create a context for an internal operation (no client).

Used for saga-initiated operations, startup tasks, etc.

pub fn child(&self, operation: &str) -> Self

Create a child context with extended lineage.

Used when making sub-operations (nested commands, queries from reports, etc.) to track the call chain. Preserves the parent’s windback state.

Example

use std::sync::Arc;
use uuid::Uuid;
use myko::request::RequestContext;

let tx: Arc<str> = "tx-1".into();
let client_id: Arc<str> = "client-1".into();
let host_id = Uuid::new_v4();
let parent = RequestContext::from_client(tx, client_id, host_id);
let child = parent.child("CreateBinding");
assert_eq!(child.lineage.len(), 2);
assert_eq!(child.lineage[0].as_ref(), "client");
assert_eq!(child.lineage[1].as_ref(), "CreateBinding");

pub fn is_windback(&self) -> bool

Check if this context is in windback mode.

pub fn windback(&self) -> Option<&str>

Get the windback timestamp if set.

pub fn tx(&self) -> &str

Get the transaction ID as a string slice.

pub fn client_id(&self) -> Option<&str>

Get the client ID if present.

pub fn lineage_string(&self) -> String

Get the lineage as a string for logging.

Trait Implementations

impl Clone for RequestContext

fn clone(&self) -> RequestContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RequestContext

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

Formats the value using the given formatter.