Struct RemoteComputationRegistry 

pub struct RemoteComputationRegistry { /* private fields */ }

Executable, schema-identified registry for remote named computations.

Registration couples every handler name to a declared input/output schema pair, so the complete registry fingerprint used during peer negotiation describes the code-selection surface that can actually run. The handler is still responsible for enforcing those declared schemas when it decodes and encodes its raw bytes; registration does not silently choose a codec. Dispatch requires an immutable admitted session and supplies an explicit Cx clone to the handler. The registry does not spawn tasks or provide ambient authority.

Implementations

impl RemoteComputationRegistry

pub fn new() -> Self

Creates an empty executable registry.

pub fn register<I, O, F, Fut>( &mut self, name: impl Into<String>, handler: F, ) -> Result<(), ComputationSchemaRegistryError>

where I: HasSchema, O: HasSchema, F: Fn(Cx, RemoteComputationInvocation) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<RemoteOutcome, RemoteError>> + Send + 'static,

Registers a Cx-threaded asynchronous named computation.

I and O define the stable wire schemas advertised during peer negotiation. The handler receives the raw admitted invocation so the application remains explicit about its chosen serialization codec.

pub const fn schema_registry(&self) -> &ComputationSchemaRegistry

Schema registry that must be used to build the peer-admission policy.

pub fn len(&self) -> usize

Number of executable named computations.

pub fn is_empty(&self) -> bool

Returns true when no executable computation is registered.

pub async fn dispatch( &self, cx: &Cx, session: &RemotePeerSession, request: SpawnRequest, ) -> Result<RemoteOutcome, RemoteComputationDispatchError>

Authorizes and executes one named-computation request.

No handler is invoked until the session capability accepts the name. The returned future is awaited inline and is never detached.

Trait Implementations

impl Clone for RemoteComputationRegistry

fn clone(&self) -> RemoteComputationRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RemoteComputationRegistry

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

Formats the value using the given formatter.

impl Default for RemoteComputationRegistry

fn default() -> RemoteComputationRegistry

Returns the “default value” for a type.