Class ConnectionManager

Hierarchy

ConnectionManager

Index

Constructors

Properties

dialAttemptsForPeer dialErrorsForPeer keepAliveManager libp2pComponents onEventHandlers options instances

Methods

dialPeer getTagNamesForPeer run shouldDialPeer startPeerConnectionListener startPeerDisconnectionListener startPeerDiscoveryListener stop create

Constructors

`Private` constructor

new ConnectionManager(libp2pComponents: Libp2p, keepAliveOptions: KeepAliveOptions, relay?: IRelay, options?: Partial<ConnectionManagerOptions>): ConnectionManager
Parameters
- libp2pComponents: Libp2p
- keepAliveOptions: KeepAliveOptions
- Optional relay: IRelay
- Optional options: Partial<ConnectionManagerOptions>
Returns ConnectionManager
- Defined in packages/core/src/lib/connection_manager.ts:45

Properties

`Private` dialAttemptsForPeer

dialAttemptsForPeer: Map<string, number> = ...

`Private` dialErrorsForPeer

dialErrorsForPeer: Map<string, any> = ...

`Private` keepAliveManager

keepAliveManager: KeepAliveManager

`Private` libp2pComponents

libp2pComponents: Libp2p

`Private` onEventHandlers

onEventHandlers: {
    peer:connect: ((evt: CustomEvent<Connection>) => void);
    peer:disconnect: (() => ((evt: CustomEvent<Connection>) => void));
    peer:discovery: ((evt: CustomEvent<PeerInfo>) => Promise<void>);
} = ...

Type declaration

peer:connect: ((evt: CustomEvent<Connection>) => void)
- - (evt: CustomEvent<Connection>): void
  - Parameters
    - evt: CustomEvent<Connection>
    Returns void
peer:disconnect: (() => ((evt: CustomEvent<Connection>) => void))
- - (): ((evt: CustomEvent<Connection>) => void)
  - Returns ((evt: CustomEvent<Connection>) => void)
    - - (evt: CustomEvent<Connection>): void
      - Parameters
        
        evt: CustomEvent<Connection>
        
        Returns void
peer:discovery: ((evt: CustomEvent<PeerInfo>) => Promise<void>)
- - (evt: CustomEvent<PeerInfo>): Promise<void>
  - Parameters
    - evt: CustomEvent<PeerInfo>
    Returns Promise<void>

`Private` options

options: ConnectionManagerOptions

`Static` `Private` instances

instances: Map<string, ConnectionManager> = ...

Methods

`Private` dialPeer

dialPeer(peerId: PeerId): Promise<void>
Parameters
- peerId: PeerId
Returns Promise<void>
- Defined in packages/core/src/lib/connection_manager.ts:88

`Private` getTagNamesForPeer

getTagNamesForPeer(peerId: PeerId): Promise<string[]>
Fetches the tag names for a given peer
Parameters
- peerId: PeerId
Returns Promise<string[]>
- Defined in packages/core/src/lib/connection_manager.ts:223

`Private` run

run(): Promise<void>
Returns Promise<void>
- Defined in packages/core/src/lib/connection_manager.ts:65

`Private` shouldDialPeer

shouldDialPeer(peerId: PeerId): Promise<boolean>
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
Parameters
- peerId: PeerId
Returns Promise<boolean>
- Defined in packages/core/src/lib/connection_manager.ts:196

`Private` startPeerConnectionListener

startPeerConnectionListener(): void
Returns void
- Defined in packages/core/src/lib/connection_manager.ts:141

`Private` startPeerDisconnectionListener

startPeerDisconnectionListener(): void
Returns void
- Defined in packages/core/src/lib/connection_manager.ts:148

`Private` startPeerDiscoveryListener

startPeerDiscoveryListener(): void
Returns void
- Defined in packages/core/src/lib/connection_manager.ts:134

stop

stop(): void
Returns void
- Defined in packages/core/src/lib/connection_manager.ts:72

`Static` create

create(peerId: string, libp2p: Libp2p, keepAliveOptions: KeepAliveOptions, relay?: IRelay, options?: ConnectionManagerOptions): ConnectionManager
Parameters
- peerId: string
- libp2p: Libp2p
- keepAliveOptions: KeepAliveOptions
- Optional relay: IRelay
- Optional options: ConnectionManagerOptions
Returns ConnectionManager
- Defined in packages/core/src/lib/connection_manager.ts:24

Class ConnectionManager

Hierarchy

Index

Constructors

Properties

Methods

Constructors

Private constructor

Parameters

libp2pComponents: Libp2p

keepAliveOptions: KeepAliveOptions

Optional relay: IRelay

Optional options: Partial<ConnectionManagerOptions>

Returns ConnectionManager

Properties

Private dialAttemptsForPeer

Private dialErrorsForPeer

Private keepAliveManager

Private libp2pComponents

Private onEventHandlers

Type declaration

peer:connect: ((evt: CustomEvent<Connection>) => void)

Parameters

evt: CustomEvent<Connection>

Returns void

peer:disconnect: (() => ((evt: CustomEvent<Connection>) => void))

Returns ((evt: CustomEvent<Connection>) => void)

Parameters

evt: CustomEvent<Connection>

Returns void

peer:discovery: ((evt: CustomEvent<PeerInfo>) => Promise<void>)

Parameters

evt: CustomEvent<PeerInfo>

Returns Promise<void>

Private options

Static Private instances

Methods

Private dialPeer

Parameters

peerId: PeerId

Returns Promise<void>

Private getTagNamesForPeer

Parameters

peerId: PeerId

Returns Promise<string[]>

Private run

Returns Promise<void>

Private shouldDialPeer

Parameters

peerId: PeerId

Returns Promise<boolean>

Private startPeerConnectionListener

Returns void

Private startPeerDisconnectionListener

Returns void

Private startPeerDiscoveryListener

Returns void

stop

Returns void

Static create

Parameters

peerId: string

libp2p: Libp2p

keepAliveOptions: KeepAliveOptions

Optional relay: IRelay

Optional options: ConnectionManagerOptions

Returns ConnectionManager

Settings

Member Visibility

Theme

`Private` constructor

`Optional` relay: IRelay

`Optional` options: Partial<ConnectionManagerOptions>

`Private` dialAttemptsForPeer

`Private` dialErrorsForPeer

`Private` keepAliveManager

`Private` libp2pComponents

`Private` onEventHandlers

`Private` options

`Static` `Private` instances

`Private` dialPeer

`Private` getTagNamesForPeer

`Private` run

`Private` shouldDialPeer

`Private` startPeerConnectionListener

`Private` startPeerDisconnectionListener

`Private` startPeerDiscoveryListener

`Static` create

`Optional` relay: IRelay

`Optional` options: ConnectionManagerOptions