File tree Expand file tree Collapse file tree 5 files changed +14
-5
lines changed Expand file tree Collapse file tree 5 files changed +14
-5
lines changed Original file line number Diff line number Diff line change @@ -109,7 +109,9 @@ sync = [
109
109
" dep:futures" ,
110
110
" dep:serde_json" ,
111
111
" dep:crc32fast" ,
112
- " dep:chrono"
112
+ " dep:chrono" ,
113
+ " dep:uuid" ,
114
+ " tokio/fs"
113
115
]
114
116
hrana = [
115
117
" parser" ,
Original file line number Diff line number Diff line change @@ -34,9 +34,12 @@ cfg_core! {
34
34
}
35
35
36
36
cfg_replication_or_sync ! {
37
+
37
38
pub type FrameNo = u64 ;
38
39
39
40
#[ derive( Debug ) ]
41
+ // TODO(lucio): remove this once we use these fields in our sync code
42
+ #[ allow( dead_code) ]
40
43
pub struct Replicated {
41
44
pub ( crate ) frame_no: Option <FrameNo >,
42
45
pub ( crate ) frames_synced: usize ,
@@ -47,12 +50,16 @@ cfg_replication_or_sync! {
47
50
/// where in the log you might be. Beware that this value can be reset to a lower value by the
48
51
/// server in certain situations. Please use `frames_synced` if you want to track the amount of
49
52
/// work a sync has done.
53
+ // TODO(lucio): remove this once we use these fields in our sync code
54
+ #[ allow( dead_code) ]
50
55
pub fn frame_no( & self ) -> Option <FrameNo > {
51
56
self . frame_no
52
57
}
53
58
54
59
/// The count of frames synced during this call of `sync`. A frame is a 4kB frame from the
55
60
/// libsql write ahead log.
61
+ // TODO(lucio): remove this once we use these fields in our sync code
62
+ #[ allow( dead_code) ]
56
63
pub fn frames_synced( & self ) -> usize {
57
64
self . frames_synced
58
65
}
Original file line number Diff line number Diff line change @@ -119,7 +119,7 @@ impl Builder<()> {
119
119
}
120
120
}
121
121
122
- cfg_replication_or_remote ! {
122
+ cfg_replication_or_remote_or_sync ! {
123
123
/// Remote configuration type used in [`Builder`].
124
124
pub struct Remote {
125
125
url: String ,
@@ -505,7 +505,7 @@ cfg_remote! {
505
505
}
506
506
}
507
507
508
- cfg_replication_or_remote ! {
508
+ cfg_replication_or_remote_or_sync ! {
509
509
impl Remote {
510
510
fn connector<C >( mut self , connector: C ) -> Remote
511
511
where
Original file line number Diff line number Diff line change @@ -10,7 +10,7 @@ macro_rules! cfg_core {
10
10
}
11
11
}
12
12
13
- macro_rules! cfg_replication_or_remote {
13
+ macro_rules! cfg_replication_or_remote_or_sync {
14
14
( $( $item: item) * ) => {
15
15
$(
16
16
#[ cfg( any( feature = "replication" , feature = "sync" , feature = "remote" ) ) ]
Original file line number Diff line number Diff line change 1
- cfg_replication_or_remote ! {
1
+ cfg_replication_or_remote_or_sync ! {
2
2
pub mod box_clone_service;
3
3
mod http;
4
4
pub ( crate ) use self :: http:: { ConnectorService , Socket } ;
You can’t perform that action at this time.
0 commit comments