Struct SimulatedSignalPlane 

pub struct SimulatedSignalPlane { /* private fields */ }

Deterministic in-process signal plane for seam tests and future consumers.

Implementations

impl SimulatedSignalPlane

pub fn new(members: Vec<String>) -> SimulatedSignalPlane

pub fn schedule_mut(&mut self) -> &mut SignalPlaneSchedule

pub fn round(&self) -> u64

pub fn advance_round(&mut self)

Advance one deterministic gossip round.

pub fn members_with_signal(&self, message: &SignalPlaneMessage) -> Vec<String>

Members whose local simulated peer has learned message.

Trait Implementations

impl Debug for SimulatedSignalPlane

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

Formats the value using the given formatter.

impl Default for SimulatedSignalPlane

fn default() -> SimulatedSignalPlane

Returns the “default value” for a type.

impl SignalPlane for SimulatedSignalPlane

fn set_members(&mut self, members: Vec<String>)

Replace the admitted-member set this signal plane may talk to.

fn publish(&mut self, from: String, message: SignalPlaneMessage)

Publish a non-authoritative signal from an admitted member.

fn drain_received(&mut self, member: &String) -> Vec<ReceivedSignal>

Drain signals delivered to member.