| 773 | } |
| 774 | |
| 775 | rocksdb::Status Storage::FlushScripts(engine::Context &ctx, const rocksdb::WriteOptions &options, |
| 776 | rocksdb::ColumnFamilyHandle *cf_handle) { |
| 777 | std::string begin_key = kLuaFuncSHAPrefix, end_key = util::StringNext(kLuaFuncSHAPrefix); |
| 778 | |
| 779 | auto batch = GetWriteBatchBase(); |
| 780 | auto s = batch->DeleteRange(cf_handle, begin_key, end_key); |
| 781 | if (!s.ok()) { |
| 782 | return s; |
| 783 | } |
| 784 | |
| 785 | return Write(ctx, options, batch->GetWriteBatch()); |
| 786 | } |
| 787 | |
| 788 | StatusOr<int> Storage::IngestSST(const std::string &sst_dir, const rocksdb::IngestExternalFileOptions &ingest_options) { |
| 789 | std::vector<std::string> sst_files; |
no test coverage detected