Skip to main content

HttpEndpointConfig

Struct HttpEndpointConfig 

Source
pub struct HttpEndpointConfig {
    pub base_url: String,
    pub http_method: Option<String>,
    pub throw_exception_on_failure: bool,
    pub ok_status_code_range: (u16, u16),
    pub follow_redirects: bool,
    pub connect_timeout: Duration,
    pub response_timeout: Option<Duration>,
    pub query_params: HashMap<String, String>,
    pub allow_private_ips: bool,
    pub blocked_hosts: Vec<String>,
    pub max_body_size: usize,
}
Expand description

Configuration for an HTTP client (producer) endpoint.

§Memory Limits

HTTP operations enforce conservative memory limits to prevent denial-of-service attacks from untrusted network sources. These limits are significantly lower than file component limits (100MB) because HTTP typically handles API responses rather than large file transfers, and clients may be untrusted.

§Default Limits

  • HTTP client body: 10MB (typical API responses)
  • HTTP server request: 2MB (untrusted network input - see HttpServerConfig)
  • HTTP server response: 10MB (same as client - see HttpServerConfig)

§Rationale

The 10MB limit for HTTP client responses is appropriate for most API interactions while providing protection against:

  • Malicious servers sending oversized responses
  • Runaway processes generating unexpectedly large payloads
  • Memory exhaustion attacks

The 2MB server request limit is even more conservative because it handles input from potentially untrusted clients on the public internet.

§Overriding Limits

Override the default client body limit using the maxBodySize URI parameter:

http://api.example.com/large-data?maxBodySize=52428800

For server endpoints, use maxRequestBody and maxResponseBody parameters:

http://0.0.0.0:8080/upload?maxRequestBody=52428800

§Behavior When Exceeded

When a body exceeds the configured limit:

  • An error is returned immediately
  • No memory is exhausted - the limit is checked before allocation
  • The HTTP connection is terminated cleanly

§Security Considerations

HTTP endpoints should be treated with more caution than file endpoints because:

  • Clients may be unknown and untrusted
  • Network traffic can be spoofed or malicious
  • DoS attacks often exploit unbounded resource consumption

Only increase limits when you control both ends of the connection or when business requirements demand larger payloads.

Fields§

§base_url: String§http_method: Option<String>§throw_exception_on_failure: bool§ok_status_code_range: (u16, u16)§follow_redirects: bool§connect_timeout: Duration§response_timeout: Option<Duration>§query_params: HashMap<String, String>§allow_private_ips: bool§blocked_hosts: Vec<String>§max_body_size: usize

Trait Implementations§

Source§

impl Clone for HttpEndpointConfig

Source§

fn clone(&self) -> HttpEndpointConfig

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for HttpEndpointConfig

Source§

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

Formats the value using the given formatter. Read more
Source§

impl UriConfig for HttpEndpointConfig

Source§

fn scheme() -> &'static str

Returns “http” as the primary scheme (also accepts “https”)

Source§

fn from_uri(uri: &str) -> Result<Self, CamelError>

Parse a URI string into this configuration.
Source§

fn from_components(parts: UriComponents) -> Result<Self, CamelError>

Parse already-extracted URI components into this configuration.
Source§

fn validate(self) -> Result<Self, CamelError>

Override to add validation logic after parsing.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

impl<T> FutureExt for T

Source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,