Struct TenancyRouter 

pub struct TenancyRouter<T> { /* private fields */ }

Turns a TenancySpi implementation into a RoutingSpi.

Implementations

impl<T: TenancySpi> TenancyRouter<T>

pub fn new(spi: T) -> Self

Wraps a tenancy implementation.

pub fn spi(&self) -> &T

The wrapped tenancy implementation.

pub async fn admit_write(&self, partition: &PartitionId, epoch: Epoch) -> bool

The migration write gate for a resolved decision (docs/06 §2): whether a write that resolved at epoch for partition may still commit. The engine calls this at dispatch; false is surfaced as a retryable stale-epoch error. Delegates to the TenancySpi.

pub async fn resolve(&self, ctx: &RequestCtx<'_>) -> Result<Resolved, SpiError>

Resolves the full routing plan for ctx (the single-document path).

Errors

Returns SpiError if the endpoint is not tenancy-aware, the partition cannot be resolved, no placement exists, or the configured transforms are invalid (e.g. a shared-index id rule that omits the partition).

pub fn resolve_partition( &self, ctx: &RequestCtx<'_>, body: BodyDoc<'_>, ) -> Result<PartitionId, SpiError>

Resolves just the partition id for a request and document, without a placement lookup. The per-document entry point for bulk demux (docs/04 §3), where each operation carries its own source as a BodyDoc.

Errors

Returns SpiError::PartitionUnresolved if no configured source yields the partition.

pub async fn resolve_placement( &self, ctx: &RequestCtx<'_>, partition: PartitionId, logical_index: &str, ) -> Result<Resolved, SpiError>

Resolves a known partition to its placement and the routing plan for a given logical index. Separated from Self::resolve_partition so a bulk request can resolve the partition per document but cache the placement per partition.

Errors

Returns SpiError if no placement exists or the configured transforms are invalid (e.g. a shared-index id rule that omits the partition).

Trait Implementations

impl<T: Debug> Debug for TenancyRouter<T>

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

Formats the value using the given formatter.

impl<T: TenancySpi> Router for TenancyRouter<T>

async fn resolve(&self, ctx: &RequestCtx<'_>) -> Result<Resolved, SpiError>

Resolves the full routing plan for a single-document request.

fn resolve_partition( &self, ctx: &RequestCtx<'_>, body: BodyDoc<'_>, ) -> Result<PartitionId, SpiError>

Resolves just the partition id for a request and document (the bulk demux entry point).

async fn resolve_placement( &self, ctx: &RequestCtx<'_>, partition: PartitionId, logical_index: &str, ) -> Result<Resolved, SpiError>

Resolves a known partition to its placement and routing plan.

async fn admit_write(&self, partition: &PartitionId, epoch: Epoch) -> bool

The migration write gate: may a write that resolved at epoch for partition still commit? false ⇒ reject as a retryable stale-epoch error.

fn cluster_endpoint(&self, cluster: &ClusterId) -> Option<String>

The base URL of a cluster by id, for the cursor-affinity and admin paths that route by cluster without a placement. Default None.

impl<T: TenancySpi> RoutingSpi for TenancyRouter<T>

async fn route(&self, ctx: &RequestCtx<'_>) -> Result<RouteDecision, SpiError>

Resolves the routing decision for an authenticated request.