websocket

Documentation

Index

• type DefaultProtocol
  • func (Protocol *DefaultProtocol) Decode(message []byte) (version byte, messageType int, protoType int, route []byte, body []byte)
  • func (Protocol *DefaultProtocol) Encode(route []byte, body []byte, messageType int, protoType int) []byte
  • func (Protocol *DefaultProtocol) Read()
• type Protocol

Types

type DefaultProtocol

type DefaultProtocol struct{}

func (*DefaultProtocol) Decode

func (Protocol *DefaultProtocol) Decode(message []byte) (version byte, messageType int, protoType int, route []byte, body []byte)

func (*DefaultProtocol) Encode

func (Protocol *DefaultProtocol) Encode(route []byte, body []byte, messageType int, protoType int) []byte

func (*DefaultProtocol) Read

func (Protocol *DefaultProtocol) Read()

type Protocol

type Protocol interface {
	Decode(message []byte) (version byte, messageType int, protoType int, route []byte, body []byte)
	Encode(route []byte, body []byte, messageType int, protoType int) []byte
	Read()
}