codec

README

protoc -I=. --go_out=./codec/pb --go_opt=module="gitee.com/go-course/go8/micro/rpc/rpc_protobuf/codec/pb" codec/pb/header.proto

Documentation

Index

• Variables
• func ReadRequestBody(r io.Reader, header *pb.RequestHeader, request proto.Message) error
• func ReadRequestHeader(r io.Reader, header *pb.RequestHeader) (err error)
• func ReadResponseBody(r io.Reader, header *pb.ResponseHeader, response proto.Message) error
• func ReadResponseHeader(r io.Reader, header *pb.ResponseHeader) error
• func WriteRequest(w io.Writer, id uint64, method string, request proto.Message) error
• func WriteResponse(w io.Writer, id uint64, serr string, response proto.Message) (err error)

Variables

var (
	UseSnappy            = true
	UseCrc32ChecksumIEEE = true
)

Functions

func ReadRequestBody

func ReadRequestBody(r io.Reader, header *pb.RequestHeader, request proto.Message) error

func ReadRequestHeader

func ReadRequestHeader(r io.Reader, header *pb.RequestHeader) (err error)

func ReadResponseBody

func ReadResponseBody(r io.Reader, header *pb.ResponseHeader, response proto.Message) error

func ReadResponseHeader

func ReadResponseHeader(r io.Reader, header *pb.ResponseHeader) error

func WriteRequest

func WriteRequest(w io.Writer, id uint64, method string, request proto.Message) error

func WriteResponse

func WriteResponse(w io.Writer, id uint64, serr string, response proto.Message) (err error)