libp2p/protocols/connectivity/relay/rtransport

    Dark Mode
Search:
Group by:
  Source   Edit

Types

RelayTransport = ref object of Transport
  client*: RelayClient
  queue: AsyncQueue[Connection]
  selfRunning: bool
  Source   Edit

Procs

proc dial(self: RelayTransport; ma: MultiAddress): InternalRaisesFuture[
    Connection, (RelayDialError, CancelledError)] {.stackTrace: false,
    ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
  Source   Edit
proc new(T: typedesc[RelayTransport]; cl: RelayClient; upgrader: Upgrade): T:type {.
    ...raises: [].}
  Source   Edit

Methods

method accept(self: RelayTransport): InternalRaisesFuture[Connection,
    (TransportError, CancelledError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        raises: [], raises: [],
                                        tags: [RootEffect].}
  Source   Edit
method dial(self: RelayTransport; hostname: string; ma: MultiAddress;
            peerId: Opt[PeerId] = Opt.none(PeerId)): InternalRaisesFuture[
    Connection, (TransportError, CancelledError)] {.stackTrace: false,
    ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
  Source   Edit
method handles(self: RelayTransport; ma: MultiAddress): bool {....gcsafe,
    raises: [], tags: [].}
  Source   Edit
method start(self: RelayTransport; ma: seq[MultiAddress]): InternalRaisesFuture[
    void, (LPError, TransportError)] {.stackTrace: false, ...raises: [], gcsafe,
                                       raises: [], raises: [],
                                       tags: [RootEffect].}
  Source   Edit
method stop(self: RelayTransport): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}
  Source   Edit