pub struct Buffer { /* private fields */ }Implementations§
Source§impl Buffer
impl Buffer
pub fn new(capacity: usize) -> Self
pub fn process_sample(&mut self, sample: Sample, stream_key: StreamKey)
pub fn get_run(&self, stream_key: &StreamKey) -> Option<&ActiveRun>
pub fn read_aligned_window( &self, columns: &[ColumnKey], n: usize, ) -> Result<AlignedWindow, ReadError>
pub fn read_from_cursor( &self, columns: &[ColumnKey], cursors: &HashMap<StreamKey, CursorPosition>, n: usize, ) -> Result<AlignedWindow, ReadError>
pub fn read_aligned_tail( &self, columns: &[ColumnKey], ) -> Result<AlignedWindow, ReadError>
pub fn read_aligned_time_range( &self, columns: &[ColumnKey], start_time: f64, end_time: f64, ) -> Result<AlignedWindow, ReadError>
Auto Trait Implementations§
impl Freeze for Buffer
impl RefUnwindSafe for Buffer
impl Send for Buffer
impl Sync for Buffer
impl Unpin for Buffer
impl UnsafeUnpin for Buffer
impl UnwindSafe for Buffer
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more