admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-06 02:42:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

test(db): add archive test

Browse Source 
Former-commit-id: e8c2116cd7bdec959950b2d2735c4f26d0a4a1d8
This commit is contained in:
Xu Peng 2019-05-24 10:56:15 +08:00
parent 7226617782
commit 5d0b5e99f4
1 changed files with 43 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
cpp/unittest/db/meta_tests.cpp
View File

@ -86,6 +86,49 @@ TEST_F(MetaTest, GROUP_FILE_TEST) {
ASSERT_TRUE(group_file.file_type == meta::GroupFileSchema::TO_DELETE);
}
TEST_F(MetaTest, ARCHIVE_TEST) {
DBMetaOptions options;
options.path = "/tmp/vecwise_test";
options.archive_conf = ArchiveConf("delete", "disk:41");
auto impl = meta::DBMetaImpl(options);
auto group_id = "meta_test_group";
meta::GroupSchema group;
group.group_id = group_id;
auto status = impl.add_group(group);
meta::GroupFilesSchema files;
meta::GroupFileSchema group_file;
group_file.group_id = group.group_id;
auto cnt = 10;
auto each_size = 2UL;
for (auto i=0; i<cnt; ++i) {
status = impl.add_group_file(group_file);
group_file.file_type = meta::GroupFileSchema::NEW;
group_file.rows = 1024*1024*1024*each_size;
status = impl.update_group_file(group_file);
files.push_back(group_file);
}
impl.archive_files();
int i = 0;
for (auto file : files) {
status = impl.get_group_file(file.group_id, file.file_id, file);
ASSERT_TRUE(status.ok());
if (i < 5) {
ASSERT_TRUE(file.file_type == meta::GroupFileSchema::TO_DELETE);
} else {
ASSERT_EQ(file.file_type, meta::GroupFileSchema::NEW);
}
++i;
}
impl.drop_all();
}
TEST_F(MetaTest, GROUP_FILES_TEST) {
auto group_id = "meta_test_group";