brpc

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
}

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

type FrameType int32

type Handler interface {
	Handle()
}

type Header struct {
	BodySize uint32
	MetaSize uint32
}

type Message struct {
	Meta       *Meta
	Attachment io.Reader
	// contains filtered or unexported fields
}

type Meta struct {
	Request            *RequestMeta    `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response           *ResponseMeta   `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
}

type ReadWriter interface {
	Next(ctx context.Context) (*Message, error)
	Write(ctx context.Context, msg *Message) error
}

type Reader struct {
	// MaxBodySize 可选，最大 Body 大小，为 0 是会使用 全局变量 MaxBodySize
	MaxBodySize uint32
}

type RequestMeta 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
	TimeoutMs    int32  `protobuf:"varint,8,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"` // client's timeout setting for current call
	// contains filtered or unexported fields
}

type ResponseMeta 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
}

type Router struct {
	Reader *Reader
	// contains filtered or unexported fields
}

type SimpleHandler interface {
	Handler
	HandleSimple(ctx context.Context, msg *Message) *Message
}

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
}

type StreamHandler interface {
	Handler
	HandleStream(ctx context.Context, msg *Message, rw ReadWriter) error
}

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
}