Method Mutate

store_compact.go:550–606

(operation uint64, key, val []byte)

}

func (cw *compactWriter) Mutate(operation uint64, key, val []byte) error {
	if cw.syncAfterBytes > 0 && cw.bytesSinceSync > cw.syncAfterBytes {
		err := cw.file.Sync()
		if err != nil {
			return err
		}
		cw.bytesSinceSync = 0
	}

	keyStart := cw.bufWriter.Written()
	_, err := cw.bufWriter.Write(key)
	if err != nil {
		return err
	}

	_, err = cw.bufWriter.Write(val)
	if err != nil {
		return err
	}

	keyLen := len(key)
	valLen := len(val)

	opKlVl := encodeOpKeyLenValLen(operation, keyLen, valLen)

	if keyLen <= 0 && valLen <= 0 {
		keyStart = 0
	}

	pair := []uint64{opKlVl, uint64(keyStart)}
	kvsBuf, err := Uint64SliceToByteSlice(pair)
	if err != nil {
		return err
	}

	_, err = cw.kvsWriter.Write(kvsBuf)
	if err != nil {
		return err
	}

	switch operation {
	case OperationSet:
		cw.totOperationSet++
	case OperationDel:
		cw.totOperationDel++
	case OperationMerge:
		cw.totOperationMerge++
	default:
	}

	cw.totKeyByte += uint64(keyLen)
	cw.totValByte += uint64(valLen)

	cw.bytesSinceSync += keyLen + valLen + 16 /* len(kvsBuf) */

	return nil
}