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

const msgTypeLinkHeartbeat …

const msgTypeAppEntries …

const msgTypeApp …

const msgAppV2BufSize …

type msgAppV2Encoder …

func newMsgAppV2Encoder(w io.Writer, fs *stats.FollowerStats) *msgAppV2Encoder { … }

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

type msgAppV2Decoder …

func newMsgAppV2Decoder(r io.Reader, local, remote types.ID) *msgAppV2Decoder { … }

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