Struct paxakos::heartbeats::StaticConfig

pub struct StaticConfig<N, A> { /* private fields */ }

A static configuration.

Implementations

impl<N, A> StaticConfig<N, A>where
    N: Node,
    A: ApplicableTo<StateOf<N>> + Default + 'static,

pub fn with_interval(interval: Duration) -> Self

Constructs a new configuratin with the given interval.

pub fn when_leading(self, leader_interval: Duration) -> Self

Sets the interval at which leader nodes send heartbeats.

Trait Implementations

impl<N, A> Config for StaticConfig<N, A>where
    N: Node,
    A: ApplicableTo<StateOf<N>> + Default + 'static,

type Node = N

The node type that is decorated.

type Applicable = A

The applicable that is used to fill gaps, usually a no-op.

type RetryPolicy = DoNotRetry<<N as Node>::Invocation>

Type of retry policy to be used.

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

Interval at which leader nodes send heartbeats.

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

Interval at which heartbeats are sent.

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

Creates a new heartbeat value.

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

Creates a retry policy.

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.