Struct ClientKernel 

pub struct ClientKernel<T> { /* private fields */ }

Reusable provider-neutral client policy kernel.

The kernel owns only its transport. It owns no executor, queue, clock, retry policy, or request storage. Every in-flight request must consume a caller-owned ClientWorkspaceLease.

Implementations

impl<T> ClientKernel<T>

where T: BlockingAuthenticatedTransport + BoundTransport,

pub fn execute_blocking<O, const N: usize>( &self, operation: &O, lease: ClientWorkspaceLease<'_, '_, N>, ) -> Result<O::Output, ClientExecutionError<O::Error, T::Error, O::DecodeError>>

where O: ClientOperation,

Prepares, authenticates, sends once, and checked-decodes synchronously.

pub fn execute_blocking_observed<O, V, const N: usize>( &self, operation: &O, lease: ClientWorkspaceLease<'_, '_, N>, observer: &V, ) -> Result<O::Output, ClientExecutionError<O::Error, T::Error, O::DecodeError>>

where O: ClientOperation, V: DiagnosticObserver + ?Sized,

Executes synchronously while emitting opt-in payload-free lifecycle events.

impl<T> ClientKernel<T>

where T: AsyncAuthenticatedTransport + BoundTransport + Sync,

pub fn execute_async<O, const N: usize>( &self, operation: &O, lease: ClientWorkspaceLease<'_, '_, N>, ) -> impl Future<Output = Result<O::Output, ClientExecutionError<O::Error, T::Error, O::DecodeError>>> + Send

where O: ClientOperation + Sync, O::Output: Send, O::Error: Send, O::DecodeError: Send, T::Error: Send,

Prepares, authenticates, sends once, and checked-decodes with a Send transport.

pub fn execute_async_observed<O, V, const N: usize>( &self, operation: &O, lease: ClientWorkspaceLease<'_, '_, N>, observer: &V, ) -> impl Future<Output = Result<O::Output, ClientExecutionError<O::Error, T::Error, O::DecodeError>>> + Send

where O: ClientOperation + Sync, O::Output: Send, O::Error: Send, O::DecodeError: Send, T::Error: Send, V: DiagnosticObserver + Sync + ?Sized,

Executes with a Send transport and opt-in payload-free lifecycle events.

impl<T> ClientKernel<T>

where T: LocalAsyncAuthenticatedTransport + BoundTransport,

pub async fn execute_local_async<O, const N: usize>( &self, operation: &O, lease: ClientWorkspaceLease<'_, '_, N>, ) -> Result<O::Output, ClientExecutionError<O::Error, T::Error, O::DecodeError>>

where O: ClientOperation,

Prepares, authenticates, sends once, and checked-decodes locally.

pub async fn execute_local_async_observed<O, V, const N: usize>( &self, operation: &O, lease: ClientWorkspaceLease<'_, '_, N>, observer: &V, ) -> Result<O::Output, ClientExecutionError<O::Error, T::Error, O::DecodeError>>

where O: ClientOperation, V: DiagnosticObserver + ?Sized,

Executes locally while emitting opt-in payload-free lifecycle events.

impl<T> ClientKernel<T>

pub const fn new(transport: T) -> Self

Creates a kernel around one endpoint-bound authenticated transport.

pub const fn transport(&self) -> &T

Returns the underlying transport.

pub fn into_transport(self) -> T

Consumes the kernel and returns its transport.

Trait Implementations

impl<T> Debug for ClientKernel<T>

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

Formats the value using the given formatter.