Module fetcher 

Coalesced, failover federation fetch of raw event bytes.

Service::fetch is the entry point; behind it a single worker task owns every in-flight fetch and the dedup map, so no lock guards them. The per-fetch work splits across the submodules: candidate selection, the federation transport, and response validation.

Modules

error 🔒

Internal failure reporting for federation fetches.

inflight 🔒

Single-flight bookkeeping for one in-flight fetch.

opts 🔒

Caller contract and result types for a fetch: Opts in, Outcome out.

select 🔒

Candidate server selection for a fetch.

transport 🔒

Federation transport: an Op and target server in, raw response bytes out.

validate 🔒

Two-tier response validation for fetched federation data.

worker 🔒

The fetch worker loop: one task owning every in-flight fetch, lock-free.

Structs

Msg 🔒

Request to the worker. The worker replies with a subscription to the coalesced result, deferring the reply under backpressure until a slot frees.

Opts

Re-exports the fetch request contract, operation types, and response value.

Outcome

Re-exports the fetch request contract, operation types, and response value.

Service

Coordinates coalesced, validated federation fetches with candidate failover.

Enums

FanoutGrowth

Re-exports the fetch request contract, operation types, and response value.

Op

Re-exports the fetch request contract, operation types, and response value.

Constants

REQUESTS_MAX 🔒

Upper bound on concurrent in-flight fetches across all keys.

Functions

await_result 🔒

Type Aliases

EventWindow

Re-exports the fetch request contract, operation types, and response value.