Struct FlushManager 

pub struct FlushManager { /* private fields */ }

Manages adaptive flush timing based on invocation patterns.

Implementations

impl FlushManager

pub fn new(config: FlushConfig) -> Self

Creates a new flush manager with the given configuration.

pub fn with_defaults() -> Self

Creates a new flush manager with default configuration.

pub fn record_invocation(&mut self)

Records that an invocation has started.

pub fn record_flush(&mut self)

Records that a flush completed successfully.

pub fn record_flush_timeout(&mut self)

Records that a flush timed out or failed.

pub fn should_flush( &self, deadline_ms: Option<i64>, pending_count: usize, is_shutdown: bool, ) -> Option<FlushReason>

Determines if a flush should be triggered now.

Arguments

• deadline_ms - The invocation deadline in milliseconds since epoch
• pending_count - Number of signals waiting to be flushed
• is_shutdown - Whether a shutdown is in progress

pub fn should_flush_on_invocation_end( &self, pending_count: usize, ) -> Option<FlushReason>

Should be called at the end of an invocation to check for end-of-invocation flush.

pub fn average_invocation_interval(&self) -> Option<Duration>

Returns the average time between invocations, if available.

pub fn is_infrequent_pattern(&self) -> bool

Returns whether invocations are infrequent (>120s average interval).

pub fn interval(&self) -> Duration

Returns the configured flush interval.

pub fn time_until_next_flush(&self) -> Duration

Returns the time until the next periodic flush should occur.

pub fn consecutive_timeout_count(&self) -> usize

Returns the number of consecutive flush timeouts.

pub fn invocation_history_len(&self) -> usize

Returns the number of invocations in the history.