Versions in this module Expand all Collapse all v1 v1.0.1 Aug 16, 2016 Changes in this version + const IKCP_ACK_FAST + const IKCP_ASK_SEND + const IKCP_ASK_TELL + const IKCP_CMD_ACK + const IKCP_CMD_PUSH + const IKCP_CMD_WASK + const IKCP_CMD_WINS + const IKCP_DEADLINK + const IKCP_INTERVAL + const IKCP_MTU_DEF + const IKCP_OVERHEAD + const IKCP_PROBE_INIT + const IKCP_PROBE_LIMIT + const IKCP_RTO_DEF + const IKCP_RTO_MAX + const IKCP_RTO_MIN + const IKCP_RTO_NDL + const IKCP_THRESH_INIT + const IKCP_THRESH_MIN + const IKCP_WND_RCV + const IKCP_WND_SND + type ACK struct + type ACKList []ACK + func (l *ACKList) Pop() interface{} + func (l *ACKList) Push(x interface{}) + func (l ACKList) Len() int + func (l ACKList) Less(i, j int) bool + func (l ACKList) Swap(i, j int) + type AESBlockCrypt struct + func (c *AESBlockCrypt) Decrypt(dst, src []byte) + func (c *AESBlockCrypt) Encrypt(dst, src []byte) + type BlockCrypt interface + Decrypt func(dst, src []byte) + Encrypt func(dst, src []byte) + func NewAESBlockCrypt(key []byte) (BlockCrypt, error) + func NewNoneBlockCrypt(key []byte) (BlockCrypt, error) + func NewSimpleXORBlockCrypt(key []byte) (BlockCrypt, error) + func NewTEABlockCrypt(key []byte) (BlockCrypt, error) + type FEC struct + type KCP struct + func NewKCP(conv uint32, output Output) *KCP + func (kcp *KCP) Check(current uint32) uint32 + func (kcp *KCP) Input(data []byte, update_ack bool) int + func (kcp *KCP) NoDelay(nodelay, interval, resend, nc int) int + func (kcp *KCP) PeekSize() (length int) + func (kcp *KCP) Recv(buffer []byte) (n int) + func (kcp *KCP) Send(buffer []byte) int + func (kcp *KCP) SetMtu(mtu int) int + func (kcp *KCP) Update(current uint32) + func (kcp *KCP) WaitSnd() int + func (kcp *KCP) WndSize(sndwnd, rcvwnd int) int + type Listener struct + func Listen(laddr string) (*Listener, error) + func ListenWithOptions(laddr string, block BlockCrypt, dataShards, parityShards int) (*Listener, error) + func (l *Listener) Accept() (*UDPSession, error) + func (l *Listener) Addr() net.Addr + func (l *Listener) Close() error + func (l *Listener) SetDSCP(dscp int) error + func (l *Listener) SetReadBuffer(bytes int) error + func (l *Listener) SetWriteBuffer(bytes int) error + type NoneBlockCrypt struct + func (c *NoneBlockCrypt) Decrypt(dst, src []byte) + func (c *NoneBlockCrypt) Encrypt(dst, src []byte) + type Output func(buf []byte, size int) + type Segment struct + func NewSegment(size int) *Segment + type SimpleXORBlockCrypt struct + func (c *SimpleXORBlockCrypt) Decrypt(dst, src []byte) + func (c *SimpleXORBlockCrypt) Encrypt(dst, src []byte) + type Snmp struct + ActiveOpens uint64 + BytesReceived uint64 + BytesSent uint64 + CurrEstab uint64 + EarlyRetransSegs uint64 + FECErrs uint64 + FECRecovered uint64 + FECSegs uint64 + FastRetransSegs uint64 + InCsumErrors uint64 + InErrs uint64 + InSegs uint64 + LostSegs uint64 + MaxConn uint64 + OutBytes uint64 + OutSegs uint64 + PassiveOpens uint64 + RepeatSegs uint64 + RetransSegs uint64 + var DefaultSnmp *Snmp + func (s *Snmp) Copy() *Snmp + type TEABlockCrypt struct + func (c *TEABlockCrypt) Decrypt(dst, src []byte) + func (c *TEABlockCrypt) Encrypt(dst, src []byte) + type UDPSession struct + func Dial(raddr string) (*UDPSession, error) + func DialWithOptions(raddr string, block BlockCrypt, dataShards, parityShards int) (*UDPSession, error) + func (s *UDPSession) Close() error + func (s *UDPSession) GetConv() uint32 + 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) SetDeadline(t time.Time) error + func (s *UDPSession) SetKeepAlive(interval int) + func (s *UDPSession) SetMtu(mtu int) + func (s *UDPSession) SetNoDelay(nodelay, interval, resend, nc int) + 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) Write(b []byte) (n int, err error) Incompatible versions in this module v4.3.4+incompatible Dec 26, 2018
Go to main page