qnet

package
v0.6.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 11, 2022 License: BSD-3-Clause Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StatBytesRecv   int = iota // bytes received
	StatBytesSent              // bytes sent
	StatPacketsRecv            // packets received
	StatPacketsSent            // packets sent
	NumStat
)

Variables

View Source 
var (
	ErrConnIsClosing        = errors.New("connection is closing when sending")
	ErrConnOutboundOverflow = errors.New("connection outbound queue overflow")
	ErrConnForceClose       = errors.New("connection forced to close")
)
View Source 
var ErrBufferOutOfRange = errors.New("buffer out of range")
View Source 
var (
	RequestReadTimeout = 100 // 默认read超时时间，100s
)
View Source 
var (
	TConnReadTimeout = 200 // seconds
)

Functions

func DecodeRequestBody added in v0.6.3 

func DecodeRequestBody(req *http.Request, ptr interface{}) error

解析http请求的body为json

func GetClientIP added in v0.6.3 

func GetClientIP(req *http.Request) string

获取http请求的来源IP

func NewFakeConn 

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

func ReadMagicLenMessage added in v0.6.6 

func ReadMagicLenMessage(conn net.Conn, msg proto.Message) error

读取magic开头的message

func ReadPacket added in v0.6.6 

func ReadPacket(conn net.Conn, enc codec.Encoder, decrypt cipher.BlockCryptor) (*fatchoy.Packet, error)

func SendPacket added in v0.6.6 

func SendPacket(conn net.Conn, enc codec.Encoder, encrypt cipher.BlockCryptor, pkt *fatchoy.Packet) error

func WriteMagicLenMessage added in v0.6.6 

func WriteMagicLenMessage(conn net.Conn, msg proto.Message) error

写入magic开头的message

Types

type Buffer 

type Buffer struct {
	bytes.Buffer
}

func (*Buffer) PeekBool 

func (b *Buffer) PeekBool() bool

func (*Buffer) PeekFloat32 

func (b *Buffer) PeekFloat32() float32

func (*Buffer) PeekFloat64 

func (b *Buffer) PeekFloat64() float64

func (*Buffer) PeekInt16 

func (b *Buffer) PeekInt16() int16

func (*Buffer) PeekInt32 

func (b *Buffer) PeekInt32() int32

func (*Buffer) PeekInt64 

func (b *Buffer) PeekInt64() int64

func (*Buffer) PeekInt8 

func (b *Buffer) PeekInt8() int8

func (*Buffer) PeekUint16 

func (b *Buffer) PeekUint16() uint16

func (*Buffer) PeekUint32 

func (b *Buffer) PeekUint32() uint32

func (*Buffer) PeekUint64 

func (b *Buffer) PeekUint64() uint64

func (*Buffer) PeekUint8 

func (b *Buffer) PeekUint8() uint8

func (*Buffer) ReadBool 

func (b *Buffer) ReadBool() bool

func (*Buffer) ReadFloat32 

func (b *Buffer) ReadFloat32() float32

func (*Buffer) ReadFloat64 

func (b *Buffer) ReadFloat64() float64

func (*Buffer) ReadInt16 

func (b *Buffer) ReadInt16() int16

func (*Buffer) ReadInt32 

func (b *Buffer) ReadInt32() int32

func (*Buffer) ReadInt64 

func (b *Buffer) ReadInt64() int64

func (*Buffer) ReadInt8 

func (b *Buffer) ReadInt8() int8

func (*Buffer) ReadUint16 

func (b *Buffer) ReadUint16() uint16

func (*Buffer) ReadUint32 

func (b *Buffer) ReadUint32() uint32

func (*Buffer) ReadUint64 

func (b *Buffer) ReadUint64() uint64

func (*Buffer) ReadUint8 

func (b *Buffer) ReadUint8() uint8

func (*Buffer) WriteBool 

func (b *Buffer) WriteBool(v bool)

func (*Buffer) WriteFloat32 

func (b *Buffer) WriteFloat32(f float32)

func (*Buffer) WriteFloat64 

func (b *Buffer) WriteFloat64(f float64)

func (*Buffer) WriteInt16 

func (b *Buffer) WriteInt16(n int16)

func (*Buffer) WriteInt32 

func (b *Buffer) WriteInt32(n int32)

func (*Buffer) WriteInt64 

func (b *Buffer) WriteInt64(n int64)

func (*Buffer) WriteInt8 

func (b *Buffer) WriteInt8(n int8)

func (*Buffer) WriteUInt8 

func (b *Buffer) WriteUInt8(n uint8)

func (*Buffer) WriteUint16 

func (b *Buffer) WriteUint16(n uint16)

func (*Buffer) WriteUint32 

func (b *Buffer) WriteUint32(n uint32)

func (*Buffer) WriteUint64 

func (b *Buffer) WriteUint64(n uint64)

type Error 

type Error struct {
	Err      error
	Endpoint fatchoy.Endpoint
}

func NewError 

func NewError(err error, endpoint fatchoy.Endpoint) *Error

func (Error) Error 

func (e Error) Error() string

type FakeConn 

type FakeConn struct {
	StreamConn
}

a fake endpoint

func (*FakeConn) Close 

func (c *FakeConn) Close() error

func (*FakeConn) ForceClose 

func (c *FakeConn) ForceClose(error)

func (*FakeConn) Go 

func (c *FakeConn) Go(flag fatchoy.EndpointFlag)

func (*FakeConn) Node added in v0.6.2 

func (c *FakeConn) Node() fatchoy.NodeID

func (*FakeConn) RawConn 

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

func (*FakeConn) Send added in v0.4.1 

func (c *FakeConn) Send(pkt *fatchoy.Packet) error

func (*FakeConn) SetNode added in v0.6.2 

func (c *FakeConn) SetNode(v fatchoy.NodeID)

type StreamConn 

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

stream connection

func (*StreamConn) ErrorChan added in v0.3.5 

func (c *StreamConn) ErrorChan() <-chan error

func (*StreamConn) Init added in v0.1.14 

func (c *StreamConn) Init(node fatchoy.NodeID, enc codec.Encoder, incoming chan<- *fatchoy.Packet,
	outQueueSize int, stat *stats.Stats)

func (*StreamConn) IsRunning added in v0.1.20 

func (c *StreamConn) IsRunning() bool

func (*StreamConn) Node added in v0.6.2 

func (c *StreamConn) Node() fatchoy.NodeID

func (*StreamConn) OutMsgChan added in v0.4.1 

func (c *StreamConn) OutMsgChan() chan<- *fatchoy.Packet

func (*StreamConn) RemoteAddr 

func (c *StreamConn) RemoteAddr() string

func (*StreamConn) SetEncryptPair 

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

func (*StreamConn) SetNode added in v0.6.2 

func (c *StreamConn) SetNode(node fatchoy.NodeID)

func (*StreamConn) SetRemoteAddr 

func (c *StreamConn) SetRemoteAddr(addr string)

func (*StreamConn) SetUserData 

func (c *StreamConn) SetUserData(ud interface{})

func (*StreamConn) Stats 

func (c *StreamConn) Stats() *stats.Stats

func (*StreamConn) UserData 

func (c *StreamConn) UserData() interface{}

type TcpConn 

type TcpConn struct {
	StreamConn
	// contains filtered or unexported fields
}

TCP connection

func NewTcpConn 

func NewTcpConn(node fatchoy.NodeID, conn net.Conn, enc codec.Encoder, incoming chan<- *fatchoy.Packet,
	outsize int, stats *stats.Stats) *TcpConn

func (*TcpConn) Close 

func (t *TcpConn) Close() error

func (*TcpConn) ForceClose 

func (t *TcpConn) ForceClose(err error)

func (*TcpConn) Go 

func (t *TcpConn) Go(flag fatchoy.EndpointFlag)

func (*TcpConn) RawConn 

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

func (*TcpConn) Send added in v0.4.1 

func (t *TcpConn) Send(pkt *fatchoy.Packet) error

type TcpServer 

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

func NewTcpServer 

func NewTcpServer(enc codec.Encoder, incoming chan *fatchoy.Packet, outsize int) *TcpServer

func (*TcpServer) BacklogChan 

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

func (*TcpServer) Close 

func (s *TcpServer) Close()

func (*TcpServer) ErrorChan 

func (s *TcpServer) ErrorChan() chan error

func (*TcpServer) Listen 

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

func (*TcpServer) Shutdown 

func (s *TcpServer) Shutdown()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.