Struct HttpSinkConfig 

pub struct HttpSinkConfig {
    pub max_queue_bytes: usize,
    pub hard_queue_bytes: usize,
    pub max_in_flight_requests: usize,
    pub request_timeout: Duration,
    pub retry_by_priority: [Take<ExponentialBackoff>; 4],
}

Configuration for HttpEventSink’s transport: how much to buffer, how aggressively to shed load under backpressure, how much concurrency to allow, and how hard to retry each priority class.

The byte caps sit far above what a healthy co-located ingestion service (e.g. a monolith) will ever accumulate, so a normal run drops nothing; they only bite during a real outage.

Fields

max_queue_bytes: usize

Soft cap, in bytes: once the queue holds at least this many bytes, new Traces items (thread and image blocks) are dropped. Default 128 MiB.

hard_queue_bytes: usize

Hard cap, in bytes: once the queue holds at least this many bytes, new Logs/Metrics items are dropped too. Clamped to be at least max_queue_bytes. Metadata (process/stream) is never dropped. Default 256 MiB.

max_in_flight_requests: usize

Maximum number of insert_* HTTP requests in flight at once. Set to 1 to restore strictly serial sends. Default 3.

request_timeout: Duration

Per-request timeout (covers connect + send + receive for one attempt).

This is a deliberate addition beyond Unreal parity: Unreal’s per-priority retry window is a total retry budget, not a socket timeout (it never sets one either), so a single attempt against an ingestion service that accepts the TCP connection but never responds can hang indefinitely. Without a bound here, that hang is fatal at shutdown: Drop for HttpEventSink joins the worker thread, so a short-lived process would freeze on exit whenever ingestion is unresponsive (as opposed to merely offline, which fails fast with a connection error). Default 10 seconds.

retry_by_priority: [Take<ExponentialBackoff>; 4]

Retry strategy per UploadPriority (indexed by UploadPriority as usize).

Implementations

impl HttpSinkConfig

pub const DEFAULT_MAX_QUEUE_BYTES: usize

Default soft byte cap: 128 MiB.

pub const DEFAULT_HARD_QUEUE_BYTES: usize

Default hard byte cap: 256 MiB.

pub const DEFAULT_MAX_IN_FLIGHT_REQUESTS: usize = 3

Default in-flight request cap (Unreal parity).

pub const DEFAULT_REQUEST_TIMEOUT: Duration

Default per-request timeout.

pub fn default_retry_by_priority() -> [Take<ExponentialBackoff>; 4]

The default per-priority retry table: Metadata gets the most retries, Traces the fewest, mirroring the Unreal sink’s RetryCountByPriority ({10,5,2,1}).

Trait Implementations

impl Default for HttpSinkConfig

fn default() -> HttpSinkConfig

Returns the “default value” for a type.