Struct fluvio_future::doomsday::DoomsdayTimer

pub struct DoomsdayTimer { /* private fields */ }

DoomsdayTimer will configurably panic or exit if it is not reset() at least every duration

Implementations

impl DoomsdayTimer

pub fn spawn( duration: Duration, exit_on_explode: bool, ) -> (Self, JoinHandle<()>)

Spawn a new doomsday timer. If exit_on_explode is true, it will terminate process with exit(1) if it explodes. Otherwise it will call panic(). Note that awaiting on the jh will panic if the DoomsdayTimer panicked

pub async fn reset(&self)

Reset the timer to it’s full duration

pub fn explode(&self)

Force the timer to explode

pub fn defuse(&self)

Defuse the timer. Cannot be undone and will no longer explode

Trait Implementations

impl Clone for DoomsdayTimer

fn clone(&self) -> DoomsdayTimer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Display for DoomsdayTimer

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

Formats the value using the given formatter.