Struct tvix_glue::fetchers::Fetcher

pub struct Fetcher<BS, DS, PS, NS> {
    http_client: Client,
    blob_service: BS,
    directory_service: DS,
    path_info_service: PS,
    nar_calculation_service: NS,
}

Knows how to fetch a given Fetch.

Fields

http_client: Client

blob_service: BS

directory_service: DS

path_info_service: PS

nar_calculation_service: NS

Implementations

impl<BS, DS, PS, NS> Fetcher<BS, DS, PS, NS>

pub fn new( blob_service: BS, directory_service: DS, path_info_service: PS, nar_calculation_service: NS, ) -> Self

async fn download( &self, url: Url, ) -> Result<Box<dyn AsyncBufRead + Unpin + Send>, FetcherError>

Constructs a HTTP request to the passed URL, and returns a AsyncReadBuf to it. In case the URI uses the file:// scheme, use tokio::fs to open it.

impl<BS, DS, PS, NS> Fetcher<BS, DS, PS, NS>

where BS: BlobService + Clone + 'static, DS: DirectoryService + Clone, PS: PathInfoService, NS: NarCalculationService,

pub async fn ingest( &self, fetch: Fetch, ) -> Result<(Node, CAHash, u64), FetcherError>

Ingest the data from a specified Fetch. On success, return the root node, a content digest and length. Returns an error if there was a failure during fetching, or the contents didn’t match the previously communicated hash contained inside the FetchArgs.

pub async fn ingest_and_persist<'a>( &self, name: &'a str, fetch: Fetch, ) -> Result<(StorePathRef<'a>, Node), FetcherError>

Ingests the data from a specified Fetch, persists the returned node in the PathInfoService, and returns the calculated StorePath, as well as the root node pointing to the contents. The root node can be used to descend into the data without doing the lookup to the PathInfoService again.