Struct CallContext 

pub struct CallContext { /* private fields */ }

Metadata about the current server-side method call.

Passed to ServerInterceptor::before and ServerInterceptor::after.

Implementations

impl CallContext

pub fn method(&self) -> &str

Returns the JSON-RPC method name.

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

Returns the caller identity, once something has established one.

pub fn set_caller_identity(&self, identity: impl Into<String>) -> bool

Records who the caller is, if nothing has yet.

Returns true when this call set the identity and false when one was already present — in which case the existing identity stands and the argument is dropped.

Takes &self deliberately: the caller is established by an authentication interceptor, and ServerInterceptor::before receives a shared reference. Anything that needs &mut here is unreachable from the place that has the answer.

Example

use a2a_protocol_server::CallContext;

let ctx = CallContext::new("SendMessage");
assert!(ctx.set_caller_identity("user@example.com"));
assert_eq!(ctx.caller_identity(), Some("user@example.com"));

// A second interceptor does not get to overwrite it.
assert!(!ctx.set_caller_identity("someone-else"));
assert_eq!(ctx.caller_identity(), Some("user@example.com"));

pub fn extensions(&self) -> &[String]

Returns the active extension URIs.

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

Returns the request/trace ID if set.

pub const fn http_headers(&self) -> &HashMap<String, String>

Returns the HTTP request headers (read-only).

pub const fn trace_context(&self) -> Option<&TraceContext>

The W3C trace this call belongs to, when the caller propagated one.

None means the caller sent no traceparent, or sent one this SDK refused. It never means “we made one up”: the server propagates traces and does not start them, so a Some here is evidence that something upstream is actually tracing.

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

Returns the tenant this call resolved to, if any.

Prefer this over TenantContext::current anywhere the value has to survive a tokio::spawn: the task-local is not inherited by a spawned task, and this field is an owned copy taken before the spawn.

impl CallContext

pub fn new(method: impl Into<String>) -> CallContext

Creates a new CallContext for the given method.

pub fn with_trace_context(self, trace_context: TraceContext) -> CallContext

Sets the trace this call belongs to.

pub fn with_tenant(self, tenant: impl Into<String>) -> CallContext

Sets the resolved tenant.

pub fn with_caller_identity(self, identity: String) -> CallContext

Sets the caller identity at construction.

For a caller building a context directly. An interceptor holding &CallContext wants set_caller_identity.

pub fn with_extensions(self, extensions: Vec<String>) -> CallContext

Sets the active extensions.

pub fn with_request_id(self, id: impl Into<String>) -> CallContext

Sets the request/trace ID explicitly.

pub fn with_http_headers(self, headers: HashMap<String, String>) -> CallContext

Sets the HTTP headers map (replacing any existing headers).

Automatically extracts x-request-id into request_id if present.

pub fn with_http_header( self, key: impl Into<String>, value: impl Into<String>, ) -> CallContext

Adds a single HTTP header (key is lowercased for case-insensitive matching).

If the key is x-request-id, also populates request_id.

Trait Implementations

impl Clone for CallContext

fn clone(&self) -> CallContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CallContext

Hand-written so a caller’s credentials cannot reach a log through a debug-print.

Until 0.13.0 CallContext reached only the interceptor chain. It now rides on RequestContext into every AgentExecutor, and the derived Debug printed http_headers verbatim — Authorization, Cookie, whatever the deployment forwards. tracing::debug!("{ctx:?}") inside an executor is a natural thing to write, and the executor is the component most likely to be LLM-adjacent or to forward its context somewhere else.

Header names are printed and values are not, rather than redacting a named list of sensitive ones: a denylist rots the moment a deployment forwards a header nobody thought of, and the names alone answer the question a debug-print is usually asking. Read a value deliberately with http_header when you want one.

This is the same call auth::jwt already makes for its signing secret.

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

Formats the value using the given formatter.