kcp

Documentation

Index

• type KcpListener
  • func NewKcpListener(addr string, gs rua.GameServer, key []byte, bufSize int) *KcpListener
  • func (l *KcpListener) Start() error
  • func (l *KcpListener) WithCrypt(crypt string) *KcpListener
  • func (l *KcpListener) WithDataShards(shards int) *KcpListener
  • func (l *KcpListener) WithGuardian(g func(c *kcp.UDPSession, gs rua.GameServer) bool) *KcpListener
  • func (l *KcpListener) WithLogger(logger rua.Logger) *KcpListener
  • func (l *KcpListener) WithMaxAttempts(count int) *KcpListener
  • func (l *KcpListener) WithParityShards(shards int) *KcpListener
  • func (l *KcpListener) WithPeerReadTimeout(t int) *KcpListener
  • func (l *KcpListener) WithPeerTag(t string) *KcpListener
  • func (l *KcpListener) WithPeerWriteTimeout(t int) *KcpListener
  • func (l *KcpListener) WithUpgrader(f func(c *kcp.UDPSession) (net.Conn, error)) *KcpListener

Types

type KcpListener

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

func NewKcpListener

func NewKcpListener(addr string, gs rua.GameServer, key []byte, bufSize int) *KcpListener

func (*KcpListener) Start

func (l *KcpListener) Start() error

func (*KcpListener) WithCrypt

func (l *KcpListener) WithCrypt(crypt string) *KcpListener

func (*KcpListener) WithDataShards

func (l *KcpListener) WithDataShards(shards int) *KcpListener

func (*KcpListener) WithGuardian

func (l *KcpListener) WithGuardian(g func(c *kcp.UDPSession, gs rua.GameServer) bool) *KcpListener

func (*KcpListener) WithLogger

func (l *KcpListener) WithLogger(logger rua.Logger) *KcpListener

func (*KcpListener) WithMaxAttempts

func (l *KcpListener) WithMaxAttempts(count int) *KcpListener

func (*KcpListener) WithParityShards

func (l *KcpListener) WithParityShards(shards int) *KcpListener

func (*KcpListener) WithPeerReadTimeout

func (l *KcpListener) WithPeerReadTimeout(t int) *KcpListener

func (*KcpListener) WithPeerTag

func (l *KcpListener) WithPeerTag(t string) *KcpListener

func (*KcpListener) WithPeerWriteTimeout

func (l *KcpListener) WithPeerWriteTimeout(t int) *KcpListener

func (*KcpListener) WithUpgrader

func (l *KcpListener) WithUpgrader(f func(c *kcp.UDPSession) (net.Conn, error)) *KcpListener