Struct HandoffBuffer 

pub struct HandoffBuffer { /* private fields */ }

In-memory buffer for handoff contexts with TTL-based expiry.

Implementations

impl HandoffBuffer

pub fn new(default_ttl_secs: u64) -> Self

Create a new HandoffBuffer with the specified default TTL in seconds.

pub fn insert(&mut self, context: HandoffContext) -> Uuid

Insert a handoff context into the buffer. Computes expiry from ctx.ttl_secs or falls back to default_ttl.

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

Get a reference to a handoff context by ID. Returns None if not found or if expired.

pub fn latest_for_agent(&self, to_agent: &str) -> Option<&HandoffContext>

Get the most recent handoff for a specific target agent. Returns the handoff with the latest timestamp that hasn’t expired.

pub fn sweep_expired(&mut self) -> usize

Remove all expired entries and return the count swept.

pub fn len(&self) -> usize

Get the number of entries in the buffer.

pub fn is_empty(&self) -> bool

Check if the buffer is empty.

pub fn iter( &self, ) -> impl Iterator<Item = (&Uuid, &HandoffContext, &DateTime<Utc>)>

Iterate over all entries (including expired ones). The iterator yields (id, context, expiry) tuples.

pub fn default_ttl_secs(&self) -> u64

Get the default TTL in seconds.

Trait Implementations

impl Debug for HandoffBuffer

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

Formats the value using the given formatter.