Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

anet

package

Go to main page

Versions in this module

v0

v0.0.2

Aug 26, 2021

Changes in this version

type Connection

+ GetTcpConnection func() *net.TCPConn

+ GetWsConnection func() *websocket.Conn

type Message

+ GetSeq func() uint32

+ GetVer func() uint32

type MsgHandle

+ SetRpcxRouter func(router RpcxRouter)

+ type RpcxRouter interface

+ Handle func(request Request)

type Server

+ SetRpcxRouter func(router RpcxRouter)

+ StartTcp func()

+ StartWebsocket func()

v0.0.1

Aug 18, 2021

Changes in this version

+ type ConnManager interface

+ Add func(conn Connection)

+ ClearConn func()

+ Get func(connID uint32) (Connection, error)

+ Len func() int

+ Remove func(conn Connection)

+ type Connection interface

+ Context func() context.Context

+ GetConnID func() uint32

+ GetProperty func(key string) (interface{}, error)

+ GetTCPConnection func() *net.TCPConn

+ RemoteAddr func() net.Addr

+ RemoveProperty func(key string)

+ SendBuffMsg func(msgID uint32, data []byte) error

+ SendMsg func(msgID uint32, data []byte) error

+ SetProperty func(key string, value interface{})

+ Start func()

+ Stop func()

+ type DataPack interface

+ GetHeadLen func() uint32

+ Pack func(msg Message) ([]byte, error)

+ Unpack func([]byte) (Message, error)

+ type Message interface

+ GetData func() []byte

+ GetDataLen func() uint32

+ GetMsgID func() uint32

+ SetData func([]byte)

+ SetDataLen func(uint32)

+ SetMsgID func(uint32)

+ type MsgHandle interface

+ AddRouter func(msgID uint32, router Router)

+ DoMsgHandler func(request Request)

+ SendMsgToTaskQueue func(request Request)

+ StartWorkerPool func()

+ type Packet interface

+ GetHeadLen func() uint32

+ Pack func(msg Message) ([]byte, error)

+ Unpack func(binaryData []byte) (Message, error)

+ type Request interface

+ GetConnection func() Connection

+ GetData func() []byte

+ GetMsgID func() uint32

+ type Router interface

+ Handle func(request Request)

+ PostHandle func(request Request)

+ PreHandle func(request Request)

+ type Server interface

+ AddRouter func(msgID uint32, router Router)

+ CallOnConnStart func(conn Connection)

+ CallOnConnStop func(conn Connection)

+ GetConnMgr func() ConnManager

+ Packet func() Packet

+ Serve func()

+ SetOnConnStart func(func(Connection))

+ SetOnConnStop func(func(Connection))

+ Start func()

+ Stop func()