Struct holochain_state::source_chain::SourceChain

pub struct SourceChain { /* fields omitted */ }

Implementations

impl SourceChain

pub async fn new(
    vault: EnvWrite,
    author: AgentPubKey
) -> SourceChainResult<Self>

pub fn public_only(&mut self)

pub fn snapshot(&self) -> SourceChainResult<Scratch>

Take a snapshot of the scratch space that will not remain in sync with future updates.

pub fn scratch(&self) -> SyncScratch

pub fn agent_pubkey(&self) -> &AgentPubKey

pub fn scratch_elements(&self) -> SourceChainResult<Vec<Element>>

This has to clone all the data because we can’t return references to constructed data.

pub fn persisted_chain_head(&self) -> (HeaderHash, u32, Timestamp)

Accessor for the chain head that will be used at flush time to check the “as at” for ordering integrity etc.

pub fn chain_head(&self) -> SourceChainResult<(HeaderHash, u32, Timestamp)>

pub async fn put_countersigned(
    &self,
    zome: Option<Zome>,
    entry: Entry,
    chain_top_ordering: ChainTopOrdering
) -> SourceChainResult<HeaderHash>

pub async fn put<H: HeaderInner, B: HeaderBuilder<H>>(
    &self,
    zome: Option<Zome>,
    header_builder: B,
    maybe_entry: Option<Entry>,
    chain_top_ordering: ChainTopOrdering
) -> SourceChainResult<HeaderHash>

pub fn has_initialized(&self) -> SourceChainResult<bool>

pub fn is_empty(&self) -> SourceChainResult<bool>

pub fn len(&self) -> SourceChainResult<u32>

pub fn valid_cap_grant(
    &self,
    check_function: &GrantedFunction,
    check_agent: &AgentPubKey,
    check_secret: Option<&CapSecret>
) -> SourceChainResult<Option<CapGrant>>

pub async fn query(&self, query: QueryFilter) -> SourceChainResult<Vec<Element>>

Query Headers in the source chain. This returns a Vec rather than an iterator because it is intended to be used by the query host function, which crosses the wasm boundary

pub async fn unlock_chain(&self) -> SourceChainResult<()>

pub async fn is_chain_locked(&self, lock: Vec<u8>) -> SourceChainResult<bool>

pub async fn accept_countersigning_preflight_request(
    &self,
    preflight_request: PreflightRequest,
    agent_index: u8
) -> SourceChainResult<CounterSigningAgentState>

pub fn countersigning_op(&self) -> SourceChainResult<Option<DhtOp>>

If there is a countersigning session get the StoreEntry op to send to the entry authorities.

pub fn lock_for_entry(entry: Option<&Entry>) -> SourceChainResult<Vec<u8>>

pub fn flush<'life0, 'life_self, 'async_recursion>(
    &'life_self self,
    network: &'life0 (dyn HolochainP2pCellT + Send + Sync)
) -> Pin<Box<dyn Future<Output = SourceChainResult<Vec<(Option<Zome>, SignedHeaderHashed)>>> + Send + 'async_recursion>> where
    'life0: 'async_recursion,
    'life_self: 'async_recursion, 

Trait Implementations

impl Clone for SourceChain

fn clone(&self) -> SourceChain

Returns a copy of the value.

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

Performs copy-assignment from source.