qnet

Mar 30, 2021

Changes in this version

+ func ReadPacketMessage(conn net.Conn, decoder fatchoy.ProtocolDecoder, decrypt cipher.BlockCryptor, ...) error

Feb 25, 2021

Changes in this version

+ var RequestReadTimeout = 15

+ func DialTCP(address string) (*net.TCPConn, error)

+ func ListenTCP(address string) (*net.TCPListener, error)

+ func ReadProtoMessage(conn net.Conn, cdec choykit.Codec, msgOut proto.Message) (*choykit.Packet, error)

+ func RequestMessage(conn net.Conn, cdec choykit.Codec, reqCommand int32, ...) error

+ func SendPacketMessage(conn net.Conn, cdec choykit.Codec, pkt *choykit.Packet) error

+ func SendProtoMessage(conn net.Conn, cdec choykit.Codec, command int32, msgIn proto.Message) error

type ConnBase

+ func (c *ConnBase) Codec() choykit.Codec

type RpcContext

+ func (r *RpcContext) NodeID() choykit.NodeID

Apr 25, 2021

Changes in this version

type ConnBase

+ func (c *ConnBase) SetEncryptPair(encrypt cipher.BlockCryptor, decrypt cipher.BlockCryptor)

Apr 20, 2021

Changes in this version

type WsConn

+ func (c *WsConn) ReadPacket(pkt *fatchoy.Packet) error

Apr 20, 2021

Changes in this version

+ const NumStat

+ const StatBytesRecv

+ const StatBytesSent

+ const StatPacketsRecv

+ const StatPacketsSent

+ const WSCONN_MAX_PAYLOAD

+ var ErrConnForceClose = errors.New("connection forced to close")

+ var ErrConnIsClosing = errors.New("connection is closing when sending")

+ var ErrConnOutboundOverflow = errors.New("connection outbound queue overflow")

+ var TConnReadTimeout = 100

+ var WSConnReadTimeout = 100 * time.Second

+ func NewError(err error, endpoint fatchoy.Endpoint) error

+ func NewFakeConn(node fatchoy.NodeID, addr string) fatchoy.Endpoint

+ type ConnBase struct

+ func (c *ConnBase) Context() *fatchoy.ServiceContext

+ func (c *ConnBase) Encoder() fatchoy.ProtocolCodec

+ func (c *ConnBase) IsClosing() bool

+ func (c *ConnBase) NodeID() fatchoy.NodeID

+ func (c *ConnBase) RemoteAddr() string

+ func (c *ConnBase) SetContext(v *fatchoy.ServiceContext)

+ func (c *ConnBase) SetEncrypt(encrypt cipher.BlockCryptor, decrypt cipher.BlockCryptor)

+ func (c *ConnBase) SetNodeID(node fatchoy.NodeID)

+ func (c *ConnBase) SetRemoteAddr(addr string)

+ func (c *ConnBase) SetUserData(ud interface{})

+ func (c *ConnBase) Stats() *fatchoy.Stats

+ func (c *ConnBase) UserData() interface{}

+ type Error struct

+ Endpoint fatchoy.Endpoint

+ Err error

+ func (e Error) Error() string

+ type FakeConn struct

+ func (c *FakeConn) Close() error

+ func (c *FakeConn) ForceClose(error)

+ func (c *FakeConn) Go(bool, bool)

+ func (c *FakeConn) RawConn() net.Conn

+ func (c *FakeConn) SendPacket(*fatchoy.Packet) error

+ type RpcContext struct

+ func NewRpcContext(request, reply int32, body interface{}, handler RpcHandler) *RpcContext

+ func (r *RpcContext) Body() interface{}

+ func (r *RpcContext) DecodeMsg(v proto.Message) error

+ func (r *RpcContext) Done(ec uint32, body interface{})

+ func (r *RpcContext) Errno() uint32

+ func (r *RpcContext) Run() error

+ func (r *RpcContext) Succeed() bool

+ type RpcFactory struct

+ func (r *RpcFactory) Call(request, reply int32, body proto.Message) *RpcContext

+ func (r *RpcFactory) CallAsync(request, reply int32, body proto.Message, cb RpcHandler) *RpcContext

+ func (r *RpcFactory) Go()

+ func (r *RpcFactory) Init(ctx *fatchoy.ServiceContext) error

+ func (r *RpcFactory) Shutdown()

+ type RpcHandler func(*RpcContext) error

+ type TcpConn struct

+ func NewTcpConn(node fatchoy.NodeID, conn net.Conn, encoder fatchoy.ProtocolCodec, ...) *TcpConn

+ func (t *TcpConn) Close() error

+ func (t *TcpConn) ForceClose(err error)

+ func (t *TcpConn) Go(writer, reader bool)

+ func (t *TcpConn) OutboundQueue() chan *fatchoy.Packet

+ func (t *TcpConn) RawConn() net.Conn

+ func (t *TcpConn) SendPacket(pkt *fatchoy.Packet) error

+ type TcpServer struct

+ func NewTcpServer(encoder fatchoy.ProtocolCodec, inbound chan *fatchoy.Packet, outsize int32) *TcpServer

+ func (s *TcpServer) BacklogChan() chan fatchoy.Endpoint

+ func (s *TcpServer) Close()

+ func (s *TcpServer) ErrorChan() chan error

+ func (s *TcpServer) Listen(addr string) error

+ func (s *TcpServer) Shutdown()

+ type WsConn struct

+ func NewWsConn(node fatchoy.NodeID, conn *websocket.Conn, encoder fatchoy.ProtocolCodec, ...) *WsConn

+ func (c *WsConn) Close() error

+ func (c *WsConn) ForceClose(err error)

+ func (c *WsConn) Go(writer, reader bool)

+ func (c *WsConn) RawConn() net.Conn

+ func (c *WsConn) SendPacket(pkt *fatchoy.Packet) error

+ type WsServer struct

+ func NewWebsocketServer(addr, path string, encoder fatchoy.ProtocolCodec, inbound chan *fatchoy.Packet, ...) *WsServer

+ func (s *WsServer) BacklogChan() chan *WsConn

+ func (s *WsServer) ErrChan() chan error

+ func (s *WsServer) Go()

+ func (s *WsServer) Shutdown()