Struct paxakos::leadership::ensure::EnsureLeadership

pub struct EnsureLeadership<N, C> where
    N: Node,
    C: Config,  { /* private fields */ }

Trait Implementations

impl<N: Debug, C: Debug> Debug for EnsureLeadership<N, C> where
    N: Node,
    C: Config, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<N, C> Decoration for EnsureLeadership<N, C> where
    N: NodeImpl + 'static,
    C: Config<Node = N> + 'static, 

type Arguments = C

Arguments this decoration requires.

type Decorated = N

Type of the decorated node.

fn wrap(
    decorated: Self::Decorated,
    arguments: Self::Arguments
) -> Result<Self, Box<dyn Error + Send + Sync + 'static>>

Wraps this decoration around the given node, using the given arguments.

fn peek_into(decorated: &Self) -> &Self::Decorated

Returns a reference to the decorated node.

fn unwrap(decorated: Self) -> Self::Decorated

Unwraps this decoration.

impl<N, C> DelegatingNodeImpl for EnsureLeadership<N, C> where
    N: NodeImpl + 'static,
    C: Config<Node = N>, 

type Delegate = N

Type of node that’s delegated to.

fn delegate(&self) -> &Self::Delegate

Returns a reference to the node that’s delegated to.

impl<N, C> Node for EnsureLeadership<N, C> where
    N: Node + 'static,
    C: Config<Node = N>, 

type Invocation = <N as Node>::Invocation

Parametrization of the paxakos algorithm.

type Shutdown = <N as Node>::Shutdown

Type that will perform graceful shutdown if requsted.

fn id(&self) -> NodeIdOf<Self>

This node’s identifier.

fn status(&self) -> NodeStatus

Node’s current status.

fn participation(&self) -> Participation<RoundNumOf<Self>>

Node’s current mode of participation.

fn poll_events(&mut self, cx: &mut Context<'_>) -> Poll<EventFor<Self>>

Polls the node’s event stream.

fn handle(&self) -> HandleFor<Self>

Returns a handle for this node.

fn prepare_snapshot(&self) -> LocalBoxFuture<'static, SnapshotFor<Self>>

Requests that snapshot of the node’s current state be taken.

fn affirm_snapshot(
    &self,
    snapshot: SnapshotFor<Self>
) -> LocalBoxFuture<'static, Result<(), AffirmSnapshotError>>

Affirms that the given snapshot was written to persistent storage.

fn install_snapshot(
    &self,
    snapshot: SnapshotFor<Self>
) -> LocalBoxFuture<'static, Result<(), InstallSnapshotError>>

Requests that the given snapshot be installed.

fn read_stale<F, T>(&self, f: F) -> LocalBoxFuture<'_, Result<T, Disoriented>> where
    F: FnOnce(&StateOf<Self>) -> T + Send + 'static,
    T: Send + 'static, 

Reads the node’s current state.

fn append<A, P, R>(
    &self,
    applicable: A,
    args: P
) -> LocalBoxFuture<'_, AppendResultFor<Self, A, R>> where
    A: ApplicableTo<StateOf<Self>> + 'static,
    P: Into<AppendArgs<Self::Invocation, R>>,
    R: RetryPolicy<Invocation = Self::Invocation>, 

Appends applicable to the shared log.

fn append_static<A, P, R>(
    &self,
    applicable: A,
    args: P
) -> LocalBoxFuture<'static, StaticAppendResultFor<Self, A, R>> where
    A: ApplicableTo<StateOf<Self>> + 'static,
    P: Into<AppendArgs<Self::Invocation, R>>,
    R: RetryPolicy<Invocation = Self::Invocation>,
    R::StaticError: From<ShutDownOr<R::Error>>, 

Appends applicable to the shared log.

fn shut_down(self) -> Self::Shutdown

Begins a graceful shutdown of this node.

fn next_event(&mut self) -> NextEvent<'_, Self>

Returns a future that polls this node for events until the next one is returned.