libp2p/protocols/protocol

    Dark Mode
Search:
Group by:
  Source   Edit

Types

LPProtocol = ref object of RootObj
  codecs*: seq[string]
  handlerImpl: LPProtoHandler ## invoked by the protocol negotiator
  started*: bool
  maxIncomingStreams: Opt[int]
  Source   Edit
LPProtoHandler = proc (conn: Connection; proto: string): Future[void] {.async.}
  Source   Edit

Procs

func codec(p: LPProtocol): string {....raises: [], tags: [].}
  Source   Edit
func codec=(p: LPProtocol; codec: string) {....raises: [], tags: [].}
  Source   Edit
func handler=(p: LPProtocol; handler: LPProtoHandler) {....raises: [], tags: [].}
  Source   Edit
func handler=[E](p: LPProtocol; handler: proc (conn: Connection; proto: string): InternalRaisesFuture[
    void, E]) {....raises: [].}
  Source   Edit
proc maxIncomingStreams(p: LPProtocol): int {....raises: [], tags: [].}
  Source   Edit
proc maxIncomingStreams=(p: LPProtocol; val: int) {....raises: [], tags: [].}
  Source   Edit
proc new(T: type LPProtocol; codecs: seq[string]; handler: LPProtoHandler;
         maxIncomingStreams: Opt[int] | int = Opt.none(int)): T:type {.
    ...raises: [].}
  Source   Edit
proc new[E](T: type LPProtocol; codecs: seq[string]; handler: proc (
    conn: Connection; proto: string): InternalRaisesFuture[void, E];
            maxIncomingStreams: Opt[int] | int = Opt.none(int)): T:type {.
    ...raises: [].}
  Source   Edit

Methods

method init(p: LPProtocol) {.base, ...gcsafe, raises: [], tags: [].}
  Source   Edit
method start(p: LPProtocol): InternalRaisesFuture[void, (CancelledError,)] {.
    base, stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [].}
  Source   Edit
method stop(p: LPProtocol): InternalRaisesFuture[void, void] {.base,
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [].}
  Source   Edit

Templates

template handler(p: LPProtocol): LPProtoHandler
  Source   Edit
template handler(p: LPProtocol; conn: Connection; proto: string): Future[void]
  Source   Edit