Struct HttpClientProvider

pub struct HttpClientProvider { /* private fields */ }

HTTP client capability provider implementation struct

Implementations

impl HttpClientProvider

pub async fn new(config: &HashMap<String, String>) -> Result<Self>

Trait Implementations

impl Clone for HttpClientProvider

fn clone(&self) -> HttpClientProvider

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Provider for HttpClientProvider

Handle provider control commands

fn init( &self, init_config: impl ProviderInitConfig, ) -> impl Future<Output = Result<(), E>> + Send

Initialize the provider

fn on_config_update( &self, update: impl ProviderConfigUpdate, ) -> impl Future<Output = Result<(), E>> + Send

Process a configuration update for the provider

fn receive_link_config_as_source( &self, config: LinkConfig<'_>, ) -> impl Future<Output = Result<(), E>> + Send

Receive and handle a link that has been established on the lattice where this provider is the source.

fn receive_link_config_as_target( &self, config: LinkConfig<'_>, ) -> impl Future<Output = Result<(), E>> + Send

Receive and handle a link that has been established on the lattice where this provider is the target.

fn delete_link_as_target( &self, _info: impl LinkDeleteInfo, ) -> impl Future<Output = Result<(), E>> + Send

Notify the provider that the link is dropped where the provider is the target

fn delete_link_as_source( &self, _info: impl LinkDeleteInfo, ) -> impl Future<Output = Result<(), E>> + Send

Notify the provider that the link is dropped where the provider is the source

fn health_request( &self, _arg: &HealthCheckRequest, ) -> impl Future<Output = Result<HealthCheckResponse, E>> + Send

Perform health check. Called at regular intervals by host Default implementation always returns healthy

fn shutdown(&self) -> impl Future<Output = Result<(), E>> + Send

Handle system shutdown message

impl ServeOutgoingHandlerHttp<Option<Context>> for HttpClientProvider

async fn handle( &self, cx: Option<Context>, request: Request<HttpBody>, options: Option<RequestOptions>, ) -> Result<Result<Response<impl Body<Data = Bytes, Error = Infallible> + Send + 'static>, ErrorCode>>