libp2p/dial

Search:
Group by:
Source   Edit  

Types

Dial = ref object of RootObj
Source   Edit  
DialFailedError = object of LPError
Source   Edit  

Methods

method addTransport(self: Dial; transport: Transport) {.base, ...raises: [],
    tags: [], forbids: [].}
Source   Edit  
method connect(self: Dial; address: MultiAddress; allowUnknownPeerId = false): InternalRaisesFuture[
    PeerId, (DialFailedError, CancelledError)] {.base, ...stackTrace: false,
    raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
Connects to a peer and retrieve its PeerId Source   Edit  
method connect(self: Dial; peerId: PeerId; addrs: seq[MultiAddress];
               forceDial = false; reuseConnection = true; dir = Direction.Out): InternalRaisesFuture[
    void, (DialFailedError, CancelledError)] {.base, ...stackTrace: false,
    raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
connect remote peer without negotiating a protocol Source   Edit  
method dial(self: Dial; peerId: PeerId; addrs: seq[MultiAddress];
            protos: seq[string]; forceDial = false): InternalRaisesFuture[
    Connection, (DialFailedError, CancelledError)] {.base, ...stackTrace: false,
    raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
create a protocol stream and establish a connection if one doesn't exist already Source   Edit  
method dial(self: Dial; peerId: PeerId; protos: seq[string]): InternalRaisesFuture[
    Connection, (DialFailedError, CancelledError)] {.base, ...stackTrace: false,
    raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
create a protocol stream over an existing connection Source   Edit  
method dialAndUpgrade(self: Dial; peerId: Opt[PeerId]; addrs: seq[MultiAddress];
                      dir = Direction.Out): InternalRaisesFuture[Muxer,
    (CancelledError, MaError, TransportAddressError, LPError)] {.base,
    ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect],
    forbids: [].}
Source   Edit  
method dialAndUpgrade(self: Dial; peerId: Opt[PeerId]; hostname: string;
                      addrs: MultiAddress; dir = Direction.Out): InternalRaisesFuture[
    Muxer, (CancelledError,)] {.base, ...stackTrace: false, raises: [], gcsafe,
                                raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
method negotiateStream(self: Dial; conn: Connection; protos: seq[string]): InternalRaisesFuture[
    Connection, (CatchableError,)] {.base, ...stackTrace: false, raises: [],
                                     gcsafe, raises: [], tags: [RootEffect],
                                     forbids: [].}
Source   Edit  
method tryDial(self: Dial; peerId: PeerId; addrs: seq[MultiAddress]): InternalRaisesFuture[
    Opt[MultiAddress], (DialFailedError, CancelledError)] {.base,
    ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect],
    forbids: [].}
Source   Edit