network

package

v0.2.3 Latest Latest Go to latest Published: Sep 14, 2025 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewBufferedConn(conn net.Conn) *BufferedConn

func (c *BufferedConn) Peek(n int) ([]byte, error)

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

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

func NewQueueListener(queue <-chan *BufferedConn) QueueListener

func (l QueueListener) Accept() (net.Conn, error)

func (l QueueListener) Addr() net.Addr

func (l QueueListener) Close() error

type TimeoutConn struct {
	net.Conn
	Timeout time.Duration
}

func NewTimeoutConn(conn net.Conn, timeout time.Duration) *TimeoutConn

NewTimeoutConn creates new TimeoutConn

func (t *TimeoutConn) Read(b []byte) (int, error)

Read reads data from connection with deadline

func (t *TimeoutConn) SetTimeout(timeout time.Duration)

SetTimeout sets timeout for connection

func (t *TimeoutConn) Write(b []byte) (int, error)

Write writes data to connection with deadline