Struct InMemoryMeshRuntime 

pub struct InMemoryMeshRuntime { /* private fields */ }

Implementations

impl InMemoryMeshRuntime

pub fn new() -> Self

Trait Implementations

impl Debug for InMemoryMeshRuntime

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

Formats the value using the given formatter.

impl Default for InMemoryMeshRuntime

fn default() -> Self

Returns the “default value” for a type.

impl MeshRuntime for InMemoryMeshRuntime

fn respond(&self, request_id: &str, _data_base64: &str) -> bool

Marks a pending query as answered. Returns true if the request was pending.

NOTE: Unlike LoopbackMeshRuntime and StatementStoreMeshRuntime, this implementation does NOT emit a meshReply event and ignores data_base64. This is a known asymmetry — the InMemoryMeshRuntime is for unit testing, not production mesh transport.

fn publish(&self, _topic: &str, _data_base64: &str) -> bool

fn subscribe(&self, topic: &str) -> bool

fn put_object( &self, path: &str, data_base64: &str, policy: MeshObjectPolicy, ) -> bool

fn get_object_result(&self, path: &str) -> MeshObjectResult

fn request(&self, _path: &str, _data_base64: &str) -> String

fn status(&self) -> MeshStatusResult

fn supports_private(&self) -> bool

fn put_private_object( &self, data_base64: &str, policy: MeshObjectPolicy, ) -> MeshPrivateObjectRef

fn get_private_object_result( &self, handle: &str, capability: &str, ) -> MeshObjectResult

fn request_private( &self, handle: &str, capability: &str, _data_base64: &str, ) -> String

fn publish_private_control( &self, capability: &str, envelope: MeshControlEnvelope, ) -> bool

fn subscribe_private_control(&self, capability: &str) -> bool

fn publish_private_receipt(&self, capability: &str, data_base64: &str) -> bool

fn subscribe_private_receipt(&self, capability: &str) -> bool

fn drain_events(&self) -> Vec<HostPushEvent>

fn get_object(&self, path: &str) -> Option<String>