Struct holochain_types::db_cache::DhtDbQueryCache

pub struct DhtDbQueryCache { /* private fields */ }

This cache allows us to track selected database queries that are too slow to run frequently. The queries are lazily evaluated and cached. Then the cache is updated in memory without needing to go to the database.

Implementations

impl DhtDbQueryCache

pub async fn get_state( &self ) -> &RwShare<HashMap<Arc<AgentPubKey>, ActivityState>>

Get the caches internal state for testing.

impl DhtDbQueryCache

pub fn new(dht_db: DbRead<DbKindDht>) -> Self

Create a new cache for dht database queries.

pub async fn get_activity_to_integrate( &self ) -> DatabaseResult<Vec<(Arc<AgentPubKey>, RangeInclusive<u32>)>>

Get any activity that is ready to be integrated. This returns a range of activity that is ready to be integrated for each agent.

pub async fn is_chain_empty(&self, author: &AgentPubKey) -> DatabaseResult<bool>

Is the SourceChain empty for this AgentPubKey?

pub async fn set_all_activity_to_integrated( &self, integrated_activity: Vec<(Arc<AgentPubKey>, RangeInclusive<u32>)> ) -> DbCacheResult<()>

Mark agent activity as actually integrated.

pub async fn set_activity_ready_to_integrate( &self, agent: &AgentPubKey, action_sequence: u32 ) -> DbCacheResult<()>

Set activity to ready to integrate.

pub async fn set_activity_to_integrated( &self, agent: &AgentPubKey, action_sequence: u32 ) -> DbCacheResult<()>

Set activity to to integrated.

Trait Implementations

impl Clone for DhtDbQueryCache

fn clone(&self) -> DhtDbQueryCache

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl From<DbRead<DbKindDht>> for DhtDbQueryCache

fn from(db: DbRead<DbKindDht>) -> Self

Converts to this type from the input type.

impl From<DbWrite<DbKindDht>> for DhtDbQueryCache

fn from(db: DbWrite<DbKindDht>) -> Self

Converts to this type from the input type.