Struct KvEntry 

pub struct KvEntry {
    pub key: Vec<u8>,
    pub value: Vec<u8>,
    pub expires_at_micros: Option<u64>,
    pub version: u64,
    pub scope: Option<Box<MemoryRowScope>>,
    pub source: Option<Box<SourceRef>>,
}

One stored entry: an arbitrary-bytes key and value plus optional expiry. The key and value are owned Vec<u8>, so the public API never leaks the bytes crate, and they ride the wire as CBOR byte strings, byte-exact.

Fields

key: Vec<u8>

value: Vec<u8>

expires_at_micros: Option<u64>

Absolute expiry in epoch microseconds, or None for no expiry. Expired entries are hidden on read.

version: u64

Optimistic-concurrency version, assigned by the store and bumped on every successful mutation of this key. The token a KvCas precondition matches against. A versioned managed backend reports >= 1 for a live entry and reserves 0 solely for “unversioned”: a store that does not track versions, or an entry written before versioning. A caller must therefore never treat 0 as a valid compare token. The field is skipped on the wire when 0 so those entries stay byte-identical.

scope: Option<Box<MemoryRowScope>>

The memory scope, present only on a memory read-view row. Recall reads it to rebuild the item and filter by scope. A generic entry leaves it None. Boxed so a generic entry stays small (the scope is five optional strings).

source: Option<Box<SourceRef>>

The origin log record this entry was folded from (stream, topic, partition, offset). Every managed write goes log-first through a mutation topic, so a stored entry points back to the record that wrote it, the same provenance a memory row carries. Absent on an entry written before provenance stamping, or read from a store that does not track it. Boxed, like scope, so a generic entry stays small.

Implementations

impl KvEntry

pub fn key_str(&self) -> Option<&str>

The key decoded as UTF-8, or None when it is not valid UTF-8. Keys are arbitrary bytes, so a binary key has no string form.

impl KvEntry

pub fn decode_value<T: DeserializeOwned>(&self) -> Result<T, DecodeError>

Decode the value as JSON into T. Sugar for decode_value_with::<Json, _>.

pub fn decode_value_with<C, T>(&self) -> Result<T, DecodeError>

where C: Decoder<T>,

Decode the value with any Decoder (Json, Msgpack, or your own).

Trait Implementations

impl Clone for KvEntry

fn clone(&self) -> KvEntry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KvEntry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for KvEntry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for KvEntry

impl PartialEq for KvEntry

fn eq(&self, other: &KvEntry) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for KvEntry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for KvEntry