dubbo

Documentation

Index

• func NewRpcClientPackageHandler() protocol.Protocol
• type CallType
• type DubboPackage
  • func (p *DubboPackage) Marshal() (*bytes.Buffer, error)
  • func (p *DubboPackage) Unmarshal(buf *bytes.Buffer, pendingRsp *sync.Map) error
• type Response
  • func NewResponse(reply interface{}, atta map[string]string) *Response
• type RpcClientPackageHandler
  • func (p RpcClientPackageHandler) Read(data []byte, pendingRsp *sync.Map) (interface{}, int, error)
  • func (p RpcClientPackageHandler) Write(clientReq *protocol.Request) ([]byte, error)
• type SequenceType
• type SerialID

Functions

func NewRpcClientPackageHandler

func NewRpcClientPackageHandler() protocol.Protocol

Types

type CallType

type CallType int32

CallType call type

const (
	// CT_UNKNOWN unknown call type
	CT_UNKNOWN CallType = 0
	// CT_OneWay call one way
	CT_OneWay CallType = 1
	// CT_TwoWay call in request/response
	CT_TwoWay CallType = 2
)

type DubboPackage

type DubboPackage struct {
	Header  hessian.DubboHeader
	Service hessian.Service
	Body    interface{}
	Err     error
}

nolint

func (*DubboPackage) Marshal

func (p *DubboPackage) Marshal() (*bytes.Buffer, error)

Marshal encode hessian package. DubboPackage -> byte

func (*DubboPackage) Unmarshal

func (p *DubboPackage) Unmarshal(buf *bytes.Buffer, pendingRsp *sync.Map) error

Unmarshal decodes hessian package. byte -> DubboPackage

type Response

type Response struct {
	Reply interface{}
	// contains filtered or unexported fields
}

////////////////////////////////////////// Response ////////////////////////////////////////// Response is protocol protocol response.

func NewResponse

func NewResponse(reply interface{}, atta map[string]string) *Response

NewResponse creates a new Response.

type RpcClientPackageHandler

type RpcClientPackageHandler struct {
}

RpcClientPackageHandler handle package for client in getty.

func (RpcClientPackageHandler) Read

func (p RpcClientPackageHandler) Read(data []byte, pendingRsp *sync.Map) (interface{}, int, error)

Read decode @data to DubboPackage.

func (RpcClientPackageHandler) Write

func (p RpcClientPackageHandler) Write(clientReq *protocol.Request) ([]byte, error)

Write encode @clientReq to []byte

type SequenceType

type SequenceType int64

SequenceType sequence type

type SerialID

type SerialID byte

SerialID serial ID

const (
	// S_Dubbo protocol serial id
	S_Dubbo SerialID = 2
)