Struct Node 

pub struct Node {
    work_dir: TempDir,
    config: RustNodeTestingConfig,
    store: Store<NodeTestingService>,
}

Fields

work_dir: TempDir

config: RustNodeTestingConfig

store: Store<NodeTestingService>

Implementations

impl Node

pub fn new( work_dir: TempDir, config: RustNodeTestingConfig, store: Store<NodeTestingService>, ) -> Self

pub fn work_dir(&self) -> &TempDir

pub fn config(&self) -> &RustNodeTestingConfig

pub fn service(&self) -> &NodeTestingService

fn service_mut(&mut self) -> &mut NodeTestingService

pub fn set_dyn_effects(&mut self, effects: DynEffects)

pub fn remove_dyn_effects(&mut self) -> Option<DynEffects>

pub fn dial_addr(&self) -> P2pConnectionOutgoingInitOpts

pub fn state(&self) -> &State

pub fn node_id(&self) -> ClusterNodeId

pub fn peer_id(&self) -> PeerId

pub fn pending_events( &mut self, poll: bool, ) -> impl Iterator<Item = (PendingEventId, &Event)>

pub fn pending_events_with_state( &mut self, poll: bool, ) -> (&State, impl Iterator<Item = (PendingEventId, &Event)>)

fn dispatch<T>(&mut self, action: T) -> bool

where T: Into<Action> + EnablingCondition<State>,

pub fn dispatch_event(&mut self, event: Event) -> bool

pub fn get_pending_event(&self, event_id: PendingEventId) -> Option<&Event>

pub fn take_pending_event(&mut self, event_id: PendingEventId) -> Option<Event>

pub fn take_event_and_dispatch(&mut self, event_id: PendingEventId) -> bool

pub fn check_timeouts(&mut self)

pub fn advance_time(&mut self, by_nanos: u64)

pub async fn wait_for_next_pending_event( &mut self, ) -> Option<(PendingEventId, &Event)>

pub async fn wait_for_event( &mut self, event_pattern: &str, ) -> Option<PendingEventId>

pub async fn wait_for_event_and_dispatch(&mut self, event_pattern: &str) -> bool

pub fn p2p_disconnect(&mut self, peer_id: PeerId) -> bool