websocket

Documentation

Index

• Constants
• Variables
• type DefaultProtocol
  • func (p *DefaultProtocol) Decode(message []byte) (messageType byte, id int64, route []byte, body []byte)
  • func (p *DefaultProtocol) Encode(messageType byte, id int64, route []byte, body []byte) []byte
  • func (p *DefaultProtocol) Reader() func(n int, buf []byte, fn func(bytes []byte)) error
• type Protocol

Constants

const HeadLen = 16

Variables

var PingMessage = []byte{0x0, 0x0, 0x9, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0}

var PongMessage = []byte{0x0, 0x0, 0xa, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0}

Types

type DefaultProtocol

type DefaultProtocol struct{}

func (*DefaultProtocol) Decode

func (p *DefaultProtocol) Decode(message []byte) (messageType byte, id int64, route []byte, body []byte)

func (*DefaultProtocol) Encode

func (p *DefaultProtocol) Encode(messageType byte, id int64, route []byte, body []byte) []byte

func (*DefaultProtocol) Reader

func (p *DefaultProtocol) Reader() func(n int, buf []byte, fn func(bytes []byte)) error

type Protocol

type Protocol interface {
	Decode(message []byte) (messageType byte, id int64, route []byte, body []byte)
	Encode(messageType byte, id int64, route []byte, body []byte) []byte
	Reader() func(n int, buf []byte, fn func(bytes []byte)) error
}