Struct TieredSinkConfig 

pub struct TieredSinkConfig {
    pub spool_path: PathBuf,
    pub send_timeout_ms: u64,
    pub compression: CompressionCodec,
    pub drain_strategy: DrainStrategy,
    pub ordering: OrderingMode,
    pub max_spool_bytes: Option<u64>,
    pub max_spool_items: Option<usize>,
    pub circuit_failure_threshold: u32,
    pub circuit_reset_timeout_ms: u64,
    pub drain_interval_ms: u64,
    pub disk_aware: Option<DiskAwareConfig>,
}

Available on crate feature tiered-sink only.

Configuration for TieredSink.

Fields

spool_path: PathBuf

Path to the spool file for disk fallback.

send_timeout_ms: u64

Timeout for primary sink operations. If exceeded, message is spooled to disk.

compression: CompressionCodec

Compression codec for spooled messages.

drain_strategy: DrainStrategy

Strategy for draining spooled messages back to primary.

ordering: OrderingMode

Ordering mode for message delivery.

max_spool_bytes: Option<u64>

Maximum spool file size in bytes. Spool operations fail when exceeded.

max_spool_items: Option<usize>

Maximum messages in spool.

circuit_failure_threshold: u32

Circuit breaker: failures before opening circuit.

circuit_reset_timeout_ms: u64

Circuit breaker: how long to wait before probing.

drain_interval_ms: u64

Interval for drain task to check spool.

disk_aware: Option<DiskAwareConfig>

Disk-aware capacity management. When configured, a background poller checks available disk space and stops spooling if the filesystem exceeds the configured usage threshold.

Implementations

impl TieredSinkConfig

pub fn new(spool_path: impl Into<PathBuf>) -> Self

Create a new config with the given spool path.

pub fn send_timeout(self, timeout: Duration) -> Self

Set send timeout.

pub fn compression(self, codec: CompressionCodec) -> Self

Set compression codec.

pub fn drain_strategy(self, strategy: DrainStrategy) -> Self

Set drain strategy.

pub fn ordering(self, mode: OrderingMode) -> Self

Set ordering mode.

pub fn max_spool_bytes(self, max: u64) -> Self

Set maximum spool size.

pub fn disk_aware(self, config: DiskAwareConfig) -> Self

Enable disk-aware capacity management with default settings.

pub fn send_timeout_duration(&self) -> Duration

Get send timeout as Duration.

pub fn circuit_reset_timeout(&self) -> Duration

Get circuit reset timeout as Duration.

pub fn drain_interval(&self) -> Duration

Get drain interval as Duration.

Trait Implementations

impl Clone for TieredSinkConfig

fn clone(&self) -> TieredSinkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TieredSinkConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TieredSinkConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TieredSinkConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.