Struct CaptureBuffer 

pub struct CaptureBuffer { /* private fields */ }

Thread-safe in-memory buffer for captured web content

Uses a VecDeque internally for efficient FIFO operations with RwLock for thread-safe concurrent access.

Implementations

impl CaptureBuffer

pub fn new() -> Self

Create a new capture buffer with default settings

pub fn builder() -> CaptureBufferBuilder

Create a new capture buffer builder

pub fn with_config(config: BufferConfig) -> Self

Create a new capture buffer with custom configuration

pub async fn push(&self, record: CaptureRecord)

Push a new capture record into the buffer

If the buffer is at capacity, the oldest record is evicted (FIFO).

pub async fn get(&self, id: Uuid) -> Option<CaptureRecord>

Get a capture by its ID

pub async fn get_recent(&self, limit: usize) -> Vec<CaptureRecord>

Get the most recent N captures

Returns captures in reverse chronological order (newest first).

pub async fn get_since(&self, timestamp: DateTime<Utc>) -> Vec<CaptureRecord>

Get all captures since a given timestamp

pub async fn get_by_url(&self, url: &str) -> Vec<CaptureRecord>

Get all captures for a specific URL

pub async fn clear(&self)

Clear all captures from the buffer

pub async fn len(&self) -> usize

Get the current number of captures in the buffer

pub async fn is_empty(&self) -> bool

Check if the buffer is empty

pub async fn stats(&self) -> BufferStats

Get buffer statistics

pub async fn cleanup_expired(&self) -> usize

Remove expired captures from the buffer

Returns the number of captures removed.

pub fn start_cleanup_task(self: &Arc<Self>) -> JoinHandle<()>

Start the background cleanup task

This spawns a task that periodically removes expired captures.

pub async fn start_cleanup(self: &Arc<Self>)

Start cleanup task and store handle internally

pub async fn stop_cleanup(&self)

Stop the cleanup task if running

pub fn config(&self) -> &BufferConfig

Get the buffer configuration

Trait Implementations

impl Default for CaptureBuffer

fn default() -> Self

Returns the “default value” for a type.