kcp

package module

Go to main page

Versions in this module

v2

v2.0.3

Nov 11, 2016

Changes in this version

+ type ConnectedUDPConn struct

+ Conn net.Conn

+ func (c *ConnectedUDPConn) WriteTo(b []byte, addr net.Addr) (int, error)

type Listener

+ func ServeConn(block BlockCrypt, dataShards, parityShards int, conn net.PacketConn) (*Listener, error)

type Snmp

+ KCPInErrors uint64

type UDPSession

+ func NewConn(raddr string, block BlockCrypt, dataShards, parityShards int, ...) (*UDPSession, error)

v2.0.2

Sep 8, 2016

Changes in this version

type Listener

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

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

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

v2.0.1

Sep 6, 2016

v2.0.0

Aug 25, 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 NewBlowfishBlockCrypt(key []byte) (BlockCrypt, error)

+ func NewCast5BlockCrypt(key []byte) (BlockCrypt, error)

+ func NewNoneBlockCrypt(key []byte) (BlockCrypt, error)

+ func NewSalsa20BlockCrypt(key []byte) (BlockCrypt, error)

+ func NewSimpleXORBlockCrypt(key []byte) (BlockCrypt, error)

+ func NewTEABlockCrypt(key []byte) (BlockCrypt, error)

+ func NewTripleDESBlockCrypt(key []byte) (BlockCrypt, error)

+ func NewTwofishBlockCrypt(key []byte) (BlockCrypt, error)

+ func NewXTEABlockCrypt(key []byte) (BlockCrypt, error)

+ type BlowfishBlockCrypt struct

+ func (c *BlowfishBlockCrypt) Decrypt(dst, src []byte)

+ func (c *BlowfishBlockCrypt) Encrypt(dst, src []byte)

+ type Cast5BlockCrypt struct

+ func (c *Cast5BlockCrypt) Decrypt(dst, src []byte)

+ func (c *Cast5BlockCrypt) Encrypt(dst, src []byte)

+ 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() (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) 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 Option interface

+ type OptionWithConvId struct

+ Id uint32

+ type Output func(buf []byte, size int)

+ type Salsa20BlockCrypt struct

+ func (c *Salsa20BlockCrypt) Decrypt(dst, src []byte)

+ func (c *Salsa20BlockCrypt) Encrypt(dst, src []byte)

+ 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 TripleDESBlockCrypt struct

+ func (c *TripleDESBlockCrypt) Decrypt(dst, src []byte)

+ func (c *TripleDESBlockCrypt) Encrypt(dst, src []byte)

+ type TwofishBlockCrypt struct

+ func (c *TwofishBlockCrypt) Decrypt(dst, src []byte)

+ func (c *TwofishBlockCrypt) Encrypt(dst, src []byte)

+ type UDPSession struct

+ func Dial(raddr string) (*UDPSession, error)

+ func DialWithOptions(raddr string, block BlockCrypt, dataShards, parityShards int, opts ...Option) (*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)

+ type XTEABlockCrypt struct

+ func (c *XTEABlockCrypt) Decrypt(dst, src []byte)

+ func (c *XTEABlockCrypt) Encrypt(dst, src []byte)

Other modules containing this package

gopkg.in/xtaci/kcp-go.v1

gopkg.in/xtaci/kcp-go.v4

gopkg.in/xtaci/kcp-go.v5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL