dubbothrift

Documentation

Index

• Constants
• Variables
• type Frame
  • func NewRpcRequest(headers types.HeaderMap, data types.IoBuffer) *Frame
  • func NewRpcResponse(headers types.HeaderMap, data types.IoBuffer) *Frame
  • func (r *Frame) Clone() api.HeaderMap
  • func (r *Frame) GetData() types.IoBuffer
  • func (r *Frame) GetHeader() types.HeaderMap
  • func (r *Frame) GetRequestId() uint64
  • func (r *Frame) GetStatusCode() uint32
  • func (r *Frame) GetStreamType() api.StreamType
  • func (r *Frame) GetTimeout() int32
  • func (r *Frame) IsHeartbeatFrame() bool
  • func (r *Frame) SetData(data types.IoBuffer)
  • func (r *Frame) SetRequestId(id uint64)
• type Header
• type XCodec
  • func (codec *XCodec) HTTPMapping() api.HTTPMapping
  • func (codec *XCodec) NewXProtocol(_ context.Context) api.XProtocol
  • func (codec *XCodec) ProtocolMatch() api.ProtocolMatch
  • func (codec *XCodec) ProtocolName() api.ProtocolName

Constants

const (
	MessageLenSize       = 4
	MagicLen             = 2
	MessageLenIdx        = 2
	MessageHeaderLenIdx  = 6
	MessageHeaderLenSize = 2
	HeaderIdx            = 9
	HeaderLen            = 9
	IdLen                = 8
)

thrift protocol

const (
	EventRequest  int = 1 // request
	EventResponse int = 2 // response
)

const (
	ServiceNameHeader     string = "service"
	MethodNameHeader      string = "method"
	SeqIdNameHeader       string = "seqId"
	MessageTypeNameHeader string = "messageType"
)

const (
	ProtocolName = "dubbo-thrift"
)

const (
	ResponseStatusSuccess = uint16(thrift.REPLY)
)

const (
	UnKnownCmdType string = "unknown cmd type"
)

req/resp type

Variables

var MagicTag = []byte{0xda, 0xbc}

*

• Thrift framed protocol codec for dubbo. *
• |<- message header ->|<- message body ->|
• +----------------------+----------------+----------------------+------------------+---------------------------+------------------+
• message size (4 byte) | magic (2 bytes)|message size (4 bytes)|head size(2 bytes)| version (1 byte) | header | message body |
• +----------------------+----------------+----------------------+------------------+---------------------------+------------------+
• |<- message size ->| *
• header fields in version 1:
• string - service name
• long - dubbo request id

Types

type Frame

type Frame struct {
	Header
	// contains filtered or unexported fields
}

func NewRpcRequest

func NewRpcRequest(headers types.HeaderMap, data types.IoBuffer) *Frame

NewRpcRequest is a utility function which build rpc Request object of bolt protocol.

func NewRpcResponse

func NewRpcResponse(headers types.HeaderMap, data types.IoBuffer) *Frame

NewRpcResponse is a utility function which build rpc Response object of bolt protocol.

func (*Frame) Clone

func (r *Frame) Clone() api.HeaderMap

func (*Frame) GetData

func (r *Frame) GetData() types.IoBuffer

func (*Frame) GetHeader

func (r *Frame) GetHeader() types.HeaderMap

func (*Frame) GetRequestId

func (r *Frame) GetRequestId() uint64

~ XFrame

func (*Frame) GetStatusCode

func (r *Frame) GetStatusCode() uint32

func (*Frame) GetStreamType

func (r *Frame) GetStreamType() api.StreamType

func (*Frame) GetTimeout

func (r *Frame) GetTimeout() int32

dubbothrift use defualt timeout TODO: use dubbothrift timeout

func (*Frame) IsHeartbeatFrame

func (r *Frame) IsHeartbeatFrame() bool

func (*Frame) SetData

func (r *Frame) SetData(data types.IoBuffer)

func (*Frame) SetRequestId

func (r *Frame) SetRequestId(id uint64)

type Header

type Header struct {
	FrameLength   uint32
	Magic         []byte
	MessageLength uint32
	HeaderLength  uint16
	Version       byte
	Id            uint64
	Direction     int
	protocol.CommonHeader
}

type XCodec

type XCodec struct {
	// contains filtered or unexported fields
}

func (*XCodec) HTTPMapping

func (codec *XCodec) HTTPMapping() api.HTTPMapping

not implement yet

func (*XCodec) NewXProtocol

func (codec *XCodec) NewXProtocol(_ context.Context) api.XProtocol

func (*XCodec) ProtocolMatch

func (codec *XCodec) ProtocolMatch() api.ProtocolMatch

func (*XCodec) ProtocolName

func (codec *XCodec) ProtocolName() api.ProtocolName