Struct DhtRegistrationPublisher 

pub struct DhtRegistrationPublisher { /* private fields */ }

Common publisher for DHT-backed registries.

Implementations

impl DhtRegistrationPublisher

pub fn new(topic: impl Into<String>) -> Self

Create a publisher for topic.

pub fn topic(&self) -> &str

Return the DHT topic used by this publisher.

pub async fn publish( &self, context: &RegistrationContext<'_>, value: Encoded, ) -> Result<()>

Publish value, tombstoning older values previously published by this publisher.

pub async fn publish_many( &self, context: &RegistrationContext<'_>, values: impl IntoIterator<Item = Encoded>, ) -> Result<()>

Publish the current value set, tombstoning older values previously published by this publisher.

Invariant: after a successful call, DHT data previously emitted by this publisher is exactly values. Preservation: every stale local value is tombstoned after every current value is touched under the same publisher serialization lock.

pub async fn publish_many_replacing( &self, context: &RegistrationContext<'_>, values: impl IntoIterator<Item = Encoded>, replaces_observed_value: impl Fn(&Encoded) -> bool, ) -> Result<()>

Publish the current value set, tombstoning older observed values with the same registry key.

Invariant: registry topics are keyed presence sets, not append-only heartbeat logs. Preservation: every observed value replaced by the current publish is tombstoned after the replacement value has been touched, while unrelated publisher keys stay joinable.

pub async fn publish_many_replacing_and_compacting( &self, context: &RegistrationContext<'_>, values: impl IntoIterator<Item = Encoded>, replaces_observed_value: impl Fn(&Encoded) -> bool, preserves_observed_value: impl Fn(&Encoded) -> bool, ) -> Result<()>

Publish values, tombstone stale observed registry values, and compact at the owner.

This never sends a replacement value set computed from an observed client snapshot. Compaction is requested with only the removable payloads, so the storage owner computes the final live set from its current local entry and preserves concurrent live writes.

Trait Implementations

impl Clone for DhtRegistrationPublisher

fn clone(&self) -> DhtRegistrationPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DhtRegistrationPublisher

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

Formats the value using the given formatter.