Struct paxakos::RequestHandler [−][src]
pub struct RequestHandler<I: Invocation>(_);Expand description
Used by Communicators to prepare
replies.
Implementations
pub fn handle_prepare(
&self,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>
) -> impl Future<Output = Result<PromiseFor<I>, PrepareError<I>>>
pub fn handle_prepare(
&self,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>
) -> impl Future<Output = Result<PromiseFor<I>, PrepareError<I>>>
Asks this node to answer a send_prepare sent by another node.
pub fn handle_proposal<E: Into<Arc<LogEntryOf<I>>>>(
&self,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>,
entry: E
) -> impl Future<Output = Result<YeaOf<I>, AcceptError<I>>>
pub fn handle_proposal<E: Into<Arc<LogEntryOf<I>>>>(
&self,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>,
entry: E
) -> impl Future<Output = Result<YeaOf<I>, AcceptError<I>>>
Asks this node to answer a send_proposal sent by another node.
pub fn handle_commit<E: Into<Arc<LogEntryOf<I>>>>(
&self,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>,
entry: E
) -> impl Future<Output = Result<(), CommitError<I>>>
pub fn handle_commit<E: Into<Arc<LogEntryOf<I>>>>(
&self,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>,
entry: E
) -> impl Future<Output = Result<(), CommitError<I>>>
Asks this node to commit the given log entry for the given round number.
pub fn handle_commit_by_id(
&self,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>,
entry_id: LogEntryIdOf<I>
) -> impl Future<Output = Result<(), CommitError<I>>>
pub fn handle_commit_by_id(
&self,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>,
entry_id: LogEntryIdOf<I>
) -> impl Future<Output = Result<(), CommitError<I>>>
Asks this node to answer a send_commit_by_id sent by another node.
Trait Implementations
Auto Trait Implementations
impl<I> !RefUnwindSafe for RequestHandler<I>
impl<I> Send for RequestHandler<I>
impl<I> Sync for RequestHandler<I>
impl<I> Unpin for RequestHandler<I>
impl<I> !UnwindSafe for RequestHandler<I>
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span, returning an
Instrumented wrapper. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more