Struct AgentStateGetRequest 

pub struct AgentStateGetRequest {
    pub cf_name: String,
    pub key: Vec<u8>,
    pub role: u32,
    pub entity_id: u64,
    pub system: bool,
    pub snapshot_seq: u64,
}

Which agent column family to read. A NAME, not an id: the agent CFs are created directly on the shared DB, so their physical ids are a node-local detail that a coordinator must not have to know (and must not be able to guess wrong — naming the CF is what makes the allowlist check possible).

Fields

cf_name: String

key: Vec<u8>

role: u32

Logical row address. When role is non-zero the server builds the physical key itself from (entity_id, role, key-as-suffix) and cf_name is ignored.

Prefer this over a raw key. Whether a row lives in the collapsed causal CF under an [entity_id][role][suffix] key or in a legacy per-role CF under the bare suffix is SERVER state (collapsed_active()), and it differs between stores. A coordinator that hand-built physical keys would have to track the storage layout to stay correct — which is exactly the coupling that keeps agent semantics stuck inside the storage process. Addressing a row logically leaves layout where it belongs.

CausalRole tag byte; 0 = address by raw key instead

entity_id: u64

ignored unless role is set

system: bool

address the SYSTEM_ENTITY namespace, not entity_id

snapshot_seq: u64

Snapshot-bounded read: resolve the row as of this engine sequence, ignoring every version committed after it. 0 = read the latest committed version.

Required for an optimistic transaction driven from outside the storage process. Such a transaction baselines its read set on ONE snapshot; reading “latest” instead would let a write committed after the snapshot leak into the decision while the read set still claims the older baseline — the value and the version it is validated against would describe different instants.

Trait Implementations

impl Clone for AgentStateGetRequest

fn clone(&self) -> AgentStateGetRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentStateGetRequest

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

Formats the value using the given formatter.

impl Default for AgentStateGetRequest

fn default() -> Self

Returns the “default value” for a type.

impl Message for AgentStateGetRequest

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for AgentStateGetRequest

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for AgentStateGetRequest