79 lines
3.0 KiB
Rust
79 lines
3.0 KiB
Rust
use super::*;
|
|
|
|
impl StorageManager {
|
|
pub(crate) async fn debug_local_records(&self) -> String {
|
|
let inner = self.inner.lock().await;
|
|
let Some(local_record_store) = &inner.local_record_store else {
|
|
return "not initialized".to_owned();
|
|
};
|
|
local_record_store.debug_records()
|
|
}
|
|
pub(crate) async fn debug_remote_records(&self) -> String {
|
|
let inner = self.inner.lock().await;
|
|
let Some(remote_record_store) = &inner.remote_record_store else {
|
|
return "not initialized".to_owned();
|
|
};
|
|
remote_record_store.debug_records()
|
|
}
|
|
pub(crate) async fn purge_local_records(&self, reclaim: Option<usize>) -> String {
|
|
let mut inner = self.inner.lock().await;
|
|
let Some(local_record_store) = &mut inner.local_record_store else {
|
|
return "not initialized".to_owned();
|
|
};
|
|
let reclaimed = local_record_store
|
|
.reclaim_space(reclaim.unwrap_or(usize::MAX))
|
|
.await;
|
|
return format!("Local records purged: reclaimed {} bytes", reclaimed);
|
|
}
|
|
pub(crate) async fn purge_remote_records(&self, reclaim: Option<usize>) -> String {
|
|
let mut inner = self.inner.lock().await;
|
|
let Some(remote_record_store) = &mut inner.remote_record_store else {
|
|
return "not initialized".to_owned();
|
|
};
|
|
let reclaimed = remote_record_store
|
|
.reclaim_space(reclaim.unwrap_or(usize::MAX))
|
|
.await;
|
|
return format!("Remote records purged: reclaimed {} bytes", reclaimed);
|
|
}
|
|
pub(crate) async fn debug_local_record_subkey_info(
|
|
&self,
|
|
key: TypedKey,
|
|
subkey: ValueSubkey,
|
|
) -> String {
|
|
let inner = self.inner.lock().await;
|
|
let Some(local_record_store) = &inner.local_record_store else {
|
|
return "not initialized".to_owned();
|
|
};
|
|
local_record_store
|
|
.debug_record_subkey_info(key, subkey)
|
|
.await
|
|
}
|
|
pub(crate) async fn debug_remote_record_subkey_info(
|
|
&self,
|
|
key: TypedKey,
|
|
subkey: ValueSubkey,
|
|
) -> String {
|
|
let inner = self.inner.lock().await;
|
|
let Some(remote_record_store) = &inner.remote_record_store else {
|
|
return "not initialized".to_owned();
|
|
};
|
|
remote_record_store
|
|
.debug_record_subkey_info(key, subkey)
|
|
.await
|
|
}
|
|
pub(crate) async fn debug_local_record_info(&self, key: TypedKey) -> String {
|
|
let inner = self.inner.lock().await;
|
|
let Some(local_record_store) = &inner.local_record_store else {
|
|
return "not initialized".to_owned();
|
|
};
|
|
local_record_store.debug_record_info(key)
|
|
}
|
|
pub(crate) async fn debug_remote_record_info(&self, key: TypedKey) -> String {
|
|
let inner = self.inner.lock().await;
|
|
let Some(remote_record_store) = &inner.remote_record_store else {
|
|
return "not initialized".to_owned();
|
|
};
|
|
remote_record_store.debug_record_info(key)
|
|
}
|
|
}
|