Struct HttpTransportConfig 

pub struct HttpTransportConfig {
    pub endpoint: Option<String>,
    pub listen: Option<String>,
    pub recv_path: String,
    pub recv_buffer_size: usize,
    pub recv_timeout_ms: u64,
    pub filters_in: Vec<FilterRule>,
    pub filters_out: Vec<FilterRule>,
    pub connect_timeout_ms: u64,
    pub send_timeout_ms: u64,
    pub max_body_bytes: usize,
    pub tls_ca_path: Option<String>,
}

Available on crate features transport-http and transport only.

Configuration for HTTP transport.

Fields

endpoint: Option<String>

Endpoint URL for sending (e.g., “http://loader:8080/ingest”). None = send disabled.

listen: Option<String>

Listen address for receiving (e.g., “0.0.0.0:8080”). None = receive disabled. Requires the http-server feature.

recv_path: String

Path to accept POSTs on for receive mode. Default: “/ingest”.

recv_buffer_size: usize

Receive buffer size (bounded channel capacity). Default: 10000.

recv_timeout_ms: u64

Receive timeout in milliseconds. Default: 100.

filters_in: Vec<FilterRule>

Inbound message filters (applied on recv before caller sees messages).

filters_out: Vec<FilterRule>

Outbound message filters (applied on send before transport dispatches).

connect_timeout_ms: u64

Connect timeout (ms) for the send-side HTTP client. Default 5000.

send_timeout_ms: u64

Total request timeout (ms) per send. Default 30000. Prevents a hung send from consuming worker capacity indefinitely.

max_body_bytes: usize

Maximum accepted request body size in bytes (receive side). Default 16 MiB. Oversized POSTs are rejected with 413 before buffering.

tls_ca_path: Option<String>

Private-CA PEM path for the send-side HTTPS client. When set and the tls feature is enabled, the client trusts this CA in addition to the OS native roots, built via the unified crate::tls module and fed to reqwest with use_preconfigured_tls. None = native roots only (reqwest default). Maps to TlsTrust { native_roots: true, extra_roots: [ca] }.

Implementations

impl HttpTransportConfig

pub fn from_cascade() -> Self

Load from the config cascade under the transport.http key.

pub fn sender(endpoint: &str) -> Self

Create a send-only config pointing at the given endpoint URL.

pub fn receiver(listen: &str) -> Self

Create a receive-only config listening on the given address.

Trait Implementations

impl Clone for HttpTransportConfig

fn clone(&self) -> HttpTransportConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpTransportConfig

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

Formats the value using the given formatter.

impl Default for HttpTransportConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for HttpTransportConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl FromCascade for HttpTransportConfig

fn from_cascade_key(key: &str) -> Self

Load Self from the config cascade under key, registering the section in the global registry; falls back to Default if the cascade is unavailable or the key is absent/invalid.

impl Serialize for HttpTransportConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.