Struct DataspaceRegistry 

pub struct DataspaceRegistry { /* private fields */ }

A dataspace registry for async coordination between processes.

The registry stores broadcast channels indexed by type and Identifier. Processes can subscribe to receive assertion and retraction updates for a given type and identifier filter, and other processes can assert or retract values that are delivered to all matching subscribers.

Thread Safety

DataspaceRegistry is Clone and can be safely shared across threads and tasks. All operations are thread-safe.

Implementations

impl DataspaceRegistry

pub fn new() -> Self

Creates a new empty registry with the default channel capacity.

pub fn try_current() -> Option<Self>

Returns the dataspace registry for the current supervision tree, if one exists.

pub fn with_channel_capacity(capacity: usize) -> Self

Creates a new empty registry with the given channel capacity for broadcast channels.

pub fn assert<T>(&self, value: T, id: impl Into<Identifier>)

where T: Clone + Send + Sync + 'static,

Asserts a value with the given identifier, notifying all matching subscribers.

The assertion is automatically associated with the current process, and will be automatically retracted when that process exists. Only the owning process may update an existing assertion for a given type/identifier combination.

pub fn retract<T>(&self, id: impl Into<Identifier>)

where T: Clone + Send + Sync + 'static,

Retracts the value of the given type and identifier, notifying all matching subscribers.

Only the process that originally asserted the value may retract it.

pub fn send<T>(&self, value: T, id: impl Into<Identifier>)

where T: Clone + Send + Sync + 'static,

Sends a transient message with the given identifier to all matching subscribers.

Unlike assert, only the current matching subscribers are notified: messages are never stored or replayed. If not matching subscribers exist, the message is dropped.

pub fn current_values<T>(&self, filter: IdentifierFilter) -> Vec<T>

where T: Clone + Send + Sync + 'static,

This is a synchronous point-in-time read that locks the registry, collects matching values, and returns immediately without creating any subscription or channel. Use this when you need a snapshot of what is currently asserted rather than ongoing notifications of future changes.

pub fn subscribe<T>(&self, filter: IdentifierFilter) -> Subscription<T>

where T: Clone + Send + Sync + 'static,

Subscribes to updates matching the given filter.

Returns a Subscription that can be used to asynchronously receive updates. Any updates to assertions that match the filter at the time of subscribing will be immediately replayed into the subscription’s pending queue. Messages are never replayed, so only those sent after subscribing are delivered.

Trait Implementations

impl Clone for DataspaceRegistry

fn clone(&self) -> DataspaceRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for DataspaceRegistry

fn default() -> Self

Returns the “default value” for a type.