Struct RingBuffer 

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

Ring Buffer.

Implementations

impl<T> RingBuffer<T>

pub fn new<F>(factory: F, size: usize, sequencer: Arc<dyn Sequencer>) -> Self

where F: Fn() -> T,

Creates a new ring buffer with the given factory, size, and sequencer.

pub fn add_gating_sequences(&self, sequences: Vec<Arc<Sequence>>)

Adds gating sequences to the sequencer.

pub fn get(&self, sequence: i64) -> &T

Gets a reference to the event at the given sequence.

pub fn get_mut(&mut self, sequence: i64) -> &mut T

Gets a mutable reference to the event at the given sequence.

pub unsafe fn get_unchecked(&self, sequence: i64) -> &T

Unsafe access for high performance (internal use).

Safety

The caller must ensure that the sequence number is valid and that no other thread is concurrently modifying the same slot.

pub unsafe fn get_unchecked_mut(&self, sequence: i64) -> &mut T

Unsafe mutable access for high performance (internal use).

Safety

The caller must ensure that the sequence number is valid and that they have exclusive access to the slot (e.g., via the Disruptor protocol).

pub fn next(&self) -> i64

Claims the next sequence in the ring buffer.

pub fn publish(&self, sequence: i64)

Publishes the sequence, making it available to consumers.

Trait Implementations

impl<T: Send> Send for RingBuffer<T>

impl<T: Send> Sync for RingBuffer<T>