pub struct StoredRow<T = Vec<u8>> {
pub record: StoredRecord<T>,
pub stream: Identifier,
pub sequence: u64,
}Fields§
§record: StoredRecord<T>§stream: Identifier§sequence: u64Trait Implementations§
Source§impl<'de, T> Deserialize<'de> for StoredRow<T>where
T: Deserialize<'de>,
impl<'de, T> Deserialize<'de> for StoredRow<T>where
T: Deserialize<'de>,
Source§fn deserialize<__D>(
__deserializer: __D,
) -> Result<StoredRow<T>, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D,
) -> Result<StoredRow<T>, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl Entry for StoredRow
impl Entry for StoredRow
type Selection = StreamSelection
fn position(&self) -> &StorageCursor
fn matches(&self, selection: &StreamSelection) -> bool
fn start(selection: &StreamSelection) -> u64
fn pending(queued: Queued<'_>) -> &[Self]
fn scan<'a>( backend: &'a dyn StorageBackend, snapshot: &'a BackendSnapshot, selection: &'a StreamSelection, page: ScanPage, memory: RetainedMemory, ) -> StorageFuture<'a, Vec<Self>>
impl<T> Eq for StoredRow<T>where
T: Eq,
Source§impl<T> MemorySize for StoredRow<T>where
T: MemorySize,
impl<T> MemorySize for StoredRow<T>where
T: MemorySize,
fn memory_size(&self) -> usize
Source§const INLINE_ONLY: bool = false
const INLINE_ONLY: bool = false
True only when every value occupies exactly
size_of::<Self>() bytes,
with no separately owned allocations or additional accounting charge.Source§impl<T> Serialize for StoredRow<T>where
T: Serialize,
impl<T> Serialize for StoredRow<T>where
T: Serialize,
Source§fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
Serialize this value into the given Serde serializer. Read more
impl<T> StructuralPartialEq for StoredRow<T>where
T: PartialEq,
Source§impl Value for StoredRow
impl Value for StoredRow
fn write(&self, bytes: &mut Vec<u8>)
fn size(&self) -> usize
fn memory(input: &mut Reader<'_>) -> Result<usize, MessageError>
fn read(input: &mut Reader<'_>) -> Result<StoredRow, MessageError>
fn size_many(values: &[Self]) -> usize
fn write_many(values: &[Self], bytes: &mut Vec<u8>)
fn memory_many( input: &mut Reader<'_>, count: usize, ) -> Result<usize, MessageError>
fn read_many( input: &mut Reader<'_>, count: usize, ) -> Result<Vec<Self>, MessageError>
Auto Trait Implementations§
impl<T> Freeze for StoredRow<T>where
StoredRecord<T>: Freeze,
impl<T> RefUnwindSafe for StoredRow<T>where
StoredRecord<T>: RefUnwindSafe,
impl<T> Send for StoredRow<T>where
StoredRecord<T>: Send,
impl<T> Sync for StoredRow<T>where
StoredRecord<T>: Sync,
impl<T> Unpin for StoredRow<T>where
StoredRecord<T>: Unpin,
impl<T> UnsafeUnpin for StoredRow<T>where
StoredRecord<T>: UnsafeUnpin,
impl<T> UnwindSafe for StoredRow<T>where
StoredRecord<T>: UnwindSafe,
Blanket Implementations§
impl<T> Allocation for T
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