File tree Expand file tree Collapse file tree 3 files changed +3
-5
lines changed Expand file tree Collapse file tree 3 files changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -24,16 +24,14 @@ use std::collections::BTreeMap;
24
24
use std:: str;
25
25
26
26
#[ derive( Serialize , Deserialize , Debug ) ]
27
+ #[ serde( rename = "camelCase" ) ]
27
28
struct Message {
28
- #[ serde( rename = "records" ) ]
29
29
records : Vec < Data > ,
30
- #[ serde( rename = "requestId" ) ]
31
30
request_id : String ,
32
31
timestamp : u64 ,
33
32
}
34
33
#[ derive( Serialize , Deserialize , Debug ) ]
35
34
struct Data {
36
- #[ serde( rename = "data" ) ]
37
35
data : String ,
38
36
}
39
37
Original file line number Diff line number Diff line change @@ -44,8 +44,8 @@ use crate::{
44
44
use serde:: { Deserialize , Serialize } ;
45
45
46
46
#[ derive( Serialize , Deserialize , Debug ) ]
47
+ #[ serde( rename = "camelCase" ) ]
47
48
struct Message {
48
- #[ serde( rename = "commonAttributes" ) ]
49
49
common_attributes : CommonAttributes ,
50
50
}
51
51
Original file line number Diff line number Diff line change @@ -51,10 +51,10 @@ pub const MIN_STREAM_HOT_TIER_SIZE_BYTES: u64 = 10737418240; // 10 GiB
51
51
const HOT_TIER_SYNC_DURATION : Interval = clokwerk:: Interval :: Minutes ( 1 ) ;
52
52
pub const INTERNAL_STREAM_HOT_TIER_SIZE_BYTES : u64 = 10485760 ; //10 MiB
53
53
pub const CURRENT_HOT_TIER_VERSION : & str = "v2" ;
54
+
54
55
#[ derive( Debug , serde:: Deserialize , serde:: Serialize ) ]
55
56
pub struct StreamHotTier {
56
57
pub version : Option < String > ,
57
- #[ serde( rename = "size" ) ]
58
58
pub size : String ,
59
59
#[ serde( skip_serializing_if = "Option::is_none" ) ]
60
60
pub used_size : Option < String > ,
You can’t perform that action at this time.
0 commit comments