Struct ate::mesh::ChainGuard

pub struct ChainGuard { /* fields omitted */ }

Implementations

impl ChainGuard

pub fn as_ref(&self) -> &Chain

pub fn as_arc(&self) -> Arc<Chain>

pub async fn dio(&self, session: &dyn AteSession) -> Arc<Dio>

pub async fn dio_mut(&self, session: &dyn AteSession) -> Arc<DioMut>

Opens a data access layer that allows mutable changes to data. Transaction consistency on commit will be guarranted for local redo log files

pub async fn dio_fire(&self, session: &dyn AteSession) -> Arc<DioMut>

Opens a data access layer that allows mutable changes to data (in a fire-and-forget mode). No transaction consistency on commits will be enforced

pub async fn dio_full(&self, session: &dyn AteSession) -> Arc<DioMut>

Opens a data access layer that allows mutable changes to data. Transaction consistency on commit will be guarranted for all remote replicas

pub async fn dio_trans(
    &self,
    session: &dyn AteSession,
    scope: TransactionScope
) -> Arc<DioMut>

Opens a data access layer that allows mutable changes to data. Transaction consistency on commit must be specified

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

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

Methods from Deref<Target = Chain>

pub async fn backup(
    &'a self,
    include_active_files: bool
) -> Result<(), SerializationError>

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

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

pub fn remote_addr(&'a self) -> Option<&'a MeshAddress>

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 count(&'a self) -> usize

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

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

pub async fn sync_ext(&'a self, timeout: Duration) -> Result<(), CommitError>

pub async fn shutdown(&self) -> Result<(), CompactError>

pub fn metrics(&'a self) -> &'a Arc<StdMutex<Metrics>>

pub fn throttle(&'a self) -> &'a Arc<StdMutex<Throttle>>

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

pub async fn dio(self: &Arc<Chain>, session: &dyn AteSession) -> Arc<Dio>

Opens a data access layer that allows read only access to data within the chain In order to make changes to data you must use ‘.dio_mut’, ‘.dio_fire’, ‘.dio_full’ or ‘.dio_trans’

pub async fn dio_mut(self: &Arc<Chain>, session: &dyn AteSession) -> Arc<DioMut>

Opens a data access layer that allows mutable changes to data. Transaction consistency on commit will be guarranted for local redo log files

pub async fn dio_fire(
    self: &Arc<Chain>,
    session: &dyn AteSession
) -> Arc<DioMut>

Opens a data access layer that allows mutable changes to data (in a fire-and-forget mode). No transaction consistency on commits will be enforced

pub async fn dio_full(
    self: &Arc<Chain>,
    session: &dyn AteSession
) -> Arc<DioMut>

Opens a data access layer that allows mutable changes to data. Transaction consistency on commit will be guarranted for all remote replicas

pub async fn dio_trans(
    self: &Arc<Chain>,
    session: &dyn AteSession,
    scope: TransactionScope
) -> Arc<DioMut>

Opens a data access layer that allows mutable changes to data. Transaction consistency on commit must be specified

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

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

pub fn add_service<CTX, REQ, RES, ERR, C, F>(
    self: &Arc<Self>,
    session: &dyn AteSession,
    context: Arc<CTX>,
    callback: C
) -> Arc<ServiceHook> where
    CTX: Send + Sync + 'static,
    REQ: DeserializeOwned + Send + Sync + Sized + 'static,
    RES: Serialize + Send + Sync + Sized + 'static,
    ERR: Serialize + Send + Sync + Sized + 'static,
    C: Fn(Arc<CTX>, REQ) -> F + Send + 'static,
    F: Future<Output = Result<RES, ERR>> + Send + 'static, 

pub fn add_generic_service(
    self: &Arc<Self>,
    session: Box<dyn AteSession>,
    handler: &Arc<dyn ServiceInvoker>
) -> Arc<ServiceHook>

Trait Implementations

impl Deref for ChainGuard

type Target = Chain

The resulting type after dereferencing.

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

Dereferences the value.

impl Drop for ChainGuard

fn drop(&mut self)

Executes the destructor for this type.