Struct Hub 

struct Hub {
    client: Client,
    endpoint: String,
    token: Option<String>,
}

Fields

client: Client

endpoint: String

token: Option<String>

Implementations

impl Hub

pub(super) fn headers( &self, root: &[&str], files: &[String], events: &mut dyn FnMut(ModelEvent), ) -> Result<Vec<(RemoteObject, Inventory)>>

Workers only fetch data. The caller emits events and restores file order.

fn fetch_headers( &self, requests: &[Request<'_>], next: &AtomicUsize, failed: &AtomicBool, sender: SyncSender<(usize, Result<(RemoteObject, Inventory)>)>, )

Stop claiming shards after an error; finish and drain shards already claimed.

fn header(&self, request: &Request<'_>) -> Result<(RemoteObject, Inventory)>

impl Hub

fn get(&self, url: Url) -> RequestBuilder

fn url(&self, components: &[&str]) -> Result<Url>

fn json(&self, components: &[&str]) -> Result<Value>

fn inspect( &self, repo: &str, revision: &str, events: &mut dyn FnMut(ModelEvent), ) -> Result<(Source, ModelDescription)>

fn range(&self, url: Url, offset: u64, length: u64) -> Result<(Vec<u8>, u64)>