nnet

Sep 14, 2023

Changes in this version

+ func WithNNetClientEvents(onReady OnReadyFunc, packer packet.Packer) nnet.RunOption

May 4, 2023

Changes in this version

+ const Data

+ const Handshake

+ const HandshakeAck

+ const Heartbeat

+ const Kick

+ const Notify

+ const Push

+ const Request

+ const Response

+ const Unknown

+ var ErrPacketSizeExceed = errors.New("packer: packet size exceed")

+ var ErrRouteInfoNotFound = errors.New("route info not found in dictionary")

+ var ErrWrongMessage = errors.New("wrong message")

+ var ErrWrongMessageType = errors.New("wrong message type")

+ func NewRouter() core.Router

+ func WithNNetClientPipeline(onReady OnReadyFunc, packer packet.Packer) core.RunOption

+ func WithNNetClientProtocol(onReady OnReadyFunc) []core.RunOption

+ func WithNNetProtocol(config Config) []core.RunOption

+ type Config struct

+ HandshakeValidator HandshakeValidatorFunc

+ HeartbeatInterval time.Duration

+ type HandshakeAckPayloadFunc func() interface

+ type HandshakeReq struct

+ ClientId string

+ ClientSecret string

+ Payload interface{}

+ Type string

+ Version string

+ type HandshakeResp struct

+ Heartbeat int64

+ Payload interface{}

+ type HandshakeValidatorFunc func(*HandshakeReq) error

+ type Header struct

+ Length uint32

+ PacketType Type

+ type Match struct

+ Code uint16

+ Route string

+ type MessageHeader struct

+ ID uint64

+ MsgType MsgType

+ Route string

+ type MsgType byte

+ func (t MsgType) String() string

+ type OnReadyFunc func()

+ type Packer struct

+ func NewPacker(routeMap *RouteMap) *Packer

+ func (d *Packer) Pack(header interface{}, data []byte) ([]byte, error)

+ func (d *Packer) Unpack(data []byte) ([]packet.IPacket, error)

+ type Packet struct

+ Data []byte

+ func (p *Packet) GetBody() []byte

+ func (p *Packet) GetHeader() interface{}

+ func (p *Packet) GetLen() uint64

+ func (p *Packet) String() string

+ type RouteMap struct

+ Codes map[uint16]string

+ Routes map[string]uint16

+ func NewRouteMap() *RouteMap

+ type Type byte