Struct pancake_engine_ssi::opers::txn::Txn

pub struct Txn<'txn> {
    db: &'txn DB,
    db_state_guard: RwLockReadGuard<'txn, DbState>,
    snap: CachedSnap,
    snap_list_ver: ListVer,
    dependent_itvs_prim: IntervalSet<&'txn PrimaryKey>,
    dependent_itvs_scnds: HashMap<ScndIdxNum, IntervalSet<&'txn SubValue>>,
    staging: Option<StagingUnit>,
}

Fields

db: &'txn DB

db_state_guard: RwLockReadGuard<'txn, DbState>

snap: CachedSnap

snap_list_ver: ListVer

dependent_itvs_prim: IntervalSet<&'txn PrimaryKey>

dependent_itvs_scnds: HashMap<ScndIdxNum, IntervalSet<&'txn SubValue>>

staging: Option<StagingUnit>

Implementations

impl<'txn> Txn<'txn>

pub(super) fn has_conflict(&mut self) -> Result<bool>

impl<'txn> Txn<'txn>

pub(super) fn notify_fc_worker<const LEN: usize>( &self, updated_mhlv: Option<ListVer>, fc_able_commit_vers: [Option<CommitVer>; LEN] )

fn send_updated_min_held_list_ver(&self, updated_mhlv: Option<ListVer>)

fn send_fc_able_commit_vers<const LEN: usize>( &self, fc_able_commit_vers: [Option<CommitVer>; LEN] )

impl<'txn> Txn<'txn>

pub(super) async fn new( db: &'txn DB, db_state_guard: RwLockReadGuard<'txn, DbState> ) -> Self

pub(super) async fn try_commit(self) -> Result<TryCommitResult<'txn>>

fn update_snapshot_for_conflict_checking( &mut self, lsm_state: MutexGuard<'_, LsmState> ) -> Result<()>

pub(super) async fn reset(&mut self) -> Result<()>

pub(super) async fn close(self) -> Result<()>

fn do_commit(self, lsm_state: MutexGuard<'_, LsmState>) -> Result<()>

impl<'txn> Txn<'txn>

pub fn get_pk_one( &mut self, pk: &'txn PrimaryKey ) -> Result<Option<(PKShared, PVShared)>>

pub fn get_pk_range( &mut self, pk_lo: Option<&'txn PrimaryKey>, pk_hi: Option<&'txn PrimaryKey> ) -> impl Iterator<Item = Entry<'_, PKShared, PVShared>>

pub fn get_sv_range( &mut self, sv_spec_arg: &SubValueSpec, sv_lo: Option<&'txn SubValue>, sv_hi: Option<&'txn SubValue> ) -> Result<impl Iterator<Item = Entry<'_, SVPKShared, PVShared>>>

pub fn put( &mut self, pk: &'txn PKShared, new_pv: &Option<PVShared> ) -> Result<()>

fn put_scnd_stg_delta( &mut self, pk: &'txn PKShared, old_pv: &Option<PVShared>, new_pv: &Option<PVShared> ) -> Result<()>

fn ensure_create_staging(&mut self) -> Result<()>

impl<'txn> Txn<'txn>

pub async fn run<ClientOk>( db: &'txn DB, retry_limit: usize, client_fn: impl FnMut(&mut Self) -> Result<ClientCommitDecision<ClientOk>> ) -> Result<ClientOk>