mod caches;
mod image_decode_cache;
mod image_stats_cache;
mod tensor_stats_cache;
mod transform_database_store;
mod video_asset_cache;
mod video_stream_cache;
pub use caches::{Cache, Caches};
pub use image_decode_cache::ImageDecodeCache;
pub use image_stats_cache::ImageStatsCache;
pub use tensor_stats_cache::TensorStatsCache;
pub use transform_database_store::TransformDatabaseStoreCache;
pub use video_asset_cache::VideoAssetCache;
pub use video_stream_cache::{
SharablePlayableVideoStream, VideoStreamCache, VideoStreamProcessingError,
};
fn filter_blob_removed_events(
events: &[&re_chunk_store::ChunkStoreEvent],
) -> ahash::HashSet<crate::StoredBlobCacheKey> {
use re_sdk_types::Component as _;
events
.iter()
.filter_map(|e| e.to_deletion())
.flat_map(|del| {
del.chunk
.component_descriptors()
.filter(|descr| {
descr.component_type == Some(re_sdk_types::components::Blob::name())
})
.flat_map(|descr| {
del.chunk
.row_ids()
.map(move |row_id| crate::StoredBlobCacheKey::new(row_id, descr.component))
})
})
.collect()
}