Struct NetworkManager 

pub struct NetworkManager { /* private fields */ }

Implementations

impl NetworkManager

pub async fn new( config: &NetworkConfig, event_dispatcher: Arc<dyn NetworkEventDispatcher>, prom_registry: &mut Registry, ) -> Result<Self>

Create a new NetworkManager with an event dispatcher.

The dispatcher receives all network events (gossipsub messages, streams, etc.) and must implement NetworkEventDispatcher for reliable delivery.

Trait Implementations

impl Actor for NetworkManager

type Context = Context<NetworkManager>

Actor execution context type

fn start(self) -> Addr<Self>

Start a new asynchronous actor, returning its address.

fn create<F>(f: F) -> Addr<Self>

where F: FnOnce(&mut Context<Self>) -> Self,

Start a new asynchronous actor given a Context.

fn start_in_arbiter<F>(wrk: &ArbiterHandle, f: F) -> Addr<Self>

where F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,

Start new actor in arbiter’s thread.

fn started(&mut self, ctx: &mut Context<Self>)

Called when an actor gets polled the first time.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn stopped(&mut self, ctx: &mut Self::Context)

Called after an actor is stopped.

impl ActorSpawn for NetworkManager

fn spawn(self, ctx: Self::Context)

impl Handler<AnnounceBlob> for NetworkManager

type Result = Response<<AnnounceBlob as Message>::Result>

The type of value that this handler will return.

fn handle( &mut self, request: AnnounceBlob, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<Bootstrap> for NetworkManager

type Result = Response<<Bootstrap as Message>::Result>

The type of value that this handler will return.

fn handle(&mut self, _msg: Bootstrap, _ctx: &mut Context<Self>) -> Self::Result

This method is called for every message received by this actor.

impl Handler<Dial> for NetworkManager

type Result = Response<<Dial as Message>::Result>

The type of value that this handler will return.

fn handle(&mut self, Dial: Dial, _ctx: &mut Context<Self>) -> Self::Result

This method is called for every message received by this actor.

impl<T> Handler<FromStreamInner<T>> for NetworkManager

where Self: StreamHandler<T>,

type Result = ()

The type of value that this handler will return.

fn handle( &mut self, msg: FromStreamInner<T>, ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<ListenOn> for NetworkManager

type Result = <ListenOn as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, ListenOn: ListenOn, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<MeshPeerCount> for NetworkManager

type Result = <MeshPeerCount as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, MeshPeerCount: MeshPeerCount, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<MeshPeers> for NetworkManager

type Result = <MeshPeers as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, MeshPeers: MeshPeers, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<NetworkMessage> for NetworkManager

type Result = ()

The type of value that this handler will return.

fn handle( &mut self, msg: NetworkMessage, ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<OpenStream> for NetworkManager

type Result = Pin<Box<dyn Future<Output = <OpenStream as Message>::Result>>>

The type of value that this handler will return.

fn handle( &mut self, OpenStream: OpenStream, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<PeerCount> for NetworkManager

type Result = <PeerCount as Message>::Result

The type of value that this handler will return.

fn handle(&mut self, _msg: PeerCount, _ctx: &mut Context<Self>) -> usize

This method is called for every message received by this actor.

impl Handler<Publish> for NetworkManager

type Result = <Publish as Message>::Result

The type of value that this handler will return.

fn handle(&mut self, _: Publish, _ctx: &mut Context<Self>) -> Self::Result

This method is called for every message received by this actor.

impl Handler<QueryBlob> for NetworkManager

type Result = Pin<Box<dyn Future<Output = <QueryBlob as Message>::Result>>>

The type of value that this handler will return.

fn handle( &mut self, request: QueryBlob, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<RequestBlob> for NetworkManager

type Result = Pin<Box<dyn Future<Output = <RequestBlob as Message>::Result>>>

The type of value that this handler will return.

fn handle( &mut self, request: RequestBlob, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<SendSpecializedNodeInvitationResponse> for NetworkManager

type Result = <SendSpecializedNodeInvitationResponse as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, _: SendSpecializedNodeInvitationResponse, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<SendSpecializedNodeVerificationRequest> for NetworkManager

type Result = <SendSpecializedNodeVerificationRequest as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, _: SendSpecializedNodeVerificationRequest, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<Subscribe> for NetworkManager

type Result = <Subscribe as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, Subscribe: Subscribe, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<Unsubscribe> for NetworkManager

type Result = <Unsubscribe as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, Unsubscribe: Unsubscribe, _ctx: &mut Context<Self>, ) -> Self::Result

This method is called for every message received by this actor.