Enum TransactionMessage

pub enum TransactionMessage {
    TransactionOperation(WrappedServerMessage),
    Register(Sender<TransactionMessage>),
    Ping((usize, String)),
    Deregister(usize),
    CloseConnection,
    Registered(usize),
    Unregistered,
    Error(NanoServiceError),
}

The message that is to be sent between actors on the same machine.

Fields

• TransactionOperation: a transaction operation that is to be sent to the key value store and thus over a TCP connection
• Register: a message to register a transaction actor with the router
• Ping: a message to ping the connection to ensure it is still alive (router ID, connection ID)
• Deregister: a message to deregister a transaction actor from the router
• CloseConnection: a message to close the connection
• Registered: a message to confirm that a transaction actor has been registered
• Unregistered: a message to confirm that a transaction actor has been deregistered
• Error: a message to send an error to the client

Variants

TransactionOperation(WrappedServerMessage)

Register(Sender<TransactionMessage>)

Ping((usize, String))

Deregister(usize)

CloseConnection

Registered(usize)

Unregistered

Error(NanoServiceError)

Implementations

impl TransactionMessage

pub fn extract_transaction_operation( self, ) -> Result<(usize, ServerTransactionMessage), NanoServiceError>

Extracts the transaction operation and server ID.

Returns

A tuple containing the server ID and the transaction operation.

Trait Implementations

impl Clone for TransactionMessage

fn clone(&self) -> TransactionMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TransactionMessage

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

Formats the value using the given formatter.