+2

ufos/src/server.rs

reviewed

··· 33 33 34 34 #[derive(Debug, Serialize, JsonSchema)] 35 35 struct MetaInfo { 36 36 + storage_name: String, 36 37 storage: serde_json::Value, 37 38 consumer: ConsumerInfo, 38 39 } ··· 57 58 .map_err(failed_to_get("consumer info"))?; 58 59 59 60 ok_cors(MetaInfo { 61 61 + storage_name: storage.name(), 60 62 storage: storage_info, 61 63 consumer, 62 64 })

+2

ufos/src/storage.rs

reviewed

··· 32 32 33 33 #[async_trait] 34 34 pub trait StoreReader: Send + Sync { 35 35 + fn name(&self) -> String; 36 36 + 35 37 async fn get_storage_stats(&self) -> StorageResult<serde_json::Value>; 36 38 37 39 async fn get_consumer_info(&self) -> StorageResult<ConsumerInfo>;

+3

ufos/src/storage_fjall.rs

reviewed

··· 435 435 436 436 #[async_trait] 437 437 impl StoreReader for FjallReader { 438 438 + fn name(&self) -> String { 439 439 + "fjall storage v2".into() 440 440 + } 438 441 async fn get_storage_stats(&self) -> StorageResult<serde_json::Value> { 439 442 let s = self.clone(); 440 443 tokio::task::spawn_blocking(move || FjallReader::get_storage_stats(&s)).await?

+3

ufos/src/storage_mem.rs

reviewed

··· 572 572 573 573 #[async_trait] 574 574 impl StoreReader for MemReader { 575 575 + fn name(&self) -> String { 576 576 + "in-memory store".into() 577 577 + } 575 578 async fn get_storage_stats(&self) -> StorageResult<serde_json::Value> { 576 579 let s = self.clone(); 577 580 tokio::task::spawn_blocking(move || MemReader::get_storage_stats(&s)).await?