Struct OffloadManager 

pub struct OffloadManager { /* private fields */ }

Manager for offloading tasks to background execution.

Supports task deduplication, timeout policies, and metrics collection.

Implementations

impl OffloadManager

pub fn new(config: OffloadConfig) -> Self

Create a new OffloadManager with the given configuration.

pub fn with_defaults() -> Self

Create a new OffloadManager with default configuration.

pub fn spawn<F>(&self, kind: impl Into<SmolStr>, task: F) -> OffloadKey

where F: Future<Output = ()> + Send + 'static,

Spawn a task with auto-generated key and specified kind.

The kind is used for metrics labels and tracing.

Example

manager.spawn("revalidate", async { /* ... */ });
manager.spawn("warmup", async { /* ... */ });

pub fn spawn_with_key<K, F>(&self, key: K, task: F) -> bool

where K: Into<OffloadKey>, F: Future<Output = ()> + Send + 'static,

Spawn a task with a specific key.

If a task with the same key is already in flight and deduplication is enabled, the new task will be skipped.

Returns true if the task was spawned, false if it was deduplicated.

pub fn active_task_count(&self) -> usize

Get the number of currently active tasks.

pub fn total_task_count(&self) -> usize

Get the total number of tracked tasks (including finished).

pub fn cleanup_finished(&self)

Clean up finished task handles.

pub fn cancel_all(&self)

Cancel all running tasks.

pub fn cancel(&self, key: &OffloadKey) -> bool

Cancel a specific task by key.

pub fn is_in_flight(&self, key: &OffloadKey) -> bool

Check if a task with the given key is in flight.

pub async fn wait_all(&self)

Wait for all currently tracked tasks to complete.

This polls active tasks until all are finished, with a small yield between checks to avoid busy-waiting.

pub async fn wait_all_timeout(&self, timeout: Duration) -> bool

Wait for all tasks with a timeout.

Returns true if all tasks completed within the timeout, false if the timeout was reached.

Trait Implementations

impl Clone for OffloadManager

fn clone(&self) -> OffloadManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OffloadManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for OffloadManager

fn default() -> Self

Returns the “default value” for a type.

impl Offload<'static> for OffloadManager

fn spawn<F>(&self, kind: impl Into<SmolStr>, future: F)

where F: Future<Output = ()> + Send + 'static,

Spawn a future to be executed in the background.