Struct ServiceCtx 

pub struct ServiceCtx { /* private fields */ }

Process-aware context injected into VX endpoint handlers.

Provides access to the service’s private heap state and the Tri-Lane router for inter-service communication.

Example

async fn handle(ctx: &ServiceCtx) -> Result<String, VilError> {
    let db = ctx.state::<DbPool>()?;
    ctx.send("analytics", b"page_view").await?;
    Ok("ok".into())
}

Implementations

impl ServiceCtx

pub fn new( service_name: impl Into<String>, state: Arc<dyn Any + Send + Sync>, tri_lane: Arc<TriLaneRouter>, ) -> Self

Create a new service context.

pub fn service_name(&self) -> &str

Get the service name.

pub fn state<T: Send + Sync + 'static>(&self) -> Result<&T, VilError>

Downcast the private heap state to a concrete type.

Returns Err if the type does not match.

pub fn state_raw(&self) -> &Arc<dyn Any + Send + Sync>

Get a reference to the raw state Arc (for advanced usage).

pub fn tri_lane(&self) -> &Arc<TriLaneRouter>

Get a reference to the Tri-Lane router.

pub async fn send(&self, target: &str, data: &[u8]) -> Result<usize, VilError>

Send data to a target service via the Data Lane.

Use this for payload transfer (request/response bodies, file data).

pub async fn trigger( &self, target: &str, data: &[u8], ) -> Result<usize, VilError>

Send data to a target service via the Trigger Lane.

Use this for request initiation, auth tokens, session start signals.

pub async fn control( &self, target: &str, data: &[u8], ) -> Result<usize, VilError>

Send data to a target service via the Control Lane.

Use this for backpressure signals, circuit breaker, health propagation. Control Lane is never blocked by Data Lane congestion.

Trait Implementations

impl Clone for ServiceCtx

fn clone(&self) -> ServiceCtx

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServiceCtx

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

Formats the value using the given formatter.

impl FromRequestParts<AppState> for ServiceCtx

type Rejection = VilError

If the extractor fails it’ll use this “rejection” type. A rejection is a kind of error that can be converted into a response.

fn from_request_parts<'life0, 'life1, 'async_trait>( parts: &'life0 mut Parts, _state: &'life1 AppState, ) -> Pin<Box<dyn Future<Output = Result<Self, Self::Rejection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Perform the extraction.