tcpx

package

v0.2.1 Latest Latest Go to latest Published: Dec 3, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func WithConnectTimeout(timeout time.Duration) opt.Option[connectOptions]

type Client interface {
	Dial() (Connect, error)
}

func NewClient(conf *ClientConfig) Client

type ClientConfig struct {
	Addr    string
	Timeout time.Duration
}

type Connect interface {
	Send([]byte) error
	Receive([]byte) error
	SetTimeout(time.Duration)
	Conn() net.Conn
	Close()
}

func NewConnect(conn net.Conn, opts ...opt.Option[connectOptions]) Connect

type Server interface {
	Start(ServerRegisterFunc) error
	Shutdown()
}

func NewServer(conf *ServerConfig) Server

type ServerConfig struct {
	Addr    string
	Timeout time.Duration
}

type ServerRegisterFunc func(Connect)