Struct ic_agent::agent::http_transport::HyperTransport

pub struct HyperTransport<B1, S = Client<HttpsConnector<HttpConnector>, B1>> { /* private fields */ }

Available on crate feature hyper only.

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

Implementations

impl<B1: HyperBody + From<Vec<u8>>> HyperTransport<B1>

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

Creates a replica transport from a HTTP URL.

impl<B1, S> HyperTransport<B1, S>

where B1: HyperBody + From<Vec<u8>>, S: HyperService<B1>,

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

Creates a replica transport from a HTTP URL and a HyperService.

pub fn create_with_service_route( route_provider: Arc<dyn RouteProvider>, service: S ) -> Result<Self, AgentError>

Creates a replica transport from a RouteProvider and a HyperService.

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

Sets a max response body size limit

Trait Implementations

impl<B1: Debug, S: Debug> Debug for HyperTransport<B1, S>

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

Formats the value using the given formatter.

impl<B1, S> Transport for HyperTransport<B1, S>

where B1: HyperBody + From<Vec<u8>>, S: HyperService<B1>,

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

Sends an asynchronous request to a replica. The Request ID is non-mutable and depends on the content of the envelope.

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.