Struct Txn 

pub struct Txn<'conn>(/* private fields */);

Implementations

impl<'conn> Txn<'conn>

pub fn new(tx: Transaction<'conn>) -> Self

Trait Implementations

impl<'conn> AdminEnt for Txn<'conn>

fn create_dyn(&self, ent: Box<dyn Ent>) -> Result<Id, DatabaseError>

Create an entity from a boxed dynamic Ent.

fn update_dyn(&self, ent: Box<dyn Ent>) -> Result<(), DatabaseError>

Update an entity from a boxed dynamic Ent.

fn find_edges_by_dest(&self, dest: Id) -> Result<Vec<Edge>, DatabaseError>

fn remove_edges_by_dest(&self, dest: Id) -> Result<(), DatabaseError>

fn list_entities( &self, entity_type: &str, cursor: Option<Id>, limit: usize, ) -> Result<Vec<Box<dyn Ent>>, DatabaseError>

List entities of a specific type with cursor-based pagination.

fn audit_ent_edges<E>(&self, id: u64) -> Result<(), AuditError>

where E: Ent, Self: Sized,

fn fix_ent_edges<E>(self, id: u64) -> Result<(), AuditError>

where E: Ent, Self: Sized,

impl<'conn> QueryEdge for Txn<'conn>

fn find_edges( &self, source: Id, query: EdgeQuery<'_>, ) -> Result<EdgeQueryResult, DatabaseError>

Find edges

impl<'conn> ReadEnt for Txn<'conn>

fn get(&self, id: Id) -> Result<Option<Box<dyn Ent>>, DatabaseError>

impl<'conn> Transactional for Txn<'conn>

fn create_edge(&self, edge: EdgeValue) -> Result<(), DatabaseError>

fn delete(&self, id: Id) -> Result<(), DatabaseError>

fn update<T: Ent, F: FnOnce(&mut T), B: BorrowMut<T>>( &self, ent0: B, mutator: F, ) -> Result<bool, DatabaseError>

fn create<E: Ent>(&self, ent: E) -> Result<Id, DatabaseError>

fn commit(self) -> Result<(), DatabaseError>