Struct HttpHandler 

pub struct HttpHandler {
    pub endpoint: String,
    pub method: HttpMethod,
    pub headers: FxHashMap<String, String>,
    pub auth: Option<AuthConfig>,
    pub timeout_ms: Option<u64>,
    /* private fields */
}

Fields

endpoint: String

method: HttpMethod

headers: FxHashMap<String, String>

auth: Option<AuthConfig>

timeout_ms: Option<u64>

Implementations

impl HttpHandler

pub fn new( endpoint: String, method: HttpMethod, headers: FxHashMap<String, String>, auth: Option<AuthConfig>, timeout_ms: Option<u64>, ) -> Self

pub async fn execute(&self, input: HttpInput) -> Result<HttpOutput>

Trait Implementations

impl Clone for HttpHandler

fn clone(&self) -> HttpHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpHandler

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

Formats the value using the given formatter.

impl Handler for HttpHandler

type Input = HttpInput

Input type for the handler

type Output = HttpOutput

Output type for the handler

type Error = Error

Error type that can be converted to pforge_runtime::Error

fn handle<'life0, 'async_trait>( &'life0 self, input: Self::Input, ) -> Pin<Box<dyn Future<Output = Result<Self::Output>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the handler with type-safe input.

fn input_schema() -> RootSchema

Generate JSON schema for input (override for custom schemas).

fn output_schema() -> RootSchema

Generate JSON schema for output.