Struct casper_node::reactor::joiner::Reactor

pub struct Reactor { /* fields omitted */ }

Joining node reactor.

Implementations

impl Reactor

pub async fn into_validator_config(self) -> ValidatorInitConfig

Deconstructs the reactor into config useful for creating a Validator reactor. Shuts down the network, closing all incoming and outgoing connections, and frees up the listening socket.

Trait Implementations

impl DataSize for Reactor

const IS_DYNAMIC: bool

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

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.

fn estimate_heap_size(&self) -> usize

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

impl Reactor for Reactor

type Event = Event

Event type associated with reactor.

type Config = WithDir<Reactor>

A configuration for the reactor

type Error = Error

The error type returned by the reactor.

fn new(
    initializer: Self::Config,
    registry: &Registry,
    event_queue: EventQueueHandle<Self::Event>,
    rng: &mut dyn CryptoRngCore
) -> Result<(Self, Effects<Self::Event>), Self::Error>

Creates a new instance of the reactor.

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

Dispatches an event on the reactor.

fn is_stopped(&mut self) -> bool

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

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

Instructs the reactor to update performance metrics, if any.