parser

Documentation

Index

• Constants
• type Creator
• type Decode
• type Finish
• type PacketHeader
  • func (p *PacketHeader) IsAck() bool
  • func (p *PacketHeader) IsBinary() bool
  • func (p *PacketHeader) IsEvent() bool
  • func (p PacketHeader) MarshalBinary() ([]byte, error)
  • func (p *PacketHeader) UnmarshalBinary(data []byte) error
• type PacketType
  • func (p *PacketType) FromChar(b byte) error
  • func (p PacketType) ToChar() byte
• type Parser

Constants

const ProtocolVersion = 5

Types

type Creator

type Creator func() Parser

type Decode

type Decode func(types ...reflect.Type) (values []reflect.Value, err error)

type Finish

type Finish func(header *PacketHeader, eventName string, decode Decode)

type PacketHeader

type PacketHeader struct {
	Type        PacketType
	Namespace   string
	ID          *uint64
	Attachments int
}

func (*PacketHeader) IsAck

func (p *PacketHeader) IsAck() bool

func (*PacketHeader) IsBinary

func (p *PacketHeader) IsBinary() bool

func (*PacketHeader) IsEvent

func (p *PacketHeader) IsEvent() bool

func (PacketHeader) MarshalBinary

func (p PacketHeader) MarshalBinary() ([]byte, error)

func (*PacketHeader) UnmarshalBinary

func (p *PacketHeader) UnmarshalBinary(data []byte) error

type PacketType

type PacketType byte

const (
	PacketTypeConnect PacketType = iota
	PacketTypeDisconnect
	PacketTypeEvent
	PacketTypeAck
	PacketTypeConnectError
	PacketTypeBinaryEvent
	PacketTypeBinaryAck
)

func (*PacketType) FromChar

func (p *PacketType) FromChar(b byte) error

func (PacketType) ToChar

func (p PacketType) ToChar() byte

type Parser

type Parser interface {
	Encode(header *PacketHeader, v any) (buffers [][]byte, err error)
	Add(data []byte, finish Finish) error
	Reset()
	JSONSerializer() serializer.JSONSerializer
}