Method load

kayak/wal/leveldb_wal.go:196–219

(logHeader []byte)

}

func (p *LevelDBWal) load(logHeader []byte) (l *kt.Log, err error) {
	l = new(kt.Log)

	if err = utils.DecodeMsgPack(logHeader, &l.LogHeader); err != nil {
		log.WithField("header", logHeader).WithError(err).Debug("decode log header failed")
		err = errors.Wrap(err, "decode log header failed")
		return
	}

	dataKey := append(append([]byte(nil), logDataKeyPrefix...), p.uint64ToBytes(l.Index)...)

	var encData []byte
	if encData, err = p.db.Get(dataKey, nil); err != nil {
		err = errors.Wrap(err, "get log data failed")
		return
	}

	// load data
	if err = utils.DecodeMsgPack(encData, &l.Data); err != nil {
		err = errors.Wrap(err, "decode log data failed")
	}

	return
}

func (p *LevelDBWal) uint64ToBytes(o uint64) (res []byte) {
	res = make([]byte, 8)