brpcpb

package
v0.0.0-...-3b6a1d2 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

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

Default values for StreamSettings fields.

Variables

View Source 
var (
	Errno_name = map[int32]string{
		1001: "ENOSERVICE",
		1002: "ENOMETHOD",
		1003: "EREQUEST",
		1004: "ERPCAUTH",
		1005: "ETOOMANYFAILS",
		1006: "EPCHANFINISH",
		1007: "EBACKUPREQUEST",
		1008: "ERPCTIMEDOUT",
		1009: "EFAILEDSOCKET",
		1010: "EHTTP",
		1011: "EOVERCROWDED",
		1012: "ERTMPPUBLISHABLE",
		1013: "ERTMPCREATESTREAM",
		1014: "EEOF",
		1015: "EUNUSED",
		1016: "ESSL",
		1017: "EH2RUNOUTSTREAMS",
		1018: "EREJECT",
		2001: "EINTERNAL",
		2002: "ERESPONSE",
		2003: "ELOGOFF",
		2004: "ELIMIT",
		2005: "ECLOSE",
		2006: "EITP",
		3001: "ERDMA",
		3002: "ERDMAMEM",
	}
	Errno_value = map[string]int32{
		"ENOSERVICE":        1001,
		"ENOMETHOD":         1002,
		"EREQUEST":          1003,
		"ERPCAUTH":          1004,
		"ETOOMANYFAILS":     1005,
		"EPCHANFINISH":      1006,
		"EBACKUPREQUEST":    1007,
		"ERPCTIMEDOUT":      1008,
		"EFAILEDSOCKET":     1009,
		"EHTTP":             1010,
		"EOVERCROWDED":      1011,
		"ERTMPPUBLISHABLE":  1012,
		"ERTMPCREATESTREAM": 1013,
		"EEOF":              1014,
		"EUNUSED":           1015,
		"ESSL":              1016,
		"EH2RUNOUTSTREAMS":  1017,
		"EREJECT":           1018,
		"EINTERNAL":         2001,
		"ERESPONSE":         2002,
		"ELOGOFF":           2003,
		"ELIMIT":            2004,
		"ECLOSE":            2005,
		"EITP":              2006,
		"ERDMA":             3001,
		"ERDMAMEM":          3002,
	}
)

Enum value maps for Errno.

View Source 
var (
	TalkType_name = map[int32]string{
		0: "TALK_TYPE_NORMAL",
		1: "TALK_TYPE_ONEWAY",
	}
	TalkType_value = map[string]int32{
		"TALK_TYPE_NORMAL": 0,
		"TALK_TYPE_ONEWAY": 1,
	}
)

Enum value maps for TalkType.

View Source 
var (
	ConnectionType_name = map[int32]string{
		0: "CONNECTION_TYPE_UNKNOWN",
		1: "CONNECTION_TYPE_SINGLE",
		2: "CONNECTION_TYPE_POOLED",
		4: "CONNECTION_TYPE_SHORT",
	}
	ConnectionType_value = map[string]int32{
		"CONNECTION_TYPE_UNKNOWN": 0,
		"CONNECTION_TYPE_SINGLE":  1,
		"CONNECTION_TYPE_POOLED":  2,
		"CONNECTION_TYPE_SHORT":   4,
	}
)

Enum value maps for ConnectionType.

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_REDIS",
		11: "PROTOCOL_NSHEAD_CLIENT",
		12: "PROTOCOL_NSHEAD",
		13: "PROTOCOL_HADOOP_RPC",
		14: "PROTOCOL_HADOOP_SERVER_RPC",
		15: "PROTOCOL_MONGO",
		16: "PROTOCOL_UBRPC_COMPACK",
		17: "PROTOCOL_DIDX_CLIENT",
		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",
	}
	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_REDIS":             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_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,
	}
)

Enum value maps for ProtocolType.

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",
	}
	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,
	}
)

Enum value maps for CompressType.

View Source 
var (
	// Talk type.
	//
	// optional brpc.TalkType request_talk_type = 90001;
	E_RequestTalkType = &file_options_proto_extTypes[1]
	// optional brpc.TalkType response_talk_type = 90002;
	E_ResponseTalkType = &file_options_proto_extTypes[2]
	// If set, override service_timeout.
	//
	// optional int64 method_timeout = 90003;
	E_MethodTimeout = &file_options_proto_extTypes[3]
	// Compression for request/response.
	//
	// optional brpc.CompressType request_compression = 90004;
	E_RequestCompression = &file_options_proto_extTypes[4]
	// optional brpc.CompressType response_compression = 90005;
	E_ResponseCompression = &file_options_proto_extTypes[5]
)

Extension fields to descriptorpb.MethodOptions.

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",
	}
	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,
	}
)

Enum value maps for FrameType.

View Source 
var (
	// Timeout in milliseconds, at service level.
	//
	// optional int64 service_timeout = 90000;
	E_ServiceTimeout = &file_options_proto_extTypes[0]
)

Extension fields to descriptorpb.ServiceOptions.

View Source 
var File_baidu_rpc_meta_proto protoreflect.FileDescriptor
View Source 
var File_error_proto protoreflect.FileDescriptor
View Source 
var File_options_proto protoreflect.FileDescriptor
View Source 
var File_streaming_rpc_meta_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

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"`
	// contains filtered or unexported fields
}

func (*ChunkInfo) Descriptor deprecated 

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

Deprecated: Use ChunkInfo.ProtoReflect.Descriptor instead.

func (*ChunkInfo) GetChunkId 

func (x *ChunkInfo) GetChunkId() int64

func (*ChunkInfo) GetStreamId 

func (x *ChunkInfo) GetStreamId() int64

func (*ChunkInfo) ProtoMessage 

func (*ChunkInfo) ProtoMessage()

func (*ChunkInfo) ProtoReflect 

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

func (*ChunkInfo) Reset 

func (x *ChunkInfo) Reset()

func (*ChunkInfo) String 

func (x *ChunkInfo) String() string

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) Descriptor 

func (CompressType) Descriptor() protoreflect.EnumDescriptor

func (CompressType) Enum 

func (x CompressType) Enum() *CompressType

func (CompressType) EnumDescriptor deprecated 

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

Deprecated: Use CompressType.Descriptor instead.

func (CompressType) Number 

func (x CompressType) Number() protoreflect.EnumNumber

func (CompressType) String 

func (x CompressType) String() string

func (CompressType) Type 

func (CompressType) Type() protoreflect.EnumType

func (*CompressType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

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) Descriptor 

func (ConnectionType) Descriptor() protoreflect.EnumDescriptor

func (ConnectionType) Enum 

func (x ConnectionType) Enum() *ConnectionType

func (ConnectionType) EnumDescriptor deprecated 

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

Deprecated: Use ConnectionType.Descriptor instead.

func (ConnectionType) Number 

func (x ConnectionType) Number() protoreflect.EnumNumber

func (ConnectionType) String 

func (x ConnectionType) String() string

func (ConnectionType) Type 

func (ConnectionType) Type() protoreflect.EnumType

func (*ConnectionType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type Errno 

type Errno int32
const (
	// Errno caused by client
	Errno_ENOSERVICE Errno = 1001 // Service not found
	Errno_ENOMETHOD  Errno = 1002 // Method not found
	Errno_EREQUEST   Errno = 1003 // Bad Request
	Errno_ERPCAUTH   Errno = 1004 // Unauthorized, can't be called EAUTH
	// directly which is defined in MACOSX
	Errno_ETOOMANYFAILS     Errno = 1005 // Too many sub calls failed
	Errno_EPCHANFINISH      Errno = 1006 // [Internal] ParallelChannel finished
	Errno_EBACKUPREQUEST    Errno = 1007 // Sending backup request
	Errno_ERPCTIMEDOUT      Errno = 1008 // RPC call is timed out
	Errno_EFAILEDSOCKET     Errno = 1009 // Broken socket
	Errno_EHTTP             Errno = 1010 // Bad http call
	Errno_EOVERCROWDED      Errno = 1011 // The server is overcrowded
	Errno_ERTMPPUBLISHABLE  Errno = 1012 // RtmpRetryingClientStream is publishable
	Errno_ERTMPCREATESTREAM Errno = 1013 // createStream was rejected by the RTMP server
	Errno_EEOF              Errno = 1014 // Got EOF
	Errno_EUNUSED           Errno = 1015 // The socket was not needed
	Errno_ESSL              Errno = 1016 // SSL related error
	Errno_EH2RUNOUTSTREAMS  Errno = 1017 // The H2 socket was run out of streams
	Errno_EREJECT           Errno = 1018 // The Request is rejected
	// Errno caused by server
	Errno_EINTERNAL Errno = 2001 // Internal Server Error
	Errno_ERESPONSE Errno = 2002 // Bad Response
	Errno_ELOGOFF   Errno = 2003 // Server is stopping
	Errno_ELIMIT    Errno = 2004 // Reached server's limit on resources
	Errno_ECLOSE    Errno = 2005 // Close socket initiatively
	Errno_EITP      Errno = 2006 // Failed Itp response
	// Errno related to RDMA (may happen at both sides)
	Errno_ERDMA    Errno = 3001 // RDMA verbs error
	Errno_ERDMAMEM Errno = 3002 // Memory not registered for RDMA
)

func (Errno) Descriptor 

func (Errno) Descriptor() protoreflect.EnumDescriptor

func (Errno) Enum 

func (x Errno) Enum() *Errno

func (Errno) EnumDescriptor deprecated 

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

Deprecated: Use Errno.Descriptor instead.

func (Errno) Number 

func (x Errno) Number() protoreflect.EnumNumber

func (Errno) String 

func (x Errno) String() string

func (Errno) Type 

func (Errno) Type() protoreflect.EnumType

func (*Errno) UnmarshalJSON deprecated 

func (x *Errno) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Feedback 

type Feedback struct {
	ConsumedSize *int64 `protobuf:"varint,1,opt,name=consumed_size,json=consumedSize" json:"consumed_size,omitempty"`
	// contains filtered or unexported fields
}

func (*Feedback) Descriptor deprecated 

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

Deprecated: Use Feedback.ProtoReflect.Descriptor instead.

func (*Feedback) GetConsumedSize 

func (x *Feedback) GetConsumedSize() int64

func (*Feedback) ProtoMessage 

func (*Feedback) ProtoMessage()

func (*Feedback) ProtoReflect 

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

func (*Feedback) Reset 

func (x *Feedback) Reset()

func (*Feedback) String 

func (x *Feedback) String() string

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) Descriptor 

func (FrameType) Descriptor() protoreflect.EnumDescriptor

func (FrameType) Enum 

func (x FrameType) Enum() *FrameType

func (FrameType) EnumDescriptor deprecated 

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

Deprecated: Use FrameType.Descriptor instead.

func (FrameType) Number 

func (x FrameType) Number() protoreflect.EnumNumber

func (FrameType) String 

func (x FrameType) String() string

func (FrameType) Type 

func (FrameType) Type() protoreflect.EnumType

func (*FrameType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

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_REDIS             ProtocolType = 10
	ProtocolType_PROTOCOL_NSHEAD_CLIENT     ProtocolType = 11 // implemented in baidu-rpc-ub
	ProtocolType_PROTOCOL_NSHEAD            ProtocolType = 12
	ProtocolType_PROTOCOL_HADOOP_RPC        ProtocolType = 13
	ProtocolType_PROTOCOL_HADOOP_SERVER_RPC ProtocolType = 14
	ProtocolType_PROTOCOL_MONGO             ProtocolType = 15 // server side only
	ProtocolType_PROTOCOL_UBRPC_COMPACK     ProtocolType = 16
	ProtocolType_PROTOCOL_DIDX_CLIENT       ProtocolType = 17 // Client side only
	ProtocolType_PROTOCOL_MEMCACHE          ProtocolType = 18 // Client side only
	ProtocolType_PROTOCOL_ITP               ProtocolType = 19
	ProtocolType_PROTOCOL_NSHEAD_MCPACK     ProtocolType = 20
	ProtocolType_PROTOCOL_DISP_IDL          ProtocolType = 21 // Client side only
	ProtocolType_PROTOCOL_ERSDA_CLIENT      ProtocolType = 22 // Client side only
	ProtocolType_PROTOCOL_UBRPC_MCPACK2     ProtocolType = 23 // Client side only
	// Reserve special protocol for cds-agent, which depends on FIFO right now
	ProtocolType_PROTOCOL_CDS_AGENT ProtocolType = 24 // Client side only
	ProtocolType_PROTOCOL_ESP       ProtocolType = 25 // Client side only
	ProtocolType_PROTOCOL_H2        ProtocolType = 26
)

func (ProtocolType) Descriptor 

func (ProtocolType) Descriptor() protoreflect.EnumDescriptor

func (ProtocolType) Enum 

func (x ProtocolType) Enum() *ProtocolType

func (ProtocolType) EnumDescriptor deprecated 

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

Deprecated: Use ProtocolType.Descriptor instead.

func (ProtocolType) Number 

func (x ProtocolType) Number() protoreflect.EnumNumber

func (ProtocolType) String 

func (x ProtocolType) String() string

func (ProtocolType) Type 

func (ProtocolType) Type() protoreflect.EnumType

func (*ProtocolType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

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"`
	// contains filtered or unexported fields
}

func (*RpcMeta) Descriptor deprecated 

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

Deprecated: Use RpcMeta.ProtoReflect.Descriptor instead.

func (*RpcMeta) GetAttachmentSize 

func (x *RpcMeta) GetAttachmentSize() int32

func (*RpcMeta) GetAuthenticationData 

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

func (*RpcMeta) GetChunkInfo 

func (x *RpcMeta) GetChunkInfo() *ChunkInfo

func (*RpcMeta) GetCompressType 

func (x *RpcMeta) GetCompressType() int32

func (*RpcMeta) GetCorrelationId 

func (x *RpcMeta) GetCorrelationId() int64

func (*RpcMeta) GetRequest 

func (x *RpcMeta) GetRequest() *RpcRequestMeta

func (*RpcMeta) GetResponse 

func (x *RpcMeta) GetResponse() *RpcResponseMeta

func (*RpcMeta) GetStreamSettings 

func (x *RpcMeta) GetStreamSettings() *StreamSettings

func (*RpcMeta) ProtoMessage 

func (*RpcMeta) ProtoMessage()

func (*RpcMeta) ProtoReflect 

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

func (*RpcMeta) Reset 

func (x *RpcMeta) Reset()

func (*RpcMeta) String 

func (x *RpcMeta) String() string

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"`
	RequestId    *string `protobuf:"bytes,7,opt,name=request_id,json=requestId" json:"request_id,omitempty"`  // correspond to x-request-id in http header
	TimeoutMs    *int32  `protobuf:"varint,8,opt,name=timeout_ms,json=timeoutMs" json:"timeout_ms,omitempty"` // client's timeout setting for current call
	// contains filtered or unexported fields
}

func (*RpcRequestMeta) Descriptor deprecated 

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

Deprecated: Use RpcRequestMeta.ProtoReflect.Descriptor instead.

func (*RpcRequestMeta) GetLogId 

func (x *RpcRequestMeta) GetLogId() int64

func (*RpcRequestMeta) GetMethodName 

func (x *RpcRequestMeta) GetMethodName() string

func (*RpcRequestMeta) GetParentSpanId 

func (x *RpcRequestMeta) GetParentSpanId() int64

func (*RpcRequestMeta) GetRequestId 

func (x *RpcRequestMeta) GetRequestId() string

func (*RpcRequestMeta) GetServiceName 

func (x *RpcRequestMeta) GetServiceName() string

func (*RpcRequestMeta) GetSpanId 

func (x *RpcRequestMeta) GetSpanId() int64

func (*RpcRequestMeta) GetTimeoutMs 

func (x *RpcRequestMeta) GetTimeoutMs() int32

func (*RpcRequestMeta) GetTraceId 

func (x *RpcRequestMeta) GetTraceId() int64

func (*RpcRequestMeta) ProtoMessage 

func (*RpcRequestMeta) ProtoMessage()

func (*RpcRequestMeta) ProtoReflect 

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

func (*RpcRequestMeta) Reset 

func (x *RpcRequestMeta) Reset()

func (*RpcRequestMeta) String 

func (x *RpcRequestMeta) String() string

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"`
	// contains filtered or unexported fields
}

func (*RpcResponseMeta) Descriptor deprecated 

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

Deprecated: Use RpcResponseMeta.ProtoReflect.Descriptor instead.

func (*RpcResponseMeta) GetErrorCode 

func (x *RpcResponseMeta) GetErrorCode() int32

func (*RpcResponseMeta) GetErrorText 

func (x *RpcResponseMeta) GetErrorText() string

func (*RpcResponseMeta) ProtoMessage 

func (*RpcResponseMeta) ProtoMessage()

func (*RpcResponseMeta) ProtoReflect 

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

func (*RpcResponseMeta) Reset 

func (x *RpcResponseMeta) Reset()

func (*RpcResponseMeta) String 

func (x *RpcResponseMeta) String() string

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"`
	// contains filtered or unexported fields
}

func (*StreamFrameMeta) Descriptor deprecated 

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

Deprecated: Use StreamFrameMeta.ProtoReflect.Descriptor instead.

func (*StreamFrameMeta) GetFeedback 

func (x *StreamFrameMeta) GetFeedback() *Feedback

func (*StreamFrameMeta) GetFrameType 

func (x *StreamFrameMeta) GetFrameType() FrameType

func (*StreamFrameMeta) GetHasContinuation 

func (x *StreamFrameMeta) GetHasContinuation() bool

func (*StreamFrameMeta) GetSourceStreamId 

func (x *StreamFrameMeta) GetSourceStreamId() int64

func (*StreamFrameMeta) GetStreamId 

func (x *StreamFrameMeta) GetStreamId() int64

func (*StreamFrameMeta) ProtoMessage 

func (*StreamFrameMeta) ProtoMessage()

func (*StreamFrameMeta) ProtoReflect 

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

func (*StreamFrameMeta) Reset 

func (x *StreamFrameMeta) Reset()

func (*StreamFrameMeta) String 

func (x *StreamFrameMeta) String() string

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"`
	// contains filtered or unexported fields
}

func (*StreamSettings) Descriptor deprecated 

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

Deprecated: Use StreamSettings.ProtoReflect.Descriptor instead.

func (*StreamSettings) GetNeedFeedback 

func (x *StreamSettings) GetNeedFeedback() bool

func (*StreamSettings) GetStreamId 

func (x *StreamSettings) GetStreamId() int64

func (*StreamSettings) GetWritable 

func (x *StreamSettings) GetWritable() bool

func (*StreamSettings) ProtoMessage 

func (*StreamSettings) ProtoMessage()

func (*StreamSettings) ProtoReflect 

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

func (*StreamSettings) Reset 

func (x *StreamSettings) Reset()

func (*StreamSettings) String 

func (x *StreamSettings) String() string

type TalkType 

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

func (TalkType) Descriptor 

func (TalkType) Descriptor() protoreflect.EnumDescriptor

func (TalkType) Enum 

func (x TalkType) Enum() *TalkType

func (TalkType) EnumDescriptor deprecated 

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

Deprecated: Use TalkType.Descriptor instead.

func (TalkType) Number 

func (x TalkType) Number() protoreflect.EnumNumber

func (TalkType) String 

func (x TalkType) String() string

func (TalkType) Type 

func (TalkType) Type() protoreflect.EnumType

func (*TalkType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

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.