nebula.core.network.forwarder#
Classes#
Module Contents#
- class nebula.core.network.forwarder.Forwarder(config, cm)#
- Parameters:
cm (nebula.core.network.communications.CommunicationsManager)
- config#
- cm#
- pending_messages#
- pending_messages_lock#
- interval#
- number_forwarded_messages#
- messages_interval#
- async start()#
- async run_forwarder()#
- async process_pending_messages(messages_left)#
- async forward(msg, addr_from)#