Skip to main content

fetch_footers

Function fetch_footers 

Source
async fn fetch_footers(
    io: &dyn WalObjectIo,
    objects: impl Stream<Item = Result<ListedObject>>,
    concurrency: usize,
) -> Result<FetchedObjects>
Expand description

Fetches and verifies the headers and footers of objects as they are listed, up to concurrency objects at a time, and returns them ordered by object sequence whatever the order the fetches complete in. An object the object store no longer has is returned as vanished; a failed listing or any other failure abandons the remaining fetches.