Struct EarlyRequestContext 

pub struct EarlyRequestContext { /* private fields */ }

Fixed early-request projection. It is metadata, not a second execution context, admission permission or source receipt. No trace/sequence is minted.

let forged = saddle_observability::EarlyRequestContext { context: todo!() };

Implementations

impl EarlyRequestContext

pub fn socket_accepted(application: &str) -> Self

No request bytes/identities have been accepted yet. Application is the existing configured application label, NOT peer/body/header data.

Examples found in repository

examples/early_request_diagnostic.rs (line 36)

fn main() {
    // Caller is at the accepted socket phase; no trace, span, request or task is
    // fabricated to satisfy a constructor. The output may genuinely be absent.
    let scope =
        RequestDiagnosticScope::early(None, EarlyRequestContext::socket_accepted("example"))
            .with_phase(DiagnosticRequestPhase::ReadingHead);
    let failure = match read_head(&mut io::empty(), &scope) {
        Err(failure) => failure,
        Ok(()) => panic!("owned empty reader must fail"),
    };
    let id = failure.source_diagnostic().id();
    let (retained, delivery) = failure.finish_boundary_retained(
        None,
        &DiagnosticOutcomeAxes {
            operation: OperationOutcome::Failed,
            ..Default::default()
        },
    );
    assert_eq!(retained.error().kind(), io::ErrorKind::UnexpectedEof);
    assert_eq!(retained.source_diagnostic().id(), id);
    assert_eq!(
        delivery.source_submission(),
        DiagnosticSubmission::OutputUnavailable
    );
    assert_eq!(
        delivery.boundary_submission(),
        DiagnosticSubmission::OutputUnavailable
    );
    // Real consumer keeps `retained` in its task/response result, not just bool.
    println!("GO: early source retained without invented identities or output");
}

pub fn unavailable() -> Self

Facts cannot be recovered at this boundary. Known facts must be attached below; this is distinct from an identity that has never been established.

pub fn with_application( self, application: &ApplicationId, ) -> Result<Self, ContextBindingError<Self>>

pub fn with_trace( self, trace: &TraceCorrelationId, ) -> Result<Self, ContextBindingError<Self>>

An already validated protocol identity. Does not generate a root span.

pub fn with_rpc( self, rpc: &RpcCorrelationId, ) -> Result<Self, ContextBindingError<Self>>

pub fn with_event( self, event: &EventContext, ) -> Result<Self, ContextBindingError<Self>>

pub fn with_call( self, call: &CallContext, ) -> Result<Self, ContextBindingError<Self>>

pub fn with_request( self, request: &RequestIdentity, ) -> Result<Self, ContextBindingError<Self>>

pub fn with_route( self, route: &RouteIdentity, ) -> Result<Self, ContextBindingError<Self>>

pub fn with_module( self, module: &ModuleId, ) -> Result<Self, ContextBindingError<Self>>

pub fn with_service( self, service: &ServiceId, ) -> Result<Self, ContextBindingError<Self>>

pub fn with_operation( self, operation: &OperationId, ) -> Result<Self, ContextBindingError<Self>>