Struct DistributedReadRegistry 

pub struct DistributedReadRegistry { /* private fields */ }

Server-owned coordinator registry. It is deliberately independent of the HTTP connection: timeout, disconnect, and explicit cancel all use the same idempotent transition and invoke peer cleanup outside its entry lock.

Implementations

impl DistributedReadRegistry

pub fn new() -> Self

pub fn register_with_id( &self, execution_id: ReadExecutionId, owner: ReadExecutionOwner, plan: ReadExecutionPlanSummary, peer_cancellations: Vec<PeerCancellation>, ) -> Result<()>

Register before dispatching any worker request. Supplying the planner’s request_id makes that one ID the coordinator/worker/HTTP correlation key required by the distributed-read protocol.

pub fn register( &self, owner: ReadExecutionOwner, plan: ReadExecutionPlanSummary, peer_cancellations: Vec<PeerCancellation>, ) -> Result<ReadExecutionId>

Allocate a fresh request ID for a coordinator that does not already have one from route planning.

pub fn publish_prepared( &self, execution_id: &ReadExecutionId, prepared: PreparedResult, ) -> Result<ReadExecutionSummary>

Publish only P2.11’s immutable prepared result. This is the sole transition that permits the HTTP adapter to open a row stream.

pub fn fail( &self, execution_id: &ReadExecutionId, failure: ReadExecutionFailure, ) -> Result<ReadExecutionSummary>

Record a classified coordinator failure and cancel every registered peer exactly once. No prepared rows survive this transition.

pub fn cancel( &self, execution_id: &ReadExecutionId, requester_profile: Option<&str>, ) -> Result<ReadCancellation>

pub fn summary( &self, execution_id: &ReadExecutionId, requester_profile: Option<&str>, ) -> Result<ReadExecutionSummary>

pub fn open_prepared( &self, execution_id: &ReadExecutionId, requester_profile: Option<&str>, ) -> Result<PreparedReadLease>

Obtain a read-only lease only after P2.11 preparation succeeded.

pub fn cleanup_terminal_before(&self, cutoff: SystemTime)

Remove only small, terminal tombstones and never a live preparation or a retained prepared result. The server calls this with session TTL.

pub fn cleanup_after(&self, ttl: Duration)

Trait Implementations

impl Clone for DistributedReadRegistry

fn clone(&self) -> DistributedReadRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for DistributedReadRegistry

fn default() -> DistributedReadRegistry

Returns the “default value” for a type.