Struct rings_core::dht::Stabilizer

pub struct Stabilizer { /* private fields */ }

The stabilization runner.

Implementations

impl Stabilizer

pub async fn wait(self: Arc<Self>, interval: Duration)

Run stabilization in a loop.

impl Stabilizer

pub fn new(transport: Arc<SwarmTransport>) -> Self

Create a new stabilization runner.

pub async fn stabilize(&self) -> Result<()>

Run stabilization once.

pub async fn clean_unavailable_connections(&self) -> Result<()>

Clean unavailable connections in transport.

pub async fn notify_predecessor(&self) -> Result<()>

Notify predecessor, this is a DHT operation.

pub async fn correct_stabilize(&self) -> Result<()>

Call stabilization from correct chord implementation

Trait Implementations

impl Clone for Stabilizer

fn clone(&self) -> Stabilizer

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.