Struct DiskPayloadStore 

pub struct DiskPayloadStore { /* private fields */ }

PayloadStore that keeps offloaded payload blobs as files under dir, with a background death-epoch sweeper.

The sweeper is spawned on construction and aborted on Drop; its shutdown token is owned by the sweeper task and never cancelled by the store. All sweeping runs on the real clock — it must observe actual file ages (the decorator’s injectable test clock never reaches the store).

Implementations

impl DiskPayloadStore

pub fn new( dir: PathBuf, sweep_interval: Duration, shutdown_token: CancellationToken, ) -> Self

Create a store writing blobs into dir (production clock).

The shutdown_token stops the background payload sweeper; it is owned by the sweeper task and never cancelled by the store.

Trait Implementations

impl Debug for DiskPayloadStore

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

Formats the value using the given formatter.

impl Drop for DiskPayloadStore

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.

impl PayloadStore for DiskPayloadStore

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reclaim payload space now: best-effort unlink of every entry of the payload dir. Unlink failures never turn clear into Err — each failure WARNs and the rest of the dir is still attempted.

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, name: &'life1 str, bytes: &'life2 [u8], _death_epoch: SystemTime, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store bytes under name until death_epoch.

fn read<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read the payload stored under name.

fn unlink<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove the payload stored under name.