MCPcopy Create free account
hub / github.com/apache/kvrocks / FlushScripts

Method FlushScripts

src/storage/storage.cc:775–786  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

773}
774
775rocksdb::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
788StatusOr<int> Storage::IngestSST(const std::string &sst_dir, const rocksdb::IngestExternalFileOptions &ingest_options) {
789 std::vector<std::string> sst_files;

Callers 1

ScriptFlushMethod · 0.80

Calls 3

StringNextFunction · 0.85
WriteFunction · 0.85
DeleteRangeMethod · 0.80

Tested by

no test coverage detected