Struct DynamicSupervisorState 

pub struct DynamicSupervisorState {
    pub child_failure_state: HashMap<String, ChildFailureState>,
    pub restart_log: Vec<RestartLog>,
    pub options: DynamicSupervisorOptions,
    pub active_children: HashMap<String, ActiveChild>,
}

Fields

child_failure_state: HashMap<String, ChildFailureState>

restart_log: Vec<RestartLog>

options: DynamicSupervisorOptions

active_children: HashMap<String, ActiveChild>

Trait Implementations

impl Clone for DynamicSupervisorState

fn clone(&self) -> DynamicSupervisorState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DynamicSupervisorState

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

Formats the value using the given formatter.

impl SupervisorCore for DynamicSupervisorState

type Message = DynamicSupervisorMsg

type Options = DynamicSupervisorOptions

type Strategy = ()

fn child_failure_state(&mut self) -> &mut HashMap<String, ChildFailureState>

fn restart_log(&mut self) -> &mut Vec<RestartLog>

fn options(&self) -> &DynamicSupervisorOptions

fn restart_msg( &self, child_spec: &ChildSpec, _strategy: (), _myself: ActorRef<Self::Message>, ) -> Self::Message

fn prepare_child_failure( &mut self, child_spec: &ChildSpec, ) -> Result<(), ActorProcessingErr>

Increments the failure count for a given child.
Resets the child’s restart_count to 0 if the time since last fail >= child’s reset_after duration.

fn handle_child_exit( &mut self, child_spec: &ChildSpec, abnormal: bool, ) -> Result<bool, ActorProcessingErr>

Called when a child terminates or fails.

fn handle_child_restart( &mut self, child_spec: &ChildSpec, abnormal: bool, myself: ActorRef<Self::Message>, reason: &ExitReason, ) -> Result<(), ActorProcessingErr>

Called when a child exits abnormally or normally.

fn track_global_restart( &mut self, child_id: &str, ) -> Result<(), ActorProcessingErr>

Updates meltdown log and checks meltdown thresholds.

fn schedule_restart( &mut self, child_spec: &ChildSpec, strategy: Self::Strategy, myself: ActorRef<Self::Message>, ) -> Result<(), ActorProcessingErr>

Schedule a future spawn for a child, respecting any child-level backoff_fn.