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

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}

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
}