Struct Command 

pub struct Command {
    pub command_type: CommandType,
    pub key: String,
    pub value: Option<Vec<u8>>,
    pub metadata: HashMap<String, String>,
}

A command to be applied to the state machine. Supports both key-value and database operations.

Fields

command_type: CommandType

key: String

value: Option<Vec<u8>>

metadata: HashMap<String, String>

Implementations

impl Command

pub fn get(key: impl Into<String>) -> Self

Create a get command.

pub fn set(key: impl Into<String>, value: Vec<u8>) -> Self

Create a set command.

pub fn delete(key: impl Into<String>) -> Self

Create a delete command.

pub fn sql(statement: impl Into<String>) -> Self

Create a SQL execution command.

pub fn document_insert(collection: impl Into<String>, document: Vec<u8>) -> Self

Create a document insert command.

pub fn document_update( collection: impl Into<String>, doc_id: impl Into<String>, document: Vec<u8>, ) -> Self

Create a document update command.

pub fn document_delete( collection: impl Into<String>, doc_id: impl Into<String>, ) -> Self

Create a document delete command.

pub fn graph_create_node(label: impl Into<String>, properties: Vec<u8>) -> Self

Create a graph node create command.

pub fn graph_create_edge( edge_type: impl Into<String>, from_node: impl Into<String>, to_node: impl Into<String>, properties: Vec<u8>, ) -> Self

Create a graph edge create command.

pub fn tx_begin(tx_id: u64) -> Self

Create a transaction begin command.

pub fn tx_commit(tx_id: u64) -> Self

Create a transaction commit command.

pub fn tx_rollback(tx_id: u64) -> Self

Create a transaction rollback command.

pub fn to_bytes(&self) -> Vec<u8>

Serialize the command.

pub fn from_bytes(bytes: &[u8]) -> Option<Self>

Deserialize a command.

pub fn is_write(&self) -> bool

Check if this command is a write operation (modifies state).

pub fn sql_statement(&self) -> Option<&str>

Get the SQL statement if this is a SQL command.

pub fn transaction_id(&self) -> Option<u64>

Get the transaction ID if this is a transaction command.

Trait Implementations

impl Clone for Command

fn clone(&self) -> Command

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Command

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Command

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Command

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

where __S: Serializer,

Serialize this value into the given Serde serializer.