kubernetes/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/msg_codec.go

type messageEncoder …

func (enc *messageEncoder) encode(m *raftpb.Message) error { … }

type messageDecoder …

var readBytesLimit …

var ErrExceedSizeLimit …

func (dec *messageDecoder) decode() (raftpb.Message, error) { … }

func (dec *messageDecoder) decodeLimit(numBytes uint64) (raftpb.Message, error) { … }