udpsession

Feb 17, 2023

Changes in this version

type UDPSession

+ func (s *UDPSession) SetPollIntervalMs(interval uint32)

Dec 3, 2022

Changes in this version

+ var KCPInErrors = metrics.RegisterMetric("errors", "KCPInErrors")

+ var KCPReceiveErrors = metrics.RegisterMetric("errors", "KCPReceiveErrors")

+ var KCPSendErrors = metrics.RegisterMetric("errors", "KCPSendErrors")

+ var UDPInErrors = metrics.RegisterMetric("errors", "UDPInErrors")

Jun 21, 2022

Changes in this version

+ func SetGlobalMTU(mtu int32)

Mar 5, 2022

Changes in this version

+ func DialWithOptionsReturnConn(ctx context.Context, network, laddr, raddr string, block cipher.BlockCipher) (net.Conn, error)

+ func TestHelperGenRot13Input(size int) []byte

+ func TestHelperRot13(in []byte) ([]byte, error)

+ func TestHelperServeConn(conn *UDPSession) error

+ type Listener struct

+ func ListenWithOptions(laddr string, users map[string]*appctlpb.User) (*Listener, error)

+ func (l *Listener) Accept() (net.Conn, error)

+ func (l *Listener) AcceptKCP() (*UDPSession, error)

+ func (l *Listener) Addr() net.Addr

+ func (l *Listener) Close() error

+ func (l *Listener) SetDSCP(dscp int) error

+ func (l *Listener) SetDeadline(t time.Time) error

+ func (l *Listener) SetReadBuffer(bytes int) error

+ func (l *Listener) SetReadDeadline(t time.Time) error

+ func (l *Listener) SetWriteBuffer(bytes int) error

+ func (l *Listener) SetWriteDeadline(t time.Time) error

+ type UDPSession struct

+ func DialWithOptions(ctx context.Context, network, laddr, raddr string, block cipher.BlockCipher) (*UDPSession, error)

+ func (s *UDPSession) Close() error

+ func (s *UDPSession) GetConv() uint32

+ func (s *UDPSession) GetRTO() uint32

+ func (s *UDPSession) GetSRTT() int32

+ func (s *UDPSession) GetSRTTVar() int32

+ func (s *UDPSession) IsClient() bool

+ func (s *UDPSession) IsServer() bool

+ func (s *UDPSession) LocalAddr() net.Addr

+ func (s *UDPSession) Read(b []byte) (n int, err error)

+ func (s *UDPSession) RemoteAddr() net.Addr

+ func (s *UDPSession) SetACKNoDelay(nodelay bool)

+ func (s *UDPSession) SetDSCP(dscp int) error

+ func (s *UDPSession) SetDUP(dup int)

+ func (s *UDPSession) SetDeadline(t time.Time) error

+ func (s *UDPSession) SetMtu(mtu int) bool

+ func (s *UDPSession) SetNoDelay(nodelay, interval, resend uint32, nc bool)

+ func (s *UDPSession) SetReadBuffer(bytes int) error

+ func (s *UDPSession) SetReadDeadline(t time.Time) error

+ func (s *UDPSession) SetStreamMode(enable bool)

+ func (s *UDPSession) SetWindowSize(sndwnd, rcvwnd int)

+ func (s *UDPSession) SetWriteBuffer(bytes int) error

+ func (s *UDPSession) SetWriteDeadline(t time.Time) error

+ func (s *UDPSession) SetWriteDelay(delay bool)

+ func (s *UDPSession) Write(b []byte) (n int, err error)

+ func (s *UDPSession) WriteBuffers(v [][]byte) (n int, err error)