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>

where T: BlockingAuthenticatedTransport + BoundTransport,

pub fn execute_blocking_with<'operation, O, R, P, D, F, G, const N: usize>( &self, operation: &'operation O, lease: ClientWorkspaceLease<'_, '_, N>, prepare: F, decode: G, ) -> Result<R, ClientExecutionError<P, T::Error, D>>

where F: for<'guard> FnOnce(&'operation O, &'guard mut PreparationStorageGuard<'_>) -> Result<PreparedRequest<'guard>, P>, G: FnOnce(&'operation O, ClientResponse<'_, '_>) -> Result<R, D>,

Executes through cleanup-owning provider preparation and decoding hooks.

impl<T> ClientKernel<T>

where T: AsyncAuthenticatedTransport + BoundTransport + Sync,

pub fn execute_async_with<'operation, O, R, P, D, F, G, const N: usize>( &self, operation: &'operation O, lease: ClientWorkspaceLease<'_, '_, N>, prepare: F, decode: G, ) -> impl Future<Output = Result<R, ClientExecutionError<P, T::Error, D>>> + Send

where O: Sync, P: Send, R: Send, D: Send, F: for<'guard> FnOnce(&'operation O, &'guard mut PreparationStorageGuard<'_>) -> Result<PreparedRequest<'guard>, P> + Send, G: FnOnce(&'operation O, ClientResponse<'_, '_>) -> Result<R, D> + Send, T::Error: Send,

Send-async equivalent of Self::execute_blocking_with.

impl<T> ClientKernel<T>

where T: LocalAsyncAuthenticatedTransport + BoundTransport,

pub async fn execute_local_async_with<'operation, O, R, P, D, F, G, const N: usize>( &self, operation: &'operation O, lease: ClientWorkspaceLease<'_, '_, N>, prepare: F, decode: G, ) -> Result<R, ClientExecutionError<P, T::Error, D>>

where F: for<'guard> FnOnce(&'operation O, &'guard mut PreparationStorageGuard<'_>) -> Result<PreparedRequest<'guard>, P>, G: FnOnce(&'operation O, ClientResponse<'_, '_>) -> Result<R, D>,

Local-async equivalent of Self::execute_blocking_with.

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.