kubernetes/vendor/go.etcd.io/etcd/server/v3/wal/decoder.go

const minSectorSize …

const frameSizeBytes …

type decoder …

func newDecoder(r ...fileutil.FileReader) *decoder { … }

func (d *decoder) decode(rec *walpb.Record) error { … }

func (d *decoder) decodeRecord(rec *walpb.Record) error { … }

func decodeFrameSize(lenField int64) (recBytes int64, padBytes int64) { … }

// isTornEntry determines whether the last entry of the WAL was partially written
// and corrupted because of a torn write.
func (d *decoder) isTornEntry(data []byte) bool { … }

func (d *decoder) updateCRC(prevCrc uint32) { … }

func (d *decoder) lastCRC() uint32 { … }

func (d *decoder) lastOffset() int64 { … }

func mustUnmarshalEntry(d []byte) raftpb.Entry { … }

func mustUnmarshalState(d []byte) raftpb.HardState { … }

func readInt64(r io.Reader) (int64, error) { … }