Trait parallel_processor::buckets::bucket_writer::BucketItemSerializer

pub trait BucketItemSerializer {
    type InputElementType<'a>: ?Sized;
    type ExtraData;
    type ReadBuffer;
    type ExtraDataBuffer;
    type ReadType<'a>;

    // Required methods
    fn new() -> Self;
    fn reset(&mut self);
    fn write_to(
        &mut self,
        element: &Self::InputElementType<'_>,
        bucket: &mut Vec<u8>,
        extra_data: &Self::ExtraData,
        extra_read_buffer: &Self::ExtraDataBuffer
    );
    fn read_from<'a, S: Read>(
        &mut self,
        stream: S,
        read_buffer: &'a mut Self::ReadBuffer,
        extra_read_buffer: &mut Self::ExtraDataBuffer
    ) -> Option<Self::ReadType<'a>>;
    fn get_size(
        &self,
        element: &Self::InputElementType<'_>,
        extra: &Self::ExtraData
    ) -> usize;
}

Required Associated Types

type InputElementType<'a>: ?Sized

type ExtraData

type ReadBuffer

type ExtraDataBuffer

type ReadType<'a>

Required Methods

fn new() -> Self

Creates a new instance

fn reset(&mut self)

Reset on non continuous data

fn write_to( &mut self, element: &Self::InputElementType<'_>, bucket: &mut Vec<u8>, extra_data: &Self::ExtraData, extra_read_buffer: &Self::ExtraDataBuffer )

fn read_from<'a, S: Read>( &mut self, stream: S, read_buffer: &'a mut Self::ReadBuffer, extra_read_buffer: &mut Self::ExtraDataBuffer ) -> Option<Self::ReadType<'a>>

fn get_size( &self, element: &Self::InputElementType<'_>, extra: &Self::ExtraData ) -> usize

Implementors

impl BucketItemSerializer for BytesSliceSerializer

type InputElementType<'a> = [u8]

type ExtraData = ()

type ExtraDataBuffer = ()

type ReadBuffer = ()

type ReadType<'a> = ()

impl<const LEN: usize> BucketItemSerializer for SortedDataSerializer<LEN>

type InputElementType<'a> = SortedData<LEN>

type ExtraData = ()

type ExtraDataBuffer = ()

type ReadBuffer = SortedData<LEN>

type ReadType<'a> = &'a SortedData<LEN>

impl<const SIZE: usize> BucketItemSerializer for BytesArraySerializer<SIZE>

type InputElementType<'a> = [u8; SIZE]

type ExtraData = ()

type ExtraDataBuffer = ()

type ReadBuffer = [u8; SIZE]

type ReadType<'a> = &'a [u8; SIZE]