Class Engine

crates/consensus/engine/src/task_queue/core.rs:41–52

/// retried in-place.
#[derive(Debug)]
pub struct Engine<EngineClient_: EngineClient> {
    /// The state of the engine.
    state: EngineState,
    /// A sender that can be used to notify the engine actor of state changes.
    state_sender: Sender<EngineState>,
    /// A sender that can be used to notify the engine actor of task queue length changes.
    task_queue_length: Sender<usize>,
    /// The task queue.
    tasks: BinaryHeap<(EngineTask<EngineClient_>, Reverse<u64>)>,
    /// Monotonic sequence number used to preserve FIFO order within equal-priority tasks.
    next_task_sequence: u64,
}

impl<EngineClient_: EngineClient> Engine<EngineClient_> {
    /// Creates a new [`Engine`] with an empty task queue and the passed initial [`EngineState`].