pub struct ClientProxyAdapter<A: AtomicBroadcast> { /* private fields */ }
Implementations§
Source§impl<A: AtomicBroadcast> ClientProxyAdapter<A>
impl<A: AtomicBroadcast> ClientProxyAdapter<A>
Trait Implementations§
Source§impl<A: AtomicBroadcast + Send> AtomicBroadcast for ClientProxyAdapter<A>where
A::Transaction: Unpin + Clone + AsRef<RequestId>,
A::Decision: Unpin + Clone + Eq + ResponseInfo,
impl<A: AtomicBroadcast + Send> AtomicBroadcast for ClientProxyAdapter<A>where
A::Transaction: Unpin + Clone + AsRef<RequestId>,
A::Decision: Unpin + Clone + Eq + ResponseInfo,
Source§type Config = <A as AtomicBroadcast>::Config
type Config = <A as AtomicBroadcast>::Config
Custom configuration for the algorithm
Source§type ReplicaMessage = CustomReplicaMessage<<A as AtomicBroadcast>::ReplicaMessage, <A as AtomicBroadcast>::Transaction, <A as AtomicBroadcast>::Decision>
type ReplicaMessage = CustomReplicaMessage<<A as AtomicBroadcast>::ReplicaMessage, <A as AtomicBroadcast>::Transaction, <A as AtomicBroadcast>::Decision>
Messages the algorithm sends between replicas
Source§type Transaction = <A as AtomicBroadcast>::Transaction
type Transaction = <A as AtomicBroadcast>::Transaction
Requests for the algorithm
Source§type Decision = (<A as AtomicBroadcast>::Decision, Box<[Signature]>)
type Decision = (<A as AtomicBroadcast>::Decision, Box<[Signature]>)
Responses by the algorithm
Source§fn start(
self,
config: AtomicBroadcastConfiguration<Self::Config>,
channels: AtomicBroadcastChannels<Self::ReplicaMessage, Self::Transaction, Self::Decision>,
ready_for_clients: impl Send + 'static + FnOnce() + Sync,
) -> JoinHandle<Result<(), Error>>
fn start( self, config: AtomicBroadcastConfiguration<Self::Config>, channels: AtomicBroadcastChannels<Self::ReplicaMessage, Self::Transaction, Self::Decision>, ready_for_clients: impl Send + 'static + FnOnce() + Sync, ) -> JoinHandle<Result<(), Error>>
Start the atomic broadcast
Auto Trait Implementations§
impl<A> Freeze for ClientProxyAdapter<A>where
A: Freeze,
impl<A> RefUnwindSafe for ClientProxyAdapter<A>where
A: RefUnwindSafe,
impl<A> Send for ClientProxyAdapter<A>where
A: Send,
impl<A> Sync for ClientProxyAdapter<A>where
A: Sync,
impl<A> Unpin for ClientProxyAdapter<A>where
A: Unpin,
impl<A> UnwindSafe for ClientProxyAdapter<A>where
A: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more