Struct Forwarder 

pub struct Forwarder {

    pub apikey_validation_interval: i64,
    pub backoff_base: f64,
    pub backoff_factor: f64,
    pub backoff_max: f64,
    pub connection_reset_interval: u64,
    pub flush_to_disk_mem_ratio: f64,
    pub high_prio_buffer_size: usize,
    pub http_protocol: ForwarderHttpProtocol,
    pub max_concurrent_requests: usize,
    pub num_workers: usize,
    pub outdated_file_in_days: u32,
    pub recovery_interval: u32,
    pub recovery_reset: bool,
    pub retry_queue_capacity_time_interval_sec: u64,
    pub retry_queue_max_size: Option<u64>,
    pub retry_queue_payloads_max_size: Option<u64>,
    pub stop_timeout: u64,
    pub storage_max_disk_ratio: f64,
    pub storage_max_size_in_bytes: u64,
    pub storage_path: PathBuf,
    pub timeout: u64,
}

Forwarder retry, backoff, worker, and disk-storage settings.

Fields

apikey_validation_interval: i64

How often, in seconds, API keys are checked for validity against the intake.

backoff_base: f64

Base delay, in seconds, for retry backoff.

backoff_factor: f64

Multiplier applied to the backoff delay after each failed attempt.

backoff_max: f64

Maximum retry backoff delay, in seconds.

connection_reset_interval: u64

How often, in seconds, idle connections are reset.

flush_to_disk_mem_ratio: f64

Fraction of the in-memory retry queue at which payloads spill to disk.

high_prio_buffer_size: usize

Capacity of the high-priority send buffer.

http_protocol: ForwarderHttpProtocol

HTTP protocol the forwarder negotiates with the intake.

max_concurrent_requests: usize

Maximum number of in-flight requests to the intake.

num_workers: usize

Number of forwarder worker tasks.

outdated_file_in_days: u32

Age, in days, after which payloads queued on disk are discarded.

recovery_interval: u32

Number of retry cycles between attempts to recover a failed endpoint.

recovery_reset: bool

Whether the recovery interval resets after a successful send.

retry_queue_capacity_time_interval_sec: u64

Retry-queue capacity expressed as seconds of buffered payloads.

retry_queue_max_size: Option<u64>

Maximum number of payloads held in the in-memory retry queue.

retry_queue_payloads_max_size: Option<u64>

Maximum total size, in bytes, of payloads held in the retry queue.

stop_timeout: u64

Grace period, in seconds, the forwarder is given to drain before shutdown.

storage_max_disk_ratio: f64

Fraction of available disk the on-disk retry store may use.

storage_max_size_in_bytes: u64

Maximum size, in bytes, of the on-disk retry store.

storage_path: PathBuf

Directory where retry payloads are persisted to disk.

timeout: u64

Per-request timeout, in seconds, for calls to the intake.

Trait Implementations

impl Clone for Forwarder

fn clone(&self) -> Forwarder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Forwarder

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

Formats the value using the given formatter.

impl Default for Forwarder

fn default() -> Forwarder

Returns the “default value” for a type.

impl PartialEq for Forwarder

fn eq(&self, other: &Forwarder) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Forwarder

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Forwarder