Struct ConditionalBatchWriteRequest 

pub struct ConditionalBatchWriteRequest {
    pub gate: Option<WriteEntry>,
    pub condition: i32,
    pub condition_value: Vec<u8>,
    pub entries: Vec<WriteEntry>,
    pub shard_id: u64,
    pub shard_epoch: u64,
    pub read_set: Vec<AgentTxnRead>,
    pub condition_seq: u64,
}

Fields

gate: Option<WriteEntry>

PUT or DELETE; MERGE is invalid as a gate

condition: i32

condition_value: Vec<u8>

expected value for IF_VALUE_EQUALS

entries: Vec<WriteEntry>

plain entries gated by gate

shard_id: u64

shard_epoch: u64

read_set: Vec<AgentTxnRead>

Only for WRITE_CONDITION_IF_READ_SET_UNCHANGED. Each entry is a key the caller read at observed_seq; the batch applies only if none of them has been overwritten since. Validated at the SAME atomic point the batch is applied, so no concurrent write can slip in between.

condition_seq: u64

Only for WRITE_CONDITION_IF_SEQ_EQUALS: the exact engine sequence the gate key must still hold.

Implementations

impl ConditionalBatchWriteRequest

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 ConditionalBatchWriteRequest

fn clone(&self) -> ConditionalBatchWriteRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConditionalBatchWriteRequest

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

Formats the value using the given formatter.

impl Default for ConditionalBatchWriteRequest

fn default() -> Self

Returns the “default value” for a type.

impl Message for ConditionalBatchWriteRequest

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 ConditionalBatchWriteRequest

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ConditionalBatchWriteRequest