Struct edm_core::connector::HttpConnector

pub struct HttpConnector { /* private fields */ }

Available on crate features connector-http and connector only.

A connector to HTTP services.

Implementations

impl HttpConnector

pub fn try_new(method: &str, base_url: &str) -> Result<Self, Error>

Constructs a new instance, returning an error if it fails.

pub fn try_with_config(config: &Table) -> Result<Self, Error>

Attempts to construct a new instance from the config.

pub fn insert_header(&mut self, key: &str, value: impl Into<JsonValue>)

Inserts a key/value pair into the request headers.

pub fn set_query<T: Serialize>(&mut self, query: &T)

Sets the request query.

pub fn set_body<T: Serialize>(&mut self, body: &T)

Sets the request body.

pub fn set_json_pointer(&mut self, pointer: impl Into<String>)

Sets a JSON Pointer for looking up a value from the response data. It only applies when the response data is a JSON object.

pub async fn fetch( &self, query: Option<&str>, params: Option<&Map> ) -> Result<Response, Error>

Makes an HTTP request with the given query and params.

pub async fn fetch_json<T: DeserializeOwned>( &self, query: Option<&str>, params: Option<&Map> ) -> Result<T, Error>

Makes an HTTP request with the given query and params, and deserializes the response body via JSON.

Trait Implementations

impl Connector for HttpConnector

fn try_new_data_source(config: &Table) -> Result<DataSource, Error>

Constructs a new data source with the configuration, returning an error if it fails.

async fn execute( &self, query: &str, params: Option<&Map> ) -> Result<Option<u64>, Error>

Executes the query and returns the total number of rows affected.

async fn query( &self, query: &str, params: Option<&Map> ) -> Result<Vec<Record>, Error>

Executes the query and parses it as Vec<Record>.

async fn query_as<T: DeserializeOwned>( &self, query: &str, params: Option<&Map> ) -> Result<Vec<T>, Error>

Executes the query and parses it as Vec<T>.

async fn query_one( &self, query: &str, params: Option<&Map> ) -> Result<Option<Record>, Error>

Executes the query and parses it as a Record.

async fn query_one_as<T: DeserializeOwned>( &self, query: &str, params: Option<&Map> ) -> Result<Option<T>, Error>

Executes the query and parses it as an instance of type T.