pub trait EventManager<E, Z>: EventFirer + EventProcessor<E, Z> + EventRestarter + HasEventManagerId + ProgressReporter{ }
Expand description

EventManager is the main communications hub. For the “normal” multi-processed mode, you may want to look into LlmpRestartingEventManager

Object Safety§

This trait is not object safe.

Implementors§

source§

impl EventManager<PythonExecutor, StdFuzzer<QueueScheduler<StdState<BytesInput, PythonCorpus, PythonRand, PythonCorpus>>, PythonFeedback, PythonFeedback, PythonObserversTuple>> for PythonEventManager

source§

impl<E, EM, SP, Z> EventManager<E, Z> for CentralizedEventManager<EM, SP>
where EM: EventStatsCollector + EventManager<E, Z>, EM::State: HasExecutions + HasMetadata + HasLastReportTime, E: HasObservers<State = Self::State> + Executor<Self, Z>, for<'a> E::Observers: Deserialize<'a>, Z: EvaluatorObservers<E::Observers, State = Self::State> + ExecutionProcessor<E::Observers, State = Self::State>, SP: ShMemProvider + 'static,

source§

impl<E, MT, S, SP, Z> EventManager<E, Z> for SimpleRestartingEventManager<MT, S, SP>

source§

impl<E, MT, S, Z> EventManager<E, Z> for SimpleEventManager<MT, S>

source§

impl<E, S, SP, Z> EventManager<E, Z> for LlmpEventManager<S, SP>
where E: HasObservers<State = S> + Executor<Self, Z>, for<'a> E::Observers: Deserialize<'a>, S: State + HasExecutions + HasMetadata + HasLastReportTime, SP: ShMemProvider, Z: EvaluatorObservers<E::Observers, State = S> + ExecutionProcessor<E::Observers, State = S>,

source§

impl<E, S, SP, Z> EventManager<E, Z> for LlmpRestartingEventManager<S, SP>
where E: HasObservers<State = S> + Executor<LlmpEventManager<S, SP>, Z>, for<'a> E::Observers: Deserialize<'a>, S: State + HasExecutions + HasMetadata + HasLastReportTime, SP: ShMemProvider + 'static, Z: EvaluatorObservers<E::Observers, State = S> + ExecutionProcessor<E::Observers>,

source§

impl<E, S, SP, Z> EventManager<E, Z> for TcpRestartingEventManager<S, SP>

source§

impl<E, S, Z> EventManager<E, Z> for NopEventManager<S>

source§

impl<E, S, Z> EventManager<E, Z> for TcpEventManager<S>
where E: HasObservers<State = S> + Executor<Self, Z>, for<'a> E::Observers: Deserialize<'a>, S: State + HasExecutions + HasMetadata + HasLastReportTime, Z: EvaluatorObservers<E::Observers, State = S> + ExecutionProcessor<E::Observers, State = S>,