Struct HttpRemoteClient 

pub struct HttpRemoteClient { /* private fields */ }

Reference HTTP RemoteClient implementation. A single instance is tied to exactly one RemoteConfig and one base URL.

Implementations

impl HttpRemoteClient

pub fn new(cfg: RemoteConfig) -> Self

Build a client from a parsed RemoteConfig. A fresh reqwest::Client is created per call; callers who want to pool connections across remotes should build one client explicitly and share it via the future with_client constructor (deferred, tracked in B3.3).

pub async fn negotiate_capabilities(&mut self) -> Result<(), ClientError>

Negotiate capabilities with the remote by calling list_refs and intersecting the server’s advertised set with the local one. After this call, Self::capabilities returns the agreed set that all subsequent verbs must operate under.

pub const fn capabilities(&self) -> &CapabilitySet

The agreed-upon capability set. Before Self::negotiate_capabilities has been called this is the local advertisement; after, it’s the intersection with the server.

Trait Implementations

impl Debug for HttpRemoteClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RemoteClient for HttpRemoteClient

fn list_refs( &self, ) -> Pin<Box<dyn Future<Output = Result<RefsResponse, ClientError>> + Send + '_>>

GET /remote/v1/refs - enumerate the server’s current refs and the capability set it will negotiate against.

fn fetch_blocks( &self, wants: Vec<Cid>, have_set: BloomHaveSet, ) -> Pin<Box<dyn Future<Output = Result<Bytes, ClientError>> + Send + '_>>

POST /remote/v1/fetch-blocks - request a CAR body containing every block in wants and its transitive graph, minus anything in have_set.

fn push_blocks( &self, car_body: Bytes, ) -> Pin<Box<dyn Future<Output = Result<PushResponse, ClientError>> + Send + '_>>

POST /remote/v1/push-blocks - upload a CAR body. Requires the bearer token.

fn advance_head( &self, old: Cid, new: Cid, ref_name: String, ) -> Pin<Box<dyn Future<Output = Result<(), ClientError>> + Send + '_>>

POST /remote/v1/advance-head - atomic compare-and-swap on a named ref. Requires the bearer token. Returns ClientError::CasMismatch on 409.