Skip to main content

resolve_sync

Function resolve_sync 

Source
pub fn resolve_sync(
    fetch_url: impl Fn(&PartitionRef) -> Result<String, TesseraError> + Sync,
    refs: &[PartitionRef],
) -> Result<Vec<ResolvedPartition>, TesseraError>
Expand description

Resolve presigned URLs for refs concurrently, preserving order.

A single ref is fetched inline; multiple refs are fanned out over at most MAX_WORKERS worker threads with short-circuit on the first error.

§Errors

Returns the first fetch error, if any.

§Panics

Panics if internal bookkeeping is inconsistent (a slot is unresolved although no error was recorded) — unreachable by construction.