protocolmux

package

v1.0.0 Latest Latest Go to latest Published: May 9, 2026 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func IsRESPPrefix(prefix byte) bool

func NormalizeServeError(err error) error

func Serve(ctx context.Context, listener net.Listener, httpListener *Listener, onRESPConn func(net.Conn), onHTTPConn func(net.Conn)) error

type BufferedConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func (c *BufferedConn) ConnectionState() tls.ConnectionState

func (c *BufferedConn) Read(p []byte) (int, error)

type Listener struct {
	// contains filtered or unexported fields
}

func NewListener(addr net.Addr, buffer int) *Listener

func (l *Listener) Accept() (net.Conn, error)

func (l *Listener) Addr() net.Addr

func (l *Listener) Close() error

func (l *Listener) Put(conn net.Conn) error