Trait tinychain::cluster::Replica

pub trait Replica {
    // Required methods
    fn state<'life0, 'async_trait>(
        &'life0 self,
        txn_id: TxnId
    ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn replicate<'life0, 'life1, 'async_trait>(
        &'life0 self,
        txn: &'life1 Txn,
        source: Link
    ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

A state which supports replication in a [Cluster]

Required Methods

fn state<'life0, 'async_trait>( &'life0 self, txn_id: TxnId ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn replicate<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 Txn, source: Link ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementations on Foreign Types

impl Replica for BlockChain<Class>

fn state<'life0, 'async_trait>( &'life0 self, txn_id: TxnId ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn replicate<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 Txn, source: Link ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Replica for BlockChain<Library>

fn state<'life0, 'async_trait>( &'life0 self, txn_id: TxnId ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn replicate<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 Txn, source: Link ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Replica for BlockChain<Service>

fn state<'life0, 'async_trait>( &'life0 self, txn_id: TxnId ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn replicate<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 Txn, source: Link ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Replica for BlockChain<CollectionBase>

fn state<'life0, 'async_trait>( &'life0 self, _txn_id: TxnId ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn replicate<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 Txn, source: Link ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Replica for Chain<CollectionBase>

fn state<'life0, 'async_trait>( &'life0 self, txn_id: TxnId ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn replicate<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 Txn, source: Link ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl<T> Replica for SyncChain<T>

where T: Persist<CacheBlock, Txn = Txn> + Route<State> + Restore<CacheBlock> + TryCastFrom<State> + ToState<State> + Transact + Clone + Send + Sync + Debug,

fn state<'life0, 'async_trait>( &'life0 self, _txn_id: TxnId ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn replicate<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 Txn, source: Link ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors

impl Replica for Service

impl Replica for Version

impl<T: DirItem + Route<State> + Debug> Replica for Dir<T>

where BlockChain<T>: Replica, DirEntry<T>: Clone, Cluster<Self>: Clone, Self: Persist<CacheBlock, Txn = Txn, Schema = Schema> + Route<State> + Debug,