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) {}