libp2p/transports/quictransport

Search:
Group by:
Source   Edit  

Types

QuicMuxer = ref object of Muxer
Source   Edit   
QuicSession = ref object of P2PConnection
  when defined(libp2p_agents_metrics):
Source   Edit   
QuicStream = ref object of P2PConnection
Source   Edit   
QuicTransport = ref object of Transport
Source   Edit   
QuicTransportDialError = object of transport.TransportDialError
Source   Edit   
QuicTransportError = object of transport.TransportError
Source   Edit  

Procs

func hash(s: QuicStream): Hash {....raises: [], tags: [], forbids: [].}
Source   Edit   
proc new(_: type QuicMuxer; conn: P2PConnection;
         peerId: Opt[PeerId] = Opt.none(PeerId)): QuicMuxer {.
    ...raises: [CertificateParsingError, LPError].}
Source   Edit   
proc new(_: type QuicTransport; u: Upgrade; privateKey: PrivateKey;
         certGenerator: CertGenerator; connManager: ConnManager = nil): QuicTransport
Source   Edit   
proc new(_: type QuicTransport; u: Upgrade; privateKey: PrivateKey;
         connManager: ConnManager = nil): QuicTransport
Source   Edit  

Methods

method accept(self: QuicTransport): InternalRaisesFuture[RawConn,
    (TransportError, CancelledError)] {....stackTrace: false, raises: [], gcsafe,
                                        tags: [RootEffect], forbids: [].}
Source   Edit   
method close(m: QuicMuxer): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method close(session: QuicSession): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method closed(session: QuicSession): bool {....raises: [], tags: [], forbids: [].}
Source   Edit   
method closeImpl(stream: QuicStream): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method closeWrite(stream: QuicStream): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Close the write side of the QUIC stream Source   Edit   
method dial(self: QuicTransport; hostname: string; address: MultiAddress;
            peerId: Opt[PeerId] = Opt.none(PeerId)): InternalRaisesFuture[
    RawConn, (TransportError, CancelledError)] {....stackTrace: false, raises: [],
    gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method getStreams(m: QuicMuxer): seq[MuxedStream] {....gcsafe, raises: [],
    tags: [], forbids: [].}
Source   Edit   
method getWrapped(self: QuicSession): P2PConnection {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
method getWrapped(self: QuicStream): P2PConnection {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
method handle(m: QuicMuxer): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method handles(transport: QuicTransport; address: MultiAddress): bool {.
    ...raises: [], tags: [], forbids: [].}
Source   Edit   
method newStream(m: QuicMuxer; name: string = ""; lazy: bool = false): InternalRaisesFuture[
    MuxedStream, (CancelledError, LPStreamError, MuxerError)] {.
    ...stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method readOnce(stream: QuicStream; pbytes: pointer; nbytes: int): InternalRaisesFuture[
    int, (CancelledError, LPStreamError)] {....stackTrace: false, raises: [],
    gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method resetImpl(stream: QuicStream): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method start(self: QuicTransport; addrs: seq[MultiAddress]): InternalRaisesFuture[
    void, (LPError, TransportError, CancelledError)] {....stackTrace: false,
    raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method stop(transport: QuicTransport): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit   
method upgrade(self: QuicTransport; conn: RawConn; peerId: Opt[PeerId]): InternalRaisesFuture[
    Muxer, (CancelledError, LPError)] {....stackTrace: false, raises: [], gcsafe,
                                        tags: [RootEffect], forbids: [].}
Source   Edit   
method write(stream: QuicStream; bytes: sink seq[byte]): InternalRaisesFuture[
    void, (CancelledError, LPStreamError)] {....stackTrace: false, raises: [],
    gcsafe, tags: [RootEffect], forbids: [].}
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, ==, $, libp2p_multicodec_exts, MultiCodecError, codec, codec, ==, ==, InvalidMultiCodec, hash, multiCodec, multiCodec, MultiCodec, write, DNS_OR_IP, shortLog, init, random, UDP_DNS, $, MaError, libp2p_network_bytes, writeField, ephemeral, replaceIp, MaPatternOp, ==, WS_DNS, initVBuffer, <=, MaxSizeError, decode, ==, shortLog, filterIt, ECDHEScheme, shortLog, hash, supportsPacked, writeField, init, closed, [], shuffle, random, init, Secret, peekVarint, payload, $, validate, mapOr, chroniclesFormatItIMPL, init, Memory, bytes, publicRoutableAddressPolicy, getPubKey, maxInlineKeyLength, TranscoderDNS, QUIC, writeField, [], init, ephemeral, withValue, PeerInfoObserver, getIp, generateBytes, WS_IP, write, MAKind, decode, getBytes, write, decode, init, noPrivateAddressPolicy, getRepeatedField, generate, matchPartial, getBytes, len, areAddrsConsistent, init, readLp, HTTP, initVBuffer, atEof, LPStreamTrackerName, removeObserver, peekSeq, update, TCP_IP4, toOpt, join, fullAddrs, payloadType, LPStreamError, init, IP, protoAddress, QUIC_V1_IP, newRng, ==, shortLog, withValue, checkValid, getPublicKey, chroniclesFormatItIMPL, libp2p_multiaddress_exts, WebSockets, readFieldInto, getPart, CircuitRelay, extractPublicKey, mapAnd, new, maErr, computeFieldSize, UDP_IP, newLPStreamEOFError, init, random, ==, DNSADDR, AddressMapper, write, notifyObservers, WSS, QUIC_V1, TCP_IP, close, init, closeImpl, toCidString, readSeq, toBytes, TCP_DNS, closeWrite, shortLog, wasResetLocally, encode, UDP_IP4, len, capLen, init, protoName, protoArgument, toRawBytes, supportsPacked, $, writeField, TCP_IP6, init, DNS, WSS_DNS, match, writeLPVarint, CryptoResult, LPStream, parseFullAddress, WebRTCDirect, PeerAddressPolicy, init, $, UDP, PeerInfo, TranscoderOnion, StreamTracker, defaultAddressPolicy, init, LPStreamResetError, writeArray, LPStreamIncompleteError, PeerId, >, [], LPStreamEOFError, IP6, shortLog, reset, initVBuffer, PKScheme, random, stretchKeys, accepts, addObserver, Connection, write, init, generate, TCP, PrivateKey, readFieldInto, write, init, RawConn, &=, PeerInfoError, newBearSslRng, verify, newLPStreamClosedError, random, TranscoderMemory, toString, TranscoderIP4, init, toException, init, goffset, getRawBytes, pick, KeyPair, init, high, cmp, init, DefaultConnectionTimeout, Signature, chroniclesFormatItIMPL, contains, hash, exclIfIt, computeFieldSize, computeFieldSize, supportsPacked, stripPeerId, toBytes, DigestSheme, IPFS, getField, shortLog, readOnce, init, resetImpl, isEmpty, shortLog, data, chroniclesFormatItIMPL, hex, protocols, chroniclesFormatItIMPL, computeFieldSize, HTTPS, UNIX, LPError, supportsPacked, readFieldInto, TLS_WS, sign, encode, Rng, getProtocolArgument, supported, MaResult, init, supportsPacked, toBytes, QUIC_V1_IP4, writeSeq, finish, &, DNS6, expandAddrs, writeField, decode, IpTransportProtocol, key, IP4, TranscoderPort, getBytes, readFieldInto, DNSANY, >=, QUIC_V1_DNS, payloadDomain, $, MaPattern, withValue, MuxedStream, init, LPStreamLimitError, TranscoderOnion3, SignedPayload, mac, toBytes, protoArgument, newLPStreamLimitError, keyOpenArray, match, WebSockets_DNS, SignedPeerRecord, $, isEmpty, writeLp, toCid, init, newLPStreamIncompleteError, MAProtocol, newLPStreamResetError, initStream, init, getField, DNS4, readFieldInto, getWrapped, selectBest, supportsPacked, P2PPattern, Envelope, hasPublicKey, toException, init, Stream, isEnough, Reliable, addrs, hex, closeImpl, getBytes, ivOpenArray, WS, init, encode, take, init, init, match, readArray, filterAddrs, <, iv, readLine, Eof, CryptoError, computeFieldSize, append, hash, init, parseFullAddress, WSS_IP, LPStreamConnDownError, peekArray, PeerRecord, SupportedSchemes, generate, QUIC_DNS, Unreliable, SupportedSchemesInt, random, checkFutures, supportsPacked, macOpenArray, init, checkAddresses, validate, protoCode, mapEq, libp2p_pki_schemes, Onion3, TcpOnion3, toFullAddress, pickOne, concat, TranscoderP2P, AddressInfo, ConnectionTrackerName, TranscoderIP6, new, write, EnvelopeError, computeFieldSize, encode, len, newLPStreamRemoteClosedError, TranscoderIP6Zone, MaPatResult, Direction, init, InvalidVarintError, shortLog, items, init, write, write, init, UTP, readVarint, verify, readFieldInto, TimeoutHandler, QUIC_IP, init, PublicKey, WebSockets_IP, VBuffer, writeLp, writePBVarint, toChunks, readExactly, newLPStreamConnDownError, init, initStream, MultiAddress, supportsPacked, readVarint, toOpt, closeWithEOF, RsaDefaultKeySize, orError, LPStreamRemoteClosedError, <, MaInvalidAddress, generate, LPStreamClosedError, writeField, write, getOrder, TranscoderUnix, toOpt, writeVarint, TransportInvalidAddrError, TransportStartError, dial, Transport, newTransportClosedError, TransportDialError, upgrade, safeCloseWait, toTransportAddress, stop, accept, TransportError, TransportClosedError, NetworkReachability, initialize, dial, safeClose, handles, start

Made with Nim. Generated: 2026-07-14 05:50:23 UTC