internal

Documentation

Index

• Constants
• Variables
• func DeadlineUpdate(conn Deadline) func()
• func DefaultTLSConfig() *tls.Config
• func IsNormalCloseError(err error) bool
• func IsPassableNetwork(network string) error
• func Log(message string, err error, addr net.Addr)
• type Conn
• type Deadline
• type PacketWrite
  • func (a *PacketWrite) Write(p []byte) (n int, err error)

Constants

const (
	NetTCP  = "tcp"
	NetUDP  = "udp"
	NetUNIX = "unix"
	NetQUIC = "quic"
)

const (
	UDPPacketSize = 65535
)

Variables

var DataPool = pool.New[*data.Buffer](func() *data.Buffer {
	return data.NewBuffer(512)
})

var (
	ErrServAlreadyRunning = errors.New("server already running")
)

Functions

func DeadlineUpdate

func DeadlineUpdate(conn Deadline) func()

func DefaultTLSConfig

func DefaultTLSConfig() *tls.Config

func IsNormalCloseError

func IsNormalCloseError(err error) bool

func IsPassableNetwork

func IsPassableNetwork(network string) error

func Log

func Log(message string, err error, addr net.Addr)

Types

type Conn

type Conn interface {
	io.ReadWriteCloser
	Deadline
}

type Deadline

type Deadline interface {
	SetDeadline(t time.Time) error
}

type PacketWrite

type PacketWrite struct {
	Addr net.Addr
	Conn interface {
		WriteTo(p []byte, addr net.Addr) (n int, err error)
	}
}

func (*PacketWrite) Write

func (a *PacketWrite) Write(p []byte) (n int, err error)