libp2p/protocols/connectivity/dcutr/core

Search:
Group by:
Source   Edit  

Types

DcutrError = object of LPError
Source   Edit  
DcutrMsg {.proto2.} = object
  msgType* {.fieldNumber: 1, required, ext.}: MsgType
  addrs* {.fieldNumber: 2, ext.}: seq[MultiAddress]
Source   Edit  
MsgType {.pure.} = enum
  Connect = 100, Sync = 300
Source   Edit  

Consts

DcutrCodec = "/libp2p/dcutr"
Source   Edit  

Procs

proc decode(_: type DcutrMsg; buf`gensym0: seq[byte]): Result[DcutrMsg, string] {.
    ...raises: [].}
Source   Edit  
proc encode(c`gensym0: DcutrMsg): seq[byte] {....raises: [], tags: [RootEffect],
    forbids: [].}
Source   Edit  
proc expectDcutrConnection(connManager: ConnManager; peerId: PeerId;
                           dir: Direction): Future[Muxer].Raising(
    [AlreadyExpectingConnectionError, CancelledError]) {....raises: [DcutrError],
    raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
proc getHolePunchableAddrs(addrs: seq[MultiAddress]): seq[MultiAddress] {.
    ...raises: [LPError], raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
proc send(stream: Stream; msgType: MsgType; addrs: seq[MultiAddress]): InternalRaisesFuture[
    void, (CancelledError, LPStreamError)] {....stackTrace: false, raises: [],
    gcsafe, raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
proc waitExpectedConnection[T](fut: Future[T]): Future[void].Raising(
    [DialFailedError, CancelledError]) {....raises: [], raises: [].}
Source   Edit  

Exports

DNS_OR_IP, contains, exclIfIt, hash, shortLog, readSeq, UDP_DNS, MaError, IPFS, writeField, data, MaPatternOp, isEmpty, WS_DNS, initVBuffer, hex, protocols, bytes, ==, HTTPS, UNIX, filterIt, QUIC_DNS, shortLog, LPError, TranscoderIP6, encode, getProtocolArgument, MaResult, init, supportsPacked, peekVarint, mapOr, QUIC_V1_IP4, writeSeq, &, Memory, DNS6, TLS_WS, TranscoderDNS, QUIC, [], [], IP4, TranscoderPort, withValue, getIp, $, WS_IP, withValue, MAKind, TranscoderOnion3, getRepeatedField, matchPartial, IpTransportProtocol, match, WebSockets_DNS, WebSockets, $, areAddrsConsistent, isEmpty, HTTP, finish, init, TcpOnion3, MAProtocol, peekSeq, TCP_IP4, toOpt, concat, init, IP, protoAddress, DNS4, QUIC_V1_IP, readArray, withValue, P2PPattern, isEnough, libp2p_multiaddress_exts, Reliable, len, WS, getPart, CircuitRelay, mapAnd, maErr, <, UDP_IP, DNSANY, DNSADDR, append, write, WSS_IP, peekArray, WSS, QUIC_V1, TCP_IP, getField, Unreliable, checkFutures, TCP_DNS, UDP_IP4, capLen, init, protoName, protoArgument, validate, mapEq, Onion3, MaPattern, MaInvalidAddress, TCP_IP6, TranscoderP2P, toException, WSS_DNS, writeLPVarint, write, WebRTCDirect, len, UDP, TranscoderIP6Zone, MaPatResult, TranscoderOnion, QUIC_V1_DNS, readFieldInto, init, shortLog, writeArray, readFieldInto, init, UTP, [], computeFieldSize, IP6, writeField, initVBuffer, QUIC_IP, initVBuffer, WebSockets_IP, VBuffer, writePBVarint, toChunks, TCP, protoArgument, replaceIp, init, take, MultiAddress, supportsPacked, &=, readVarint, toOpt, TranscoderMemory, TranscoderIP4, init, protoCode, $, toException, DNS, items, computeFieldSize, TranscoderUnix, high, toOpt, toString, writeVarint