brpc

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

README

brpc适配

Documentation

Index

Constants

View Source 
const Default_StreamSettings_NeedFeedback bool = false
View Source 
const Default_StreamSettings_Writable bool = false

Variables

View Source 
var CompressType_name = map[int32]string{
	0: "COMPRESS_TYPE_NONE",
	1: "COMPRESS_TYPE_SNAPPY",
	2: "COMPRESS_TYPE_GZIP",
	3: "COMPRESS_TYPE_ZLIB",
	4: "COMPRESS_TYPE_LZ4",
}
View Source 
var CompressType_value = map[string]int32{
	"COMPRESS_TYPE_NONE":   0,
	"COMPRESS_TYPE_SNAPPY": 1,
	"COMPRESS_TYPE_GZIP":   2,
	"COMPRESS_TYPE_ZLIB":   3,
	"COMPRESS_TYPE_LZ4":    4,
}
View Source 
var ConnectionType_name = map[int32]string{
	0: "CONNECTION_TYPE_UNKNOWN",
	1: "CONNECTION_TYPE_SINGLE",
	2: "CONNECTION_TYPE_POOLED",
	4: "CONNECTION_TYPE_SHORT",
}
View Source 
var ConnectionType_value = map[string]int32{
	"CONNECTION_TYPE_UNKNOWN": 0,
	"CONNECTION_TYPE_SINGLE":  1,
	"CONNECTION_TYPE_POOLED":  2,
	"CONNECTION_TYPE_SHORT":   4,
}
View Source 
var E_MethodTimeout = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.MethodOptions)(nil),
	ExtensionType: (*int64)(nil),
	Field:         90003,
	Name:          "brpc.method_timeout",
	Tag:           "varint,90003,opt,name=method_timeout,json=methodTimeout",
	Filename:      "options.proto",
}
View Source 
var E_RequestCompression = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.MethodOptions)(nil),
	ExtensionType: (*CompressType)(nil),
	Field:         90004,
	Name:          "brpc.request_compression",
	Tag:           "varint,90004,opt,name=request_compression,json=requestCompression,enum=brpc.CompressType,def=0",
	Filename:      "options.proto",
}
View Source 
var E_RequestTalkType = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.MethodOptions)(nil),
	ExtensionType: (*TalkType)(nil),
	Field:         90001,
	Name:          "brpc.request_talk_type",
	Tag:           "varint,90001,opt,name=request_talk_type,json=requestTalkType,enum=brpc.TalkType,def=0",
	Filename:      "options.proto",
}
View Source 
var E_ResponseCompression = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.MethodOptions)(nil),
	ExtensionType: (*CompressType)(nil),
	Field:         90005,
	Name:          "brpc.response_compression",
	Tag:           "varint,90005,opt,name=response_compression,json=responseCompression,enum=brpc.CompressType,def=0",
	Filename:      "options.proto",
}
View Source 
var E_ResponseTalkType = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.MethodOptions)(nil),
	ExtensionType: (*TalkType)(nil),
	Field:         90002,
	Name:          "brpc.response_talk_type",
	Tag:           "varint,90002,opt,name=response_talk_type,json=responseTalkType,enum=brpc.TalkType,def=0",
	Filename:      "options.proto",
}
View Source 
var E_ServiceTimeout = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.ServiceOptions)(nil),
	ExtensionType: (*int64)(nil),
	Field:         90000,
	Name:          "brpc.service_timeout",
	Tag:           "varint,90000,opt,name=service_timeout,json=serviceTimeout,def=10000",
	Filename:      "options.proto",
}
View Source 
var FrameType_name = map[int32]string{
	0: "FRAME_TYPE_UNKNOWN",
	1: "FRAME_TYPE_RST",
	2: "FRAME_TYPE_CLOSE",
	3: "FRAME_TYPE_DATA",
	4: "FRAME_TYPE_FEEDBACK",
}
View Source 
var FrameType_value = map[string]int32{
	"FRAME_TYPE_UNKNOWN":  0,
	"FRAME_TYPE_RST":      1,
	"FRAME_TYPE_CLOSE":    2,
	"FRAME_TYPE_DATA":     3,
	"FRAME_TYPE_FEEDBACK": 4,
}
View Source 
var ProtocolType_name = map[int32]string{
	0:  "PROTOCOL_UNKNOWN",
	1:  "PROTOCOL_BAIDU_STD",
	2:  "PROTOCOL_STREAMING_RPC",
	3:  "PROTOCOL_HULU_PBRPC",
	4:  "PROTOCOL_SOFA_PBRPC",
	5:  "PROTOCOL_RTMP",
	6:  "PROTOCOL_THRIFT",
	7:  "PROTOCOL_HTTP",
	8:  "PROTOCOL_PUBLIC_PBRPC",
	9:  "PROTOCOL_NOVA_PBRPC",
	10: "PROTOCOL_NSHEAD_CLIENT",
	11: "PROTOCOL_NSHEAD",
	12: "PROTOCOL_HADOOP_RPC",
	13: "PROTOCOL_HADOOP_SERVER_RPC",
	14: "PROTOCOL_MONGO",
	15: "PROTOCOL_UBRPC_COMPACK",
	16: "PROTOCOL_DIDX_CLIENT",
	17: "PROTOCOL_REDIS",
	18: "PROTOCOL_MEMCACHE",
	19: "PROTOCOL_ITP",
	20: "PROTOCOL_NSHEAD_MCPACK",
	21: "PROTOCOL_DISP_IDL",
	22: "PROTOCOL_ERSDA_CLIENT",
	23: "PROTOCOL_UBRPC_MCPACK2",
	24: "PROTOCOL_CDS_AGENT",
	25: "PROTOCOL_ESP",
	26: "PROTOCOL_H2",
}
View Source 
var ProtocolType_value = map[string]int32{
	"PROTOCOL_UNKNOWN":           0,
	"PROTOCOL_BAIDU_STD":         1,
	"PROTOCOL_STREAMING_RPC":     2,
	"PROTOCOL_HULU_PBRPC":        3,
	"PROTOCOL_SOFA_PBRPC":        4,
	"PROTOCOL_RTMP":              5,
	"PROTOCOL_THRIFT":            6,
	"PROTOCOL_HTTP":              7,
	"PROTOCOL_PUBLIC_PBRPC":      8,
	"PROTOCOL_NOVA_PBRPC":        9,
	"PROTOCOL_NSHEAD_CLIENT":     10,
	"PROTOCOL_NSHEAD":            11,
	"PROTOCOL_HADOOP_RPC":        12,
	"PROTOCOL_HADOOP_SERVER_RPC": 13,
	"PROTOCOL_MONGO":             14,
	"PROTOCOL_UBRPC_COMPACK":     15,
	"PROTOCOL_DIDX_CLIENT":       16,
	"PROTOCOL_REDIS":             17,
	"PROTOCOL_MEMCACHE":          18,
	"PROTOCOL_ITP":               19,
	"PROTOCOL_NSHEAD_MCPACK":     20,
	"PROTOCOL_DISP_IDL":          21,
	"PROTOCOL_ERSDA_CLIENT":      22,
	"PROTOCOL_UBRPC_MCPACK2":     23,
	"PROTOCOL_CDS_AGENT":         24,
	"PROTOCOL_ESP":               25,
	"PROTOCOL_H2":                26,
}
View Source 
var TalkType_name = map[int32]string{
	0: "TALK_TYPE_NORMAL",
	1: "TALK_TYPE_ONEWAY",
}
View Source 
var TalkType_value = map[string]int32{
	"TALK_TYPE_NORMAL": 0,
	"TALK_TYPE_ONEWAY": 1,
}

Functions

func NewBaiduRpcProtocol 

func NewBaiduRpcProtocol() net2.Protocol

Types

type BaiduRpcCodec 

type BaiduRpcCodec struct {
	*net.TCPConn
}

func (*BaiduRpcCodec) Close 

func (c *BaiduRpcCodec) Close() error

func (*BaiduRpcCodec) Receive 

func (c *BaiduRpcCodec) Receive() (interface{}, error)

func (*BaiduRpcCodec) Send 

func (c *BaiduRpcCodec) Send(msg interface{}) error

type BaiduRpcMessage 

type BaiduRpcMessage struct {
	Meta       *RpcMeta
	Payload    []byte
	Attachment []byte
}

//////////////////////////////////////////////////////////////////////////////

type BaiduRpcProtocol 

type BaiduRpcProtocol struct {
}

func (*BaiduRpcProtocol) NewCodec 

func (m *BaiduRpcProtocol) NewCodec(rw io.ReadWriter) (cc net2.Codec, err error)

type ChunkInfo 

type ChunkInfo struct {
	StreamId             *int64   `protobuf:"varint,1,req,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	ChunkId              *int64   `protobuf:"varint,2,req,name=chunk_id,json=chunkId" json:"chunk_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChunkInfo) Descriptor 

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

func (*ChunkInfo) GetChunkId 

func (m *ChunkInfo) GetChunkId() int64

func (*ChunkInfo) GetStreamId 

func (m *ChunkInfo) GetStreamId() int64

func (*ChunkInfo) ProtoMessage 

func (*ChunkInfo) ProtoMessage()

func (*ChunkInfo) Reset 

func (m *ChunkInfo) Reset()

func (*ChunkInfo) String 

func (m *ChunkInfo) String() string

func (*ChunkInfo) XXX_DiscardUnknown 

func (m *ChunkInfo) XXX_DiscardUnknown()

func (*ChunkInfo) XXX_Marshal 

func (m *ChunkInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChunkInfo) XXX_Merge 

func (dst *ChunkInfo) XXX_Merge(src proto.Message)

func (*ChunkInfo) XXX_Size 

func (m *ChunkInfo) XXX_Size() int

func (*ChunkInfo) XXX_Unmarshal 

func (m *ChunkInfo) XXX_Unmarshal(b []byte) error

type CompressType 

type CompressType int32
const (
	CompressType_COMPRESS_TYPE_NONE   CompressType = 0
	CompressType_COMPRESS_TYPE_SNAPPY CompressType = 1
	CompressType_COMPRESS_TYPE_GZIP   CompressType = 2
	CompressType_COMPRESS_TYPE_ZLIB   CompressType = 3
	CompressType_COMPRESS_TYPE_LZ4    CompressType = 4
)

func (CompressType) Enum 

func (x CompressType) Enum() *CompressType

func (CompressType) EnumDescriptor 

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

func (CompressType) String 

func (x CompressType) String() string

func (*CompressType) UnmarshalJSON 

func (x *CompressType) UnmarshalJSON(data []byte) error

type ConnectionType 

type ConnectionType int32
const (
	// bit-exclusive values since we may OR them to represent supported types.
	ConnectionType_CONNECTION_TYPE_UNKNOWN ConnectionType = 0
	ConnectionType_CONNECTION_TYPE_SINGLE  ConnectionType = 1
	ConnectionType_CONNECTION_TYPE_POOLED  ConnectionType = 2
	ConnectionType_CONNECTION_TYPE_SHORT   ConnectionType = 4
)

func (ConnectionType) Enum 

func (x ConnectionType) Enum() *ConnectionType

func (ConnectionType) EnumDescriptor 

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

func (ConnectionType) String 

func (x ConnectionType) String() string

func (*ConnectionType) UnmarshalJSON 

func (x *ConnectionType) UnmarshalJSON(data []byte) error

type Feedback 

type Feedback struct {
	ConsumedSize         *int64   `protobuf:"varint,1,opt,name=consumed_size,json=consumedSize" json:"consumed_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Feedback) Descriptor 

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

func (*Feedback) GetConsumedSize 

func (m *Feedback) GetConsumedSize() int64

func (*Feedback) ProtoMessage 

func (*Feedback) ProtoMessage()

func (*Feedback) Reset 

func (m *Feedback) Reset()

func (*Feedback) String 

func (m *Feedback) String() string

func (*Feedback) XXX_DiscardUnknown 

func (m *Feedback) XXX_DiscardUnknown()

func (*Feedback) XXX_Marshal 

func (m *Feedback) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Feedback) XXX_Merge 

func (dst *Feedback) XXX_Merge(src proto.Message)

func (*Feedback) XXX_Size 

func (m *Feedback) XXX_Size() int

func (*Feedback) XXX_Unmarshal 

func (m *Feedback) XXX_Unmarshal(b []byte) error

type FrameType 

type FrameType int32
const (
	FrameType_FRAME_TYPE_UNKNOWN  FrameType = 0
	FrameType_FRAME_TYPE_RST      FrameType = 1
	FrameType_FRAME_TYPE_CLOSE    FrameType = 2
	FrameType_FRAME_TYPE_DATA     FrameType = 3
	FrameType_FRAME_TYPE_FEEDBACK FrameType = 4
)

func (FrameType) Enum 

func (x FrameType) Enum() *FrameType

func (FrameType) EnumDescriptor 

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

func (FrameType) String 

func (x FrameType) String() string

func (*FrameType) UnmarshalJSON 

func (x *FrameType) UnmarshalJSON(data []byte) error

type MTProtoMeta 

type MTProtoMeta struct {
	AuthKeyId            *int64   `protobuf:"varint,1,opt,name=auth_key_id,json=authKeyId" json:"auth_key_id,omitempty"`
	SessionId            *int64   `protobuf:"varint,2,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
	MessageId            *int64   `protobuf:"varint,3,opt,name=message_id,json=messageId" json:"message_id,omitempty"`
	Layer                *int32   `protobuf:"varint,4,opt,name=layer" json:"layer,omitempty"`
	UserId               *int32   `protobuf:"varint,5,opt,name=user_id,json=userId" json:"user_id,omitempty"`
	AccessHash           *int64   `protobuf:"varint,6,opt,name=access_hash,json=accessHash" json:"access_hash,omitempty"`
	ServerId             *int32   `protobuf:"varint,7,opt,name=server_id,json=serverId" json:"server_id,omitempty"`
	ClientConnId         *int64   `protobuf:"varint,8,opt,name=client_conn_id,json=clientConnId" json:"client_conn_id,omitempty"`
	ClientAddr           *string  `protobuf:"bytes,9,opt,name=client_addr,json=clientAddr" json:"client_addr,omitempty"`
	From                 *string  `protobuf:"bytes,10,opt,name=from" json:"from,omitempty"`
	ReceiveTime          *int64   `protobuf:"varint,11,opt,name=receive_time,json=receiveTime" json:"receive_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MTProtoMeta) Descriptor 

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

func (*MTProtoMeta) GetAccessHash 

func (m *MTProtoMeta) GetAccessHash() int64

func (*MTProtoMeta) GetAuthKeyId 

func (m *MTProtoMeta) GetAuthKeyId() int64

func (*MTProtoMeta) GetClientAddr 

func (m *MTProtoMeta) GetClientAddr() string

func (*MTProtoMeta) GetClientConnId 

func (m *MTProtoMeta) GetClientConnId() int64

func (*MTProtoMeta) GetFrom 

func (m *MTProtoMeta) GetFrom() string

func (*MTProtoMeta) GetLayer 

func (m *MTProtoMeta) GetLayer() int32

func (*MTProtoMeta) GetMessageId 

func (m *MTProtoMeta) GetMessageId() int64

func (*MTProtoMeta) GetReceiveTime 

func (m *MTProtoMeta) GetReceiveTime() int64

func (*MTProtoMeta) GetServerId 

func (m *MTProtoMeta) GetServerId() int32

func (*MTProtoMeta) GetSessionId 

func (m *MTProtoMeta) GetSessionId() int64

func (*MTProtoMeta) GetUserId 

func (m *MTProtoMeta) GetUserId() int32

func (*MTProtoMeta) ProtoMessage 

func (*MTProtoMeta) ProtoMessage()

func (*MTProtoMeta) Reset 

func (m *MTProtoMeta) Reset()

func (*MTProtoMeta) String 

func (m *MTProtoMeta) String() string

func (*MTProtoMeta) XXX_DiscardUnknown 

func (m *MTProtoMeta) XXX_DiscardUnknown()

func (*MTProtoMeta) XXX_Marshal 

func (m *MTProtoMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MTProtoMeta) XXX_Merge 

func (dst *MTProtoMeta) XXX_Merge(src proto.Message)

func (*MTProtoMeta) XXX_Size 

func (m *MTProtoMeta) XXX_Size() int

func (*MTProtoMeta) XXX_Unmarshal 

func (m *MTProtoMeta) XXX_Unmarshal(b []byte) error

type ProtocolType 

type ProtocolType int32
const (
	ProtocolType_PROTOCOL_UNKNOWN           ProtocolType = 0
	ProtocolType_PROTOCOL_BAIDU_STD         ProtocolType = 1
	ProtocolType_PROTOCOL_STREAMING_RPC     ProtocolType = 2
	ProtocolType_PROTOCOL_HULU_PBRPC        ProtocolType = 3
	ProtocolType_PROTOCOL_SOFA_PBRPC        ProtocolType = 4
	ProtocolType_PROTOCOL_RTMP              ProtocolType = 5
	ProtocolType_PROTOCOL_THRIFT            ProtocolType = 6
	ProtocolType_PROTOCOL_HTTP              ProtocolType = 7
	ProtocolType_PROTOCOL_PUBLIC_PBRPC      ProtocolType = 8
	ProtocolType_PROTOCOL_NOVA_PBRPC        ProtocolType = 9
	ProtocolType_PROTOCOL_NSHEAD_CLIENT     ProtocolType = 10
	ProtocolType_PROTOCOL_NSHEAD            ProtocolType = 11
	ProtocolType_PROTOCOL_HADOOP_RPC        ProtocolType = 12
	ProtocolType_PROTOCOL_HADOOP_SERVER_RPC ProtocolType = 13
	ProtocolType_PROTOCOL_MONGO             ProtocolType = 14
	ProtocolType_PROTOCOL_UBRPC_COMPACK     ProtocolType = 15
	ProtocolType_PROTOCOL_DIDX_CLIENT       ProtocolType = 16
	ProtocolType_PROTOCOL_REDIS             ProtocolType = 17
	ProtocolType_PROTOCOL_MEMCACHE          ProtocolType = 18
	ProtocolType_PROTOCOL_ITP               ProtocolType = 19
	ProtocolType_PROTOCOL_NSHEAD_MCPACK     ProtocolType = 20
	ProtocolType_PROTOCOL_DISP_IDL          ProtocolType = 21
	ProtocolType_PROTOCOL_ERSDA_CLIENT      ProtocolType = 22
	ProtocolType_PROTOCOL_UBRPC_MCPACK2     ProtocolType = 23
	// Reserve special protocol for cds-agent, which depends on FIFO right now
	ProtocolType_PROTOCOL_CDS_AGENT ProtocolType = 24
	ProtocolType_PROTOCOL_ESP       ProtocolType = 25
	ProtocolType_PROTOCOL_H2        ProtocolType = 26
)

func (ProtocolType) Enum 

func (x ProtocolType) Enum() *ProtocolType

func (ProtocolType) EnumDescriptor 

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

func (ProtocolType) String 

func (x ProtocolType) String() string

func (*ProtocolType) UnmarshalJSON 

func (x *ProtocolType) UnmarshalJSON(data []byte) error

type RpcMeta 

type RpcMeta struct {
	Request              *RpcRequestMeta  `protobuf:"bytes,1,opt,name=request" json:"request,omitempty"`
	Response             *RpcResponseMeta `protobuf:"bytes,2,opt,name=response" json:"response,omitempty"`
	CompressType         *int32           `protobuf:"varint,3,opt,name=compress_type,json=compressType" json:"compress_type,omitempty"`
	CorrelationId        *int64           `protobuf:"varint,4,opt,name=correlation_id,json=correlationId" json:"correlation_id,omitempty"`
	AttachmentSize       *int32           `protobuf:"varint,5,opt,name=attachment_size,json=attachmentSize" json:"attachment_size,omitempty"`
	ChunkInfo            *ChunkInfo       `protobuf:"bytes,6,opt,name=chunk_info,json=chunkInfo" json:"chunk_info,omitempty"`
	AuthenticationData   []byte           `protobuf:"bytes,7,opt,name=authentication_data,json=authenticationData" json:"authentication_data,omitempty"`
	StreamSettings       *StreamSettings  `protobuf:"bytes,8,opt,name=stream_settings,json=streamSettings" json:"stream_settings,omitempty"`
	MtprotoMeta          *MTProtoMeta     `protobuf:"bytes,9,opt,name=mtproto_meta,json=mtprotoMeta" json:"mtproto_meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*RpcMeta) Descriptor 

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

func (*RpcMeta) GetAttachmentSize 

func (m *RpcMeta) GetAttachmentSize() int32

func (*RpcMeta) GetAuthenticationData 

func (m *RpcMeta) GetAuthenticationData() []byte

func (*RpcMeta) GetChunkInfo 

func (m *RpcMeta) GetChunkInfo() *ChunkInfo

func (*RpcMeta) GetCompressType 

func (m *RpcMeta) GetCompressType() int32

func (*RpcMeta) GetCorrelationId 

func (m *RpcMeta) GetCorrelationId() int64

func (*RpcMeta) GetMtprotoMeta 

func (m *RpcMeta) GetMtprotoMeta() *MTProtoMeta

func (*RpcMeta) GetRequest 

func (m *RpcMeta) GetRequest() *RpcRequestMeta

func (*RpcMeta) GetResponse 

func (m *RpcMeta) GetResponse() *RpcResponseMeta

func (*RpcMeta) GetStreamSettings 

func (m *RpcMeta) GetStreamSettings() *StreamSettings

func (*RpcMeta) ProtoMessage 

func (*RpcMeta) ProtoMessage()

func (*RpcMeta) Reset 

func (m *RpcMeta) Reset()

func (*RpcMeta) String 

func (m *RpcMeta) String() string

func (*RpcMeta) XXX_DiscardUnknown 

func (m *RpcMeta) XXX_DiscardUnknown()

func (*RpcMeta) XXX_Marshal 

func (m *RpcMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcMeta) XXX_Merge 

func (dst *RpcMeta) XXX_Merge(src proto.Message)

func (*RpcMeta) XXX_Size 

func (m *RpcMeta) XXX_Size() int

func (*RpcMeta) XXX_Unmarshal 

func (m *RpcMeta) XXX_Unmarshal(b []byte) error

type RpcRequestMeta 

type RpcRequestMeta struct {
	ServiceName          *string  `protobuf:"bytes,1,req,name=service_name,json=serviceName" json:"service_name,omitempty"`
	MethodName           *string  `protobuf:"bytes,2,req,name=method_name,json=methodName" json:"method_name,omitempty"`
	LogId                *int64   `protobuf:"varint,3,opt,name=log_id,json=logId" json:"log_id,omitempty"`
	TraceId              *int64   `protobuf:"varint,4,opt,name=trace_id,json=traceId" json:"trace_id,omitempty"`
	SpanId               *int64   `protobuf:"varint,5,opt,name=span_id,json=spanId" json:"span_id,omitempty"`
	ParentSpanId         *int64   `protobuf:"varint,6,opt,name=parent_span_id,json=parentSpanId" json:"parent_span_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RpcRequestMeta) Descriptor 

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

func (*RpcRequestMeta) GetLogId 

func (m *RpcRequestMeta) GetLogId() int64

func (*RpcRequestMeta) GetMethodName 

func (m *RpcRequestMeta) GetMethodName() string

func (*RpcRequestMeta) GetParentSpanId 

func (m *RpcRequestMeta) GetParentSpanId() int64

func (*RpcRequestMeta) GetServiceName 

func (m *RpcRequestMeta) GetServiceName() string

func (*RpcRequestMeta) GetSpanId 

func (m *RpcRequestMeta) GetSpanId() int64

func (*RpcRequestMeta) GetTraceId 

func (m *RpcRequestMeta) GetTraceId() int64

func (*RpcRequestMeta) ProtoMessage 

func (*RpcRequestMeta) ProtoMessage()

func (*RpcRequestMeta) Reset 

func (m *RpcRequestMeta) Reset()

func (*RpcRequestMeta) String 

func (m *RpcRequestMeta) String() string

func (*RpcRequestMeta) XXX_DiscardUnknown 

func (m *RpcRequestMeta) XXX_DiscardUnknown()

func (*RpcRequestMeta) XXX_Marshal 

func (m *RpcRequestMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcRequestMeta) XXX_Merge 

func (dst *RpcRequestMeta) XXX_Merge(src proto.Message)

func (*RpcRequestMeta) XXX_Size 

func (m *RpcRequestMeta) XXX_Size() int

func (*RpcRequestMeta) XXX_Unmarshal 

func (m *RpcRequestMeta) XXX_Unmarshal(b []byte) error

type RpcResponseMeta 

type RpcResponseMeta struct {
	ErrorCode            *int32   `protobuf:"varint,1,opt,name=error_code,json=errorCode" json:"error_code,omitempty"`
	ErrorText            *string  `protobuf:"bytes,2,opt,name=error_text,json=errorText" json:"error_text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RpcResponseMeta) Descriptor 

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

func (*RpcResponseMeta) GetErrorCode 

func (m *RpcResponseMeta) GetErrorCode() int32

func (*RpcResponseMeta) GetErrorText 

func (m *RpcResponseMeta) GetErrorText() string

func (*RpcResponseMeta) ProtoMessage 

func (*RpcResponseMeta) ProtoMessage()

func (*RpcResponseMeta) Reset 

func (m *RpcResponseMeta) Reset()

func (*RpcResponseMeta) String 

func (m *RpcResponseMeta) String() string

func (*RpcResponseMeta) XXX_DiscardUnknown 

func (m *RpcResponseMeta) XXX_DiscardUnknown()

func (*RpcResponseMeta) XXX_Marshal 

func (m *RpcResponseMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcResponseMeta) XXX_Merge 

func (dst *RpcResponseMeta) XXX_Merge(src proto.Message)

func (*RpcResponseMeta) XXX_Size 

func (m *RpcResponseMeta) XXX_Size() int

func (*RpcResponseMeta) XXX_Unmarshal 

func (m *RpcResponseMeta) XXX_Unmarshal(b []byte) error

type StreamFrameMeta 

type StreamFrameMeta struct {
	StreamId             *int64     `protobuf:"varint,1,req,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	SourceStreamId       *int64     `protobuf:"varint,2,opt,name=source_stream_id,json=sourceStreamId" json:"source_stream_id,omitempty"`
	FrameType            *FrameType `protobuf:"varint,3,opt,name=frame_type,json=frameType,enum=brpc.FrameType" json:"frame_type,omitempty"`
	HasContinuation      *bool      `protobuf:"varint,4,opt,name=has_continuation,json=hasContinuation" json:"has_continuation,omitempty"`
	Feedback             *Feedback  `protobuf:"bytes,5,opt,name=feedback" json:"feedback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*StreamFrameMeta) Descriptor 

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

func (*StreamFrameMeta) GetFeedback 

func (m *StreamFrameMeta) GetFeedback() *Feedback

func (*StreamFrameMeta) GetFrameType 

func (m *StreamFrameMeta) GetFrameType() FrameType

func (*StreamFrameMeta) GetHasContinuation 

func (m *StreamFrameMeta) GetHasContinuation() bool

func (*StreamFrameMeta) GetSourceStreamId 

func (m *StreamFrameMeta) GetSourceStreamId() int64

func (*StreamFrameMeta) GetStreamId 

func (m *StreamFrameMeta) GetStreamId() int64

func (*StreamFrameMeta) ProtoMessage 

func (*StreamFrameMeta) ProtoMessage()

func (*StreamFrameMeta) Reset 

func (m *StreamFrameMeta) Reset()

func (*StreamFrameMeta) String 

func (m *StreamFrameMeta) String() string

func (*StreamFrameMeta) XXX_DiscardUnknown 

func (m *StreamFrameMeta) XXX_DiscardUnknown()

func (*StreamFrameMeta) XXX_Marshal 

func (m *StreamFrameMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamFrameMeta) XXX_Merge 

func (dst *StreamFrameMeta) XXX_Merge(src proto.Message)

func (*StreamFrameMeta) XXX_Size 

func (m *StreamFrameMeta) XXX_Size() int

func (*StreamFrameMeta) XXX_Unmarshal 

func (m *StreamFrameMeta) XXX_Unmarshal(b []byte) error

type StreamSettings 

type StreamSettings struct {
	StreamId             *int64   `protobuf:"varint,1,req,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	NeedFeedback         *bool    `protobuf:"varint,2,opt,name=need_feedback,json=needFeedback,def=0" json:"need_feedback,omitempty"`
	Writable             *bool    `protobuf:"varint,3,opt,name=writable,def=0" json:"writable,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamSettings) Descriptor 

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

func (*StreamSettings) GetNeedFeedback 

func (m *StreamSettings) GetNeedFeedback() bool

func (*StreamSettings) GetStreamId 

func (m *StreamSettings) GetStreamId() int64

func (*StreamSettings) GetWritable 

func (m *StreamSettings) GetWritable() bool

func (*StreamSettings) ProtoMessage 

func (*StreamSettings) ProtoMessage()

func (*StreamSettings) Reset 

func (m *StreamSettings) Reset()

func (*StreamSettings) String 

func (m *StreamSettings) String() string

func (*StreamSettings) XXX_DiscardUnknown 

func (m *StreamSettings) XXX_DiscardUnknown()

func (*StreamSettings) XXX_Marshal 

func (m *StreamSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamSettings) XXX_Merge 

func (dst *StreamSettings) XXX_Merge(src proto.Message)

func (*StreamSettings) XXX_Size 

func (m *StreamSettings) XXX_Size() int

func (*StreamSettings) XXX_Unmarshal 

func (m *StreamSettings) XXX_Unmarshal(b []byte) error

type TalkType 

type TalkType int32
const (
	TalkType_TALK_TYPE_NORMAL TalkType = 0
	TalkType_TALK_TYPE_ONEWAY TalkType = 1
)

func (TalkType) Enum 

func (x TalkType) Enum() *TalkType

func (TalkType) EnumDescriptor 

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

func (TalkType) String 

func (x TalkType) String() string

func (*TalkType) UnmarshalJSON 

func (x *TalkType) UnmarshalJSON(data []byte) error

Source Files

View all Source files

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.