Versions in this module Expand all Collapse all v0 v0.0.6 May 7, 2023 v0.0.5 Apr 15, 2023 Changes in this version + const CompressTypeGzip + const CompressTypeNo + const CompressTypeSnappy + const ErrorCodeUnknown + var ErrBodyTooLarge = errors.New("body size is too large") + var ErrCompressUnknown = errors.New("unsupported compress type") + var ErrInvalidHeader = errors.New("invalid header") + var ErrInvalidMeta = errors.New("invalid meta") + var ErrInvalidProtocol = errors.New("invalid protocol") + var ErrMethodNotFound = errors.New("service or method not found") + var File_brpc_proto protoreflect.FileDescriptor + var File_streaming_proto protoreflect.FileDescriptor + var FrameType_name = map[int32]string + var FrameType_value = map[string]int32 + var MaxBodySize = uint32(10 << 20) + func GetErrorCode(msg *Message) int32 + func IsMetaInvalid(meta *Meta) error + type ChunkInfo struct + ChunkId int64 + StreamId int64 + func (*ChunkInfo) Descriptor() ([]byte, []int) + func (*ChunkInfo) ProtoMessage() + func (x *ChunkInfo) GetChunkId() int64 + func (x *ChunkInfo) GetStreamId() int64 + func (x *ChunkInfo) ProtoReflect() protoreflect.Message + func (x *ChunkInfo) Reset() + func (x *ChunkInfo) String() string + type Feedback struct + ConsumedSize int64 + func (*Feedback) Descriptor() ([]byte, []int) + func (*Feedback) ProtoMessage() + func (x *Feedback) GetConsumedSize() int64 + func (x *Feedback) ProtoReflect() protoreflect.Message + func (x *Feedback) Reset() + func (x *Feedback) String() string + type FrameType int32 + const FrameType_Close + const FrameType_Data + const FrameType_FeedBack + const FrameType_Rst + const FrameType_Unknown + func (FrameType) Descriptor() protoreflect.EnumDescriptor + func (FrameType) EnumDescriptor() ([]byte, []int) + func (FrameType) Type() protoreflect.EnumType + func (x FrameType) Enum() *FrameType + func (x FrameType) Number() protoreflect.EnumNumber + func (x FrameType) String() string + type Handler interface + Handle func() + type Header struct + BodySize uint32 + MetaSize uint32 + func ReadHeader(rd io.Reader) (Header, error) + func (h Header) Bytes() []byte + func (h Header) IsValid() error + func (h Header) PayloadSize() uint32 + func (h Header) WroteTo(w io.Writer) (int64, error) + type Message struct + Attachment io.Reader + Meta *Meta + func (req *Message) MethodName() string + func (req *Message) ServiceName() string + func (req *Message) Unmarshal(msg proto.Message) error + func (req *Message) WithMeta(fn func(m *Meta)) + func (req *Message) WroteTo(w io.Writer) (int64, error) + type Meta struct + AttachmentSize int32 + AuthenticationData []byte + ChunkInfo *ChunkInfo + CompressType int32 + CorrelationId int64 + Request *RequestMeta + Response *ResponseMeta + StreamSettings *StreamSettings + func (*Meta) Descriptor() ([]byte, []int) + func (*Meta) ProtoMessage() + func (x *Meta) GetAttachmentSize() int32 + func (x *Meta) GetAuthenticationData() []byte + func (x *Meta) GetChunkInfo() *ChunkInfo + func (x *Meta) GetCompressType() int32 + func (x *Meta) GetCorrelationId() int64 + func (x *Meta) GetRequest() *RequestMeta + func (x *Meta) GetResponse() *ResponseMeta + func (x *Meta) GetStreamSettings() *StreamSettings + func (x *Meta) ProtoReflect() protoreflect.Message + func (x *Meta) Reset() + func (x *Meta) String() string + type ReadWriter interface + Next func(ctx context.Context) (*Message, error) + Write func(ctx context.Context, msg *Message) error + type Reader struct + MaxBodySize uint32 + func (r *Reader) GetMaxBodySize() uint32 + func (r *Reader) ReadHeader(rd io.Reader) (Header, error) + func (r *Reader) ReadMessage(rd io.Reader, h Header) (*Message, error) + func (r *Reader) ReadMeta(rd io.Reader, metaSize uint32) (*Meta, error) + func (r *Reader) ReadPackage(rd io.Reader) (Header, *Message, error) + type RequestMeta struct + LogId int64 + MethodName string + ParentSpanId int64 + RequestId string + ServiceName string + SpanId int64 + TimeoutMs int32 + TraceId int64 + func (*RequestMeta) Descriptor() ([]byte, []int) + func (*RequestMeta) ProtoMessage() + func (x *RequestMeta) GetLogId() int64 + func (x *RequestMeta) GetMethodName() string + func (x *RequestMeta) GetParentSpanId() int64 + func (x *RequestMeta) GetRequestId() string + func (x *RequestMeta) GetServiceName() string + func (x *RequestMeta) GetSpanId() int64 + func (x *RequestMeta) GetTimeoutMs() int32 + func (x *RequestMeta) GetTraceId() int64 + func (x *RequestMeta) ProtoReflect() protoreflect.Message + func (x *RequestMeta) Reset() + func (x *RequestMeta) String() string + type ResponseMeta struct + ErrorCode int32 + ErrorText string + func (*ResponseMeta) Descriptor() ([]byte, []int) + func (*ResponseMeta) ProtoMessage() + func (x *ResponseMeta) GetErrorCode() int32 + func (x *ResponseMeta) GetErrorText() string + func (x *ResponseMeta) ProtoReflect() protoreflect.Message + func (x *ResponseMeta) Reset() + func (x *ResponseMeta) String() string + type Router struct + Reader *Reader + func (r *Router) Handle(ctx context.Context, conn net.Conn) + func (r *Router) Register(service, method string, handler Handler) + type SimpleHandler interface + HandleSimple func(ctx context.Context, msg *Message) *Message + type StreamFrameMeta struct + Feedback *Feedback + FrameType FrameType + HasContinuation bool + SourceStreamId int64 + StreamId int64 + func (*StreamFrameMeta) Descriptor() ([]byte, []int) + func (*StreamFrameMeta) ProtoMessage() + 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 (x *StreamFrameMeta) ProtoReflect() protoreflect.Message + func (x *StreamFrameMeta) Reset() + func (x *StreamFrameMeta) String() string + type StreamHandler interface + HandleStream func(ctx context.Context, msg *Message, rw ReadWriter) error + type StreamSettings struct + NeedFeedback bool + StreamId int64 + Writable bool + func (*StreamSettings) Descriptor() ([]byte, []int) + func (*StreamSettings) ProtoMessage() + func (x *StreamSettings) GetNeedFeedback() bool + func (x *StreamSettings) GetStreamId() int64 + func (x *StreamSettings) GetWritable() bool + func (x *StreamSettings) ProtoReflect() protoreflect.Message + func (x *StreamSettings) Reset() + func (x *StreamSettings) String() string