Versions in this module Expand all Collapse all v1 v1.0.1 Nov 14, 2025 Changes in this version + type Codec interface + Decode func(data []byte, msg proto.Message) error + Encode func(msg proto.Message) ([]byte, error) + MaxMessageSize func() int + type ProtobufCodec struct + func NewProtobufCodec(maxMessageSize int) *ProtobufCodec + func (c *ProtobufCodec) Decode(data []byte, msg proto.Message) error + func (c *ProtobufCodec) DecodeStream(r io.Reader, msg proto.Message) error + func (c *ProtobufCodec) Encode(msg proto.Message) ([]byte, error) + func (c *ProtobufCodec) EncodeStream(w io.Writer, msg proto.Message) error + func (c *ProtobufCodec) MaxMessageSize() int + type Registry interface + Default func() Codec + Get func(name string) (Codec, bool) + Register func(name string, codec Codec) + func NewRegistry() Registry + type StreamCodec interface + DecodeStream func(r io.Reader, msg proto.Message) error + EncodeStream func(w io.Writer, msg proto.Message) error
Go to main page