Struct FuelP2PService

pub struct FuelP2PService {
    pub local_peer_id: PeerId,
    /* private fields */
}

Listens to the events on the p2p network And forwards them to the Orchestrator

Fields

local_peer_id: PeerId

Store the local peer id

Implementations

impl FuelP2PService

pub async fn new( reserved_peers_updates: Sender<usize>, config: Config, codec: PostcardCodec, ) -> Result<Self>

pub async fn start(&mut self) -> Result<()>

pub fn update_metrics<T>(&self, update_fn: T)

where T: FnOnce(),

pub fn update_libp2p_metrics<E>(&self, event: &E)

where Metrics: Recorder<E>,

pub fn get_peers_ids_iter(&self) -> impl Iterator<Item = &PeerId>

pub fn publish_message( &mut self, message: GossipsubBroadcastRequest, ) -> Result<MessageId, PublishError>

pub fn send_request_msg( &mut self, peer_id: Option<PeerId>, message_request: RequestMessage, on_response: ResponseSender, ) -> Result<OutboundRequestId, RequestError>

Sends RequestMessage to a peer If the peer is not defined it will pick one at random Only returns error if no peers are connected

pub fn send_response_msg( &mut self, request_id: InboundRequestId, message: ResponseMessage, ) -> Result<(), ResponseSendError>

Sends ResponseMessage to a peer that requested the data

pub fn update_block_height(&mut self, block_height: BlockHeight)

pub fn report_message_validation_result( &mut self, msg_id: &MessageId, propagation_source: PeerId, acceptance: MessageAcceptance, )

The report is forwarded to gossipsub behaviour If acceptance is “Rejected” the gossipsub peer score is calculated And if it’s below allowed threshold the peer is banned

pub fn report_peer( &mut self, peer_id: PeerId, app_score: AppScore, reporting_service: &str, )

Report application score If application peer score is below allowed threshold the peer is banned

pub async fn next_event(&mut self) -> Option<FuelP2PEvent>

Handles P2P Events. Returns only events that are of interest to the Network Orchestrator.

pub fn peer_manager(&self) -> &PeerManager

Trait Implementations

impl TaskP2PService for FuelP2PService

fn update_metrics<T>(&self, update_fn: T)

where T: FnOnce(),

fn get_all_peer_info(&self) -> Vec<(&PeerId, &PeerInfo)>

fn get_peer_id_with_height(&self, height: &BlockHeight) -> Option<PeerId>

fn next_event(&mut self) -> BoxFuture<'_, Option<FuelP2PEvent>>

fn publish_message(&mut self, message: GossipsubBroadcastRequest) -> Result<()>

fn send_request_msg( &mut self, peer_id: Option<PeerId>, request_msg: RequestMessage, on_response: ResponseSender, ) -> Result<()>

fn send_response_msg( &mut self, request_id: InboundRequestId, message: ResponseMessage, ) -> Result<()>

fn report_message( &mut self, message: GossipsubMessageInfo, acceptance: GossipsubMessageAcceptance, ) -> Result<()>

fn report_peer( &mut self, peer_id: PeerId, score: AppScore, reporting_service: &str, ) -> Result<()>

fn update_block_height(&mut self, height: BlockHeight) -> Result<()>