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