pub struct StoredRecord<T = Vec<u8>> {
pub position: StorageCursor,
pub schema: SchemaKey,
pub scope: Option<Identifier>,
pub item: Identifier,
pub source: Option<Identifier>,
pub source_time: Option<SystemTime>,
pub payload: T,
}Fields§
§position: StorageCursor§schema: SchemaKey§scope: Option<Identifier>§item: Identifier§source: Option<Identifier>§source_time: Option<SystemTime>§payload: TTrait Implementations§
Source§impl<T> Clone for StoredRecord<T>where
T: Clone,
impl<T> Clone for StoredRecord<T>where
T: Clone,
Source§fn clone(&self) -> StoredRecord<T>
fn clone(&self) -> StoredRecord<T>
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl<T> Debug for StoredRecord<T>where
T: Debug,
impl<T> Debug for StoredRecord<T>where
T: Debug,
Source§impl Described for StoredRecord
impl Described for StoredRecord
Source§impl<'de, T> Deserialize<'de> for StoredRecord<T>where
T: Deserialize<'de>,
impl<'de, T> Deserialize<'de> for StoredRecord<T>where
T: Deserialize<'de>,
Source§fn deserialize<__D>(
__deserializer: __D,
) -> Result<StoredRecord<T>, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D,
) -> Result<StoredRecord<T>, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl Entry for StoredRecord
impl Entry for StoredRecord
type Selection = RecordSelection
fn position(&self) -> &StorageCursor
fn matches(&self, selection: &RecordSelection) -> bool
fn pending(queued: Queued<'_>) -> &[StoredRecord]
fn scan<'a>( backend: &'a (dyn StorageBackend + 'static), snapshot: &'a BackendSnapshot, selection: &'a RecordSelection, page: ScanPage, memory: RetainedMemory, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredRecord>, Error>> + Send + 'a>>
fn start(_selection: &Self::Selection) -> u64
impl<T> Eq for StoredRecord<T>where
T: Eq,
Source§impl<T> MemorySize for StoredRecord<T>where
T: MemorySize,
impl<T> MemorySize for StoredRecord<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> PartialEq for StoredRecord<T>where
T: PartialEq,
impl<T> PartialEq for StoredRecord<T>where
T: PartialEq,
Source§impl<T> Serialize for StoredRecord<T>where
T: Serialize,
impl<T> Serialize for StoredRecord<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 StoredRecord<T>where
T: PartialEq,
Source§impl Value for StoredRecord
impl Value for StoredRecord
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<StoredRecord, 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 StoredRecord<T>where
T: Freeze,
impl<T> RefUnwindSafe for StoredRecord<T>where
T: RefUnwindSafe,
impl<T> Send for StoredRecord<T>where
T: Send,
impl<T> Sync for StoredRecord<T>where
T: Sync,
impl<T> Unpin for StoredRecord<T>where
T: Unpin,
impl<T> UnsafeUnpin for StoredRecord<T>where
T: UnsafeUnpin,
impl<T> UnwindSafe for StoredRecord<T>where
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