Documentation ¶
Index ¶
- Variables
- type ChunkInfo
- type CompressType
- func (CompressType) Descriptor() protoreflect.EnumDescriptor
- func (x CompressType) Enum() *CompressType
- func (CompressType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CompressType) Number() protoreflect.EnumNumber
- func (x CompressType) String() string
- func (CompressType) Type() protoreflect.EnumType
- type Feedback
- type FrameType
- type RpcMeta
- func (*RpcMeta) Descriptor() ([]byte, []int)deprecated
- func (x *RpcMeta) GetAttachmentSize() int32
- func (x *RpcMeta) GetAuthenticationData() []byte
- func (x *RpcMeta) GetChunkInfo() *ChunkInfo
- func (x *RpcMeta) GetCompressType() int32
- func (x *RpcMeta) GetCorrelationId() int64
- func (x *RpcMeta) GetRequest() *RpcRequestMeta
- func (x *RpcMeta) GetResponse() *RpcResponseMeta
- func (x *RpcMeta) GetStreamSettings() *StreamSettings
- func (*RpcMeta) ProtoMessage()
- func (x *RpcMeta) ProtoReflect() protoreflect.Message
- func (x *RpcMeta) Reset()
- func (x *RpcMeta) String() string
- type RpcRequestMeta
- func (*RpcRequestMeta) Descriptor() ([]byte, []int)deprecated
- func (x *RpcRequestMeta) GetLogId() int64
- func (x *RpcRequestMeta) GetMethodName() string
- func (x *RpcRequestMeta) GetParentSpanId() int64
- func (x *RpcRequestMeta) GetRequestId() string
- func (x *RpcRequestMeta) GetServiceName() string
- func (x *RpcRequestMeta) GetSpanId() int64
- func (x *RpcRequestMeta) GetTraceId() int64
- func (*RpcRequestMeta) ProtoMessage()
- func (x *RpcRequestMeta) ProtoReflect() protoreflect.Message
- func (x *RpcRequestMeta) Reset()
- func (x *RpcRequestMeta) String() string
- type RpcResponseMeta
- func (*RpcResponseMeta) Descriptor() ([]byte, []int)deprecated
- func (x *RpcResponseMeta) GetErrorCode() int32
- func (x *RpcResponseMeta) GetErrorText() string
- func (*RpcResponseMeta) ProtoMessage()
- func (x *RpcResponseMeta) ProtoReflect() protoreflect.Message
- func (x *RpcResponseMeta) Reset()
- func (x *RpcResponseMeta) String() string
- type StreamFrameMeta
- func (*StreamFrameMeta) Descriptor() ([]byte, []int)deprecated
- func (x *StreamFrameMeta) GetFeedback() *Feedback
- func (x *StreamFrameMeta) GetFrameType() FrameType
- func (x *StreamFrameMeta) GetHasContinuation() bool
- func (x *StreamFrameMeta) GetSourceStreamId() int64
- func (x *StreamFrameMeta) GetStreamId() int64
- func (*StreamFrameMeta) ProtoMessage()
- func (x *StreamFrameMeta) ProtoReflect() protoreflect.Message
- func (x *StreamFrameMeta) Reset()
- func (x *StreamFrameMeta) String() string
- type StreamSettings
- func (*StreamSettings) Descriptor() ([]byte, []int)deprecated
- func (x *StreamSettings) GetNeedFeedback() bool
- func (x *StreamSettings) GetStreamId() int64
- func (x *StreamSettings) GetWritable() bool
- func (*StreamSettings) ProtoMessage()
- func (x *StreamSettings) ProtoReflect() protoreflect.Message
- func (x *StreamSettings) Reset()
- func (x *StreamSettings) String() string
Constants ¶
This section is empty.
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", } 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 ( 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 File_baidu_rpc_meta_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,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` ChunkId int64 `protobuf:"varint,2,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"` // contains filtered or unexported fields }
func (*ChunkInfo) Descriptor
deprecated
func (*ChunkInfo) GetChunkId ¶
func (*ChunkInfo) GetStreamId ¶
func (*ChunkInfo) ProtoMessage ¶
func (*ChunkInfo) ProtoMessage()
func (*ChunkInfo) ProtoReflect ¶
func (x *ChunkInfo) ProtoReflect() protoreflect.Message
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
type Feedback ¶
type Feedback struct { ConsumedSize int64 `protobuf:"varint,1,opt,name=consumed_size,json=consumedSize,proto3" json:"consumed_size,omitempty"` // contains filtered or unexported fields }
func (*Feedback) Descriptor
deprecated
func (*Feedback) GetConsumedSize ¶
func (*Feedback) ProtoMessage ¶
func (*Feedback) ProtoMessage()
func (*Feedback) ProtoReflect ¶
func (x *Feedback) ProtoReflect() protoreflect.Message
type FrameType ¶
type FrameType int32
func (FrameType) Descriptor ¶
func (FrameType) Descriptor() protoreflect.EnumDescriptor
func (FrameType) EnumDescriptor
deprecated
func (FrameType) Number ¶
func (x FrameType) Number() protoreflect.EnumNumber
func (FrameType) Type ¶
func (FrameType) Type() protoreflect.EnumType
type RpcMeta ¶
type RpcMeta struct { Request *RpcRequestMeta `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Response *RpcResponseMeta `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` CompressType int32 `protobuf:"varint,3,opt,name=compress_type,json=compressType,proto3" json:"compress_type,omitempty"` CorrelationId int64 `protobuf:"varint,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` AttachmentSize int32 `protobuf:"varint,5,opt,name=attachment_size,json=attachmentSize,proto3" json:"attachment_size,omitempty"` ChunkInfo *ChunkInfo `protobuf:"bytes,6,opt,name=chunk_info,json=chunkInfo,proto3" json:"chunk_info,omitempty"` AuthenticationData []byte `protobuf:"bytes,7,opt,name=authentication_data,json=authenticationData,proto3" json:"authentication_data,omitempty"` StreamSettings *StreamSettings `protobuf:"bytes,8,opt,name=stream_settings,json=streamSettings,proto3" json:"stream_settings,omitempty"` // contains filtered or unexported fields }
func (*RpcMeta) Descriptor
deprecated
func (*RpcMeta) GetAttachmentSize ¶
func (*RpcMeta) GetAuthenticationData ¶
func (*RpcMeta) GetChunkInfo ¶
func (*RpcMeta) GetCompressType ¶
func (*RpcMeta) GetCorrelationId ¶
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
type RpcRequestMeta ¶
type RpcRequestMeta struct { ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` MethodName string `protobuf:"bytes,2,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"` LogId int64 `protobuf:"varint,3,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"` TraceId int64 `protobuf:"varint,4,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` SpanId int64 `protobuf:"varint,5,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` ParentSpanId int64 `protobuf:"varint,6,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"` RequestId string `protobuf:"bytes,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // correspond to x-request-id in http header // 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) 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,proto3" json:"error_code,omitempty"` ErrorText string `protobuf:"bytes,2,opt,name=error_text,json=errorText,proto3" 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,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` SourceStreamId int64 `protobuf:"varint,2,opt,name=source_stream_id,json=sourceStreamId,proto3" json:"source_stream_id,omitempty"` FrameType FrameType `protobuf:"varint,3,opt,name=frame_type,json=frameType,proto3,enum=brpc.FrameType" json:"frame_type,omitempty"` HasContinuation bool `protobuf:"varint,4,opt,name=has_continuation,json=hasContinuation,proto3" json:"has_continuation,omitempty"` Feedback *Feedback `protobuf:"bytes,5,opt,name=feedback,proto3" 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,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` NeedFeedback bool `protobuf:"varint,2,opt,name=need_feedback,json=needFeedback,proto3" json:"need_feedback,omitempty"` Writable bool `protobuf:"varint,3,opt,name=writable,proto3" 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
Click to show internal directories.
Click to hide internal directories.