Struct Transaction

Source

pub struct Transaction {
    pub id: TransactionId,
    pub state: TransactionState,
    pub isolation_level: IsolationLevel,
    pub start_timestamp: u64,
    pub commit_timestamp: Option<u64>,
    pub snapshot: Snapshot,
    pub write_set: HashSet<VersionKey>,
    pub read_set: HashSet<VersionKey>,
    pub locks_held: Vec<LockRequest>,
    pub started_at: Instant,
}

Expand description

A database transaction with MVCC support.

Fields§

§id: TransactionId§state: TransactionState§isolation_level: IsolationLevel§start_timestamp: u64§commit_timestamp: Option<u64>§snapshot: Snapshot§write_set: HashSet<VersionKey>§read_set: HashSet<VersionKey>§locks_held: Vec<LockRequest>§started_at: Instant

Struct Transaction Copy item path

Fields§

Implementations§

impl Transaction

pub fn new( id: TransactionId, isolation_level: IsolationLevel, start_timestamp: u64, active_transactions: HashSet<TransactionId>, ) -> Self

pub fn is_active(&self) -> bool

pub fn duration(&self) -> Duration

pub fn add_to_write_set(&mut self, key: VersionKey)

pub fn add_to_read_set(&mut self, key: VersionKey)

Trait Implementations§

impl Debug for Transaction

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

Auto Trait Implementations§

impl Freeze for Transaction

impl RefUnwindSafe for Transaction

impl Send for Transaction

impl Sync for Transaction

impl Unpin for Transaction

impl UnsafeUnpin for Transaction

impl UnwindSafe for Transaction

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct Transaction

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,