kcp

Aug 16, 2016

Changes in this version

+ 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)

Aug 14, 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 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)