Struct CodecPartialDefault 

pub struct CodecPartialDefault<T: ?Sized, R, C: ?Sized> { /* private fields */ }

Generic partial codec for all codec operations with default behavior.

The default behaviour for partial encoding/decoding involves reading/writing the entire chunk.

This struct is generic over the input/output handle type, representation type, and codec type.

Implementations

impl<T: ?Sized, R, C: ?Sized> CodecPartialDefault<T, R, C>

pub fn new( input_output_handle: Arc<T>, decoded_representation: R, codec: Arc<C>, ) -> Self

Create a new CodecPartialDefault.

Trait Implementations

impl<T> ArrayPartialDecoderTraits for CodecPartialDefault<T, ChunkRepresentation, dyn ArrayToArrayCodecTraits>

where T: ArrayPartialDecoderTraits + ?Sized,

fn data_type(&self) -> &DataType

Return the data type of the partial decoder.

fn exists(&self) -> Result<bool, StorageError>

Returns whether the chunk exists.

fn size_held(&self) -> usize

Returns the size of chunk bytes held by the partial decoder.

fn partial_decode( &self, indexer: &dyn Indexer, options: &CodecOptions, ) -> Result<ArrayBytes<'_>, CodecError>

Partially decode a chunk.

fn supports_partial_decode(&self) -> bool

Returns whether this decoder supports partial decoding.

fn partial_decode_into( &self, indexer: &dyn Indexer, output_view: &mut ArrayBytesFixedDisjointView<'_>, options: &CodecOptions, ) -> Result<(), CodecError>

Partially decode into a preallocated output.

impl<T> ArrayPartialDecoderTraits for CodecPartialDefault<T, ChunkRepresentation, dyn ArrayToBytesCodecTraits>

where T: BytesPartialDecoderTraits + ?Sized,

fn data_type(&self) -> &DataType

Return the data type of the partial decoder.

fn exists(&self) -> Result<bool, StorageError>

Returns whether the chunk exists.

fn size_held(&self) -> usize

Returns the size of chunk bytes held by the partial decoder.

fn partial_decode( &self, indexer: &dyn Indexer, options: &CodecOptions, ) -> Result<ArrayBytes<'_>, CodecError>

Partially decode a chunk.

fn supports_partial_decode(&self) -> bool

Returns whether this decoder supports partial decoding.

fn partial_decode_into( &self, indexer: &dyn Indexer, output_view: &mut ArrayBytesFixedDisjointView<'_>, options: &CodecOptions, ) -> Result<(), CodecError>

Partially decode into a preallocated output.

impl<T> ArrayPartialEncoderTraits for CodecPartialDefault<T, ChunkRepresentation, dyn ArrayToArrayCodecTraits>

where T: ArrayPartialEncoderTraits + ?Sized,

fn into_dyn_decoder(self: Arc<Self>) -> Arc<dyn ArrayPartialDecoderTraits>

Return the encoder as an Arc<ArrayPartialDecoderTraits>.

fn erase(&self) -> Result<(), CodecError>

Erase the chunk.

fn partial_encode( &self, indexer: &dyn Indexer, bytes: &ArrayBytes<'_>, options: &CodecOptions, ) -> Result<(), CodecError>

Partially encode a chunk.

fn supports_partial_encode(&self) -> bool

Returns whether this encoder supports partial encoding.

impl<T> ArrayPartialEncoderTraits for CodecPartialDefault<T, ChunkRepresentation, dyn ArrayToBytesCodecTraits>

where T: BytesPartialEncoderTraits + ?Sized,

fn into_dyn_decoder(self: Arc<Self>) -> Arc<dyn ArrayPartialDecoderTraits>

Return the encoder as an Arc<ArrayPartialDecoderTraits>.

fn erase(&self) -> Result<(), CodecError>

Erase the chunk.

fn partial_encode( &self, indexer: &dyn Indexer, bytes: &ArrayBytes<'_>, options: &CodecOptions, ) -> Result<(), CodecError>

Partially encode a chunk.

fn supports_partial_encode(&self) -> bool

Returns whether this encoder supports partial encoding.

impl<T> AsyncArrayPartialDecoderTraits for CodecPartialDefault<T, ChunkRepresentation, dyn ArrayToArrayCodecTraits>

where T: AsyncArrayPartialDecoderTraits + ?Sized,

fn exists<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether the chunk exists.

fn size_held(&self) -> usize

Returns the size of chunk bytes held by the partial decoder.

fn data_type(&self) -> &DataType

Return the data type of the partial decoder.

fn partial_decode<'a, 'life0, 'life1, 'async_trait>( &'a self, indexer: &'life0 dyn Indexer, options: &'life1 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<ArrayBytes<'a>, CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Partially decode a chunk.

fn supports_partial_decode(&self) -> bool

Returns whether this decoder supports partial decoding.

fn partial_decode_into<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, indexer: &'life1 dyn Indexer, output_view: &'life2 mut ArrayBytesFixedDisjointView<'life3>, options: &'life4 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Async variant of ArrayPartialDecoderTraits::partial_decode_into.

impl<T> AsyncArrayPartialDecoderTraits for CodecPartialDefault<T, ChunkRepresentation, dyn ArrayToBytesCodecTraits>

where T: AsyncBytesPartialDecoderTraits + ?Sized,

fn data_type(&self) -> &DataType

Return the data type of the partial decoder.

fn exists<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether the chunk exists.

fn size_held(&self) -> usize

Returns the size of chunk bytes held by the partial decoder.

fn partial_decode<'a, 'life0, 'life1, 'async_trait>( &'a self, indexer: &'life0 dyn Indexer, options: &'life1 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<ArrayBytes<'a>, CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Partially decode a chunk.

fn supports_partial_decode(&self) -> bool

Returns whether this decoder supports partial decoding.

fn partial_decode_into<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, indexer: &'life1 dyn Indexer, output_view: &'life2 mut ArrayBytesFixedDisjointView<'life3>, options: &'life4 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Async variant of ArrayPartialDecoderTraits::partial_decode_into.

impl<T> AsyncArrayPartialEncoderTraits for CodecPartialDefault<T, ChunkRepresentation, dyn ArrayToArrayCodecTraits>

where T: AsyncArrayPartialEncoderTraits + ?Sized,

fn into_dyn_decoder(self: Arc<Self>) -> Arc<dyn AsyncArrayPartialDecoderTraits>

Return the encoder as an Arc<AsyncArrayPartialDecoderTraits>.

fn erase<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Erase the chunk.

fn partial_encode<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, indexer: &'life1 dyn Indexer, bytes: &'life2 ArrayBytes<'life3>, options: &'life4 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Partially encode a chunk.

fn supports_partial_encode(&self) -> bool

Returns whether this encoder supports partial encoding.

impl<T> AsyncArrayPartialEncoderTraits for CodecPartialDefault<T, ChunkRepresentation, dyn ArrayToBytesCodecTraits>

where T: AsyncBytesPartialEncoderTraits + ?Sized,

fn into_dyn_decoder(self: Arc<Self>) -> Arc<dyn AsyncArrayPartialDecoderTraits>

Return the encoder as an Arc<AsyncArrayPartialDecoderTraits>.

fn erase<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Erase the chunk.

fn partial_encode<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, indexer: &'life1 dyn Indexer, bytes: &'life2 ArrayBytes<'life3>, options: &'life4 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Partially encode a chunk.

fn supports_partial_encode(&self) -> bool

Returns whether this encoder supports partial encoding.

impl<T> AsyncBytesPartialDecoderTraits for CodecPartialDefault<T, BytesRepresentation, dyn BytesToBytesCodecTraits>

where T: AsyncBytesPartialDecoderTraits + ?Sized,

fn exists<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether the chunk exists.

fn size_held(&self) -> usize

Returns the size of chunk bytes held by the partial decoder.

fn partial_decode_many<'a, 'life0, 'async_trait>( &'a self, decoded_regions: ByteRangeIterator<'a>, options: &'life0 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<RawBytes<'a>>>, CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Partially decode byte ranges.

fn supports_partial_decode(&self) -> bool

Returns whether this decoder supports partial decoding.

fn partial_decode<'a, 'life0, 'async_trait>( &'a self, decoded_region: ByteRange, options: &'life0 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<Option<RawBytes<'a>>, CodecError>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Partially decode a byte range.

fn decode<'a, 'life0, 'async_trait>( &'a self, options: &'life0 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<Option<RawBytes<'a>>, CodecError>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Decode all bytes.

impl<T> AsyncBytesPartialEncoderTraits for CodecPartialDefault<T, BytesRepresentation, dyn BytesToBytesCodecTraits>

where T: AsyncBytesPartialEncoderTraits + ?Sized,

fn into_dyn_decoder(self: Arc<Self>) -> Arc<dyn AsyncBytesPartialDecoderTraits>

Return the encoder as an Arc<AsyncBytesPartialDecoderTraits>.

fn erase<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Erase the chunk.

fn partial_encode_many<'a, 'life0, 'life1, 'async_trait>( &'a self, offset_values: OffsetBytesIterator<'a, RawBytes<'life0>>, options: &'life1 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Partially encode a chunk.

fn supports_partial_encode(&self) -> bool

Returns whether this encoder supports partial encoding.

fn partial_encode<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, offset: u64, bytes: RawBytes<'life1>, options: &'life2 CodecOptions, ) -> Pin<Box<dyn Future<Output = Result<(), CodecError>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Partially encode a chunk.

impl<T> BytesPartialDecoderTraits for CodecPartialDefault<T, BytesRepresentation, dyn BytesToBytesCodecTraits>

where T: BytesPartialDecoderTraits + ?Sized,

fn exists(&self) -> Result<bool, StorageError>

Returns whether the chunk exists.

fn size_held(&self) -> usize

Returns the size of chunk bytes held by the partial decoder.

fn partial_decode_many( &self, decoded_regions: ByteRangeIterator<'_>, options: &CodecOptions, ) -> Result<Option<Vec<RawBytes<'_>>>, CodecError>

Partially decode byte ranges.

fn supports_partial_decode(&self) -> bool

Returns whether this decoder supports partial decoding.

fn partial_decode( &self, decoded_region: ByteRange, options: &CodecOptions, ) -> Result<Option<RawBytes<'_>>, CodecError>

Partially decode a byte range.

fn decode( &self, options: &CodecOptions, ) -> Result<Option<RawBytes<'_>>, CodecError>

Decode all bytes.

impl<T> BytesPartialEncoderTraits for CodecPartialDefault<T, BytesRepresentation, dyn BytesToBytesCodecTraits>

where T: BytesPartialEncoderTraits + ?Sized,

fn into_dyn_decoder(self: Arc<Self>) -> Arc<dyn BytesPartialDecoderTraits>

Return the encoder as an Arc<BytesPartialDecoderTraits>.

fn erase(&self) -> Result<(), CodecError>

Erase the chunk.

fn partial_encode_many( &self, offset_values: OffsetBytesIterator<'_, RawBytes<'_>>, options: &CodecOptions, ) -> Result<(), CodecError>

Partially encode a chunk from an OffsetBytesIterator.

fn supports_partial_encode(&self) -> bool

Returns whether this encoder supports partial encoding.

fn partial_encode( &self, offset: u64, bytes: RawBytes<'_>, options: &CodecOptions, ) -> Result<(), CodecError>

Partially encode a chunk.