udp

Documentation

Index

• func NewListener(conn net.PacketConn, cfg *ListenConfig) net.Listener
• type Conn
• type ListenConfig
• type ReadUDP
• type Relay
  • func NewRelay(pc1, pc2 net.PacketConn) *Relay
  • func (r *Relay) Run(ctx context.Context) (err error)
  • func (r *Relay) SetBufferSize(n int)
  • func (r *Relay) WithBypass(bp bypass.Bypass) *Relay
  • func (r *Relay) WithLogger(logger logger.Logger) *Relay
• type WriteUDP

Functions

func NewListener

func NewListener(conn net.PacketConn, cfg *ListenConfig) net.Listener

Types

type Conn

type Conn interface {
	net.PacketConn
	io.Reader
	io.Writer
	ReadUDP
	WriteUDP
	xnet.SetBuffer
	xnet.SyscallConn
	xnet.RemoteAddr
}

type ListenConfig

type ListenConfig struct {
	Addr           net.Addr
	Backlog        int
	ReadQueueSize  int
	ReadBufferSize int
	TTL            time.Duration
	Keepalive      bool
	Logger         logger.Logger
}

type ReadUDP

type ReadUDP interface {
	ReadFromUDP(b []byte) (n int, addr *net.UDPAddr, err error)
	ReadMsgUDP(b, oob []byte) (n, oobn, flags int, addr *net.UDPAddr, err error)
}

type Relay

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

func NewRelay

func NewRelay(pc1, pc2 net.PacketConn) *Relay

func (*Relay) Run

func (r *Relay) Run(ctx context.Context) (err error)

func (*Relay) SetBufferSize

func (r *Relay) SetBufferSize(n int)

func (*Relay) WithBypass

func (r *Relay) WithBypass(bp bypass.Bypass) *Relay

func (*Relay) WithLogger

func (r *Relay) WithLogger(logger logger.Logger) *Relay

type WriteUDP

type WriteUDP interface {
	WriteToUDP(b []byte, addr *net.UDPAddr) (int, error)
	WriteMsgUDP(b, oob []byte, addr *net.UDPAddr) (n, oobn int, err error)
}