packet

Documentation

Index

• Constants
• Variables
• type FrameDecoder
  • func NewFrameDecoder(lengthFieldLength, lengthFieldOffset int, byteOrder binary.ByteOrder) *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
  • func NewPacket(opcode uint16, buf ...byte) *Packet
  • func (p *Packet) Bufer() []byte
  • func (p *Packet) Opcode() uint16
• type Ping
  • func (p *Ping) ChannelActive(c channel.HandlerContext)
  • func (p *Ping) ChannelInActive(c channel.HandlerContext)
  • func (p *Ping) ChannelRead(c channel.HandlerContext, msg interface{})
  • func (p *Ping) OnError(c channel.HandlerContext, err error)
• type Pong
  • func (p *Pong) ChannelActive(c channel.HandlerContext)
  • func (p *Pong) ChannelInActive(c channel.HandlerContext)
  • func (p *Pong) ChannelRead(c channel.HandlerContext, msg interface{})
  • func (p *Pong) OnError(c channel.HandlerContext, err error)

Constants

const (
	OpPing    = 0x1001
	OpPong    = 0x1002
	OpMessage = 0x0001
)

Variables

var (
	OffSet             = 4
	BodyLength         = 8
	MagicNumber uint16 = 0xcafe
)

var (
	ErrInvalidPacket = errors.New("invalid packet")
	PacketPool       = sync.Pool{New: func() interface{} { return &Packet{} }}
)

var (
	ErrIllegalLengthField = errors.New("illegal length field")
)

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 Packet

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

func NewPacket

func NewPacket(opcode uint16, buf ...byte) *Packet

func (*Packet) Bufer

func (p *Packet) Bufer() []byte

func (*Packet) Opcode

func (p *Packet) Opcode() uint16

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{})

func (*Ping) OnError

func (p *Ping) OnError(c channel.HandlerContext, err error)

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{})

func (*Pong) OnError

func (p *Pong) OnError(c channel.HandlerContext, err error)