Struct RingBufferChannel 

pub struct RingBufferChannel<T> { /* private fields */ }

Ring buffer channel for append-heavy fields with bounded size

Wraps a Vec<T> with a maximum capacity. When new values are appended and the capacity is exceeded, the oldest elements are removed. This prevents unbounded memory growth for append-heavy fields like messages, events, and logs.

Examples

use juncture_core::state::channel::RingBufferChannel;

let mut ch = RingBufferChannel::new(Vec::new(), 100);
ch.update(vec!["msg1".to_string(), "msg2".to_string()]);
assert_eq!(ch.get().len(), 2);

Implementations

impl<T> RingBufferChannel<T>

pub fn new(values: Vec<T>, capacity: usize) -> Self

Create a new ring buffer channel with the given initial values and capacity

The capacity is clamped to a minimum of 1. If values exceeds the capacity, the oldest elements are trimmed.

pub const fn capacity(&self) -> usize

Get the current capacity

pub fn len(&self) -> usize

Get the current number of elements

pub fn is_empty(&self) -> bool

Check if the ring buffer is empty

Trait Implementations

impl<T: Send + Sync + Serialize + DeserializeOwned + 'static> Channel<Vec<T>> for RingBufferChannel<T>

fn update(&mut self, values: Vec<Vec<T>>) -> bool

Update the channel with new values. Returns true if the value changed.

fn get(&self) -> &Vec<T>

Get the current value

fn consume(&mut self) -> bool

Check if the channel has been consumed (for trigger-based activation)

fn checkpoint(&self) -> Option<Value>

Create a checkpoint of the current value for persistence

fn from_checkpoint(value: Value) -> Result<Self, String>

Restore from a checkpoint value

impl<T: Clone> Clone for RingBufferChannel<T>

fn clone(&self) -> RingBufferChannel<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for RingBufferChannel<T>

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

Formats the value using the given formatter.