Struct casper_node::reactor::initializer::Reactor

pub struct Reactor { /* fields omitted */ }

Initializer node reactor.

Implementations

impl Reactor

pub fn stopped_successfully(&self) -> bool

Returns whether the initialization process completed successfully or not.

Trait Implementations

impl DataSize for Reactor

pub const IS_DYNAMIC: bool

If true, the type has a heap size that can vary at runtime, depending on the actual value.

pub const STATIC_HEAP_SIZE: usize

The amount of space a value of the type always occupies. If IS_DYNAMIC is false, this is the total amount of heap memory occupied by the value. Otherwise this is a lower bound.

pub fn estimate_heap_size(&self) -> usize

Estimates the size of heap memory taken up by this value.

impl Debug for Reactor

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

Formats the value using the given formatter.

impl Reactor for Reactor

type Event = Event

Event type associated with reactor.

type Config = WithDir<Config>

A configuration for the reactor

type Error = Error

The error type returned by the reactor.

pub fn new(
    config: Self::Config,
    registry: &Registry,
    event_queue: EventQueueHandle<Self::Event>,
    _rng: &mut NodeRng
) -> Result<(Self, Effects<Self::Event>), Error>

Creates a new instance of the reactor.

pub fn dispatch_event(
    &mut self,
    effect_builder: EffectBuilder<Self::Event>,
    rng: &mut NodeRng,
    event: Event
) -> Effects<Self::Event>

Dispatches an event on the reactor.

pub fn is_stopped(&mut self) -> bool

Indicates that the reactor has completed all its work and should no longer dispatch events.

pub fn update_metrics(
    &mut self,
    _event_queue_handle: EventQueueHandle<Self::Event>
)

Instructs the reactor to update performance metrics, if any.