Trait paxakos::leadership::ensure::Config

pub trait Config {
    type Node: Node;
    type Applicable: ApplicableTo<StateOf<Self::Node>> + 'static;
    type RetryPolicy: RetryPolicy<Invocation = InvocationOf<Self::Node>, Error = AppendError<InvocationOf<Self::Node>>, StaticError = AppendError<InvocationOf<Self::Node>>>;

    fn new_leadership_taker(&self) -> Self::Applicable;
    fn retry_policy(&self) -> Self::RetryPolicy;

    fn init(&mut self, node: &Self::Node) { ... }
    fn update(&mut self, event: &EventFor<Self::Node>) { ... }
    fn interval(&self) -> Option<Duration> { ... }
}

Ensure leadership configuration.

Required Associated Types

type Node: Node

The node type that is decorated.

type Applicable: ApplicableTo<StateOf<Self::Node>> + 'static

The applicable that is used to take leadership, usually a no-op.

type RetryPolicy: RetryPolicy<Invocation = InvocationOf<Self::Node>, Error = AppendError<InvocationOf<Self::Node>>, StaticError = AppendError<InvocationOf<Self::Node>>>

Type of retry policy to be used.

See retry_policy.

Required Methods

fn new_leadership_taker(&self) -> Self::Applicable

Creates a new value to take leadership.

fn retry_policy(&self) -> Self::RetryPolicy

Creates a retry policy.

Provided Methods

fn init(&mut self, node: &Self::Node)

Initializes this configuration.

fn update(&mut self, event: &EventFor<Self::Node>)

Updates the configuration with the given event.

fn interval(&self) -> Option<Duration>

Interval after which leadership is taken.

Implementors