rust-librocksdb-sys 0.43.0+11.0.4

Native bindings to librocksdb
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//  Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.
//  This source code is licensed under both the GPLv2 (found in the
//  COPYING file in the root directory) and Apache 2.0 License
//  (found in the LICENSE.Apache file in the root directory).

#include "db/db_test_util.h"
#include "rocksdb/data_structure.h"
#include "rocksdb/slice.h"

namespace ROCKSDB_NAMESPACE {

class IntervalSetTest : public testing::Test {};

TEST_F(IntervalSetTest, BasicTest) {
  IntervalSet<int> set;
  set.insert({2, 15});
  EXPECT_EQ(set.size(), 1);
  set.insert({5, 9});
  EXPECT_EQ(set.size(), 1);
  set.insert({0, 10});
  EXPECT_EQ(set.size(), 1);
  set.insert({25, 30});
  EXPECT_EQ(set.size(), 2);
  set.insert({16, 25});
  EXPECT_EQ(set.size(), 2);
  set.insert({45, 85});
  ASSERT_EQ(set.size(), 3);
  auto iter = set.begin();
  ASSERT_EQ(*iter, Interval<int>(0, 15));
  iter++;
  ASSERT_EQ(*iter, Interval<int>(16, 30));
  iter++;
  ASSERT_EQ(*iter, Interval<int>(45, 85));
  set.insert({31});
  iter = set.begin();
  ASSERT_EQ(*iter, Interval<int>(0, 15));
  iter++;
  ASSERT_EQ(*iter, Interval<int>(16, 30));
  iter++;
  ASSERT_EQ(*iter, Interval<int>(31));
}

TEST_F(IntervalSetTest, SliceTest) {
  IntervalSet<Slice, Comparator> set(BytewiseComparator());
  EXPECT_TRUE(set.insert("k00", "k10"));
  // Should do nothing
  EXPECT_TRUE(set.insert("k02", "k08"));
  auto iter = set.begin();
  ASSERT_EQ(iter->start().ToString(), "k00");
  ASSERT_EQ(iter->end().ToString(), "k10");
  ASSERT_EQ(set.size(), 1);
  iter++;
  ASSERT_EQ(iter, set.end());
  EXPECT_TRUE(set.insert("k15", "k20"));
  EXPECT_TRUE(set.insert("k16"));
  ASSERT_EQ(set.size(), 2);
  iter = set.begin();
  ASSERT_EQ(iter->start().ToString(), "k00");
  ASSERT_EQ(iter->end().ToString(), "k10");
  iter++;
  ASSERT_EQ(iter->start().ToString(), "k15");
  ASSERT_EQ(iter->has_end(), false);
  //
}

TEST_F(IntervalSetTest, PropModeTest) {
  IntervalSet<Slice, Comparator> set(BytewiseComparator(), true);
  EXPECT_TRUE(set.insert("k00", "k10"));
  // Should do nothing
  EXPECT_FALSE(set.insert("k02", "k08"));
  EXPECT_EQ(set.size(), 1);
  EXPECT_TRUE(set.insert("k15", "k20"));
  EXPECT_EQ(set.size(), 2);
  EXPECT_FALSE(set.insert("k16"));
  ASSERT_EQ(set.size(), 2);
  auto iter = set.begin();
  ASSERT_EQ(iter->start().ToString(), "k00");
  ASSERT_EQ(iter->end().ToString(), "k10");
  iter++;
  ASSERT_EQ(iter->start().ToString(), "k15");
  ASSERT_EQ(iter->end().ToString(), "k20");
  EXPECT_TRUE(set.insert("k12", "k14"));
  iter = set.begin();
  ASSERT_EQ(set.size(), 3);
  ASSERT_EQ(iter->start().ToString(), "k00");
  ASSERT_EQ(iter->end().ToString(), "k10");
  iter++;
  ASSERT_EQ(iter->start().ToString(), "k12");
  ASSERT_EQ(iter->end().ToString(), "k14");
  iter++;
  ASSERT_EQ(iter->start().ToString(), "k15");
  ASSERT_EQ(iter->end().ToString(), "k20");
}

}  // namespace ROCKSDB_NAMESPACE

int main(int argc, char** argv) {
  ROCKSDB_NAMESPACE::port::InstallStackTraceHandler();
  ::testing::InitGoogleTest(&argc, argv);

  return RUN_ALL_TESTS();
}