Class ConnectionManager

Hierarchy

Implements

Constructors

constructor

Properties

#private attemptDial configuredPubSubTopics currentActiveParallelDialCount dialAttemptsForPeer dialErrorsForPeer dialPeer dialPeerStorePeers dispatchDiscoveryEvent dropConnection getPeerShardInfo getTagNamesForPeer isPeerDialableBasedOnBootstrapStatus isPeerTopicConfigured keepAliveManager libp2p onEventHandlers options pendingPeerDialQueue processDialQueue run shouldDialPeer startPeerConnectionListener startPeerDisconnectionListener startPeerDiscoveryListener instances

Methods

addEventListener dispatchEvent getPeersByDiscovery listenerCount removeEventListener safeDispatchEvent stop create

Constructors

Private constructor

Properties

Private #private

#private: any

Private attemptDial

attemptDial: any

Private configuredPubSubTopics

configuredPubSubTopics: any

Private currentActiveParallelDialCount

currentActiveParallelDialCount: any

Private dialAttemptsForPeer

dialAttemptsForPeer: any

Private dialErrorsForPeer

dialErrorsForPeer: any

Private dialPeer

dialPeer: any

Private dialPeerStorePeers

dialPeerStorePeers: any

Private dispatchDiscoveryEvent

dispatchDiscoveryEvent: any

Private dropConnection

dropConnection: any

Private getPeerShardInfo

getPeerShardInfo: any

Private getTagNamesForPeer

getTagNamesForPeer: any

Fetches the tag names for a given peer

Private isPeerDialableBasedOnBootstrapStatus

isPeerDialableBasedOnBootstrapStatus: any

Checks if the peer is dialable based on the following conditions:

  1. If the peer is a bootstrap peer, it is only dialable if the number of current bootstrap connections is less than the max allowed.
  2. If the peer is not a bootstrap peer

Private isPeerTopicConfigured

isPeerTopicConfigured: any

Private keepAliveManager

keepAliveManager: any

Private libp2p

libp2p: any

Private onEventHandlers

onEventHandlers: any

Private options

options: any

Private pendingPeerDialQueue

pendingPeerDialQueue: any

Private processDialQueue

processDialQueue: any

Private run

run: any

Private shouldDialPeer

shouldDialPeer: any

Checks if the peer should be dialed based on the following conditions:

  1. If the peer is already connected, don't dial
  2. If the peer is not part of any of the configured pubsub topics, don't dial
  3. If the peer is not dialable based on bootstrap status, don't dial
  4. If the peer is already has an active dial attempt, or has been dialed before, don't dial it

Returns

true if the peer should be dialed, false otherwise

Private startPeerConnectionListener

startPeerConnectionListener: any

Private startPeerDisconnectionListener

startPeerDisconnectionListener: any

Private startPeerDiscoveryListener

startPeerDiscoveryListener: any

Private Static instances

instances: any

Methods

addEventListener

  • Type Parameters

    Parameters

    • type: K
    • listener: null | EventHandler<IPeersByDiscoveryEvents[K]>
    • Optional options: boolean | AddEventListenerOptions

    Returns void

dispatchEvent

  • Parameters

    • event: Event

    Returns boolean

getPeersByDiscovery

listenerCount

  • Parameters

    • type: string

    Returns number

removeEventListener

  • Type Parameters

    Parameters

    • type: K
    • Optional listener: null | EventHandler<IPeersByDiscoveryEvents[K]>
    • Optional options: boolean | EventListenerOptions

    Returns void

safeDispatchEvent

  • Type Parameters

    • Detail

    Parameters

    Returns boolean

stop

  • Returns void

Static create

Settings

Member Visibility

Theme

On This Page

Generated using TypeDoc