Package Usage: go: golang.ngrok.com/muxado/v2
muxado implements a general purpose stream-multiplexing protocol. muxado allows clients applications
to multiplex any io.ReadWriteCloser (like a net.Conn) into multiple, independent full-duplex streams.
muxado is a useful protocol for any two communicating processes. It is an excellent base protocol
for implementing lightweight RPC. It eliminates the need for custom async/pipeling code from your peers
in order to support multiple simultaneous inflight requests between peers. For the same reason, it also
eliminates the need to build connection pools for your clients. It enables servers to initiate streams
to clients without building any NAT traversal. muxado can also yield performance improvements (especially
latency) for protocols that require rapidly opening many concurrent connections.
Here's an example client which responds to simple JSON requests from a server.
Maybe the client wants to make a request to the server instead of just responding. This is easy as well:
muxado defines the following terms for clarity of the documentation:
A "Transport" is an underlying stream (typically TCP) that is multiplexed by sending frames between muxado peers over this transport.
A "Stream" is any of the full-duplex byte-streams multiplexed over the transport
A "Session" is two peers running the muxado protocol over a single transport
muxado's design is influenced heavily by the framing layer of HTTP2 and SPDY. However, instead
of being specialized for a higher-level protocol, muxado is designed in a protocol agnostic way
with simplicity and speed in mind. More advanced features are left to higher-level libraries and protocols.
muxado's API is designed to make it seamless to integrate into existing Go programs. muxado.Session
implements the net.Listener interface and muxado.Stream implements net.Conn.
muxado ships with two wrappers that add commonly used functionality. The first is a TypedStreamSession
which allows a client application to open streams with a type identifier so that the remote peer
can identify the protocol that will be communicated on that stream.
The second wrapper is a simple Heartbeat which issues a callback to the application informing it
of round-trip latency and heartbeat failure.
2 versions
Latest release: about 2 years ago
16 dependent packages
View more package details: https://packages.ecosystem.code.gouv.fr/registries/proxy.golang.org/packages/golang.ngrok.com/muxado/v2