Class PeerSet

Manages operational connections to peers on shared fabric.

Implements

Index

Constructors

Accessors

added construction deleted peers size

Methods

[iterator] close connect delete disconnect filter find get has initializeInteractionClient map [create]

Constructors

constructor

new PeerSet(context): PeerSet
Parameters
- context: PeerSetContext
Returns PeerSet
- Defined in packages/protocol/src/peer/PeerSet.ts:123

Accessors

added

get added(): Observable<[OperationalPeer], void>
Returns Observable<[OperationalPeer], void>
Implementation of ObservableSet.added
- Defined in packages/protocol/src/peer/PeerSet.ts:159

construction

get construction(): Construction<PeerSet>
Returns Construction<PeerSet>
- Defined in packages/protocol/src/peer/PeerSet.ts:194

deleted

get deleted(): Observable<[OperationalPeer], void>
Returns Observable<[OperationalPeer], void>
Implementation of ObservableSet.deleted
- Defined in packages/protocol/src/peer/PeerSet.ts:163

peers

get peers(): BasicSet<OperationalPeer, OperationalPeer>
Returns BasicSet<OperationalPeer, OperationalPeer>
- Defined in packages/protocol/src/peer/PeerSet.ts:211

size

get size(): number
Returns number
Implementation of ImmutableSet.size
- Defined in packages/protocol/src/peer/PeerSet.ts:174

Methods

[iterator]

[iterator](): SetIterator<OperationalPeer>
Returns SetIterator<OperationalPeer>
Implementation of ImmutableSet.[iterator]
- Defined in packages/protocol/src/peer/PeerSet.ts:190

close

close(): Promise<void>
Returns Promise<void>
- Defined in packages/protocol/src/peer/PeerSet.ts:358

connect

connect(address, discoveryOptions, allowUnknownPeer?): Promise<InteractionClient>
Connect to a node on a fabric.
Parameters
- address: PeerAddress
- discoveryOptions: DiscoveryOptions
- allowUnknownPeer: boolean = false
Returns Promise<InteractionClient>
- Defined in packages/protocol/src/peer/PeerSet.ts:218

delete

delete(peer): Promise<void>
Forget a known peer.
Parameters
- peer: PeerAddress | OperationalPeer
Returns Promise<void>
- Defined in packages/protocol/src/peer/PeerSet.ts:343

disconnect

disconnect(peer): Promise<void>
Terminate any active peer connection.
Parameters
- peer: PeerAddress | OperationalPeer
Returns Promise<void>
- Defined in packages/protocol/src/peer/PeerSet.ts:329

filter

filter(predicate): OperationalPeer[]
Parameters
- predicate: ((item: OperationalPeer) => undefined | boolean)
  - - (item): undefined | boolean
    - Parameters
      item: OperationalPeer
      Returns undefined | boolean
Returns OperationalPeer[]
Implementation of ImmutableSet.filter
- Defined in packages/protocol/src/peer/PeerSet.ts:182

find

find(predicate): undefined | OperationalPeer
Parameters
- predicate: ((item: OperationalPeer) => undefined | boolean)
  - - (item): undefined | boolean
    - Parameters
      item: OperationalPeer
      Returns undefined | boolean
Returns undefined | OperationalPeer
Implementation of ImmutableSet.find
- Defined in packages/protocol/src/peer/PeerSet.ts:178

get

get(peer): undefined | OperationalPeer
Retrieve a peer by address.
Parameters
- peer: PeerAddress | OperationalPeer
Returns undefined | OperationalPeer
- Defined in packages/protocol/src/peer/PeerSet.ts:319

has

has(item): boolean
Parameters
- item: PeerAddress | OperationalPeer
Returns boolean
Implementation of ImmutableSet.has
- Defined in packages/protocol/src/peer/PeerSet.ts:167

initializeInteractionClient

initializeInteractionClient(address, discoveryOptions?): Promise<InteractionClient>
Parameters
- address: PeerAddress
- OptionaldiscoveryOptions: DiscoveryOptions
Returns Promise<InteractionClient>
- Defined in packages/protocol/src/peer/PeerSet.ts:258

map

map<T>(mapper): T[]
Type Parameters
- T
Parameters
- mapper: ((item: OperationalPeer) => T)
  - - (item): T
    - Parameters
      item: OperationalPeer
      Returns T
Returns T[]
- Defined in packages/protocol/src/peer/PeerSet.ts:186

`Static`[create]

[create](env): PeerSet
Parameters
- env: Environment
Returns PeerSet
- Defined in packages/protocol/src/peer/PeerSet.ts:198