Struct ReqwestTransport

pub struct ReqwestTransport { /* private fields */ }

A Transport using reqwest to make HTTP calls to the Internet Computer.

Implementations

impl ReqwestTransport

pub fn create<U: Into<String>>(url: U) -> Result<Self, AgentError>

Creates a replica transport from a HTTP URL. By default a request timeout of 6 minutes is used. Use create_with_client to configure this and other client options.

pub fn create_with_client<U: Into<String>>( url: U, client: Client, ) -> Result<Self, AgentError>

Creates a replica transport from a HTTP URL and a reqwest::Client.

pub fn create_with_client_route( route_provider: Arc<dyn RouteProvider>, client: Client, ) -> Result<Self, AgentError>

Creates a replica transport from a RouteProvider and a reqwest::Client.

pub fn with_max_response_body_size(self, max_response_body_size: usize) -> Self

Sets a max response body size limit

pub fn with_max_tcp_errors_retries(self, retries: usize) -> Self

Sets a max number of retries for tcp connection errors.

Trait Implementations

impl Debug for ReqwestTransport

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

Formats the value using the given formatter.

impl Transport for ReqwestTransport

fn call( &self, effective_canister_id: Principal, envelope: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<TransportCallResponse, AgentError>> + Send + '_>>

Sends a synchronous call request to a replica.

fn read_state( &self, effective_canister_id: Principal, envelope: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, AgentError>> + Send + '_>>

Sends a synchronous request to a replica. This call includes the body of the request message itself (envelope).

fn read_subnet_state( &self, subnet_id: Principal, envelope: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, AgentError>> + Send + '_>>

Sends a synchronous request to a replica. This call includes the body of the request message itself (envelope).

fn query( &self, effective_canister_id: Principal, envelope: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, AgentError>> + Send + '_>>

Sends a synchronous request to a replica. This call includes the body of the request message itself (envelope).

fn status( &self, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, AgentError>> + Send + '_>>

Sends a status request to the replica, returning whatever the replica returns. In the current spec v2, this is a CBOR encoded status message, but we are not making this API attach semantics to the response.