Struct WireTapConfig 

pub struct WireTapConfig {
    pub max_concurrent: Option<usize>,
    pub shutdown_grace: Duration,
}

Configuration for WireTapService.

Default concurrency bound is 20 (Camel-faithful flat-semaphore). shutdown_grace defaults to 5 seconds.

Fields

max_concurrent: Option<usize>

Maximum number of concurrent tap tasks. None means unlimited.

shutdown_grace: Duration

Grace period for in-flight tap tasks to complete on shutdown. A value of zero means “skip drain, cancel immediately”.

Implementations

impl WireTapConfig

pub fn validate(&self)

Validate the config, panicking on invalid states.

shutdown_grace of zero is valid (means “skip drain, cancel immediately”).

pub fn bounded(max_concurrent: usize) -> Self

Create a config with a bounded concurrency limit.

Trait Implementations

impl Clone for WireTapConfig

fn clone(&self) -> WireTapConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WireTapConfig

fn default() -> Self

Returns the “default value” for a type.