Struct AgentStateConditionalWriteRequest 

pub struct AgentStateConditionalWriteRequest {
    pub gate: Option<WriteEntry>,
    pub condition: i32,
    pub condition_value: Vec<u8>,
    pub entries: Vec<WriteEntry>,
    pub read_set: Vec<AgentTxnRead>,
    pub condition_seq: u64,
    pub role_entries: Vec<AgentStateRoleEntry>,
    pub role_gate: Option<AgentStateRoleEntry>,
    pub role_read_set: Vec<AgentStateRoleRead>,
}

Fields

gate: Option<WriteEntry>

Same shape as ConditionalBatchWriteRequest minus the shard fields — the shard is not the caller’s to choose here, it is the pinned coordination shard by construction.

condition: i32

condition_value: Vec<u8>

entries: Vec<WriteEntry>

read_set: Vec<AgentTxnRead>

condition_seq: u64

role_entries: Vec<AgentStateRoleEntry>

Logical causal rows to apply alongside entries, expanded server-side. Prefer these over raw entries for anything in a causal CF.

role_gate: Option<AgentStateRoleEntry>

The GATE, named logically. Use this instead of gate for anything in a causal CF: the coordination CF is created node-locally and is NOT in the metadata registry, so a coordinator has no way to learn its physical id — and any id it guessed would be a different CF on a different node.

The server puts the predicate on the row reads resolve to, and any additional mirror rows ride along as plain entries so the whole batch is still decided by the one predicate.

role_read_set: Vec<AgentStateRoleRead>

Read-set entries named logically, resolved server-side and merged into read_set. Needed for the same reason role_gate is: a causal row’s physical address depends on the store’s layout, and the coordination CF has no metadata id at all — a coordinator that built these itself would either guess wrong or be unable to name the row.

Implementations

impl AgentStateConditionalWriteRequest

pub fn condition(&self) -> WriteConditionKind

Returns the enum value of condition, or the default if the field is set to an invalid enum value.

pub fn set_condition(&mut self, value: WriteConditionKind)

Sets condition to the provided enum value.

Trait Implementations

impl Clone for AgentStateConditionalWriteRequest

fn clone(&self) -> AgentStateConditionalWriteRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentStateConditionalWriteRequest

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

Formats the value using the given formatter.

impl Default for AgentStateConditionalWriteRequest

fn default() -> Self

Returns the “default value” for a type.

impl Message for AgentStateConditionalWriteRequest

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 AgentStateConditionalWriteRequest

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for AgentStateConditionalWriteRequest