libp2p/transports/quictransport

    Dark Mode
Search:
Group by:
  Source   Edit

Types

QuicSession = ref object of P2PConnection
  connection: QuicConnection
  Source   Edit 
QuicStream = ref object of P2PConnection
  stream: Stream
  cached: seq[byte]
  Source   Edit 
QuicTransport = ref object of Transport
  listener: Listener
  client: QuicClient
  privateKey: PrivateKey
  connections: seq[P2PConnection]
  rng: ref HmacDrbgContext
  certGenerator: CertGenerator
  Source   Edit 
QuicTransportDialError = object of transport.TransportDialError
  Source   Edit 
QuicTransportError = object of transport.TransportError
  Source   Edit

Procs

proc getStream(session: QuicSession; direction = Direction.In): InternalRaisesFuture[
    QuicStream, (QuicTransportError,)] {.stackTrace: false, ...raises: [], gcsafe,
    tags: [RootEffect].}
  Source   Edit 
proc new(_: type QuicTransport; u: Upgrade; privateKey: PrivateKey): QuicTransport
  Source   Edit 
proc new(_: type QuicTransport; u: Upgrade; privateKey: PrivateKey;
         certGenerator: CertGenerator): QuicTransport
  Source   Edit

Methods

method accept(self: QuicTransport): InternalRaisesFuture[Connection,
    (TransportError, CancelledError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        tags: [RootEffect].}
  Source   Edit 
method close(m: QuicMuxer): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, tags: [RootEffect].}
  Source   Edit 
method close(session: QuicSession): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, tags: [RootEffect].}
  Source   Edit 
method closeImpl(stream: QuicStream): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, tags: [RootEffect].}
  Source   Edit 
method dial(self: QuicTransport; hostname: string; address: MultiAddress;
            peerId: Opt[PeerId] = Opt.none(PeerId)): InternalRaisesFuture[
    Connection, (TransportError, CancelledError)] {.stackTrace: false,
    ...raises: [], gcsafe, tags: [RootEffect].}
  Source   Edit 
method getWrapped(self: QuicSession): P2PConnection {....raises: [], tags: [].}
  Source   Edit 
method handle(m: QuicMuxer): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, tags: [RootEffect].}
  Source   Edit 
method handles(transport: QuicTransport; address: MultiAddress): bool {.
    ...raises: [], tags: [].}
  Source   Edit 
method newStream(m: QuicMuxer; name: string = ""; lazy: bool = false): InternalRaisesFuture[
    P2PConnection, (CancelledError, LPStreamError, MuxerError)] {.
    stackTrace: false, ...raises: [], gcsafe, tags: [RootEffect].}
  Source   Edit 
method readOnce(stream: QuicStream; pbytes: pointer; nbytes: int): InternalRaisesFuture[
    int, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [],
    gcsafe, tags: [RootEffect].}
  Source   Edit 
method start(self: QuicTransport; addrs: seq[MultiAddress]): InternalRaisesFuture[
    void, (LPError, TransportError)] {.stackTrace: false, ...raises: [], gcsafe,
                                       tags: [RootEffect].}
  Source   Edit 
method stop(transport: QuicTransport): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, tags: [RootEffect].}
  Source   Edit 
method upgrade(self: QuicTransport; conn: P2PConnection; peerId: Opt[PeerId]): InternalRaisesFuture[
    Muxer, (CancelledError, LPError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        tags: [RootEffect].}
  Source   Edit 
method write(stream: QuicStream; bytes: seq[byte]): InternalRaisesFuture[void,
    (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], gcsafe,
                                       tags: [RootEffect].}
  Source   Edit

Exports

mapAnd, maErr, writeSeq, DNS_OR_IP, UDP_IP, IP6, DNSANY, exclIfIt, hash, init, UDP_DNS, append, MaError, IPFS, data, WSS_IP, TranscoderOnion3, HTTPS, peekArray, MaPatternOp, isEmpty, QUIC_V1, WS_DNS, initVBuffer, TCP_IP, QUIC_V1_IP, contains, matchPartial, protocols, ==, Unreliable, readSeq, checkFutures, UNIX, QUIC_DNS, len, LPError, capLen, init, protoName, protoArgument, validate, TranscoderIP6, encode, protoCode, mapEq, [], MaPattern, TranscoderIP6Zone, $, MaResult, init, peekVarint, TranscoderP2P, protoArgument, initVBuffer, toException, init, TCP_DNS, mapOr, WSS_DNS, writeLPVarint, WebSockets_IP, compilesOr, CircuitRelay, WebRTCDirect, DNS6, WebSockets, TLS_WS, UDP, [], MaPatResult, QUIC, TranscoderOnion, QUIC_V1_DNS, IP4, TranscoderPort, UTP, withValue, safeConvert, shortLog, items, isEmpty, writeArray, WebSockets_DNS, WS_IP, withValue, public, MAKind, [], write, shortLog, DNSADDR, WSS, &, QUIC_IP, TranscoderDNS, initVBuffer, filterIt, match, TranscoderUnix, $, write, writePBVarint, valueOr, HTTP, TCP, IpTransportProtocol, finish, VBuffer, init, init, Onion3, TcpOnion3, init, getField, MultiAddress, &=, MAProtocol, readVarint, toOpt, init, $, IP, protoAddress, DNS4, readArray, TranscoderIP4, withValue, getRepeatedField, P2PPattern, MaInvalidAddress, toException, isEnough, concat, peekSeq, Reliable, hex, DNS, len, WS, high, toString, writeVarint, bytes, ==, $, MultiCodecError, codec, codec, ==, ==, InvalidMultiCodec, hash, multiCodec, multiCodec, MultiCodec, write, DNS_OR_IP, shortLog, random, UDP_DNS, $, MaError, ephemeral, MaPatternOp, ==, WS_DNS, initVBuffer, <=, decode, MaxSizeError, filterIt, ECDHEScheme, shortLog, init, closed, [], shuffle, random, VBuffer, Secret, peekVarint, random, $, validate, init, bytes, maxInlineKeyLength, TranscoderDNS, QUIC, [], ephemeral, withValue, WS_IP, public, MAKind, decode, write, write, init, valueOr, getRepeatedField, matchPartial, libp2p_pki_schemes, getBytes, WebSockets, init, readLp, HTTP, initVBuffer, atEof, LPStreamTrackerName, peekSeq, toOpt, fullAddrs, payloadType, LPStreamError, init, $, IP, protoAddress, QUIC_V1_IP, newRng, ==, withValue, checkValid, mac, getPublicKey, len, CircuitRelay, extractPublicKey, mapAnd, new, maErr, hash, UDP_IP, new, newLPStreamEOFError, init, DNSADDR, mapOr, AddressMapper, init, write, PeerId, WSS, LPStream, QUIC_V1, TCP_IP, hash, init, closeImpl, readSeq, toBytes, TCP_DNS, shortLog, encode, capLen, protoName, ==, toRawBytes, MaPattern, init, WSS_DNS, match, writeLPVarint, CryptoResult, parseFullAddress, init, WebRTCDirect, init, init, UDP, PeerInfo, TranscoderOnion, StreamTracker, write, init, LPStreamResetError, writeArray, LPStreamIncompleteError, [], LPStreamEOFError, IP6, shortLog, initVBuffer, PKScheme, init, toString, payload, init, Connection, write, init, TCP, PrivateKey, getBytes, write, init, &=, PeerInfoError, newLPStreamClosedError, random, compilesOr, close, TranscoderIP4, init, toException, DNS, goffset, readVarint, getRawBytes, >, KeyPair, init, high, cmp, DefaultConnectionTimeout, formatItIMPL, formatItIMPL, formatItIMPL, Signature, exclIfIt, formatItIMPL, toBytes, DigestSheme, IPFS, readOnce, init, isEmpty, data, shortLog, hex, protocols, init, HTTPS, QUIC_DNS, len, LPError, TLS_WS, sign, encode, supported, update, MaResult, init, TimeoutHandler, toBytes, writeSeq, &, DNS6, IpTransportProtocol, IP4, TranscoderPort, safeConvert, getField, init, >=, init, payloadDomain, $, withValue, init, LPStreamLimitError, TranscoderOnion3, SignedPayload, init, toBytes, protoArgument, newLPStreamLimitError, write, keyOpenArray, finish, match, parseFullAddress, $, isEmpty, writeLp, init, newLPStreamIncompleteError, init, newLPStreamResetError, initStream, contains, stretchKeys, getField, shortLog, DNS4, getWrapped, readArray, selectBest, write, P2PPattern, Envelope, hasPublicKey, toException, init, isEnough, Reliable, addrs, hex, closeImpl, getBytes, decode, WS, QUIC_V1_DNS, encode, init, readVarint, getField, match, <, iv, readLine, Eof, CryptoError, verify, append, DNSANY, WSS_IP, LPStreamConnDownError, peekArray, UNIX, PeerRecord, init, SupportedSchemes, getField, Unreliable, SupportedSchemesInt, random, checkFutures, macOpenArray, key, validate, $, protoCode, mapEq, init, Onion3, TcpOnion3, hash, concat, TranscoderP2P, AddressInfo, ConnectionTrackerName, TranscoderIP6, write, EnvelopeError, encode, len, newLPStreamRemoteClosedError, TranscoderIP6Zone, MaPatResult, Direction, init, InvalidVarintError, shortLog, ==, init, write, getBytes, write, init, UTP, MAProtocol, QUIC_IP, init, PublicKey, WebSockets_IP, writeLp, writePBVarint, readExactly, protoArgument, newLPStreamConnDownError, WebSockets_DNS, initStream, getField, MultiAddress, ivOpenArray, closeWithEOF, orError, getField, LPStreamRemoteClosedError, MaInvalidAddress, LPStreamClosedError, RsaDefaultKeySize, items, write, getOrder, TranscoderUnix, SignedPeerRecord, join, writeVarint, TransportInvalidAddrError, dial, upgrade, Transport, newTransportClosedError, TransportDialError, safeCloseWait, stop, accept, TransportError, TransportClosedError, NetworkReachability, handles, dial, safeClose, start

Made with Nim. Generated: 2025-04-01 15:17:53 UTC