Struct DbSession 

pub struct DbSession<C: CanisterKind> { /* private fields */ }

DbSession

Session-scoped database handle with policy (debug, metrics) and execution routing.

Implementations

impl<C: CanisterKind> DbSession<C>

pub const fn new(db: Db<C>) -> Self

pub const fn debug(self) -> Self

pub const fn metrics_sink(self, sink: &'static dyn MetricsSink) -> Self

pub const fn load<E>(&self) -> SessionLoadQuery<'_, C, E>

where E: EntityKind<Canister = C>,

pub const fn load_with_consistency<E>( &self, consistency: ReadConsistency, ) -> SessionLoadQuery<'_, C, E>

where E: EntityKind<Canister = C>,

pub const fn delete<E>(&self) -> SessionDeleteQuery<'_, C, E>

where E: EntityKind<Canister = C>,

pub const fn delete_with_consistency<E>( &self, consistency: ReadConsistency, ) -> SessionDeleteQuery<'_, C, E>

where E: EntityKind<Canister = C>,

pub fn diagnose_query<E: EntityKind<Canister = C>>( &self, query: &Query<E>, ) -> Result<QueryDiagnostics, QueryError>

pub fn execute_query<E: EntityKind<Canister = C>>( &self, query: &Query<E>, ) -> Result<Response<E>, QueryError>

pub fn execute_with_diagnostics<E: EntityKind<Canister = C>>( &self, query: &Query<E>, ) -> Result<(Response<E>, QueryExecutionDiagnostics), QueryError>

pub fn insert<E>(&self, entity: E) -> Result<E, InternalError>

where E: EntityKind<Canister = C>,

pub fn insert_many<E>( &self, entities: impl IntoIterator<Item = E>, ) -> Result<Vec<E>, InternalError>

where E: EntityKind<Canister = C>,

pub fn replace<E>(&self, entity: E) -> Result<E, InternalError>

where E: EntityKind<Canister = C>,

pub fn replace_many<E>( &self, entities: impl IntoIterator<Item = E>, ) -> Result<Vec<E>, InternalError>

where E: EntityKind<Canister = C>,

pub fn update<E>(&self, entity: E) -> Result<E, InternalError>

where E: EntityKind<Canister = C>,

pub fn update_many<E>( &self, entities: impl IntoIterator<Item = E>, ) -> Result<Vec<E>, InternalError>

where E: EntityKind<Canister = C>,

pub fn insert_view<E>( &self, view: E::ViewType, ) -> Result<E::ViewType, InternalError>

where E: EntityKind<Canister = C>,

pub fn replace_view<E>( &self, view: E::ViewType, ) -> Result<E::ViewType, InternalError>

where E: EntityKind<Canister = C>,

pub fn update_view<E>( &self, view: E::ViewType, ) -> Result<E::ViewType, InternalError>

where E: EntityKind<Canister = C>,