Enum ClientRequest 

pub enum ClientRequest {
    Propose(Vec<u8>),
    Query(Vec<u8>),
    ProposeKeyed {
        key: Vec<u8>,
        command: Vec<u8>,
    },
    QueryKeyed {
        key: Vec<u8>,
        query: Vec<u8>,
    },
    ReadIndexConfirm {
        route_key: Option<Vec<u8>>,
    },
    TwoPhasePrepare {
        tx_id: Vec<u8>,
        key: Vec<u8>,
        command: Vec<u8>,
    },
    TwoPhaseCommit {
        tx_id: Vec<u8>,
        key: Vec<u8>,
    },
    TwoPhaseAbort {
        tx_id: Vec<u8>,
        key: Vec<u8>,
    },
}

A request from a client to the cluster.

Variants

Propose(Vec<u8>)

A write: application-encoded command replicated through the Raft log.

Query(Vec<u8>)

A linearizable read: application-encoded query answered via ReadIndex.

ProposeKeyed

A write routed to the Raft group owning key (multi-Raft, write-sharding-multi-raft).

Fields

key: Vec<u8>

Shard routing key (typically the same key the command mutates).

command: Vec<u8>

Application-encoded command body.

QueryKeyed

A linearizable read routed to the Raft group owning key.

Fields

key: Vec<u8>

Shard routing key.

query: Vec<u8>

Application-encoded query body.

ReadIndexConfirm

Ask the leader to confirm a linearizable read index without executing a query (etcd-style follower read setup, read-consistency).

Fields

route_key: Option<Vec<u8>>

Shard routing key for multi-Raft; None targets group 0.

TwoPhasePrepare

Stage a command in leader memory for cross-shard 2PC (optional Tier 2).

Fields

tx_id: Vec<u8>

Shared transaction id.

key: Vec<u8>

Shard routing key.

command: Vec<u8>

Application-encoded command to commit later.

TwoPhaseCommit

Commit a previously prepared command through the normal Raft log.

Fields

tx_id: Vec<u8>

Shared transaction id.

key: Vec<u8>

Shard routing key.

TwoPhaseAbort

Drop a previously prepared command without committing.

Fields

tx_id: Vec<u8>

Shared transaction id.

key: Vec<u8>

Shard routing key.

Trait Implementations

impl Clone for ClientRequest

fn clone(&self) -> ClientRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClientRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClientRequest

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ClientRequest

impl PartialEq for ClientRequest

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ClientRequest

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 ClientRequest