@@ -36,20 +36,12 @@ use crate::{
36
36
} ,
37
37
parseable:: PARSEABLE ,
38
38
rbac:: { map:: SessionKey , role:: Action , Users } ,
39
- stats:: Stats ,
40
39
storage:: { ObjectStorageError , ObjectStoreFormat , STREAM_ROOT_DIRECTORY } ,
41
40
users:: { dashboards:: DASHBOARDS , filters:: FILTERS } ,
42
41
} ;
43
42
44
43
type StreamMetadataResponse = Result < ( String , Vec < ObjectStoreFormat > , DataSetType ) , PrismHomeError > ;
45
44
46
- #[ derive( Debug , Serialize , Default ) ]
47
- struct StreamStats {
48
- // stream_count: u32,
49
- // log_source_count: u32,
50
- stats_summary : Stats ,
51
- }
52
-
53
45
#[ derive( Debug , Serialize , Default ) ]
54
46
struct DatedStats {
55
47
date : String ,
@@ -146,14 +138,10 @@ pub async fn generate_home_response(key: &SessionKey) -> Result<HomeResponse, Pr
146
138
futures:: future:: join_all ( stats_futures) . await ;
147
139
148
140
let mut stream_details = Vec :: new ( ) ;
149
- let mut summary = StreamStats :: default ( ) ;
150
141
151
142
for result in stats_results {
152
143
match result {
153
144
Ok ( dated_stats) => {
154
- summary. stats_summary . events += dated_stats. events ;
155
- summary. stats_summary . ingestion += dated_stats. ingestion_size ;
156
- summary. stats_summary . storage += dated_stats. storage_size ;
157
145
stream_details. push ( dated_stats) ;
158
146
}
159
147
Err ( e) => {
0 commit comments