Struct SenderRuntime 

pub struct SenderRuntime { /* private fields */ }

Implementations

impl SenderRuntime

pub fn new( queue: Arc<Mutex<Queue>>, http: HttpSender, counters: Arc<Counters>, health_path: PathBuf, ) -> Self

pub async fn flush_one(&self) -> Result<Option<PathBuf>, SendError>

Process one pending segment (oldest). Returns Ok(None) if queue empty.

pub fn backoff(attempt: u32) -> Duration

Backoff schedule per spec §6: 2s, 8s, 30s, 120s, 300s (capped).

pub async fn drain_with_backoff(&self)

Drain-loop step. Caller owns the tick-or-shutdown select.