Transport = ref object of RootObj addrs*: seq[MultiAddress] running*: bool upgrader*: Upgrade: Source Edit
TransportClosedError = object of TransportError: Source Edit
TransportError = object of LPError: Source Edit
TransportInvalidAddrError = object of TransportError: Source Edit

Procs

proc dial(self: Transport; address: MultiAddress): Future[Connection] {....gcsafe, raises: [], tags: [].}: Source Edit
proc newTransportClosedError(parent: ref Exception = nil): ref LPError {. ...raises: [], tags: [].}: Source Edit

Methods

method accept(self: Transport): Future[Connection] {.base, ...gcsafe, raises: [], tags: [].}: accept incoming connections Source Edit
method dial(self: Transport; hostname: string; address: MultiAddress): Future[ Connection] {.base, ...gcsafe, raises: [], tags: [].}: dial a peer Source Edit
method handles(self: Transport; address: MultiAddress): bool {.base, ...gcsafe, raises: [], tags: [].}: check if transport supports the multiaddress Source Edit
method start(self: Transport; addrs: seq[MultiAddress]): Future[void] {.base, stackTrace: false, ...gcsafe, raises: [], raises: [], tags: [RootEffect].}: start the transport Source Edit
method stop(self: Transport): Future[void] {.base, stackTrace: false, ...gcsafe, raises: [], raises: [], tags: [RootEffect].}: stop and cleanup the transport including all outstanding connections Source Edit
method upgradeIncoming(self: Transport; conn: Connection): Future[void] {.base, ...gcsafe, raises: [], tags: [].}: base upgrade method that the transport uses to perform transport specific upgrades Source Edit
method upgradeOutgoing(self: Transport; conn: Connection; peerId: Opt[PeerId]): Future[ Connection] {.base, ...gcsafe, raises: [], tags: [].}: base upgrade method that the transport uses to perform transport specific upgrades Source Edit