protocol

Documentation

Index

• func MagicNumber() byte
• type CompressType
• type Header
  • func (h Header) CheckMagicNumber() bool
  • func (h Header) TotalLength() TotalLength
  • func (h Header) Version() byte
• type HeaderLength
• type Message
• type MessageType
• type SerializerType
• type TotalLength
• type Version

Functions

func MagicNumber

func MagicNumber() byte

Types

type CompressType

type CompressType byte

Extend header

compressor

const (
	CompressNone CompressType = iota
	Gzip
)

type Header

type Header [11]byte

func (Header) CheckMagicNumber

func (h Header) CheckMagicNumber() bool

func (Header) TotalLength

func (h Header) TotalLength() TotalLength

func (Header) Version

func (h Header) Version() byte

type HeaderLength

type HeaderLength int16

type Message

type Message struct {
}

Define message

type MessageType

type MessageType byte

const (
	// Request Type
	Request MessageType = iota
	// Response Type
	Response
)

type SerializerType

type SerializerType byte

const (
	// Using raw []byte and don't serialize/deserialize
	SerializerNone SerializerType = iota
	// JSON for Payload
	JSON
	// Protobuf for Payload
	ProtoBuffer
	// MsgPack for Payload
	MsgPack
	// Thrift for Payload
	Thrift
)

type TotalLength

type TotalLength int32

type Version

type Version byte