rpc

Documentation

Index

• Variables
• func NewEngine(encoder types.Encoder, decoder types.Decoder) types.ProtocolEngine
• func NewMixedEngine() types.ProtocolEngine
• type RespStatus
• type RpcCmd

Variables

var (
	AlreadyRegistered = "protocol code already registered."
	UnknownType       = "unknown model type."
	UnrecognizedCode  = "unrecognized protocol code."
	NoProtocolCode    = "no protocol code found."

	ErrDupRegistered    = errors.New(AlreadyRegistered)
	ErrUnknownType      = errors.New(UnknownType)
	ErrUnrecognizedCode = errors.New(UnrecognizedCode)
	ErrNoProtocolCode   = errors.New(NoProtocolCode)
)

Functions

func NewEngine

func NewEngine(encoder types.Encoder, decoder types.Decoder) types.ProtocolEngine

func NewMixedEngine

func NewMixedEngine() types.ProtocolEngine

Types

type RespStatus

type RespStatus interface {
	RespStatus() uint32
}

ResponseStatus describe that the model has the [response status] information

type RpcCmd

type RpcCmd interface {
	types.HeaderMap

	ProtocolCode() byte

	RequestID() uint64

	SetRequestID(requestID uint64)

	Header() map[string]string

	Data() types.IoBuffer

	SetHeader(header map[string]string)

	SetData(data types.IoBuffer)

	GetTimeout() int
}

RpcCmd act as basic model for different protocols