trpc

package module
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 16, 2023 License: Apache-2.0 Imports: 4 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TrpcMagic_name = map[int32]string{
		0:    "TRPC_DEFAULT_NONE",
		2352: "TRPC_MAGIC_VALUE",
	}
	TrpcMagic_value = map[string]int32{
		"TRPC_DEFAULT_NONE": 0,
		"TRPC_MAGIC_VALUE":  2352,
	}
)

Enum value maps for TrpcMagic.

View Source 
var (
	TrpcDataFrameType_name = map[int32]string{
		0: "TRPC_UNARY_FRAME",
		1: "TRPC_STREAM_FRAME",
	}
	TrpcDataFrameType_value = map[string]int32{
		"TRPC_UNARY_FRAME":  0,
		"TRPC_STREAM_FRAME": 1,
	}
)

Enum value maps for TrpcDataFrameType.

View Source 
var (
	TrpcStreamFrameType_name = map[int32]string{
		0: "TRPC_UNARY",
		1: "TRPC_STREAM_FRAME_INIT",
		2: "TRPC_STREAM_FRAME_DATA",
		3: "TRPC_STREAM_FRAME_FEEDBACK",
		4: "TRPC_STREAM_FRAME_CLOSE",
	}
	TrpcStreamFrameType_value = map[string]int32{
		"TRPC_UNARY":                 0,
		"TRPC_STREAM_FRAME_INIT":     1,
		"TRPC_STREAM_FRAME_DATA":     2,
		"TRPC_STREAM_FRAME_FEEDBACK": 3,
		"TRPC_STREAM_FRAME_CLOSE":    4,
	}
)

Enum value maps for TrpcStreamFrameType.

View Source 
var (
	TrpcStreamCloseType_name = map[int32]string{
		0: "TRPC_STREAM_CLOSE",
		1: "TRPC_STREAM_RESET",
	}
	TrpcStreamCloseType_value = map[string]int32{
		"TRPC_STREAM_CLOSE": 0,
		"TRPC_STREAM_RESET": 1,
	}
)

Enum value maps for TrpcStreamCloseType.

View Source 
var (
	TrpcProtoVersion_name = map[int32]string{
		0: "TRPC_PROTO_V1",
	}
	TrpcProtoVersion_value = map[string]int32{
		"TRPC_PROTO_V1": 0,
	}
)

Enum value maps for TrpcProtoVersion.

View Source 
var (
	TrpcCallType_name = map[int32]string{
		0: "TRPC_UNARY_CALL",
		1: "TRPC_ONEWAY_CALL",
	}
	TrpcCallType_value = map[string]int32{
		"TRPC_UNARY_CALL":  0,
		"TRPC_ONEWAY_CALL": 1,
	}
)

Enum value maps for TrpcCallType.

View Source 
var (
	TrpcMessageType_name = map[int32]string{
		0:  "TRPC_DEFAULT",
		1:  "TRPC_DYEING_MESSAGE",
		2:  "TRPC_TRACE_MESSAGE",
		4:  "TRPC_MULTI_ENV_MESSAGE",
		8:  "TRPC_GRID_MESSAGE",
		16: "TRPC_SETNAME_MESSAGE",
	}
	TrpcMessageType_value = map[string]int32{
		"TRPC_DEFAULT":           0,
		"TRPC_DYEING_MESSAGE":    1,
		"TRPC_TRACE_MESSAGE":     2,
		"TRPC_MULTI_ENV_MESSAGE": 4,
		"TRPC_GRID_MESSAGE":      8,
		"TRPC_SETNAME_MESSAGE":   16,
	}
)

Enum value maps for TrpcMessageType.

View Source 
var (
	TrpcContentEncodeType_name = map[int32]string{
		0: "TRPC_PROTO_ENCODE",
		1: "TRPC_JCE_ENCODE",
		2: "TRPC_JSON_ENCODE",
		3: "TRPC_FLATBUFFER_ENCODE",
		4: "TRPC_NOOP_ENCODE",
		5: "TRPC_XML_ENCODE",
		6: "TRPC_THRIFT_ENCODE",
	}
	TrpcContentEncodeType_value = map[string]int32{
		"TRPC_PROTO_ENCODE":      0,
		"TRPC_JCE_ENCODE":        1,
		"TRPC_JSON_ENCODE":       2,
		"TRPC_FLATBUFFER_ENCODE": 3,
		"TRPC_NOOP_ENCODE":       4,
		"TRPC_XML_ENCODE":        5,
		"TRPC_THRIFT_ENCODE":     6,
	}
)

Enum value maps for TrpcContentEncodeType.

View Source 
var (
	TrpcCompressType_name = map[int32]string{
		0: "TRPC_DEFAULT_COMPRESS",
		1: "TRPC_GZIP_COMPRESS",
		2: "TRPC_SNAPPY_COMPRESS",
		3: "TRPC_ZLIB_COMPRESS",
		4: "TRPC_SNAPPY_STREAM_COMPRESS",
		5: "TRPC_SNAPPY_BLOCK_COMPRESS",
		6: "TRPC_LZ4_FRAME_COMPRESS",
		7: "TRPC_LZ4_BLOCK_COMPRESS",
	}
	TrpcCompressType_value = map[string]int32{
		"TRPC_DEFAULT_COMPRESS":       0,
		"TRPC_GZIP_COMPRESS":          1,
		"TRPC_SNAPPY_COMPRESS":        2,
		"TRPC_ZLIB_COMPRESS":          3,
		"TRPC_SNAPPY_STREAM_COMPRESS": 4,
		"TRPC_SNAPPY_BLOCK_COMPRESS":  5,
		"TRPC_LZ4_FRAME_COMPRESS":     6,
		"TRPC_LZ4_BLOCK_COMPRESS":     7,
	}
)

Enum value maps for TrpcCompressType.

View Source 
var (
	TrpcRetCode_name = map[int32]string{
		0:    "TRPC_INVOKE_SUCCESS",
		1:    "TRPC_SERVER_DECODE_ERR",
		2:    "TRPC_SERVER_ENCODE_ERR",
		11:   "TRPC_SERVER_NOSERVICE_ERR",
		12:   "TRPC_SERVER_NOFUNC_ERR",
		21:   "TRPC_SERVER_TIMEOUT_ERR",
		22:   "TRPC_SERVER_OVERLOAD_ERR",
		23:   "TRPC_SERVER_LIMITED_ERR",
		24:   "TRPC_SERVER_FULL_LINK_TIMEOUT_ERR",
		31:   "TRPC_SERVER_SYSTEM_ERR",
		41:   "TRPC_SERVER_AUTH_ERR",
		51:   "TRPC_SERVER_VALIDATE_ERR",
		101:  "TRPC_CLIENT_INVOKE_TIMEOUT_ERR",
		102:  "TRPC_CLIENT_FULL_LINK_TIMEOUT_ERR",
		111:  "TRPC_CLIENT_CONNECT_ERR",
		121:  "TRPC_CLIENT_ENCODE_ERR",
		122:  "TRPC_CLIENT_DECODE_ERR",
		123:  "TRPC_CLIENT_LIMITED_ERR",
		124:  "TRPC_CLIENT_OVERLOAD_ERR",
		131:  "TRPC_CLIENT_ROUTER_ERR",
		141:  "TRPC_CLIENT_NETWORK_ERR",
		151:  "TRPC_CLIENT_VALIDATE_ERR",
		161:  "TRPC_CLIENT_CANCELED_ERR",
		171:  "TRPC_CLIENT_READ_FRAME_ERR",
		201:  "TRPC_STREAM_SERVER_NETWORK_ERR",
		211:  "TRPC_STREAM_SERVER_MSG_EXCEED_LIMIT_ERR",
		221:  "TRPC_STREAM_SERVER_ENCODE_ERR",
		222:  "TRPC_STREAM_SERVER_DECODE_ERR",
		231:  "TRPC_STREAM_SERVER_WRITE_END",
		232:  "TRPC_STREAM_SERVER_WRITE_OVERFLOW_ERR",
		233:  "TRPC_STREAM_SERVER_WRITE_CLOSE_ERR",
		234:  "TRPC_STREAM_SERVER_WRITE_TIMEOUT_ERR",
		251:  "TRPC_STREAM_SERVER_READ_END",
		252:  "TRPC_STREAM_SERVER_READ_CLOSE_ERR",
		253:  "TRPC_STREAM_SERVER_READ_EMPTY_ERR",
		254:  "TRPC_STREAM_SERVER_READ_TIMEOUT_ERR",
		301:  "TRPC_STREAM_CLIENT_NETWORK_ERR",
		311:  "TRPC_STREAM_CLIENT_MSG_EXCEED_LIMIT_ERR",
		321:  "TRPC_STREAM_CLIENT_ENCODE_ERR",
		322:  "TRPC_STREAM_CLIENT_DECODE_ERR",
		331:  "TRPC_STREAM_CLIENT_WRITE_END",
		332:  "TRPC_STREAM_CLIENT_WRITE_OVERFLOW_ERR",
		333:  "TRPC_STREAM_CLIENT_WRITE_CLOSE_ERR",
		334:  "TRPC_STREAM_CLIENT_WRITE_TIMEOUT_ERR",
		351:  "TRPC_STREAM_CLIENT_READ_END",
		352:  "TRPC_STREAM_CLIENT_READ_CLOSE_ERR",
		353:  "TRPC_STREAM_CLIENT_READ_EMPTY_ERR",
		354:  "TRPC_STREAM_CLIENT_READ_TIMEOUT_ERR",
		999:  "TRPC_INVOKE_UNKNOWN_ERR",
		1000: "TRPC_STREAM_UNKNOWN_ERR",
	}
	TrpcRetCode_value = map[string]int32{
		"TRPC_INVOKE_SUCCESS":                     0,
		"TRPC_SERVER_DECODE_ERR":                  1,
		"TRPC_SERVER_ENCODE_ERR":                  2,
		"TRPC_SERVER_NOSERVICE_ERR":               11,
		"TRPC_SERVER_NOFUNC_ERR":                  12,
		"TRPC_SERVER_TIMEOUT_ERR":                 21,
		"TRPC_SERVER_OVERLOAD_ERR":                22,
		"TRPC_SERVER_LIMITED_ERR":                 23,
		"TRPC_SERVER_FULL_LINK_TIMEOUT_ERR":       24,
		"TRPC_SERVER_SYSTEM_ERR":                  31,
		"TRPC_SERVER_AUTH_ERR":                    41,
		"TRPC_SERVER_VALIDATE_ERR":                51,
		"TRPC_CLIENT_INVOKE_TIMEOUT_ERR":          101,
		"TRPC_CLIENT_FULL_LINK_TIMEOUT_ERR":       102,
		"TRPC_CLIENT_CONNECT_ERR":                 111,
		"TRPC_CLIENT_ENCODE_ERR":                  121,
		"TRPC_CLIENT_DECODE_ERR":                  122,
		"TRPC_CLIENT_LIMITED_ERR":                 123,
		"TRPC_CLIENT_OVERLOAD_ERR":                124,
		"TRPC_CLIENT_ROUTER_ERR":                  131,
		"TRPC_CLIENT_NETWORK_ERR":                 141,
		"TRPC_CLIENT_VALIDATE_ERR":                151,
		"TRPC_CLIENT_CANCELED_ERR":                161,
		"TRPC_CLIENT_READ_FRAME_ERR":              171,
		"TRPC_STREAM_SERVER_NETWORK_ERR":          201,
		"TRPC_STREAM_SERVER_MSG_EXCEED_LIMIT_ERR": 211,
		"TRPC_STREAM_SERVER_ENCODE_ERR":           221,
		"TRPC_STREAM_SERVER_DECODE_ERR":           222,
		"TRPC_STREAM_SERVER_WRITE_END":            231,
		"TRPC_STREAM_SERVER_WRITE_OVERFLOW_ERR":   232,
		"TRPC_STREAM_SERVER_WRITE_CLOSE_ERR":      233,
		"TRPC_STREAM_SERVER_WRITE_TIMEOUT_ERR":    234,
		"TRPC_STREAM_SERVER_READ_END":             251,
		"TRPC_STREAM_SERVER_READ_CLOSE_ERR":       252,
		"TRPC_STREAM_SERVER_READ_EMPTY_ERR":       253,
		"TRPC_STREAM_SERVER_READ_TIMEOUT_ERR":     254,
		"TRPC_STREAM_CLIENT_NETWORK_ERR":          301,
		"TRPC_STREAM_CLIENT_MSG_EXCEED_LIMIT_ERR": 311,
		"TRPC_STREAM_CLIENT_ENCODE_ERR":           321,
		"TRPC_STREAM_CLIENT_DECODE_ERR":           322,
		"TRPC_STREAM_CLIENT_WRITE_END":            331,
		"TRPC_STREAM_CLIENT_WRITE_OVERFLOW_ERR":   332,
		"TRPC_STREAM_CLIENT_WRITE_CLOSE_ERR":      333,
		"TRPC_STREAM_CLIENT_WRITE_TIMEOUT_ERR":    334,
		"TRPC_STREAM_CLIENT_READ_END":             351,
		"TRPC_STREAM_CLIENT_READ_CLOSE_ERR":       352,
		"TRPC_STREAM_CLIENT_READ_EMPTY_ERR":       353,
		"TRPC_STREAM_CLIENT_READ_TIMEOUT_ERR":     354,
		"TRPC_INVOKE_UNKNOWN_ERR":                 999,
		"TRPC_STREAM_UNKNOWN_ERR":                 1000,
	}
)

Enum value maps for TrpcRetCode.

View Source 
var File_trpc_trpc_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type RequestProtocol 

type RequestProtocol struct {

	// 协议版本
	// 具体值与TrpcProtoVersion对应
	Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// 请求的调用类型
	// 比如: 普通调用，单向调用
	// 具体值与TrpcCallType对应
	CallType uint32 `protobuf:"varint,2,opt,name=call_type,json=callType,proto3" json:"call_type,omitempty"`
	// 请求唯一id
	RequestId uint32 `protobuf:"varint,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 请求的超时时间，单位ms
	Timeout uint32 `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// 主调服务的名称
	// trpc协议下的规范格式: trpc.应用名.服务名.pb的service名, 4段
	Caller []byte `protobuf:"bytes,5,opt,name=caller,proto3" json:"caller,omitempty"`
	// 被调服务的路由名称
	// trpc协议下的规范格式，trpc.应用名.服务名.pb的service名[.接口名]
	// 前4段是必须有，接口可选。
	Callee []byte `protobuf:"bytes,6,opt,name=callee,proto3" json:"callee,omitempty"`
	// 调用服务的接口名
	// 规范格式: /package.Service名称/接口名
	Func []byte `protobuf:"bytes,7,opt,name=func,proto3" json:"func,omitempty"`
	// 框架信息透传的消息类型
	// 比如调用链、染色key、灰度、鉴权、多环境、set名称等的标识
	// 具体值与TrpcMessageType对应
	MessageType uint32 `protobuf:"varint,8,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	// 框架透传的信息key-value对，目前分两部分
	// 1是框架层要透传的信息，key的名字要以trpc-开头
	// 2是业务层要透传的信息，业务可以自行设置
	TransInfo map[string][]byte `` /* 176-byte string literal not displayed */
	// 请求数据的序列化类型
	// 比如: proto/jce/json, 默认proto
	// 具体值与TrpcContentEncodeType对应
	ContentType uint32 `protobuf:"varint,10,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// 请求数据使用的压缩方式
	// 比如: gzip/snappy/..., 默认不使用
	// 具体值与TrpcCompressType对应
	ContentEncoding uint32 `protobuf:"varint,11,opt,name=content_encoding,json=contentEncoding,proto3" json:"content_encoding,omitempty"`
	// attachment大小
	AttachmentSize uint32 `protobuf:"varint,12,opt,name=attachment_size,json=attachmentSize,proto3" json:"attachment_size,omitempty"`
	// contains filtered or unexported fields
}

请求协议头

func (*RequestProtocol) Descriptor deprecated 

func (*RequestProtocol) Descriptor() ([]byte, []int)

Deprecated: Use RequestProtocol.ProtoReflect.Descriptor instead.

func (*RequestProtocol) GetAttachmentSize 

func (x *RequestProtocol) GetAttachmentSize() uint32

func (*RequestProtocol) GetCallType 

func (x *RequestProtocol) GetCallType() uint32

func (*RequestProtocol) GetCallee 

func (x *RequestProtocol) GetCallee() []byte

func (*RequestProtocol) GetCaller 

func (x *RequestProtocol) GetCaller() []byte

func (*RequestProtocol) GetContentEncoding 

func (x *RequestProtocol) GetContentEncoding() uint32

func (*RequestProtocol) GetContentType 

func (x *RequestProtocol) GetContentType() uint32

func (*RequestProtocol) GetFunc 

func (x *RequestProtocol) GetFunc() []byte

func (*RequestProtocol) GetMessageType 

func (x *RequestProtocol) GetMessageType() uint32

func (*RequestProtocol) GetRequestId 

func (x *RequestProtocol) GetRequestId() uint32

func (*RequestProtocol) GetTimeout 

func (x *RequestProtocol) GetTimeout() uint32

func (*RequestProtocol) GetTransInfo 

func (x *RequestProtocol) GetTransInfo() map[string][]byte

func (*RequestProtocol) GetVersion 

func (x *RequestProtocol) GetVersion() uint32

func (*RequestProtocol) ProtoMessage 

func (*RequestProtocol) ProtoMessage()

func (*RequestProtocol) ProtoReflect 

func (x *RequestProtocol) ProtoReflect() protoreflect.Message

func (*RequestProtocol) Reset 

func (x *RequestProtocol) Reset()

func (*RequestProtocol) String 

func (x *RequestProtocol) String() string

type ResponseProtocol 

type ResponseProtocol struct {

	// 协议版本
	// 具体值与TrpcProtoVersion对应
	Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// 请求的调用类型
	// 比如: 普通调用，单向调用
	// 具体值与TrpcCallType对应
	CallType uint32 `protobuf:"varint,2,opt,name=call_type,json=callType,proto3" json:"call_type,omitempty"`
	// 请求唯一id
	RequestId uint32 `protobuf:"varint,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// 请求在框架层的错误返回码
	// 具体值与TrpcRetCode对应
	Ret int32 `protobuf:"varint,4,opt,name=ret,proto3" json:"ret,omitempty"`
	// 接口的错误返回码
	// 建议业务在使用时，标识成功和失败，0代表成功，其它代表失败
	FuncRet int32 `protobuf:"varint,5,opt,name=func_ret,json=funcRet,proto3" json:"func_ret,omitempty"`
	// 调用结果信息描述
	// 失败的时候用
	ErrorMsg []byte `protobuf:"bytes,6,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// 框架信息透传的消息类型
	// 比如调用链、染色key、灰度、鉴权、多环境、set名称等的标识
	// 具体值与TrpcMessageType对应
	MessageType uint32 `protobuf:"varint,7,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	// 框架透传回来的信息key-value对，
	// 目前分两部分
	// 1是框架层透传回来的信息，key的名字要以trpc-开头
	// 2是业务层透传回来的信息，业务可以自行设置
	TransInfo map[string][]byte `` /* 176-byte string literal not displayed */
	// 响应数据的编码类型
	// 比如: proto/jce/json, 默认proto
	// 具体值与TrpcContentEncodeType对应
	ContentType uint32 `protobuf:"varint,9,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// 响应数据使用的压缩方式
	// 比如: gzip/snappy/..., 默认不使用
	// 具体值与TrpcCompressType对应
	ContentEncoding uint32 `protobuf:"varint,10,opt,name=content_encoding,json=contentEncoding,proto3" json:"content_encoding,omitempty"`
	// attachment大小
	AttachmentSize uint32 `protobuf:"varint,12,opt,name=attachment_size,json=attachmentSize,proto3" json:"attachment_size,omitempty"`
	// contains filtered or unexported fields
}

响应协议头

func (*ResponseProtocol) Descriptor deprecated 

func (*ResponseProtocol) Descriptor() ([]byte, []int)

Deprecated: Use ResponseProtocol.ProtoReflect.Descriptor instead.

func (*ResponseProtocol) GetAttachmentSize 

func (x *ResponseProtocol) GetAttachmentSize() uint32

func (*ResponseProtocol) GetCallType 

func (x *ResponseProtocol) GetCallType() uint32

func (*ResponseProtocol) GetContentEncoding 

func (x *ResponseProtocol) GetContentEncoding() uint32

func (*ResponseProtocol) GetContentType 

func (x *ResponseProtocol) GetContentType() uint32

func (*ResponseProtocol) GetErrorMsg 

func (x *ResponseProtocol) GetErrorMsg() []byte

func (*ResponseProtocol) GetFuncRet 

func (x *ResponseProtocol) GetFuncRet() int32

func (*ResponseProtocol) GetMessageType 

func (x *ResponseProtocol) GetMessageType() uint32

func (*ResponseProtocol) GetRequestId 

func (x *ResponseProtocol) GetRequestId() uint32

func (*ResponseProtocol) GetRet 

func (x *ResponseProtocol) GetRet() int32

func (*ResponseProtocol) GetTransInfo 

func (x *ResponseProtocol) GetTransInfo() map[string][]byte

func (*ResponseProtocol) GetVersion 

func (x *ResponseProtocol) GetVersion() uint32

func (*ResponseProtocol) ProtoMessage 

func (*ResponseProtocol) ProtoMessage()

func (*ResponseProtocol) ProtoReflect 

func (x *ResponseProtocol) ProtoReflect() protoreflect.Message

func (*ResponseProtocol) Reset 

func (x *ResponseProtocol) Reset()

func (*ResponseProtocol) String 

func (x *ResponseProtocol) String() string

type TrpcCallType 

type TrpcCallType int32

trpc协议中的调用类型 

const (
	// 一应一答调用，包括同步、异步
	TrpcCallType_TRPC_UNARY_CALL TrpcCallType = 0
	// 单向调用
	TrpcCallType_TRPC_ONEWAY_CALL TrpcCallType = 1
)

func (TrpcCallType) Descriptor 

func (TrpcCallType) Descriptor() protoreflect.EnumDescriptor

func (TrpcCallType) Enum 

func (x TrpcCallType) Enum() *TrpcCallType

func (TrpcCallType) EnumDescriptor deprecated 

func (TrpcCallType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcCallType.Descriptor instead.

func (TrpcCallType) Number 

func (x TrpcCallType) Number() protoreflect.EnumNumber

func (TrpcCallType) String 

func (x TrpcCallType) String() string

func (TrpcCallType) Type 

func (TrpcCallType) Type() protoreflect.EnumType

type TrpcCompressType 

type TrpcCompressType int32

trpc协议中 data 内容的压缩类型 默认使用不压缩 

const (
	// 默认不使用压缩
	TrpcCompressType_TRPC_DEFAULT_COMPRESS TrpcCompressType = 0
	// 使用gzip
	TrpcCompressType_TRPC_GZIP_COMPRESS TrpcCompressType = 1
	// 使用snappy
	//
	// Deprecated: 建议使用 TRPC_SNAPPY_STREAM_COMPRESS/TRPC_SNAPPY_BLOCK_COMPRESS, 因为现在
	// trpc-go 和 trpc-cpp 分别的使用的是 stream、block 模式，二者不兼容，跨语言调用会出错
	TrpcCompressType_TRPC_SNAPPY_COMPRESS TrpcCompressType = 2
	// 使用zlib
	TrpcCompressType_TRPC_ZLIB_COMPRESS TrpcCompressType = 3
	// 使用 stream 模式的 snappy
	TrpcCompressType_TRPC_SNAPPY_STREAM_COMPRESS TrpcCompressType = 4
	// 使用 block 模式的 snappy
	TrpcCompressType_TRPC_SNAPPY_BLOCK_COMPRESS TrpcCompressType = 5
	// 使用 frame 模式的 lz4
	TrpcCompressType_TRPC_LZ4_FRAME_COMPRESS TrpcCompressType = 6
	// 使用 block 模式的 lz4
	TrpcCompressType_TRPC_LZ4_BLOCK_COMPRESS TrpcCompressType = 7
)

func (TrpcCompressType) Descriptor 

func (TrpcCompressType) Descriptor() protoreflect.EnumDescriptor

func (TrpcCompressType) Enum 

func (x TrpcCompressType) Enum() *TrpcCompressType

func (TrpcCompressType) EnumDescriptor deprecated 

func (TrpcCompressType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcCompressType.Descriptor instead.

func (TrpcCompressType) Number 

func (x TrpcCompressType) Number() protoreflect.EnumNumber

func (TrpcCompressType) String 

func (x TrpcCompressType) String() string

func (TrpcCompressType) Type 

func (TrpcCompressType) Type() protoreflect.EnumType

type TrpcContentEncodeType 

type TrpcContentEncodeType int32

trpc协议中 data 内容的编码类型 默认使用pb 目前约定 0-127 范围的取值为框架规范的序列化方式,框架使用 

const (
	// pb
	TrpcContentEncodeType_TRPC_PROTO_ENCODE TrpcContentEncodeType = 0
	// jce
	TrpcContentEncodeType_TRPC_JCE_ENCODE TrpcContentEncodeType = 1
	// json
	TrpcContentEncodeType_TRPC_JSON_ENCODE TrpcContentEncodeType = 2
	// flatbuffer
	TrpcContentEncodeType_TRPC_FLATBUFFER_ENCODE TrpcContentEncodeType = 3
	// 不序列化
	TrpcContentEncodeType_TRPC_NOOP_ENCODE TrpcContentEncodeType = 4
	// xml
	TrpcContentEncodeType_TRPC_XML_ENCODE TrpcContentEncodeType = 5
	// thrift
	TrpcContentEncodeType_TRPC_THRIFT_ENCODE TrpcContentEncodeType = 6
)

func (TrpcContentEncodeType) Descriptor 

func (TrpcContentEncodeType) Descriptor() protoreflect.EnumDescriptor

func (TrpcContentEncodeType) Enum 

func (x TrpcContentEncodeType) Enum() *TrpcContentEncodeType

func (TrpcContentEncodeType) EnumDescriptor deprecated 

func (TrpcContentEncodeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcContentEncodeType.Descriptor instead.

func (TrpcContentEncodeType) Number 

func (x TrpcContentEncodeType) Number() protoreflect.EnumNumber

func (TrpcContentEncodeType) String 

func (x TrpcContentEncodeType) String() string

func (TrpcContentEncodeType) Type 

func (TrpcContentEncodeType) Type() protoreflect.EnumType

type TrpcDataFrameType 

type TrpcDataFrameType int32

trpc协议的二进制数据帧类型 目前支持两种类型的二进制数据帧： 1. 一应一答模式的二进制数据帧类型 2. 流式模式的二进制数据帧类型 

const (
	// trpc一应一答模式的二进制数据帧类型
	TrpcDataFrameType_TRPC_UNARY_FRAME TrpcDataFrameType = 0
	// trpc流式模式的二进制数据帧类型
	TrpcDataFrameType_TRPC_STREAM_FRAME TrpcDataFrameType = 1
)

func (TrpcDataFrameType) Descriptor 

func (TrpcDataFrameType) Descriptor() protoreflect.EnumDescriptor

func (TrpcDataFrameType) Enum 

func (x TrpcDataFrameType) Enum() *TrpcDataFrameType

func (TrpcDataFrameType) EnumDescriptor deprecated 

func (TrpcDataFrameType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcDataFrameType.Descriptor instead.

func (TrpcDataFrameType) Number 

func (x TrpcDataFrameType) Number() protoreflect.EnumNumber

func (TrpcDataFrameType) String 

func (x TrpcDataFrameType) String() string

func (TrpcDataFrameType) Type 

func (TrpcDataFrameType) Type() protoreflect.EnumType

type TrpcMagic 

type TrpcMagic int32

框架协议头里的魔数 

const (
	// trpc不用这个值，为了提供给pb工具生成代码
	TrpcMagic_TRPC_DEFAULT_NONE TrpcMagic = 0
	// trpc协议默认使用这个魔数
	TrpcMagic_TRPC_MAGIC_VALUE TrpcMagic = 2352
)

func (TrpcMagic) Descriptor 

func (TrpcMagic) Descriptor() protoreflect.EnumDescriptor

func (TrpcMagic) Enum 

func (x TrpcMagic) Enum() *TrpcMagic

func (TrpcMagic) EnumDescriptor deprecated 

func (TrpcMagic) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcMagic.Descriptor instead.

func (TrpcMagic) Number 

func (x TrpcMagic) Number() protoreflect.EnumNumber

func (TrpcMagic) String 

func (x TrpcMagic) String() string

func (TrpcMagic) Type 

func (TrpcMagic) Type() protoreflect.EnumType

type TrpcMessageType 

type TrpcMessageType int32

trpc协议中的消息透传支持的类型 

const (
	// trpc 不用这个值，为了提供给 pb 工具生成代码
	TrpcMessageType_TRPC_DEFAULT TrpcMessageType = 0
	// 染色
	TrpcMessageType_TRPC_DYEING_MESSAGE TrpcMessageType = 1
	// 调用链
	TrpcMessageType_TRPC_TRACE_MESSAGE TrpcMessageType = 2
	// 多环境
	TrpcMessageType_TRPC_MULTI_ENV_MESSAGE TrpcMessageType = 4
	// 灰度
	TrpcMessageType_TRPC_GRID_MESSAGE TrpcMessageType = 8
	// set名
	TrpcMessageType_TRPC_SETNAME_MESSAGE TrpcMessageType = 16
)

func (TrpcMessageType) Descriptor 

func (TrpcMessageType) Descriptor() protoreflect.EnumDescriptor

func (TrpcMessageType) Enum 

func (x TrpcMessageType) Enum() *TrpcMessageType

func (TrpcMessageType) EnumDescriptor deprecated 

func (TrpcMessageType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcMessageType.Descriptor instead.

func (TrpcMessageType) Number 

func (x TrpcMessageType) Number() protoreflect.EnumNumber

func (TrpcMessageType) String 

func (x TrpcMessageType) String() string

func (TrpcMessageType) Type 

func (TrpcMessageType) Type() protoreflect.EnumType

type TrpcProtoVersion 

type TrpcProtoVersion int32

trpc协议版本 

const (
	// 默认版本
	TrpcProtoVersion_TRPC_PROTO_V1 TrpcProtoVersion = 0
)

func (TrpcProtoVersion) Descriptor 

func (TrpcProtoVersion) Descriptor() protoreflect.EnumDescriptor

func (TrpcProtoVersion) Enum 

func (x TrpcProtoVersion) Enum() *TrpcProtoVersion

func (TrpcProtoVersion) EnumDescriptor deprecated 

func (TrpcProtoVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcProtoVersion.Descriptor instead.

func (TrpcProtoVersion) Number 

func (x TrpcProtoVersion) Number() protoreflect.EnumNumber

func (TrpcProtoVersion) String 

func (x TrpcProtoVersion) String() string

func (TrpcProtoVersion) Type 

func (TrpcProtoVersion) Type() protoreflect.EnumType

type TrpcRetCode 

type TrpcRetCode int32

框架层接口调用的返回码定义 

const (
	// 调用成功
	TrpcRetCode_TRPC_INVOKE_SUCCESS TrpcRetCode = 0
	// 协议错误码
	// 服务端解码错误
	TrpcRetCode_TRPC_SERVER_DECODE_ERR TrpcRetCode = 1
	// 服务端编码错误
	TrpcRetCode_TRPC_SERVER_ENCODE_ERR TrpcRetCode = 2
	// service或者func路由错误码
	// 服务端没有调用相应的service实现
	TrpcRetCode_TRPC_SERVER_NOSERVICE_ERR TrpcRetCode = 11
	// 服务端没有调用相应的接口实现
	TrpcRetCode_TRPC_SERVER_NOFUNC_ERR TrpcRetCode = 12
	// 超时/过载/限流错误码
	// 请求在服务端超时
	TrpcRetCode_TRPC_SERVER_TIMEOUT_ERR TrpcRetCode = 21
	// 请求在服务端被过载保护而丢弃请求
	// 主要用在框架内部实现的过载保护插件上
	TrpcRetCode_TRPC_SERVER_OVERLOAD_ERR TrpcRetCode = 22
	// 请求在服务端被限流
	// 主要用在外部服务治理系统的插件或者业务自定义的限流插件上，比如: 北极星限流
	TrpcRetCode_TRPC_SERVER_LIMITED_ERR TrpcRetCode = 23
	// 请求在服务端因全链路超时时间而超时
	TrpcRetCode_TRPC_SERVER_FULL_LINK_TIMEOUT_ERR TrpcRetCode = 24
	// 服务端系统错误
	TrpcRetCode_TRPC_SERVER_SYSTEM_ERR TrpcRetCode = 31
	// 服务端鉴权失败错误
	TrpcRetCode_TRPC_SERVER_AUTH_ERR TrpcRetCode = 41
	// 服务端请求参数自动校验失败错误
	TrpcRetCode_TRPC_SERVER_VALIDATE_ERR TrpcRetCode = 51
	// 超时错误码
	// 请求在客户端调用超时
	TrpcRetCode_TRPC_CLIENT_INVOKE_TIMEOUT_ERR TrpcRetCode = 101
	// 请求在客户端因全链路超时时间而超时
	TrpcRetCode_TRPC_CLIENT_FULL_LINK_TIMEOUT_ERR TrpcRetCode = 102
	// 网络相关错误码
	// 客户端连接错误
	TrpcRetCode_TRPC_CLIENT_CONNECT_ERR TrpcRetCode = 111
	// 协议相关错误码
	// 客户端编码错误
	TrpcRetCode_TRPC_CLIENT_ENCODE_ERR TrpcRetCode = 121
	// 客户端解码错误
	TrpcRetCode_TRPC_CLIENT_DECODE_ERR TrpcRetCode = 122
	// 过载保护/限流相关错误码
	// 请求在客户端被限流
	// 主要用在外部服务治理系统的插件或者业务自定义的限流插件上，比如: 北极星限流
	TrpcRetCode_TRPC_CLIENT_LIMITED_ERR TrpcRetCode = 123
	// 请求在客户端被过载保护而丢弃请求
	// 主要用在框架内部实现的过载保护插件上
	TrpcRetCode_TRPC_CLIENT_OVERLOAD_ERR TrpcRetCode = 124
	// 路由相关错误码
	// 客户端选ip路由错误
	TrpcRetCode_TRPC_CLIENT_ROUTER_ERR TrpcRetCode = 131
	// 客户端网络错误
	TrpcRetCode_TRPC_CLIENT_NETWORK_ERR TrpcRetCode = 141
	// 客户端响应参数自动校验失败错误
	TrpcRetCode_TRPC_CLIENT_VALIDATE_ERR TrpcRetCode = 151
	// 上游主动断开连接，提前取消请求错误
	TrpcRetCode_TRPC_CLIENT_CANCELED_ERR TrpcRetCode = 161
	// 客户端读取 Frame 错误
	TrpcRetCode_TRPC_CLIENT_READ_FRAME_ERR TrpcRetCode = 171
	// 服务端流式网络错误, 详细错误码需要在实现过程中再梳理
	TrpcRetCode_TRPC_STREAM_SERVER_NETWORK_ERR TrpcRetCode = 201
	// 服务端流式传输错误, 详细错误码需要在实现过程中再梳理
	// 比如：流消息过大等
	TrpcRetCode_TRPC_STREAM_SERVER_MSG_EXCEED_LIMIT_ERR TrpcRetCode = 211
	// 服务端流式编码错误
	TrpcRetCode_TRPC_STREAM_SERVER_ENCODE_ERR TrpcRetCode = 221
	// 客户端流式编解码错误
	TrpcRetCode_TRPC_STREAM_SERVER_DECODE_ERR TrpcRetCode = 222
	// 服务端流式写错误, 详细错误码需要在实现过程中再梳理
	TrpcRetCode_TRPC_STREAM_SERVER_WRITE_END          TrpcRetCode = 231
	TrpcRetCode_TRPC_STREAM_SERVER_WRITE_OVERFLOW_ERR TrpcRetCode = 232
	TrpcRetCode_TRPC_STREAM_SERVER_WRITE_CLOSE_ERR    TrpcRetCode = 233
	TrpcRetCode_TRPC_STREAM_SERVER_WRITE_TIMEOUT_ERR  TrpcRetCode = 234
	// 服务端流式读错误, 详细错误码需要在实现过程中再梳理
	TrpcRetCode_TRPC_STREAM_SERVER_READ_END         TrpcRetCode = 251
	TrpcRetCode_TRPC_STREAM_SERVER_READ_CLOSE_ERR   TrpcRetCode = 252
	TrpcRetCode_TRPC_STREAM_SERVER_READ_EMPTY_ERR   TrpcRetCode = 253
	TrpcRetCode_TRPC_STREAM_SERVER_READ_TIMEOUT_ERR TrpcRetCode = 254
	// 客户端流式网络错误, 详细错误码需要在实现过程中再梳理
	TrpcRetCode_TRPC_STREAM_CLIENT_NETWORK_ERR TrpcRetCode = 301
	// 客户端流式传输错误, 详细错误码需要在实现过程中再梳理
	// 比如：流消息过大等
	TrpcRetCode_TRPC_STREAM_CLIENT_MSG_EXCEED_LIMIT_ERR TrpcRetCode = 311
	// 客户端流式编码错误
	TrpcRetCode_TRPC_STREAM_CLIENT_ENCODE_ERR TrpcRetCode = 321
	// 客户端流式编解码错误
	TrpcRetCode_TRPC_STREAM_CLIENT_DECODE_ERR TrpcRetCode = 322
	// 客户端流式写错误, 详细错误码需要在实现过程中再梳理
	TrpcRetCode_TRPC_STREAM_CLIENT_WRITE_END          TrpcRetCode = 331
	TrpcRetCode_TRPC_STREAM_CLIENT_WRITE_OVERFLOW_ERR TrpcRetCode = 332
	TrpcRetCode_TRPC_STREAM_CLIENT_WRITE_CLOSE_ERR    TrpcRetCode = 333
	TrpcRetCode_TRPC_STREAM_CLIENT_WRITE_TIMEOUT_ERR  TrpcRetCode = 334
	// 客户端流式读错误, 详细错误码需要在实现过程中再梳理
	TrpcRetCode_TRPC_STREAM_CLIENT_READ_END         TrpcRetCode = 351
	TrpcRetCode_TRPC_STREAM_CLIENT_READ_CLOSE_ERR   TrpcRetCode = 352
	TrpcRetCode_TRPC_STREAM_CLIENT_READ_EMPTY_ERR   TrpcRetCode = 353
	TrpcRetCode_TRPC_STREAM_CLIENT_READ_TIMEOUT_ERR TrpcRetCode = 354
	// 未明确的错误
	TrpcRetCode_TRPC_INVOKE_UNKNOWN_ERR TrpcRetCode = 999
	// 未明确的错误
	TrpcRetCode_TRPC_STREAM_UNKNOWN_ERR TrpcRetCode = 1000
)

func (TrpcRetCode) Descriptor 

func (TrpcRetCode) Descriptor() protoreflect.EnumDescriptor

func (TrpcRetCode) Enum 

func (x TrpcRetCode) Enum() *TrpcRetCode

func (TrpcRetCode) EnumDescriptor deprecated 

func (TrpcRetCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcRetCode.Descriptor instead.

func (TrpcRetCode) Number 

func (x TrpcRetCode) Number() protoreflect.EnumNumber

func (TrpcRetCode) String 

func (x TrpcRetCode) String() string

func (TrpcRetCode) Type 

func (TrpcRetCode) Type() protoreflect.EnumType

type TrpcStreamCloseMeta 

type TrpcStreamCloseMeta struct {

	// 关闭的类型，关闭一端，还是全部关闭
	CloseType int32 `protobuf:"varint,1,opt,name=close_type,json=closeType,proto3" json:"close_type,omitempty"`
	// close返回码
	// 代表框架层的错误
	Ret int32 `protobuf:"varint,2,opt,name=ret,proto3" json:"ret,omitempty"`
	// close信息描述
	Msg []byte `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// 框架信息透传的消息类型
	// 比如调用链、染色key、灰度、鉴权、多环境、set名称等的标识
	// 具体值与TrpcMessageType对应
	MessageType uint32 `protobuf:"varint,4,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	// 框架透传的信息key-value对，目前分两部分
	// 1是框架层要透传的信息，key的名字要以trpc-开头
	// 2是业务层要透传的信息，业务可以自行设置
	TransInfo map[string][]byte `` /* 176-byte string literal not displayed */
	// 接口的错误返回码
	// 建议业务在使用时，标识成功和失败，0代表成功，其它代表失败
	FuncRet int32 `protobuf:"varint,6,opt,name=func_ret,json=funcRet,proto3" json:"func_ret,omitempty"`
	// contains filtered or unexported fields
}

trpc流式的RESET帧头消息定义

func (*TrpcStreamCloseMeta) Descriptor deprecated 

func (*TrpcStreamCloseMeta) Descriptor() ([]byte, []int)

Deprecated: Use TrpcStreamCloseMeta.ProtoReflect.Descriptor instead.

func (*TrpcStreamCloseMeta) GetCloseType 

func (x *TrpcStreamCloseMeta) GetCloseType() int32

func (*TrpcStreamCloseMeta) GetFuncRet 

func (x *TrpcStreamCloseMeta) GetFuncRet() int32

func (*TrpcStreamCloseMeta) GetMessageType 

func (x *TrpcStreamCloseMeta) GetMessageType() uint32

func (*TrpcStreamCloseMeta) GetMsg 

func (x *TrpcStreamCloseMeta) GetMsg() []byte

func (*TrpcStreamCloseMeta) GetRet 

func (x *TrpcStreamCloseMeta) GetRet() int32

func (*TrpcStreamCloseMeta) GetTransInfo 

func (x *TrpcStreamCloseMeta) GetTransInfo() map[string][]byte

func (*TrpcStreamCloseMeta) ProtoMessage 

func (*TrpcStreamCloseMeta) ProtoMessage()

func (*TrpcStreamCloseMeta) ProtoReflect 

func (x *TrpcStreamCloseMeta) ProtoReflect() protoreflect.Message

func (*TrpcStreamCloseMeta) Reset 

func (x *TrpcStreamCloseMeta) Reset()

func (*TrpcStreamCloseMeta) String 

func (x *TrpcStreamCloseMeta) String() string

type TrpcStreamCloseType 

type TrpcStreamCloseType int32

trpc流式关闭类型 

const (
	// 正常单向流关闭
	TrpcStreamCloseType_TRPC_STREAM_CLOSE TrpcStreamCloseType = 0
	// 异常关闭双向流
	TrpcStreamCloseType_TRPC_STREAM_RESET TrpcStreamCloseType = 1
)

func (TrpcStreamCloseType) Descriptor 

func (TrpcStreamCloseType) Descriptor() protoreflect.EnumDescriptor

func (TrpcStreamCloseType) Enum 

func (x TrpcStreamCloseType) Enum() *TrpcStreamCloseType

func (TrpcStreamCloseType) EnumDescriptor deprecated 

func (TrpcStreamCloseType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcStreamCloseType.Descriptor instead.

func (TrpcStreamCloseType) Number 

func (x TrpcStreamCloseType) Number() protoreflect.EnumNumber

func (TrpcStreamCloseType) String 

func (x TrpcStreamCloseType) String() string

func (TrpcStreamCloseType) Type 

func (TrpcStreamCloseType) Type() protoreflect.EnumType

type TrpcStreamFeedBackMeta 

type TrpcStreamFeedBackMeta struct {

	// 增加的窗口大小
	WindowSizeIncrement uint32 `protobuf:"varint,1,opt,name=window_size_increment,json=windowSizeIncrement,proto3" json:"window_size_increment,omitempty"`
	// contains filtered or unexported fields
}

trpc流式的流控帧头元信息定义

func (*TrpcStreamFeedBackMeta) Descriptor deprecated 

func (*TrpcStreamFeedBackMeta) Descriptor() ([]byte, []int)

Deprecated: Use TrpcStreamFeedBackMeta.ProtoReflect.Descriptor instead.

func (*TrpcStreamFeedBackMeta) GetWindowSizeIncrement 

func (x *TrpcStreamFeedBackMeta) GetWindowSizeIncrement() uint32

func (*TrpcStreamFeedBackMeta) ProtoMessage 

func (*TrpcStreamFeedBackMeta) ProtoMessage()

func (*TrpcStreamFeedBackMeta) ProtoReflect 

func (x *TrpcStreamFeedBackMeta) ProtoReflect() protoreflect.Message

func (*TrpcStreamFeedBackMeta) Reset 

func (x *TrpcStreamFeedBackMeta) Reset()

func (*TrpcStreamFeedBackMeta) String 

func (x *TrpcStreamFeedBackMeta) String() string

type TrpcStreamFrameType 

type TrpcStreamFrameType int32

trpc协议流式的二进制数据帧类型 目前流式帧类型分4种：INIT/DATA/FEEDBACK/CLOSE，其中CLOSE帧不带业务数据 INIT帧：FIXHEADER + TrpcStreamInitMeta DATA帧：FIXHEADER + body(业务序列化的数据) FEEDBACK帧：FIXHEADER + TrpcStreamFeedBackMeta（触发策略，高低水位+定时） CLOSE帧：FIXHEADER + TrpcStreamCloseMeta 连接和流空闲超时的回收机制不考虑 

const (
	// 一应一答的默认取值
	TrpcStreamFrameType_TRPC_UNARY TrpcStreamFrameType = 0
	// 流式INIT帧类型
	TrpcStreamFrameType_TRPC_STREAM_FRAME_INIT TrpcStreamFrameType = 1
	// 流式DATA帧类型
	TrpcStreamFrameType_TRPC_STREAM_FRAME_DATA TrpcStreamFrameType = 2
	// 流式FEEDBACK帧类型
	TrpcStreamFrameType_TRPC_STREAM_FRAME_FEEDBACK TrpcStreamFrameType = 3
	// 流式CLOSE帧类型
	TrpcStreamFrameType_TRPC_STREAM_FRAME_CLOSE TrpcStreamFrameType = 4
)

func (TrpcStreamFrameType) Descriptor 

func (TrpcStreamFrameType) Descriptor() protoreflect.EnumDescriptor

func (TrpcStreamFrameType) Enum 

func (x TrpcStreamFrameType) Enum() *TrpcStreamFrameType

func (TrpcStreamFrameType) EnumDescriptor deprecated 

func (TrpcStreamFrameType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrpcStreamFrameType.Descriptor instead.

func (TrpcStreamFrameType) Number 

func (x TrpcStreamFrameType) Number() protoreflect.EnumNumber

func (TrpcStreamFrameType) String 

func (x TrpcStreamFrameType) String() string

func (TrpcStreamFrameType) Type 

func (TrpcStreamFrameType) Type() protoreflect.EnumType

type TrpcStreamInitMeta 

type TrpcStreamInitMeta struct {

	// init请求元信息
	RequestMeta *TrpcStreamInitRequestMeta `protobuf:"bytes,1,opt,name=request_meta,json=requestMeta,proto3" json:"request_meta,omitempty"`
	// init响应元信息
	ResponseMeta *TrpcStreamInitResponseMeta `protobuf:"bytes,2,opt,name=response_meta,json=responseMeta,proto3" json:"response_meta,omitempty"`
	// 由接收端告知发送端初始的发送窗口大小
	InitWindowSize uint32 `protobuf:"varint,3,opt,name=init_window_size,json=initWindowSize,proto3" json:"init_window_size,omitempty"`
	// 请求数据的序列化类型
	// 比如: proto/jce/json, 默认proto
	// 具体值与TrpcContentEncodeType对应
	ContentType uint32 `protobuf:"varint,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// 请求数据使用的压缩方式
	// 比如: gzip/snappy/..., 默认不使用
	// 具体值与TrpcCompressType对应
	ContentEncoding uint32 `protobuf:"varint,5,opt,name=content_encoding,json=contentEncoding,proto3" json:"content_encoding,omitempty"`
	// contains filtered or unexported fields
}

trpc流式的流控帧头消息定义

func (*TrpcStreamInitMeta) Descriptor deprecated 

func (*TrpcStreamInitMeta) Descriptor() ([]byte, []int)

Deprecated: Use TrpcStreamInitMeta.ProtoReflect.Descriptor instead.

func (*TrpcStreamInitMeta) GetContentEncoding 

func (x *TrpcStreamInitMeta) GetContentEncoding() uint32

func (*TrpcStreamInitMeta) GetContentType 

func (x *TrpcStreamInitMeta) GetContentType() uint32

func (*TrpcStreamInitMeta) GetInitWindowSize 

func (x *TrpcStreamInitMeta) GetInitWindowSize() uint32

func (*TrpcStreamInitMeta) GetRequestMeta 

func (x *TrpcStreamInitMeta) GetRequestMeta() *TrpcStreamInitRequestMeta

func (*TrpcStreamInitMeta) GetResponseMeta 

func (x *TrpcStreamInitMeta) GetResponseMeta() *TrpcStreamInitResponseMeta

func (*TrpcStreamInitMeta) ProtoMessage 

func (*TrpcStreamInitMeta) ProtoMessage()

func (*TrpcStreamInitMeta) ProtoReflect 

func (x *TrpcStreamInitMeta) ProtoReflect() protoreflect.Message

func (*TrpcStreamInitMeta) Reset 

func (x *TrpcStreamInitMeta) Reset()

func (*TrpcStreamInitMeta) String 

func (x *TrpcStreamInitMeta) String() string

type TrpcStreamInitRequestMeta 

type TrpcStreamInitRequestMeta struct {

	// 主调服务的名称
	// trpc协议下的规范格式: trpc.应用名.服务名.pb的service名, 4段
	Caller []byte `protobuf:"bytes,1,opt,name=caller,proto3" json:"caller,omitempty"`
	// 被调服务的路由名称
	// trpc协议下的规范格式，trpc.应用名.服务名.pb的service名[.接口名]
	// 前4段是必须有，接口可选。
	Callee []byte `protobuf:"bytes,2,opt,name=callee,proto3" json:"callee,omitempty"`
	// 调用服务的接口名
	// 规范格式: /package.Service名称/接口名
	Func []byte `protobuf:"bytes,3,opt,name=func,proto3" json:"func,omitempty"`
	// 框架信息透传的消息类型
	// 比如调用链、染色key、灰度、鉴权、多环境、set名称等的标识
	// 具体值与TrpcMessageType对应
	MessageType uint32 `protobuf:"varint,4,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	// 框架透传的信息key-value对，目前分两部分
	// 1是框架层要透传的信息，key的名字要以trpc-开头
	// 2是业务层要透传的信息，业务可以自行设置
	// 注意: trans_info中的key-value对会全链路透传，业务请谨慎使用！
	TransInfo map[string][]byte `` /* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

trpc流式init头的请求元信息

func (*TrpcStreamInitRequestMeta) Descriptor deprecated 

func (*TrpcStreamInitRequestMeta) Descriptor() ([]byte, []int)

Deprecated: Use TrpcStreamInitRequestMeta.ProtoReflect.Descriptor instead.

func (*TrpcStreamInitRequestMeta) GetCallee 

func (x *TrpcStreamInitRequestMeta) GetCallee() []byte

func (*TrpcStreamInitRequestMeta) GetCaller 

func (x *TrpcStreamInitRequestMeta) GetCaller() []byte

func (*TrpcStreamInitRequestMeta) GetFunc 

func (x *TrpcStreamInitRequestMeta) GetFunc() []byte

func (*TrpcStreamInitRequestMeta) GetMessageType 

func (x *TrpcStreamInitRequestMeta) GetMessageType() uint32

func (*TrpcStreamInitRequestMeta) GetTransInfo 

func (x *TrpcStreamInitRequestMeta) GetTransInfo() map[string][]byte

func (*TrpcStreamInitRequestMeta) ProtoMessage 

func (*TrpcStreamInitRequestMeta) ProtoMessage()

func (*TrpcStreamInitRequestMeta) ProtoReflect 

func (x *TrpcStreamInitRequestMeta) ProtoReflect() protoreflect.Message

func (*TrpcStreamInitRequestMeta) Reset 

func (x *TrpcStreamInitRequestMeta) Reset()

func (*TrpcStreamInitRequestMeta) String 

func (x *TrpcStreamInitRequestMeta) String() string

type TrpcStreamInitResponseMeta 

type TrpcStreamInitResponseMeta struct {

	// 请求在框架层的错误返回码
	// 具体值与TrpcRetCode对应
	Ret int32 `protobuf:"varint,1,opt,name=ret,proto3" json:"ret,omitempty"`
	// 调用结果信息描述
	// 失败的时候用
	ErrorMsg []byte `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

trpc流式init头的响应元信息

func (*TrpcStreamInitResponseMeta) Descriptor deprecated 

func (*TrpcStreamInitResponseMeta) Descriptor() ([]byte, []int)

Deprecated: Use TrpcStreamInitResponseMeta.ProtoReflect.Descriptor instead.

func (*TrpcStreamInitResponseMeta) GetErrorMsg 

func (x *TrpcStreamInitResponseMeta) GetErrorMsg() []byte

func (*TrpcStreamInitResponseMeta) GetRet 

func (x *TrpcStreamInitResponseMeta) GetRet() int32

func (*TrpcStreamInitResponseMeta) ProtoMessage 

func (*TrpcStreamInitResponseMeta) ProtoMessage()

func (*TrpcStreamInitResponseMeta) ProtoReflect 

func (x *TrpcStreamInitResponseMeta) ProtoReflect() protoreflect.Message

func (*TrpcStreamInitResponseMeta) Reset 

func (x *TrpcStreamInitResponseMeta) Reset()

func (*TrpcStreamInitResponseMeta) String 

func (x *TrpcStreamInitResponseMeta) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.