Struct AnnouncingRegistry 

pub struct AnnouncingRegistry { /* private fields */ }

The announced write side — the reactive composition’s writing surface: the durable registry write side folded with the reactor, so every mutation’s post-commit announce (Reactor::announce, fail-soft each) fires right after its durable commit. This is the wrapper the engine-twin assembly constructors compose — the pair’s durable contract below is unchanged (announce is never the pair’s; the wrapper is the caller, and the announce’s machinery is the reactor’s).

Consumers bind this as the write side of their RegistryBackend (the store methods then announce post-commit); a suppressed announce is the crash-window shape the reconcile sweep closes — the mutation still committed (the seq is transactionally exact, never announce-dependent). Contract stamp: ADR-019 §5 (the post-commit announce posture) and §7 (the announced receive flow).

Implementations

impl AnnouncingRegistry

pub fn new(durable: Arc<dyn RegistryWrite>, reactor: Arc<Reactor>) -> Self

Wrap the durable write side + the reactor that announces for it.

pub fn durable(&self) -> &Arc<dyn RegistryWrite>

The durable write side below the announce (the marker write’s and the reconcile machinery’s legs run at this layer).

pub fn reactor(&self) -> &Arc<Reactor>

The reactor firing the announce legs.

Trait Implementations

impl RegistryWrite for AnnouncingRegistry

fn put<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 RepoRecord, ) -> Pin<Box<dyn Future<Output = Result<i64, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create a repo record. RegistryError::Invalid on a malformed id or record, RegistryError::AlreadyExists when the id is taken. Returns the mutation’s sequence number.

fn update<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 RepoRecord, ) -> Pin<Box<dyn Future<Output = Result<i64, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Replace a repo record (the grant-mutation path, ADR-011). RegistryError::Invalid on a malformed record, RegistryError::NotFound when the id is absent. Returns the mutation’s sequence number.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, repo_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<i64, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove a repo record. RegistryError::NotFound when the id is absent. Returns the removal’s sequence number.

fn watermark<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<i64, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The table’s current watermark: the max sequence number ever assigned (0 on a fresh table). Monotone — a committed removal advances it even though it leaves no row.

fn rows_since<'life0, 'async_trait>( &'life0 self, seq: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<RegistryRow>, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The reconcile catch-up read: every row mutated after seq, in sequence order. rows_since(0) is the whole table — the cached provider’s snapshot-refresh read (whole-table by contract).