Struct P2pState

pub struct P2pState {
    pub chain_id: ChainId,
    pub config: P2pConfig,
    pub network: P2pNetworkState,
    pub peers: BTreeMap<PeerId, P2pPeerState>,
    pub last_random_disconnection_try: Timestamp,
    pub callbacks: P2pCallbacks,
}

Fields

chain_id: ChainId

config: P2pConfig

network: P2pNetworkState

peers: BTreeMap<PeerId, P2pPeerState>

last_random_disconnection_try: Timestamp

callbacks: P2pCallbacks

Implementations

impl P2pState

pub fn channels_init<Action, State>( &self, dispatcher: &mut Dispatcher<Action, State>, peer_id: PeerId, )

where State: P2pStateTrait, Action: P2pActionTrait<State>,

Initializes enabled channels.

impl P2pState

pub fn incoming_accept( &self, peer_id: PeerId, offer: &Offer, ) -> Result<(), RejectionReason>

pub fn libp2p_incoming_accept( &self, peer_id: PeerId, ) -> Result<(), RejectionReason>

impl P2pState

pub fn identify_reducer<Action, State>( state_context: Substate<'_, Action, State, P2pState>, action: ActionWithMeta<P2pIdentifyAction>, ) -> Result<(), String>

where State: P2pStateTrait, Action: P2pActionTrait<State>,

impl P2pState

pub fn new( config: P2pConfig, callbacks: P2pCallbacks, chain_id: &ChainId, ) -> P2pState

pub fn my_id(&self) -> PeerId

pub fn peer_connection_rpc_id( &self, peer_id: &PeerId, ) -> Option<RequestId<RpcIdType>>

pub fn get_ready_peer(&self, peer_id: &PeerId) -> Option<&P2pPeerStatusReady>

Get peer in ready state. None if peer isn’t in Ready state, or if peer doesn’t exist.

pub fn get_ready_peer_mut( &mut self, peer_id: &PeerId, ) -> Option<&mut P2pPeerStatusReady>

Get peer in ready state. None if peer isn’t in Ready state, or if peer doesn’t exist.

pub fn any_ready_peers(&self) -> bool

pub fn disconnected_peers( &self, ) -> impl Iterator<Item = P2pConnectionOutgoingInitOpts>

pub fn ready_peers_iter( &self, ) -> impl Iterator<Item = (&PeerId, &P2pPeerStatusReady)>

pub fn ready_rpc_peers_iter( &self, ) -> impl Iterator<Item = (&PeerId, &P2pPeerStatusReady)>

pub fn ready_peers(&self) -> Vec<PeerId>

pub fn connected_or_connecting_peers_count(&self) -> usize

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

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

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

pub fn is_peer_rpc_timed_out( &self, peer_id: &PeerId, rpc_id: u64, now: Timestamp, ) -> bool

pub fn is_peer_streaming_rpc_timed_out( &self, peer_id: &PeerId, rpc_id: u64, now: Timestamp, ) -> bool

pub fn peer_rpc_timeouts(&self, now: Timestamp) -> Vec<(PeerId, u64, bool)>

pub fn peer_streaming_rpc_timeouts(&self, now: Timestamp) -> Vec<(PeerId, u64)>

pub fn already_has_min_peers(&self) -> bool

pub fn already_has_max_peers(&self) -> bool

pub fn already_has_max_ready_peers(&self) -> bool

The peers capacity is exceeded.

pub fn min_peers(&self) -> Limit<usize>

Minimal number of peers that the node should connect

pub fn peer_with_connection( &self, conn_id: ConnectionAddr, ) -> Option<(PeerId, &P2pPeerState)>

Peer with libp2p connection identified by conn_id.

pub fn incoming_peer_connection_mut( &mut self, peer_id: &PeerId, ) -> Option<&mut P2pConnectionIncomingState>

pub fn outgoing_peer_connection_mut( &mut self, peer_id: &PeerId, ) -> Option<&mut P2pConnectionOutgoingState>

impl P2pState

pub fn reducer<State, Action>( state_context: Substate<'_, Action, State, P2pState>, action: ActionWithMeta<P2pAction>, ) -> Result<(), String>

where State: P2pStateTrait, Action: P2pActionTrait<State>,

pub fn p2p_timeout_dispatch<State, Action>( state_context: Substate<'_, Action, State, P2pState>, meta: &ActionMeta, ) -> Result<(), String>

where State: P2pStateTrait, Action: P2pActionTrait<State>,

Trait Implementations

impl Clone for P2pState

fn clone(&self) -> P2pState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for P2pState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for P2pState

fn deserialize<__D>( __deserializer: __D, ) -> Result<P2pState, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl EnablingCondition<P2pState> for P2pAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsBestTipAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsEffectfulAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsMessageReceivedAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsRpcAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsSignalingDiscoveryAction

fn is_enabled(&self, state: &P2pState, now: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsSignalingExchangeAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsSnarkAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsSnarkJobCommitmentAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsStreamingRpcAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pChannelsTransactionAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pConnectionAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pConnectionEffectfulAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pConnectionIncomingAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pConnectionIncomingEffectfulAction

fn is_enabled(&self, _: &P2pState, _: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pConnectionOutgoingAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pConnectionOutgoingEffectfulAction

fn is_enabled(&self, _: &P2pState, _: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pDisconnectionAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pDisconnectionEffectfulAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pEffectfulAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pIdentifyAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pInitializeAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkEffectfulAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkIdentifyAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkIdentifyEffectfulAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkIdentifyStreamAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkIdentifyStreamEffectfulAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkKadAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkKadBootstrapAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkKadEffectfulAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkKadRequestAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkKademliaAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkKademliaStreamAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkNoiseAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkPnetAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkPnetEffectfulAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkPubsubAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkPubsubEffectfulAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkRpcAction

fn is_enabled(&self, state: &P2pState, time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkSchedulerAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkSchedulerEffectfulAction

fn is_enabled(&self, _state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkSelectAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pNetworkYamuxAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl EnablingCondition<P2pState> for P2pPeerAction

fn is_enabled(&self, state: &P2pState, _time: Timestamp) -> bool

Enabling condition for the Action.

impl MallocSizeOf for P2pState

fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.

impl Serialize for P2pState

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<S> SubStore<State, P2pState> for Store<S>

where S: Service,

type SubAction = P2pAction

type Service = S

fn state(&self) -> &P2pState

fn service(&mut self) -> &mut Self::Service

fn state_and_service(&mut self) -> (&P2pState, &mut Self::Service)

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

where A: Into<P2pAction> + EnablingCondition<P2pState>,

fn dispatch_callback<T>(&mut self, callback: Callback<T>, args: T) -> bool

where T: 'static, P2pAction: From<AnyAction> + EnablingCondition<P2pState>,

impl SubstateAccess<P2pConfig> for P2pState

fn substate(&self) -> Result<&P2pConfig, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pConfig, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pLimits> for P2pState

fn substate(&self) -> Result<&P2pLimits, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pLimits, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pNetworkIdentifyState> for P2pState

fn substate(&self) -> Result<&P2pNetworkIdentifyState, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pNetworkIdentifyState, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pNetworkKadBootstrapState> for P2pState

fn substate(&self) -> Result<&P2pNetworkKadBootstrapState, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pNetworkKadBootstrapState, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pNetworkKadState> for P2pState

fn substate(&self) -> Result<&P2pNetworkKadState, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pNetworkKadState, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pNetworkPubsubState> for P2pState

fn substate(&self) -> Result<&P2pNetworkPubsubState, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pNetworkPubsubState, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pNetworkSchedulerState> for P2pState

fn substate(&self) -> Result<&P2pNetworkSchedulerState, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pNetworkSchedulerState, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pNetworkState> for P2pState

fn substate(&self) -> Result<&P2pNetworkState, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pNetworkState, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pState> for P2pState

fn substate(&self) -> Result<&P2pState, String>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> Result<&mut P2pState, String>

Attempts to obtain a mutable reference to the substate.

impl SubstateAccess<P2pState> for State

fn substate(&self) -> SubstateResult<&P2pState>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> SubstateResult<&mut P2pState>

Attempts to obtain a mutable reference to the substate.