File tree 9 files changed +13
-13
lines changed
9 files changed +13
-13
lines changed Original file line number Diff line number Diff line change @@ -55,7 +55,7 @@ fn load_value(c: &mut Criterion) {
55
55
writer. write ( key. as_bytes ( ) , & data) . unwrap ( ) ;
56
56
}
57
57
58
- value_log. register ( writer) . unwrap ( ) ;
58
+ value_log. register_writer ( writer) . unwrap ( ) ;
59
59
60
60
for size in sizes {
61
61
let key = size. to_string ( ) ;
@@ -105,7 +105,7 @@ fn load_value(c: &mut Criterion) {
105
105
writer. write ( key. as_bytes ( ) , & data) . unwrap ( ) ;
106
106
}
107
107
108
- value_log. register ( writer) . unwrap ( ) ;
108
+ value_log. register_writer ( writer) . unwrap ( ) ;
109
109
110
110
for size in sizes {
111
111
let key = size. to_string ( ) ;
@@ -180,7 +180,7 @@ fn compression(c: &mut Criterion) {
180
180
writer. write ( key. as_bytes ( ) , & data) . unwrap ( ) ;
181
181
}
182
182
183
- value_log. register ( writer) . unwrap ( ) ;
183
+ value_log. register_writer ( writer) . unwrap ( ) ;
184
184
185
185
let handle_random = index. get ( b"random" ) . unwrap ( ) . unwrap ( ) ;
186
186
let handle_good_compression = index. get ( b"good_compression" ) . unwrap ( ) . unwrap ( ) ;
Original file line number Diff line number Diff line change 59
59
//! }
60
60
//!
61
61
//! // Finish writing
62
- //! value_log.register (writer)?;
62
+ //! value_log.register_writer (writer)?;
63
63
//!
64
64
//! // Get some stats
65
65
//! assert_eq!(1.0, value_log.manifest.space_amp());
Original file line number Diff line number Diff line change @@ -173,7 +173,7 @@ impl ValueLog {
173
173
/// # Errors
174
174
///
175
175
/// Will return `Err` if an IO error occurs.
176
- pub fn register < W : IndexWriter > ( & self , writer : SegmentWriter < W > ) -> crate :: Result < ( ) > {
176
+ pub fn register_writer < W : IndexWriter > ( & self , writer : SegmentWriter < W > ) -> crate :: Result < ( ) > {
177
177
self . manifest . register ( writer)
178
178
}
179
179
Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ fn basic_gc() -> value_log::Result<()> {
23
23
writer. write ( key. as_bytes ( ) , value) ?;
24
24
}
25
25
26
- value_log. register ( writer) ?;
26
+ value_log. register_writer ( writer) ?;
27
27
}
28
28
29
29
{
@@ -53,7 +53,7 @@ fn basic_gc() -> value_log::Result<()> {
53
53
writer. write ( key. as_bytes ( ) , value) ?;
54
54
}
55
55
56
- value_log. register ( writer) ?;
56
+ value_log. register_writer ( writer) ?;
57
57
}
58
58
59
59
{
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ fn basic_kv() -> value_log::Result<()> {
24
24
writer. write ( key. as_bytes ( ) , value) ?;
25
25
}
26
26
27
- value_log. register ( writer) ?;
27
+ value_log. register_writer ( writer) ?;
28
28
}
29
29
30
30
{
Original file line number Diff line number Diff line change @@ -31,7 +31,7 @@ fn gc_space_amp_target_1() -> value_log::Result<()> {
31
31
writer. write ( key. as_bytes ( ) , value. as_bytes ( ) ) ?;
32
32
}
33
33
34
- value_log. register ( writer) ?;
34
+ value_log. register_writer ( writer) ?;
35
35
}
36
36
37
37
value_log. scan_for_stats ( index. read ( ) . unwrap ( ) . values ( ) . cloned ( ) . map ( Ok ) ) ?;
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ fn basic_recovery() -> value_log::Result<()> {
24
24
writer. write ( key. as_bytes ( ) , value) ?;
25
25
}
26
26
27
- value_log. register ( writer) ?;
27
+ value_log. register_writer ( writer) ?;
28
28
}
29
29
30
30
{
Original file line number Diff line number Diff line change @@ -80,7 +80,7 @@ fn rollover_index_fail_finish() -> value_log::Result<()> {
80
80
}
81
81
82
82
// NOTE: Should return error because index fails
83
- assert ! ( value_log. register ( writer) . is_err( ) ) ;
83
+ assert ! ( value_log. register_writer ( writer) . is_err( ) ) ;
84
84
}
85
85
86
86
assert_eq ! ( value_log. manifest. list_segment_ids( ) , [ 0 ] ) ;
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ fn worst_case_space_amp() -> value_log::Result<()> {
24
24
25
25
writer. write ( key. as_bytes ( ) , value. as_bytes ( ) ) ?;
26
26
27
- value_log. register ( writer) ?;
27
+ value_log. register_writer ( writer) ?;
28
28
29
29
value_log. scan_for_stats ( index. read ( ) . unwrap ( ) . values ( ) . cloned ( ) . map ( Ok ) ) ?;
30
30
@@ -59,7 +59,7 @@ fn no_overlap_space_amp() -> value_log::Result<()> {
59
59
let mut writer = value_log. get_writer ( index_writer) ?;
60
60
61
61
writer. write ( key. as_bytes ( ) , value. as_bytes ( ) ) ?;
62
- value_log. register ( writer) ?;
62
+ value_log. register_writer ( writer) ?;
63
63
64
64
value_log. scan_for_stats ( index. read ( ) . unwrap ( ) . values ( ) . cloned ( ) . map ( Ok ) ) ?;
65
65
You can’t perform that action at this time.
0 commit comments