Documentation ¶
Index ¶
- Constants
- Variables
- type FrameDecoder
- func (f *FrameDecoder) ChannelActive(c channel.HandlerContext)
- func (f *FrameDecoder) ChannelInActive(c channel.HandlerContext)
- func (f *FrameDecoder) ChannelRead(c channel.HandlerContext, _ interface{})
- func (f *FrameDecoder) Flush(c channel.HandlerContext) error
- func (f *FrameDecoder) OnError(c channel.HandlerContext, err error)
- func (f *FrameDecoder) SetProcessNum(p int)
- func (f *FrameDecoder) Write(c channel.HandlerContext, data interface{}) error
- type Packet
- type Ping
- type Pong
Constants ¶
View Source
const ( OpPing = 0x1001 OpPong = 0x1002 OpMessage = 0x0001 )
Variables ¶
View Source
var ( OffSet = 4 BodyLength = 8 MagicNumber uint16 = 0xcafe )
View Source
var ( ErrInvalidPacket = errors.New("invalid packet") PacketPool = sync.Pool{New: func() interface{} { return &Packet{} }} )
View Source
var (
ErrIllegalLengthField = errors.New("illegal length field")
)
Functions ¶
This section is empty.
Types ¶
type FrameDecoder ¶
type FrameDecoder struct {
// contains filtered or unexported fields
}
func NewFrameDecoder ¶
func NewFrameDecoder(lengthFieldLength, lengthFieldOffset int, byteOrder binary.ByteOrder) *FrameDecoder
func (*FrameDecoder) ChannelActive ¶
func (f *FrameDecoder) ChannelActive(c channel.HandlerContext)
func (*FrameDecoder) ChannelInActive ¶
func (f *FrameDecoder) ChannelInActive(c channel.HandlerContext)
func (*FrameDecoder) ChannelRead ¶
func (f *FrameDecoder) ChannelRead(c channel.HandlerContext, _ interface{})
func (*FrameDecoder) Flush ¶
func (f *FrameDecoder) Flush(c channel.HandlerContext) error
func (*FrameDecoder) OnError ¶
func (f *FrameDecoder) OnError(c channel.HandlerContext, err error)
func (*FrameDecoder) SetProcessNum ¶
func (f *FrameDecoder) SetProcessNum(p int)
func (*FrameDecoder) Write ¶
func (f *FrameDecoder) Write(c channel.HandlerContext, data interface{}) error
OutboundHandler
type Ping ¶
type Ping struct {
// contains filtered or unexported fields
}
func (*Ping) ChannelActive ¶
func (p *Ping) ChannelActive(c channel.HandlerContext)
func (*Ping) ChannelInActive ¶
func (p *Ping) ChannelInActive(c channel.HandlerContext)
func (*Ping) ChannelRead ¶
func (p *Ping) ChannelRead(c channel.HandlerContext, msg interface{})
type Pong ¶
type Pong struct{}
func (*Pong) ChannelActive ¶
func (p *Pong) ChannelActive(c channel.HandlerContext)
func (*Pong) ChannelInActive ¶
func (p *Pong) ChannelInActive(c channel.HandlerContext)
func (*Pong) ChannelRead ¶
func (p *Pong) ChannelRead(c channel.HandlerContext, msg interface{})
Click to show internal directories.
Click to hide internal directories.