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

fastnet

package module

Go to main page

Versions in this module

v1

v1.0.3

Aug 17, 2023

retracted

v1.0.2

Jul 1, 2023

retracted

Changes in this version

+ const FastDataPack

+ const FastDataPackOld

+ const FastMessage

+ const HeaderSize

+ const HeartbeatDefaultMsgID

+ const LtvHeaderSize

+ const StackBegin

+ const StackEnd

+ const TlvHeaderSize

+ const WorkerIDWithoutWorkerPool

+ var AcceptDelay *acceptDelay

+ func CheckCRC(src []byte, crc []byte) bool

+ func GetCrC(buff []byte) []byte

+ func HeatBeatDefaultHandle(req IRequest)

+ func IsComplete(src []byte, dst []byte) bool

+ func PrintLogo()

+ func RouterRecovery(request IRequest)

+ func RouterTime(request IRequest)

+ type BaseRequest struct

+ func (br *BaseRequest) Abort()

+ func (br *BaseRequest) BindRouter(IRouter)

+ func (br *BaseRequest) BindRouterSlices([]RouterHandler)

+ func (br *BaseRequest) Call()

+ func (br *BaseRequest) GetConnection() IConnection

+ func (br *BaseRequest) GetData() []byte

+ func (br *BaseRequest) GetMessage() IMessage

+ func (br *BaseRequest) GetMsgID() uint32

+ func (br *BaseRequest) GetResponse() IcResp

+ func (br *BaseRequest) Goto(HandleStep)

+ func (br *BaseRequest) RouterSlicesNext()

+ func (br *BaseRequest) SetResponse(IcResp)

+ type BaseRouter struct

+ func (br *BaseRouter) Handle(req IRequest)

+ func (br *BaseRouter) PostHandle(req IRequest)

+ func (br *BaseRouter) PreHandle(req IRequest)

+ type Chain struct

+ func (c *Chain) GetIMessage() IMessage

+ func (c *Chain) Proceed(request IcReq) IcResp

+ func (c *Chain) ProceedWithIMessage(message IMessage, response IcReq) IcResp

+ func (c *Chain) Request() IcReq

+ func (c *Chain) ShouldIRequest(icReq IcReq) IRequest

+ type Client struct

+ func (c *Client) AddInterceptor(interceptor IInterceptor)

+ func (c *Client) AddRouter(msgID uint32, router IRouter)

+ func (c *Client) Conn() IConnection

+ func (c *Client) GetErrChan() chan error

+ func (c *Client) GetLengthField() *LengthField

+ func (c *Client) GetMsgHandler() IMsgHandle

+ func (c *Client) GetName() string

+ func (c *Client) GetOnConnStart() func(IConnection)

+ func (c *Client) GetOnConnStop() func(IConnection)

+ func (c *Client) GetPacket() IDataPack

+ func (c *Client) Restart()

+ func (c *Client) SetDecoder(decoder IDecoder)

+ func (c *Client) SetName(name string)

+ func (c *Client) SetOnConnStart(hookFunc func(IConnection))

+ func (c *Client) SetOnConnStop(hookFunc func(IConnection))

+ func (c *Client) SetPacket(packet IDataPack)

+ func (c *Client) Start()

+ func (c *Client) StartHeartBeatWithOption(interval time.Duration, option *HeartbeatOption)

+ func (c *Client) StartHeartbeat(interval time.Duration)

+ func (c *Client) Stop()

+ type ClientOption func(c IClient)

+ func WithNameClient(name string) ClientOption

+ func WithPacketClient(pack IDataPack) ClientOption

+ type ConnManager struct

+ func (connMgr *ConnManager) Add(conn IConnection)

+ func (connMgr *ConnManager) ClearConn()

+ func (connMgr *ConnManager) Get(connID uint64) (IConnection, error)

+ func (connMgr *ConnManager) GetAllConnID() []uint64

+ func (connMgr *ConnManager) Len() int

+ func (connMgr *ConnManager) Range(cb func(uint64, IConnection, interface{}) error, args interface{}) (err error)

+ func (connMgr *ConnManager) Remove(conn IConnection)

+ type Connection struct

+ func (c *Connection) Context() context.Context

+ func (c *Connection) GetConnID() uint64

+ func (c *Connection) GetConnection() net.Conn

+ func (c *Connection) GetMsgHandler() IMsgHandle

+ func (c *Connection) GetName() string

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

+ func (c *Connection) GetWorkerID() uint32

+ func (c *Connection) GetWsConn() *websocket.Conn

+ func (c *Connection) IsAlive() bool

+ func (c *Connection) LocalAddr() net.Addr

+ func (c *Connection) LocalAddrString() string

+ func (c *Connection) RemoteAddr() net.Addr

+ func (c *Connection) RemoteAddrString() string

+ func (c *Connection) RemoveProperty(key string)

+ func (c *Connection) Send(data []byte) error

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

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

+ func (c *Connection) SendToQueue(data []byte) error

+ func (c *Connection) SetHeartbeat(checker IHeartbeatChecker)

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

+ func (c *Connection) Start()

+ func (c *Connection) StartReader()

+ func (c *Connection) StartWriter()

+ func (c *Connection) Stop()

+ type DataPack struct

+ func (dp *DataPack) GetHeadLen() uint32

+ func (dp *DataPack) Pack(msg IMessage) ([]byte, error)

+ func (dp *DataPack) Unpack(binaryData []byte) (IMessage, error)

+ type DataPackLtv struct

+ func (dp *DataPackLtv) GetHeadLen() uint32

+ func (dp *DataPackLtv) Pack(msg IMessage) ([]byte, error)

+ func (dp *DataPackLtv) Unpack(binaryData []byte) (IMessage, error)

+ type FrameDecoder struct

+ LengthFieldEndOffset int

+ func (d *FrameDecoder) Decode(buff []byte) [][]byte

+ type GroupRouter struct

+ func NewGroup(start, end uint32, router *RouterSlices, Handlers ...RouterHandler) *GroupRouter

+ func (g *GroupRouter) AddHandler(MsgId uint32, Handlers ...RouterHandler)

+ func (g *GroupRouter) Use(Handlers ...RouterHandler)

+ type HandleStep int

+ const Handle

+ const HandleOver

+ const PostHandle

+ const PreHandle

+ type HeartbeatChecker struct

+ func (h *HeartbeatChecker) BindConn(conn IConnection)

+ func (h *HeartbeatChecker) BindRouter(msgID uint32, router IRouter)

+ func (h *HeartbeatChecker) BindRouterSlices(msgID uint32, handlers ...RouterHandler)

+ func (h *HeartbeatChecker) Clone() IHeartbeatChecker

+ func (h *HeartbeatChecker) MsgID() uint32

+ func (h *HeartbeatChecker) Router() IRouter

+ func (h *HeartbeatChecker) RouterSlices() []RouterHandler

+ func (h *HeartbeatChecker) SendHeartbeatMsg() error

+ func (h *HeartbeatChecker) SetHeartbeatFunc(beatFunc HeartbeatFunc)

+ func (h *HeartbeatChecker) SetHeartbeatMsgFunc(f HeartbeatMsgFunc)

+ func (h *HeartbeatChecker) SetOnRemoteNotAlive(f OnRemoteNotAlive)

+ func (h *HeartbeatChecker) Start()

+ func (h *HeartbeatChecker) Stop()

+ type HeartbeatFunc func(IConnection) error

+ type HeartbeatMsgFunc func(IConnection) []byte

+ type HeartbeatOption struct

+ HeartbeatMsgID uint32

+ MakeMsg HeartbeatMsgFunc

+ OnRemoteNotAlive OnRemoteNotAlive

+ Router IRouter

+ RouterSlices []RouterHandler

+ type HeatBeatDefaultRouter struct

+ func (r *HeatBeatDefaultRouter) Handle(req IRequest)

+ type HtlvCrcDecoder struct

+ Body []byte

+ Crc []byte

+ Data []byte

+ FunCode byte

+ Head byte

+ Length byte

+ func (hcd *HtlvCrcDecoder) GetLengthField() *LengthField

+ func (hcd *HtlvCrcDecoder) Intercept(chain IChain) IcResp

+ type IChain interface

+ GetIMessage func() IMessage

+ Proceed func(IcReq) IcResp

+ ProceedWithIMessage func(IMessage, IcReq) IcResp

+ Request func() IcReq

+ func NewChain(list []IInterceptor, pos int, req IcReq) IChain

+ type IClient interface

+ AddInterceptor func(IInterceptor)

+ AddRouter func(msgID uint32, router IRouter)

+ Conn func() IConnection

+ GetErrChan func() chan error

+ GetLengthField func() *LengthField

+ GetMsgHandler func() IMsgHandle

+ GetName func() string

+ GetOnConnStart func() func(IConnection)

+ GetOnConnStop func() func(IConnection)

+ GetPacket func() IDataPack

+ Restart func()

+ SetDecoder func(IDecoder)

+ SetName func(string)

+ SetOnConnStart func(func(IConnection))

+ SetOnConnStop func(func(IConnection))

+ SetPacket func(IDataPack)

+ Start func()

+ StartHeartBeatWithOption func(time.Duration, *HeartbeatOption)

+ StartHeartbeat func(time.Duration)

+ Stop func()

+ func NewClient(ip string, port int, opts ...ClientOption) IClient

+ func NewTLSClient(ip string, port int, opts ...ClientOption) IClient

+ func NewWsClient(ip string, port int, opts ...ClientOption) IClient

+ type IConnManager interface

+ Add func(IConnection)

+ ClearConn func()

+ Get func(uint64) (IConnection, error)

+ GetAllConnID func() []uint64

+ Len func() int

+ Range func(func(uint64, IConnection, interface{}) error, interface{}) error

+ Remove func(IConnection)

+ type IConnection interface

+ Context func() context.Context

+ GetConnID func() uint64

+ GetConnection func() net.Conn

+ GetMsgHandler func() IMsgHandle

+ GetName func() string

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

+ GetWorkerID func() uint32

+ GetWsConn func() *websocket.Conn

+ IsAlive func() bool

+ LocalAddr func() net.Addr

+ LocalAddrString func() string

+ RemoteAddr func() net.Addr

+ RemoteAddrString func() string

+ RemoveProperty func(key string)

+ Send func(data []byte) error

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

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

+ SendToQueue func(data []byte) error

+ SetHeartbeat func(checker IHeartbeatChecker)

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

+ Start func()

+ Stop func()

+ type IDataPack interface

+ GetHeadLen func() uint32

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

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

+ func NewDataPack() IDataPack

+ func NewDataPackLtv() IDataPack

+ type IDecoder interface

+ GetLengthField func() *LengthField

+ func NewHTLVCRCDecoder() IDecoder

+ func NewLTVLittleDecoder() IDecoder

+ func NewTLVDecoder() IDecoder

+ type IFrameDecoder interface

+ Decode func(buff []byte) [][]byte

+ func NewFrameDecoder(lf LengthField) IFrameDecoder

+ func NewFrameDecoderByParams(maxFrameLength uint64, ...) IFrameDecoder

+ type IFuncRequest interface

+ CallFunc func()

+ type IGroupRouterSlices interface

+ AddHandler func(MsgId uint32, Handlers ...RouterHandler)

+ Use func(Handlers ...RouterHandler)

+ type IHeartbeatChecker interface

+ BindConn func(IConnection)

+ BindRouter func(uint32, IRouter)

+ BindRouterSlices func(uint32, ...RouterHandler)

+ Clone func() IHeartbeatChecker

+ MsgID func() uint32

+ Router func() IRouter

+ RouterSlices func() []RouterHandler

+ SendHeartbeatMsg func() error

+ SetHeartbeatFunc func(HeartbeatFunc)

+ SetHeartbeatMsgFunc func(HeartbeatMsgFunc)

+ SetOnRemoteNotAlive func(OnRemoteNotAlive)

+ Start func()

+ Stop func()

+ func NewHeartbeatChecker(interval time.Duration) IHeartbeatChecker

+ type IInterceptor interface

+ Intercept func(IChain) IcResp

+ type IMessage interface

+ GetData func() []byte

+ GetDataLen func() uint32

+ GetMsgID func() uint32

+ GetRawData func() []byte

+ SetData func([]byte)

+ SetDataLen func(uint32)

+ SetMsgID func(uint32)

+ type IMsgHandle interface

+ AddInterceptor func(interceptor IInterceptor)

+ AddRouter func(msgID uint32, router IRouter)

+ AddRouterSlices func(msgId uint32, handler ...RouterHandler) IRouterSlices

+ Execute func(request IRequest)

+ Group func(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ SendMsgToTaskQueue func(request IRequest)

+ StartWorkerPool func()

+ Use func(Handlers ...RouterHandler) IRouterSlices

+ type IRequest interface

+ Abort func()

+ BindRouter func(router IRouter)

+ BindRouterSlices func([]RouterHandler)

+ Call func()

+ GetConnection func() IConnection

+ GetData func() []byte

+ GetMessage func() IMessage

+ GetMsgID func() uint32

+ GetResponse func() IcResp

+ Goto func(HandleStep)

+ RouterSlicesNext func()

+ SetResponse func(IcResp)

+ func NewFuncRequest(conn IConnection, callFunc func()) IRequest

+ func NewRequest(conn IConnection, msg IMessage) IRequest

+ type IRouter interface

+ Handle func(request IRequest)

+ PostHandle func(request IRequest)

+ PreHandle func(request IRequest)

+ type IRouterSlices interface

+ AddHandler func(msgId uint32, handlers ...RouterHandler)

+ GetHandlers func(MsgId uint32) ([]RouterHandler, bool)

+ Group func(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ Use func(Handlers ...RouterHandler)

+ type IServer interface

+ AddInterceptor func(IInterceptor)

+ AddRouter func(msgID uint32, router IRouter)

+ AddRouterSlices func(msgID uint32, router ...RouterHandler) IRouterSlices

+ GetConnMgr func() IConnManager

+ GetHeartbeat func() IHeartbeatChecker

+ GetLengthField func() *LengthField

+ GetMsgHandler func() IMsgHandle

+ GetOnConnStart func() func(IConnection)

+ GetOnConnStop func() func(IConnection)

+ GetPacket func() IDataPack

+ Group func(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ Serve func()

+ ServerName func() string

+ SetDecoder func(IDecoder)

+ SetOnConnStart func(func(IConnection))

+ SetOnConnStop func(func(IConnection))

+ SetPacket func(IDataPack)

+ SetWebsocketAuth func(func(r *http.Request) error)

+ Start func()

+ StartHeartbeat func(time.Duration)

+ StartHeartbeatWithOption func(time.Duration, *HeartbeatOption)

+ Stop func()

+ Use func(Handlers ...RouterHandler) IRouterSlices

+ func NewDefaultRouterSlicesServer(opts ...Option) IServer

+ func NewServer(opts ...Option) IServer

+ func NewUserConfDefaultRouterSlicesServer(config *xconf.Config, opts ...Option) IServer

+ func NewUserConfServer(config *xconf.Config, opts ...Option) IServer

+ type IcReq interface

+ type IcResp interface

+ type LengthField struct

+ InitialBytesToStrip int

+ LengthAdjustment int

+ LengthFieldLength int

+ LengthFieldOffset int

+ MaxFrameLength uint64

+ Order binary.ByteOrder

+ type LtvLittleDecoder struct

+ Length uint32

+ Tag uint32

+ Value []byte

+ func (ltv *LtvLittleDecoder) GetLengthField() *LengthField

+ func (ltv *LtvLittleDecoder) Intercept(chain IChain) IcResp

+ type Message struct

+ Data []byte

+ DataLen uint32

+ ID uint32

+ func NewMessage(len uint32, data []byte) *Message

+ func NewMessageByMsgId(id uint32, len uint32, data []byte) *Message

+ func NewMsgPackage(ID uint32, data []byte) *Message

+ func (msg *Message) GetData() []byte

+ func (msg *Message) GetDataLen() uint32

+ func (msg *Message) GetMsgID() uint32

+ func (msg *Message) GetRawData() []byte

+ func (msg *Message) Init(ID uint32, data []byte)

+ func (msg *Message) SetData(data []byte)

+ func (msg *Message) SetDataLen(len uint32)

+ func (msg *Message) SetMsgID(msgID uint32)

+ type MsgHandle struct

+ TaskQueue []chan IRequest

+ func (mh *MsgHandle) AddInterceptor(interceptor IInterceptor)

+ func (mh *MsgHandle) AddRouter(msgID uint32, router IRouter)

+ func (mh *MsgHandle) AddRouterSlices(msgId uint32, handler ...RouterHandler) IRouterSlices

+ func (mh *MsgHandle) Execute(request IRequest)

+ func (mh *MsgHandle) Group(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ func (mh *MsgHandle) Intercept(chain IChain) IcResp

+ func (mh *MsgHandle) SendMsgToTaskQueue(request IRequest)

+ func (mh *MsgHandle) StartOneWorker(workerID int, taskQueue chan IRequest)

+ func (mh *MsgHandle) StartWorkerPool()

+ func (mh *MsgHandle) Use(Handlers ...RouterHandler) IRouterSlices

+ type OnRemoteNotAlive func(IConnection)

+ type Option func(s *Server)

+ func WithPacket(pack IDataPack) Option

+ type PackFactory struct

+ func Factory() *PackFactory

+ func (f *PackFactory) NewPack(kind string) IDataPack

+ type Request struct

+ func (r *Request) Abort()

+ func (r *Request) BindRouter(router IRouter)

+ func (r *Request) BindRouterSlices(handlers []RouterHandler)

+ func (r *Request) Call()

+ func (r *Request) GetConnection() IConnection

+ func (r *Request) GetData() []byte

+ func (r *Request) GetMessage() IMessage

+ func (r *Request) GetMsgID() uint32

+ func (r *Request) GetResponse() IcResp

+ func (r *Request) Goto(step HandleStep)

+ func (r *Request) RouterSlicesNext()

+ func (r *Request) SetResponse(response IcResp)

+ type RequestFunc struct

+ func (rf *RequestFunc) CallFunc()

+ func (rf *RequestFunc) GetConnection() IConnection

+ type RouterHandler func(request IRequest)

+ type RouterSlices struct

+ Apis map[uint32][]RouterHandler

+ Handlers []RouterHandler

+ func NewRouterSlices() *RouterSlices

+ func (r *RouterSlices) AddHandler(msgId uint32, Handlers ...RouterHandler)

+ func (r *RouterSlices) GetHandlers(MsgId uint32) ([]RouterHandler, bool)

+ func (r *RouterSlices) Group(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ func (r *RouterSlices) Use(handles ...RouterHandler)

+ type Server struct

+ func (s *Server) AddInterceptor(interceptor IInterceptor)

+ func (s *Server) AddRouter(msgID uint32, router IRouter)

+ func (s *Server) AddRouterSlices(msgID uint32, router ...RouterHandler) IRouterSlices

+ func (s *Server) GetConnMgr() IConnManager

+ func (s *Server) GetHeartbeat() IHeartbeatChecker

+ func (s *Server) GetLengthField() *LengthField

+ func (s *Server) GetMsgHandler() IMsgHandle

+ func (s *Server) GetOnConnStart() func(IConnection)

+ func (s *Server) GetOnConnStop() func(IConnection)

+ func (s *Server) GetPacket() IDataPack

+ func (s *Server) Group(start, end uint32, Handlers ...RouterHandler) IGroupRouterSlices

+ func (s *Server) ListenTcpConn()

+ func (s *Server) ListenWebsocketConn()

+ func (s *Server) Serve()

+ func (s *Server) ServerName() string

+ func (s *Server) SetDecoder(decoder IDecoder)

+ func (s *Server) SetOnConnStart(hookFunc func(IConnection))

+ func (s *Server) SetOnConnStop(hookFunc func(IConnection))

+ func (s *Server) SetPacket(packet IDataPack)

+ func (s *Server) SetWebsocketAuth(f func(r *http.Request) error)

+ func (s *Server) Start()

+ func (s *Server) StartConn(conn IConnection)

+ func (s *Server) StartHeartbeat(interval time.Duration)

+ func (s *Server) StartHeartbeatWithOption(interval time.Duration, option *HeartbeatOption)

+ func (s *Server) Stop()

+ func (s *Server) Use(Handlers ...RouterHandler) IRouterSlices

+ type TLVDecoder struct

+ Length uint32

+ Tag uint32

+ Value []byte

+ func (tlv *TLVDecoder) GetLengthField() *LengthField

+ func (tlv *TLVDecoder) Intercept(chain IChain) IcResp

+ type WsConnection struct

+ func (c *WsConnection) Context() context.Context

+ func (c *WsConnection) GetConnID() uint64

+ func (c *WsConnection) GetConnection() net.Conn

+ func (c *WsConnection) GetMsgHandler() IMsgHandle

+ func (c *WsConnection) GetName() string

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

+ func (c *WsConnection) GetWorkerID() uint32

+ func (c *WsConnection) GetWsConn() *websocket.Conn

+ func (c *WsConnection) IsAlive() bool

+ func (c *WsConnection) LocalAddr() net.Addr

+ func (c *WsConnection) LocalAddrString() string

+ func (c *WsConnection) RemoteAddr() net.Addr

+ func (c *WsConnection) RemoteAddrString() string

+ func (c *WsConnection) RemoveProperty(key string)

+ func (c *WsConnection) Send(data []byte) error

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

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

+ func (c *WsConnection) SendToQueue(data []byte) error

+ func (c *WsConnection) SetHeartbeat(checker IHeartbeatChecker)

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

+ func (c *WsConnection) Start()

+ func (c *WsConnection) StartReader()

+ func (c *WsConnection) StartWriter()

+ func (c *WsConnection) Stop()

v1.0.1

Jun 29, 2023

retracted

v1.0.0

Jun 29, 2023

retracted