tcp

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) Reader() func(n int, buf []byte) ([]byte, error)
• 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) Reader

func (Protocol *DefaultProtocol) Reader() func(n int, buf []byte) ([]byte, error)

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
	Reader() func(n int, buf []byte) ([]byte, error)
}