Documentation ¶
Index ¶
- Constants
- Variables
- type Decoder
- func (decoder *Decoder) Clean()
- func (decoder *Decoder) DecodeData(buf []byte) (n int, err error)
- func (decoder *Decoder) DecodeDataFull(buf []byte) (n int, err error)
- func (decoder *Decoder) DecodeInt32() (int32, error)
- func (decoder *Decoder) DecodeInt32Tiny() (int32, error)
- func (decoder *Decoder) DecodeInt8() (int8, error)
- func (decoder *Decoder) DecodeInt8Tiny() (int8, error)
- func (decoder *Decoder) DecodeUInt32() (uint32, error)
- func (decoder *Decoder) DecodeUInt32Tiny() (uint32, error)
- func (decoder *Decoder) DecodeUInt64() (uint64, error)
- func (decoder *Decoder) DecodeUInt64Tiny() (uint64, error)
- type Encoder
- func (encoder *Encoder) Clean()
- func (encoder *Encoder) EncodeData(data []byte) (err error)
- func (encoder *Encoder) EncodeInt32(data int32) (err error)
- func (encoder *Encoder) EncodeInt32Tiny(data int32) (err error)
- func (encoder *Encoder) EncodeInt8(data int8) (err error)
- func (encoder *Encoder) EncodeInt8Tiny(data int8) (err error)
- func (encoder *Encoder) EncodeUInt32(data uint32) (err error)
- func (encoder *Encoder) EncodeUInt32Tiny(data uint32) (err error)
- func (encoder *Encoder) EncodeUInt64(data uint64) (err error)
- func (encoder *Encoder) EncodeUInt64Tiny(data uint64) (err error)
- func (encoder *Encoder) Flush() error
- type HeadCodec
- type IOModule
- func (ioModule *IOModule) Close()
- func (ioModule *IOModule) Codec(codec defs.ICodec) bool
- func (ioModule *IOModule) OnConnectionLost()
- func (ioModule *IOModule) UpdateCodec(codec defs.ICodec)
- func (ioModule *IOModule) Write(packet defs.IPacket)
- func (ioModule *IOModule) WriteAwait(packet defs.IPacket) (response defs.IPacket, err error)
- type RpcCall
- type StreamCodec
- type WSCodec
Constants ¶
View Source
const (
DefaultBufferSize = 8 * 1024
)
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Decoder ¶
type Decoder struct {
// contains filtered or unexported fields
}
func (*Decoder) DecodeDataFull ¶
func (*Decoder) DecodeInt32 ¶
func (*Decoder) DecodeInt32Tiny ¶
func (*Decoder) DecodeInt8 ¶
func (*Decoder) DecodeInt8Tiny ¶
func (*Decoder) DecodeUInt32 ¶
func (*Decoder) DecodeUInt32Tiny ¶
func (*Decoder) DecodeUInt64 ¶
func (*Decoder) DecodeUInt64Tiny ¶
type Encoder ¶
type Encoder struct {
// contains filtered or unexported fields
}
func (*Encoder) EncodeData ¶
func (*Encoder) EncodeInt32 ¶
func (*Encoder) EncodeInt32Tiny ¶
func (*Encoder) EncodeInt8 ¶
func (*Encoder) EncodeInt8Tiny ¶
func (*Encoder) EncodeUInt32 ¶
func (*Encoder) EncodeUInt32Tiny ¶
func (*Encoder) EncodeUInt64 ¶
func (*Encoder) EncodeUInt64Tiny ¶
type HeadCodec ¶
type HeadCodec struct {
// contains filtered or unexported fields
}
func NewHeadCodec ¶
func NewHeadCodec() *HeadCodec
type IOModule ¶
type IOModule struct {
// contains filtered or unexported fields
}
func NewIOModule ¶
func NewIOModule(conn defs.IConnection) *IOModule
func (*IOModule) OnConnectionLost ¶
func (ioModule *IOModule) OnConnectionLost()
func (*IOModule) UpdateCodec ¶
type StreamCodec ¶
type StreamCodec struct {
// contains filtered or unexported fields
}
func NewStreamCodec ¶
func NewStreamCodec() *StreamCodec
func (*StreamCodec) Init ¶
func (sc *StreamCodec) Init(conn defs.IConnection) bool
type WSCodec ¶
type WSCodec struct {
// contains filtered or unexported fields
}
func NewWSCodec ¶
func NewWSCodec() *WSCodec
Click to show internal directories.
Click to hide internal directories.