Struct ate::chain::Chain

pub struct Chain where
    Self: Send + Sync,  { /* fields omitted */ }

Represents the main API to access a specific chain-of-trust

This object must stay within scope for the duration of its use which has been optimized for infrequent initialization as creating this object will reload the entire chain’s metadata into memory.

The actual data of the chain is stored locally on disk thus huge chains can be stored here however very random access on large chains will result in random access IO on the disk.

Chains also allow subscribe/publish models to be applied to particular vectors (see the examples for details)

Implementations

impl<'a> Chain

pub async fn new(
    builder: ChainOfTrustBuilder,
    key: &ChainKey
) -> Result<Chain, ChainCreationError>

pub async fn new_ext(
    builder: ChainOfTrustBuilder,
    key: ChainKey,
    extra_loader: Option<Box<dyn Loader>>,
    allow_process_errors: bool
) -> Result<Chain, ChainCreationError>

pub fn key(&'a self) -> ChainKey

pub async fn single(&'a self) -> ChainSingleUser<'a>

pub async fn multi(&'a self) -> ChainMultiUser

pub async fn name(&'a self) -> String

pub fn default_format(&'a self) -> MessageFormat

pub async fn rotate(&'a mut self) -> Result<(), Error>

pub async fn compact(&'a mut self) -> Result<(), CompactError>

pub async fn count(&'a self) -> usize

pub async fn flush(&'a self) -> Result<(), Error>

pub async fn sync(&'a self) -> Result<(), CommitError>

pub fn repository(&self) -> Option<Arc<dyn ChainRepository>>

impl Chain

pub async fn dio<'a>(&'a self, session: &'a Session) -> Dio<'a>

pub async fn dio_ext<'a>(
    &'a self,
    session: &'a Session,
    scope: Scope
) -> Dio<'a>

impl Chain

pub async fn invoke<REQ: ?Sized, RES: ?Sized, ERR: ?Sized>(
    self: Arc<Self>,
    request: REQ
) -> Result<RES, InvokeError<ERR>> where
    REQ: Serialize + DeserializeOwned + Clone + Sync + Send,
    RES: Serialize + DeserializeOwned + Clone + Sync + Send,
    ERR: Serialize + DeserializeOwned + Clone + Sync + Send, 

pub async fn invoke_ext<REQ: ?Sized, RES: ?Sized, ERR: ?Sized>(
    self: Arc<Self>,
    session: Option<&Session>,
    request: REQ,
    timeout: Duration
) -> Result<RES, InvokeError<ERR>> where
    REQ: Serialize + DeserializeOwned + Clone + Sync + Send,
    RES: Serialize + DeserializeOwned + Clone + Sync + Send,
    ERR: Serialize + DeserializeOwned + Clone + Sync + Send, 

pub fn add_service<REQ: ?Sized, RES: ?Sized, ERR: ?Sized>(
    self: &Arc<Self>,
    session: Session,
    handler: ServiceInstance<REQ, RES, ERR>
) where
    REQ: Serialize + DeserializeOwned + Clone + Sync + Send + 'static,
    RES: Serialize + DeserializeOwned + Clone + Sync + Send + 'static,
    ERR: Debug + Serialize + DeserializeOwned + Clone + Sync + Send + 'static, 

Trait Implementations

impl Clone for Chain where
    Self: Send + Sync, 

fn clone(&self) -> Chain

Returns a copy of the value.

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

Performs copy-assignment from source.