Struct WriterHandle 

pub struct WriterHandle { /* private fields */ }

Cheap handle to the writer task. Clones share the same underlying mpsc channel; a drop of the last clone is a silent shutdown signal to the writer task (receiver closes). For a clean shutdown that releases the lease row, call WriterHandle::shutdown.

Implementations

impl WriterHandle

pub async fn apply_label(&self, req: ApplyLabelRequest) -> Result<LabelEvent>

Submit an apply-label request. Resolves when the writer has committed the transaction and broadcast the event, or returns an Err describing why the write was rejected.

pub async fn negate_label(&self, req: NegateLabelRequest) -> Result<LabelEvent>

Submit a negate-label request. Returns Error::LabelNotFound if no applied label currently exists for (service_did, uri, val).

pub async fn resolve_report( &self, req: ResolveReportRequest, ) -> Result<ResolvedReport>

Resolve a report, optionally applying a label in the same atomic transaction. The label INSERT + audit row + report UPDATE + resolution audit row all commit together or not at all; the label broadcast fires post-commit inside the writer task (§F5 + §F12 atomicity contract).

Errors:

• Error::ReportNotFound — report_id doesn’t exist.
• Error::ReportAlreadyResolved — report is not in the pending state. Handler maps to a generic InvalidRequest.

pub async fn sweep(&self, _req: SweepRequest) -> Result<SweepResult>

Trigger a §F4 retention sweep through the writer task. Loops over single-batch dispatches until a batch returns has_more = false, aggregating rows + duration. Other writer commands interleave between batches (single-writer invariant + bounded latency).

Returns rows_deleted = 0, batches = 0 when the writer was spawned with retention_days = None (sweep configured off): the first batch returns immediately and the loop exits with the no-op result.

pub fn subscribe(&self) -> Receiver<LabelEvent>

Subscribe to committed events. The returned receiver lags past the internal broadcast buffer; the consumer (subscribeLabels, #7) turns RecvError::Lagged into a connection close.

pub fn receiver_count(&self) -> usize

Count of live broadcast receivers. Exposed for test sync points (the WS handler subscribes asynchronously after upgrade; tests that want to emit an event “after the subscriber is ready” poll this until it reaches the expected count). Not a production hot path — broadcast::Sender::receiver_count walks an atomic chain.

pub fn shutdown_signal(&self) -> Receiver<bool>

Observe writer lifecycle. The returned receiver starts at false and flips to true once exactly, when the writer has accepted a shutdown command and is about to release the lease. Holders close downstream connections gracefully on the true transition.

pub async fn shutdown(&self) -> Result<()>

Explicit shutdown. Drains in-flight writes, releases the lease row, stops the heartbeat, and returns. Idempotent-ish: calling on an already-shut-down writer returns a channel-closed error, not a panic.

Trait Implementations

impl Clone for WriterHandle

fn clone(&self) -> WriterHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriterHandle

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

Formats the value using the given formatter.