Struct Transaction 

pub struct Transaction<'a> { /* private fields */ }

One in-flight MULTI block over a Remote connection.

Drop without calling Self::exec / Self::exec_watched / Self::discard sends an implicit DISCARD so the underlying socket isn’t left in MULTI mode.

Implementations

impl<'a> Transaction<'a>

pub fn queue(&mut self, parts: &[&[u8]]) -> Result<()>

Queue one command — verb + args as raw byte slices. The server replies +QUEUED synchronously; errors propagate as io::Error.

pub fn exec(self) -> Result<Vec<Reply>>

EXEC — send EXEC, return the per-queued-command reply array. Consumes the transaction handle.

When a WATCH violation aborts the transaction the server returns Nil; this method collapses that into an empty Vec for backward compatibility with v1.4.x. For new code, prefer exec_watched, which distinguishes “aborted by WATCH” (returns None) from “successful empty transaction” (returns Some(vec![])).

pub fn exec_watched(self) -> Result<Option<Vec<Reply>>>

Like exec but returns None when a WATCH violation aborts the transaction (RESP Nil reply to EXEC). Use this when you’ve called Connection::watch and need to distinguish an abort from a successfully-empty queue.

pub fn exec_typed(self) -> Result<TransactionReplies>

Like exec but returns a TransactionReplies cursor with typed extractors (next_int, next_bulk, …) so callers don’t hand-match every Reply themselves. Aborts with io::ErrorKind::InvalidData (“transaction aborted by WATCH”) if the server replied Nil; use exec_watched_typed to distinguish abort from successfully-empty.

Consumes the handle. The cursor remembers how many replies are left (TransactionReplies::remaining) so callers can sanity- check arity at the end of the read sequence.

pub fn exec_watched_typed(self) -> Result<Option<TransactionReplies>>

Like exec_watched but returns a typed TransactionReplies cursor on commit; None on WATCH abort.

pub fn discard(self) -> Result<()>

DISCARD — abandon the queued commands. Consumes the handle.

impl<'a> Transaction<'a>

pub fn set(&mut self, key: &[u8], value: &[u8]) -> Result<&mut Self>

Queue SET key value.

pub fn get(&mut self, key: &[u8]) -> Result<&mut Self>

Queue GET key.

pub fn del(&mut self, keys: &[&[u8]]) -> Result<&mut Self>

Queue DEL key [key ...].

pub fn exists(&mut self, keys: &[&[u8]]) -> Result<&mut Self>

Queue EXISTS key [key ...].

pub fn incr(&mut self, key: &[u8]) -> Result<&mut Self>

Queue INCR key.

pub fn incr_by(&mut self, key: &[u8], delta: i64) -> Result<&mut Self>

Queue INCRBY key delta.

pub fn mget(&mut self, keys: &[&[u8]]) -> Result<&mut Self>

Queue MGET key [key ...].

pub fn mset(&mut self, pairs: &[(&[u8], &[u8])]) -> Result<&mut Self>

Queue MSET key value [key value ...].

Trait Implementations

impl Debug for Transaction<'_>

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

Formats the value using the given formatter.

impl Drop for Transaction<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.