Struct MockServerHandle 

pub struct MockServerHandle { /* private fields */ }

Handle to a running in-process mock gRPC server.

Obtained from MockServerBuilder::start. The server continues to run until shutdown is called or the handle is dropped.

Implementations

impl MockServerHandle

pub fn addr(&self) -> SocketAddr

Returns the bound SocketAddr.

pub fn endpoint(&self) -> String

Returns a http:// URI string suitable for crate::AmateRSClient::connect.

pub async fn insert( &self, key: impl Into<Key>, value: CipherBlob, ) -> CoreResult<()>

Insert a key-value pair into the backing store at runtime.

This is useful for adding data after the server has started without going through the gRPC API.

Errors

Propagates errors from the underlying storage put.

pub async fn get_all(&self) -> CoreResult<Vec<(Key, CipherBlob)>>

Snapshot all key→value pairs in the backing store.

Errors

Propagates errors from the underlying storage scan.

pub fn inject_error(&self, key: impl Into<Key>, err: AmateRSError)

Inject a per-key error into the running server.

Subsequent get, set, and delete requests for key will fail with this error until clear_error is called.

pub fn clear_error(&self, key: impl Into<Key>)

Remove an injected error for key, restoring normal behaviour.

pub async fn shutdown(self)

Gracefully shut down the mock server.

Sends the shutdown signal to the background Tokio task. Calling this more than once is a no-op.

Trait Implementations

impl Drop for MockServerHandle

fn drop(&mut self)

Executes the destructor for this type.