Struct holochain_sqlite::conn::PConn

pub struct PConn { /* fields omitted */ }

Singleton Connection.

Trait Implementations

impl AsMut<PooledConnection<SqliteConnectionManager>> for PConn

fn as_mut(&mut self) -> &mut PConnInner

Performs the conversion.

impl AsP2pAgentStoreConExt for PConn

fn p2p_get_agent(
    &mut self,
    agent: &KitsuneAgent
) -> DatabaseResult<Option<AgentInfoSigned>>

Get an AgentInfoSigned record from the p2p_store

fn p2p_list_agents(&mut self) -> DatabaseResult<Vec<AgentInfoSigned>>

List all AgentInfoSigned records within a space in the p2p_agent_store

fn p2p_gossip_query_agents(
    &mut self,
    since_ms: u64,
    until_ms: u64,
    arcset: DhtArcSet
) -> DatabaseResult<Vec<AgentInfoSigned>>

Query agent list for gossip

fn p2p_query_near_basis(
    &mut self,
    basis: u32,
    limit: u32
) -> DatabaseResult<Vec<AgentInfoSigned>>

Query agents sorted by nearness to basis loc

impl AsRef<PooledConnection<SqliteConnectionManager>> for PConn

fn as_ref(&self) -> &PConnInner

Performs the conversion.

impl Borrow<PooledConnection<SqliteConnectionManager>> for PConn

fn borrow(&self) -> &PConnInner

Immutably borrows from an owned value.

impl BorrowMut<PooledConnection<SqliteConnectionManager>> for PConn

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

Mutably borrows from an owned value.

impl Deref for PConn

type Target = PConnInner

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for PConn

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<'e> ReadManager<'e> for PConn

fn with_reader<E, R, F>(&'e mut self, f: F) -> Result<R, E> where
    E: From<DatabaseError>,
    F: 'e + FnOnce(Transaction<'_>) -> Result<R, E>, 

Run a closure, passing in a new read-only transaction

fn with_reader_test<R, F>(&'e mut self, f: F) -> R where
    F: 'e + FnOnce(Transaction<'_>) -> R, 

Same as with_reader, but with no Results: everything gets unwrapped

impl<'e> WriteManager<'e> for PConn

fn with_commit_sync<E, R, F>(&'e mut self, f: F) -> Result<R, E> where
    E: From<DatabaseError>,
    F: 'e + FnOnce(&mut Transaction<'_>) -> Result<R, E>, 

Run a closure, passing in a mutable reference to a read-write transaction, and commit the transaction after the closure has run. If there is a SQLite error, recover from it and re-run the closure.

fn with_commit_test<R, F>(&'e mut self, f: F) -> Result<R, DatabaseError> where
    F: 'e + FnOnce(&mut Transaction<'_>) -> R,