protocol

package

v0.0.0-...-b9d6073 Latest Latest Go to latest Published: Jun 19, 2018 License: Apache-2.0 Imports: 10 Imported by: 3

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Loopring/motan-go

Links

Open Source Insights

Documentation ¶

Overview ¶

Package protocol is motan2 protocol codec implements.

Index ¶

Constants
func ConvertToRequest(request *Message, serialize motan.Serialization) (motan.Request, error)
func ConvertToResponse(response *Message, serialize motan.Serialization) (motan.Response, error)
func DecodeGzip(data []byte) ([]byte, error)
func DecodeGzipBody(body []byte) []byte
func EncodeGzip(data []byte) ([]byte, error)
func ExceptionToJSON(e *motan.Exception) string
type Header
type Message
- func (msg *Message) Encode() (buf *bytes.Buffer)

Constants ¶

View Source

const (
	Req = iota
	Res
)

message type

View Source

const (
	MotanMagic   = 0xf1f1
	HeaderLength = 13
)

message magic

View Source

const (
	MPath          = "M_p"
	MMethod        = "M_m"
	MExceptionn    = "M_e"
	MProcessTime   = "M_pt"
	MMethodDesc    = "M_md"
	MGroup         = "M_g"
	MProxyProtocol = "M_pp"
	MVersion       = "M_v"
	MModule        = "M_mdu"
	MSource        = "M_s"
)

View Source

const (
	Hessian = iota
	GrpcPb
	JSON
	Msgpack
	Hprose
	Pb
	Simple
	GrpcJSON
)

serialize

View Source

const (
	Normal = iota
	Exception
)

message status

Variables ¶

This section is empty.

Functions ¶

func ConvertToRequest ¶

func ConvertToRequest(request *Message, serialize motan.Serialization) (motan.Request, error)

ConvertToRequest convert motan2 protocol request message to motan Request

func ConvertToResponse ¶

func ConvertToResponse(response *Message, serialize motan.Serialization) (motan.Response, error)

ConvertToResponse convert protocol response to motan Response

func DecodeGzip ¶

func DecodeGzip(data []byte) ([]byte, error)

DecodeGzip : decode gzip

func DecodeGzipBody ¶

func DecodeGzipBody(body []byte) []byte

func EncodeGzip ¶

func EncodeGzip(data []byte) ([]byte, error)

EncodeGzip : encode gzip

func ExceptionToJSON ¶

func ExceptionToJSON(e *motan.Exception) string

Types ¶

type Header ¶

type Header struct {
	Magic         uint16
	MsgType       uint8
	VersionStatus uint8
	Serialize     uint8
	RequestID     uint64
}

func BuildHeader ¶

func BuildHeader(msgType int, proxy bool, serialize int, requestID uint64, msgStatus int) *Header

BuildHeader build header with common set

func BuildRequestHeader ¶

func BuildRequestHeader(requestID uint64) *Header

BuildRequestHeader build a proxy request header

func BuildResponseHeader ¶

func BuildResponseHeader(requestID uint64, msgStatus int) *Header

func (h *Header) GetSerialize() int

func (h *Header) GetStatus() int

func (h *Header) GetVersion() int

func (h *Header) IsGzip() bool

func (h *Header) IsHeartbeat() bool

func (h *Header) IsOneWay() bool

func (h *Header) IsProxy() bool

func (h *Header) SetGzip(isgzip bool)

func (h *Header) SetHeartbeat(isHeartbeat bool)

func (h *Header) SetOneWay(isOneWay bool)

func (h *Header) SetProxy(isProxy bool)

func (h *Header) SetRequest(isRequest bool)

func (h *Header) SetSerialize(serialize int) error

func (h *Header) SetStatus(status int) error

func (h *Header) SetVersion(version int) error

type Message ¶

type Message struct {
	Header   *Header
	Metadata map[string]string
	Body     []byte
	Type     int
}

func BuildExceptionResponse ¶

func BuildExceptionResponse(requestID uint64, errmsg string) *Message

func BuildHeartbeat ¶

func BuildHeartbeat(requestID uint64, msgType int) *Message

func ConvertToReqMessage ¶

func ConvertToReqMessage(request motan.Request, serialize motan.Serialization) (*Message, error)

ConvertToReqMessage convert motan Request to protocol request

func ConvertToResMessage ¶

func ConvertToResMessage(response motan.Response, serialize motan.Serialization) (*Message, error)

ConvertToResMessage convert motan Response to protocol response

func Decode ¶

func Decode(buf *bufio.Reader) (msg *Message, err error)

func (*Message) Encode ¶

func (msg *Message) Encode() (buf *bytes.Buffer)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Overview ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func ConvertToRequest ¶

func ConvertToResponse ¶

func DecodeGzip ¶

func DecodeGzipBody ¶

func EncodeGzip ¶

func ExceptionToJSON ¶

Types ¶

type Header ¶

func BuildHeader ¶

func BuildRequestHeader ¶

func BuildResponseHeader ¶

func (*Header) GetSerialize ¶

func (*Header) GetStatus ¶

func (*Header) GetVersion ¶

func (*Header) IsGzip ¶

func (*Header) IsHeartbeat ¶

func (*Header) IsOneWay ¶

func (*Header) IsProxy ¶

func (*Header) SetGzip ¶

func (*Header) SetHeartbeat ¶

func (*Header) SetOneWay ¶

func (*Header) SetProxy ¶

func (*Header) SetRequest ¶

func (*Header) SetSerialize ¶

func (*Header) SetStatus ¶

func (*Header) SetVersion ¶

type Message ¶

func BuildExceptionResponse ¶

func BuildHeartbeat ¶

func ConvertToReqMessage ¶

func ConvertToResMessage ¶

func Decode ¶

func (*Message) Encode ¶

Source Files ¶