Trait RingBufferOperations 

pub trait RingBufferOperations {
    // Required methods
    fn insert_ringbuffer(
        &mut self,
        ringbuffer: RingBuffer,
        bytes: EncodedBytes,
    ) -> Result<RowNumber>;
    fn insert_ringbuffer_at(
        &mut self,
        ringbuffer: &RingBuffer,
        shape: &RowShape,
        partition: Option<Partition>,
        row_number: RowNumber,
        bytes: EncodedBytes,
    ) -> Result<EncodedBytes>;
    fn update_ringbuffer(
        &mut self,
        ringbuffer: RingBuffer,
        partition: Option<Partition>,
        id: RowNumber,
        bytes: EncodedBytes,
    ) -> Result<EncodedBytes>;
    fn remove_from_ringbuffer(
        &mut self,
        ringbuffer: &RingBuffer,
        partition: Option<Partition>,
        id: RowNumber,
    ) -> Result<EncodedBytes>;
}

Required Methods

fn insert_ringbuffer( &mut self, ringbuffer: RingBuffer, bytes: EncodedBytes, ) -> Result<RowNumber>

fn insert_ringbuffer_at( &mut self, ringbuffer: &RingBuffer, shape: &RowShape, partition: Option<Partition>, row_number: RowNumber, bytes: EncodedBytes, ) -> Result<EncodedBytes>

fn update_ringbuffer( &mut self, ringbuffer: RingBuffer, partition: Option<Partition>, id: RowNumber, bytes: EncodedBytes, ) -> Result<EncodedBytes>

fn remove_from_ringbuffer( &mut self, ringbuffer: &RingBuffer, partition: Option<Partition>, id: RowNumber, ) -> Result<EncodedBytes>

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl RingBufferOperations for AdminTransaction

fn insert_ringbuffer( &mut self, _ringbuffer: RingBuffer, _row: EncodedBytes, ) -> Result<RowNumber>

fn insert_ringbuffer_at( &mut self, ringbuffer: &RingBuffer, shape: &RowShape, partition: Option<Partition>, row_number: RowNumber, bytes: EncodedBytes, ) -> Result<EncodedBytes>

fn update_ringbuffer( &mut self, ringbuffer: RingBuffer, partition: Option<Partition>, id: RowNumber, bytes: EncodedBytes, ) -> Result<EncodedBytes>

fn remove_from_ringbuffer( &mut self, ringbuffer: &RingBuffer, partition: Option<Partition>, id: RowNumber, ) -> Result<EncodedBytes>

impl RingBufferOperations for CommandTransaction

fn insert_ringbuffer( &mut self, _ringbuffer: RingBuffer, _row: EncodedBytes, ) -> Result<RowNumber>

fn insert_ringbuffer_at( &mut self, ringbuffer: &RingBuffer, shape: &RowShape, partition: Option<Partition>, row_number: RowNumber, bytes: EncodedBytes, ) -> Result<EncodedBytes>

fn update_ringbuffer( &mut self, ringbuffer: RingBuffer, partition: Option<Partition>, id: RowNumber, bytes: EncodedBytes, ) -> Result<EncodedBytes>

fn remove_from_ringbuffer( &mut self, ringbuffer: &RingBuffer, partition: Option<Partition>, id: RowNumber, ) -> Result<EncodedBytes>

impl RingBufferOperations for Transaction<'_>

fn insert_ringbuffer( &mut self, _ringbuffer: RingBuffer, _row: EncodedBytes, ) -> Result<RowNumber>

fn insert_ringbuffer_at( &mut self, ringbuffer: &RingBuffer, shape: &RowShape, partition: Option<Partition>, row_number: RowNumber, bytes: EncodedBytes, ) -> Result<EncodedBytes>

fn update_ringbuffer( &mut self, ringbuffer: RingBuffer, partition: Option<Partition>, id: RowNumber, bytes: EncodedBytes, ) -> Result<EncodedBytes>

fn remove_from_ringbuffer( &mut self, ringbuffer: &RingBuffer, partition: Option<Partition>, id: RowNumber, ) -> Result<EncodedBytes>

Implementors