Struct CacheWarmingManager 

pub struct CacheWarmingManager<B: CacheBackend + 'static> { /* private fields */ }

Cache warming manager

Implementations

impl<B: CacheBackend + 'static> CacheWarmingManager<B>

pub fn new(backend: Arc<B>) -> Self

pub async fn register_task<T>( &self, task: WarmingTask, provider: WarmingProvider<T>, ) -> CacheResult<()>

where T: Serialize + Send + Sync + 'static,

Register a warming task with its data provider

pub async fn register_simple_task<T>( &self, task_id: String, key: CacheKey, provider: Arc<dyn Fn() -> Pin<Box<dyn Future<Output = CacheResult<T>> + Send + 'static>> + Send + Sync + 'static>, strategy: WarmingStrategy, ) -> CacheResult<()>

where T: Serialize + Send + Sync + 'static,

Register a simple warming task for a single key-value pair

pub async fn start_scheduler(&self) -> CacheResult<()>

Start the warming scheduler

pub async fn stop_scheduler(&self) -> CacheResult<()>

Stop the warming scheduler

pub async fn warm_task(&self, task_id: &str) -> CacheResult<WarmingResult>

Manually trigger warming for a specific task

pub async fn warm_startup(&self) -> CacheResult<Vec<WarmingResult>>

Warm on startup - execute all startup warming tasks

pub async fn get_stats(&self) -> WarmingStats

Get warming statistics

pub async fn list_tasks(&self) -> Vec<String>

Get list of registered tasks

pub async fn remove_task(&self, task_id: &str) -> CacheResult<bool>

Remove a warming task

Trait Implementations

impl<B: CacheBackend + 'static> Drop for CacheWarmingManager<B>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.