Types
Connection = ref object of LPStream activity*: bool timeout*: Duration timerTaskFut: Future[void].Raising([]) timeoutHandler*: TimeoutHandler peerId*: PeerId observedAddr*: Opt[MultiAddress] protocol*: string transportDir*: Direction when defined(libp2p_agents_metrics): shortAgent*: string
- Source Edit
TimeoutHandler = proc (): Future[void] {.async: (...raises: []).}
- Source Edit
Consts
ConnectionTrackerName = "Connection"
- Source Edit
DefaultConnectionTimeout = (value: 300000000000)
- Source Edit
Procs
func hash(p: Connection): Hash {....raises: [], tags: [].}
- Source Edit
proc new(C: type Connection; peerId: PeerId; dir: Direction; observedAddr: Opt[MultiAddress]; timeout: Duration = DefaultConnectionTimeout; timeoutHandler: TimeoutHandler = nil): Connection {....raises: [].}
- Source Edit
func shortLog(conn: Connection): string {....raises: [], tags: [].}
- Source Edit
Methods
method closeImpl(s: Connection): InternalRaisesFuture[void, void] {. stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
- Source Edit
method getWrapped(s: Connection): Connection {.base, ...raises: [], tags: [].}
- Source Edit
method initStream(s: Connection) {....raises: [], tags: [TimeEffect, RootEffect].}
- Source Edit
Templates
template formatItIMPL(it: Connection): auto
- Source Edit
Exports
-
InvalidVarintError, atEof, newLPStreamIncompleteError, writeLp, initStream, formatItIMPL, newLPStreamResetError, readVarint, LPStreamError, closeWithEOF, newLPStreamLimitError, join, LPStreamResetError, write, Eof, newLPStreamClosedError, LPStreamIncompleteError, close, LPStreamRemoteClosedError, readLp, LPStreamEOFError, LPStreamTrackerName, shortLog, LPStreamConnDownError, LPStreamLimitError, readOnce, toException, toException, LPStream, LPStreamClosedError, newLPStreamEOFError, StreamTracker, MaxSizeError, write, closeImpl, writeLp, newLPStreamRemoteClosedError, checkFutures, readLine, Direction, readExactly, newLPStreamConnDownError, closed, LPError, shortLog, UDP_DNS, ephemeral, MaPatternOp, <=, shortLog, init, $, validate, init, TLS_WS, TranscoderDNS, ephemeral, getField, MAKind, getField, checkFieldNumber, getRepeatedField, getBytes, WebSockets, &, finish, peekSeq, fullAddrs, getProtoHeader, init, QUIC_V1_IP, withValue, getPublicKey, exceptionToAssert, new, DNSANY, DNSADDR, AddressMapper, WSS, init, toBytes, TCP_DNS, shortLog, encode, len, supported, init, ==, $, init, WSS_DNS, <, $, PeerInfo, TranscoderOnion, write, key, writeArray, PeerId, IP6, shortLog, payload, TCP, PrivateKey, getBytes, init, &=, init, $, getRawBytes, KeyPair, update, SupportedWireTypes, hash, init, DNS4, isEmpty, ProtoScalar, data, hash, HTTPS, QUIC_DNS, TranscoderIP6, encode, MaResult, DNS6, [], IpTransportProtocol, toOpenArray, TranscoderPort, isEnough, write, >=, init, payloadDomain, $, init, TranscoderOnion3, protoArgument, write, MaPattern, keyOpenArray, match, WebSockets_DNS, isEmpty, getRequiredRepeatedField, initProtoBuffer, init, init, getField, selectBest, getPtr, Envelope, init, Reliable, addrs, ProtoBuffer, match, getField, CryptoError, append, vsizeof, init, parseFullAddress, getRepeatedField, checkFutures, shuffle, validate, protoCode, getField, TranscoderP2P, sign, getBytes, encode, len, TranscoderIP6Zone, shortLog, items, getBytes, init, QUIC_IP, ProtoFieldKind, protoArgument, getField, readVarint, orError, MaInvalidAddress, writeVarint, getOrder, TranscoderUnix, SignedPeerRecord, DNS_OR_IP, init, decode, random, getProtoHeader, MaError, decode, matchPartial, WS_DNS, initVBuffer, ProtoFlags, ==, getLen, ECDHEScheme, init, [], random, Secret, peekVarint, random, mapOr, bytes, maxInlineKeyLength, QUIC, finish, withValue, getRequiredField, mac, WS_IP, public, write, valueOr, init, HTTP, initVBuffer, TcpOnion3, write, toOpt, payloadType, ProtoHeader, $, IP, protoAddress, newRng, checkValid, len, CircuitRelay, extractPublicKey, mapAnd, maErr, UDP_IP, init, ==, write, QUIC_V1, TCP_IP, writePacked, readSeq, capLen, protoName, toRawBytes, initProtoBuffer, toException, init, match, writeLPVarint, CryptoResult, parseFullAddress, ProtoResult, WebRTCDirect, UDP, isEmpty, decode, initVBuffer, PKScheme, random, write, init, write, PeerInfoError, compilesOr, TranscoderIP4, initProtoBuffer, toException, DNS, init, init, goffset, >, init, high, toString, init, cmp, init, formatItIMPL, formatItIMPL, Signature, exclIfIt, toBytes, DigestSheme, IPFS, MultiAddress, hex, protocols, UNIX, LPError, init, init, ProtoField, toBytes, writeSeq, init, ==, [], IP4, safeConvert, getField, init, withValue, SignedPayload, toBytes, init, MAProtocol, getPackedRepeatedField, contains, libp2p_pki_schemes, readArray, P2PPattern, hasPublicKey, isEnough, hex, write, WS, stretchKeys, encode, init, init, getField, iv, getField, WSS_IP, peekArray, PeerRecord, SupportedSchemes, Unreliable, SupportedSchemesInt, random, macOpenArray, mapEq, Onion3, concat, AddressInfo, init, write, EnvelopeError, MaPatResult, QUIC_V1_DNS, write, write, UTP, verify, init, PublicKey, WebSockets_IP, VBuffer, writePBVarint, getRepeatedField, ProtoError, ivOpenArray, RsaDefaultKeySize, getField, write, toException, toException, checkFutures, LPError