Struct TracingSinkClient 

pub struct TracingSinkClient<T: Transport> { /* private fields */ }

Client stub for the #trait_name service.

This client uses hardcoded method IDs (1, 2, …) and expects an Arc<RpcSession<T>> whose run task is already running. Construct sessions with RpcSession::with_channel_start to coordinate odd/even channel IDs when both peers initiate RPCs. For multi-service scenarios where method IDs must be globally unique, use [#registry_client_name] instead.

Usage

let session = Arc::new(RpcSession::new(transport));
tokio::spawn(session.clone().run()); // Start the demux loop
let client = FooClient::new(session);
let result = client.some_method(args).await?;

Implementations

impl<T: Transport + Send + Sync + 'static> TracingSinkClient<T>

pub fn new(session: Arc<RpcSession<T>>) -> Self

Create a new client with the given RPC session.

Uses hardcoded method IDs (1, 2, …). For registry-based method IDs, use [#registry_client_name::new] instead.

The provided session must be shared (Arc::clone) with the call site and have its demux loop (tokio::spawn(session.clone().run())) running.

pub fn session(&self) -> &Arc<RpcSession<T>>

Get a reference to the underlying session.

pub async fn new_span(&self, span: SpanMeta) -> Result<u64, RpcError>

Call the #name method on the remote service.

pub async fn record( &self, span_id: u64, fields: Vec<Field>, ) -> Result<(), RpcError>

Call the #name method on the remote service.

pub async fn event(&self, event: EventMeta) -> Result<(), RpcError>

Call the #name method on the remote service.

pub async fn enter(&self, span_id: u64) -> Result<(), RpcError>

Call the #name method on the remote service.

pub async fn exit(&self, span_id: u64) -> Result<(), RpcError>

Call the #name method on the remote service.

pub async fn drop_span(&self, span_id: u64) -> Result<(), RpcError>

Call the #name method on the remote service.