codec

Documentation

Index

• Variables
• func NewClientCodec(conn io.ReadWriteCloser, compressType compressor.CompressType, ...) rpc.ClientCodec
• func NewServerCodec(conn io.ReadWriteCloser, serializer serializer.Serializer) rpc.ServerCodec

Variables

var (
	InvalidSequenceError        = errors.New("invalid sequence number in response")
	UnexpectedChecksumError     = errors.New("unexpected checksum")
	NotFoundCompressorError     = errors.New("not found compressor")
	CompressorTypeMismatchError = errors.New("request and response Compressor type mismatch")
)

Functions

func NewClientCodec

func NewClientCodec(conn io.ReadWriteCloser,
	compressType compressor.CompressType, serializer serializer.Serializer) rpc.ClientCodec

NewClientCodec Create a new client codec

func NewServerCodec

func NewServerCodec(conn io.ReadWriteCloser, serializer serializer.Serializer) rpc.ServerCodec

NewServerCodec Create a new server codec