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

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 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.

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

Creates a new instance of the reactor.

pub fn dispatch_event(
    &mut self,
    effect_builder: EffectBuilder<Self::Event>,
    rng: &mut NodeRng,
    event: Self::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.