tunnel

package

v1.3.2 Latest Latest Go to latest Published: Feb 13, 2026 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/alpacax/alpamon

Links

Open Source Insights

Documentation ¶

Index ¶

func CopyBuffered(dst io.Writer, src io.Reader) (written int64, err error)
type WebSocketConn
- func NewWebSocketConn(conn *websocket.Conn) *WebSocketConn

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CopyBuffered ¶

func CopyBuffered(dst io.Writer, src io.Reader) (written int64, err error)

CopyBuffered performs io.CopyBuffer using pooled buffers. This reduces memory allocations and GC pressure.

Types ¶

type WebSocketConn ¶

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

WebSocketConn wraps a WebSocket connection to implement io.ReadWriteCloser. This adapter is required for smux which expects io.ReadWriteCloser.

func NewWebSocketConn ¶

func NewWebSocketConn(conn *websocket.Conn) *WebSocketConn

NewWebSocketConn creates a new WebSocket to io.ReadWriteCloser adapter.

func (*WebSocketConn) Close ¶

func (w *WebSocketConn) Close() error

Close closes the WebSocket connection.

func (*WebSocketConn) Read ¶

func (w *WebSocketConn) Read(b []byte) (int, error)

Read reads data from the WebSocket connection. WebSocket messages that are larger than the provided buffer are buffered internally.

func (*WebSocketConn) Write ¶

func (w *WebSocketConn) Write(b []byte) (int, error)

Write writes data to the WebSocket connection as a binary message. The write is protected by a mutex to ensure thread safety for concurrent calls from multiple smux streams.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL