Struct kanidmd_lib::be::BackendWriteTransaction

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

Implementations

impl<'a> BackendWriteTransaction<'a>

pub fn create(
    &mut self,
    cid: &Cid,
    entries: Vec<Entry<EntrySealed, EntryNew>>
) -> Result<Vec<Entry<EntrySealed, EntryCommitted>>, OperationError>

pub fn modify(
    &mut self,
    cid: &Cid,
    pre_entries: &[Arc<EntrySealedCommitted>],
    post_entries: &[EntrySealedCommitted]
) -> Result<(), OperationError>

pub fn reap_tombstones(&mut self, cid: &Cid) -> Result<usize, OperationError>

pub fn update_idxmeta(
    &mut self,
    idxkeys: Vec<IdxKey>
) -> Result<(), OperationError>

pub fn upgrade_reindex(&mut self, v: i64) -> Result<(), OperationError>

pub fn reindex(&mut self) -> Result<(), OperationError>

pub fn restore(&mut self, src_path: &str) -> Result<(), OperationError>

pub fn ruv_rebuild(&mut self) -> Result<(), OperationError>

pub fn commit(self) -> Result<(), OperationError>

pub fn get_db_s_uuid(&mut self) -> Uuid

pub fn get_db_d_uuid(&mut self) -> Uuid

This pulls the domain UUID from the database

pub fn set_db_ts_max(&mut self, ts: Duration) -> Result<(), OperationError>

pub fn get_db_ts_max(&mut self, ts: Duration) -> Result<Duration, OperationError>

Trait Implementations

impl<'a> BackendTransaction for BackendWriteTransaction<'a>

type IdlLayerType = IdlArcSqliteWriteTransaction<'a>

type RuvType = ReplicationUpdateVectorWriteTransaction<'a>

fn get_idlayer(&mut self) -> &mut IdlArcSqliteWriteTransaction<'a>

fn get_ruv(&mut self) -> &mut ReplicationUpdateVectorWriteTransaction<'a>

fn get_idxmeta_ref(&self) -> &IdxMeta

fn filter2idl(
    &mut self,
    filt: &FilterResolved,
    thres: usize
) -> Result<(IdList, FilterPlan), OperationError>

Recursively apply a filter, transforming into IdList’s on the way. This builds a query execution log, so that it can be examined how an operation proceeded.

fn search(
    &mut self,
    erl: &Limits,
    filt: &Filter<FilterValidResolved>
) -> Result<Vec<Arc<EntrySealedCommitted>>, OperationError>

fn exists(
    &mut self,
    erl: &Limits,
    filt: &Filter<FilterValidResolved>
) -> Result<bool, OperationError>

Given a filter, assert some condition exists. Basically, this is a specialised case of search, where we don’t need to load any candidates if they match. This is heavily used in uuid refint and attr uniqueness.

fn verify(&mut self) -> Vec<Result<(), ConsistencyError>>

fn verify_entry_index(
    &mut self,
    e: &Entry<EntrySealed, EntryCommitted>
) -> Result<(), ConsistencyError>

fn verify_indexes(&mut self) -> Vec<Result<(), ConsistencyError>>

fn verify_ruv(&mut self, results: &mut Vec<Result<(), ConsistencyError>>)

fn backup(&mut self, dst_path: &str) -> Result<(), OperationError>

fn name2uuid(&mut self, name: &str) -> Result<Option<Uuid>, OperationError>

fn externalid2uuid(&mut self, name: &str) -> Result<Option<Uuid>, OperationError>

fn uuid2spn(&mut self, uuid: Uuid) -> Result<Option<Value>, OperationError>

fn uuid2rdn(&mut self, uuid: Uuid) -> Result<Option<String>, OperationError>