Struct KvScan 

pub struct KvScan {
    pub v: u32,
    pub namespace: String,
    pub prefix: Option<Vec<u8>>,
    pub start: Option<Vec<u8>>,
    pub end: Option<Vec<u8>>,
    pub key_contains: Option<String>,
    pub conversation: Option<String>,
    pub stream: Option<String>,
    pub limit: usize,
    pub cursor: Option<Vec<u8>>,
}

Request to list entries in namespace. With no bounds it lists the whole namespace. prefix matches keys that start with it in byte order. start and end bound an inclusive-start, exclusive-end key range. key_contains keeps only keys that are valid UTF-8 and contain the substring (binary keys are skipped). All bounds compose.

Fields

v: u32

namespace: String

prefix: Option<Vec<u8>>

start: Option<Vec<u8>>

end: Option<Vec<u8>>

key_contains: Option<String>

conversation: Option<String>

The conversation lens: keep only rows the given conversation wrote (the text form of its gen_ai.conversation.id). The memory read view stamps this on each record it materializes, generic key-value rows leave it unset, so a scan narrows to one conversation’s memory. Absent on the wire when unfiltered, so a pre-lens scan stays byte-identical.

stream: Option<String>

The stream the lens conversation belongs to. Set alongside conversation by a client that scopes its resources to a stream. Absent on the wire when unset.

limit: usize

cursor: Option<Vec<u8>>

Trait Implementations

impl Clone for KvScan

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Command for KvScan

const CODE: u32 = AGDX_KV_SCAN_CODE

The managed command code this request rides.

type Reply = KvReply

The reply wire type.

impl Debug for KvScan

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for KvScan

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for KvScan

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Validate for KvScan

fn validate(&self) -> Result<(), InvalidError>

Reject a request that violates a pinned cap or a structural rule.