Struct FileStorage 

pub struct FileStorage { /* private fields */ }

File-based Storage implementation using one JSON sidecar per download.

use std::sync::Arc;
use gosh_dl::{DownloadEngine, EngineConfig, FileStorage};

let storage = Arc::new(FileStorage::new("/var/lib/myapp/downloads-state").await?);
let engine = DownloadEngine::with_storage(EngineConfig::default(), storage).await?;

Implementations

impl FileStorage

pub async fn new(dir: impl Into<PathBuf>) -> Result<Self>

Create a file storage rooted at dir, creating the directory if needed.

pub fn dir(&self) -> &Path

Directory holding the sidecar files.

Trait Implementations

impl Debug for FileStorage

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

Formats the value using the given formatter.

impl Storage for FileStorage

fn save_download<'life0, 'life1, 'async_trait>( &'life0 self, status: &'life1 DownloadStatus, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Save or update a download’s status

fn load_download<'life0, 'async_trait>( &'life0 self, id: DownloadId, ) -> Pin<Box<dyn Future<Output = Result<Option<DownloadStatus>>> + Send + 'async_trait>>

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

Load a download by ID

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

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

Load all downloads

fn delete_download<'life0, 'async_trait>( &'life0 self, id: DownloadId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Delete a download record

fn save_segments<'life0, 'life1, 'async_trait>( &'life0 self, id: DownloadId, segments: &'life1 [Segment], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Save segment state for an HTTP download

fn load_segments<'life0, 'async_trait>( &'life0 self, id: DownloadId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Segment>>> + Send + 'async_trait>>

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

Load segment state for an HTTP download

fn delete_segments<'life0, 'async_trait>( &'life0 self, id: DownloadId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Delete segment state for a download

fn save_torrent_data<'life0, 'life1, 'async_trait>( &'life0 self, id: DownloadId, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Save raw torrent data (bencoded metainfo) for crash recovery

fn load_torrent_data<'life0, 'async_trait>( &'life0 self, id: DownloadId, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send + 'async_trait>>

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

Load raw torrent data for crash recovery

fn save_runtime_metadata<'life0, 'life1, 'async_trait>( &'life0 self, id: DownloadId, runtime_json: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Save engine-specific runtime metadata for a download.

fn load_runtime_metadata<'life0, 'async_trait>( &'life0 self, id: DownloadId, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

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

Load engine-specific runtime metadata for a download.

fn load_all_runtime_metadata<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HashMap<DownloadId, String>>> + Send + 'async_trait>>

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

Load all persisted runtime metadata keyed by download ID.

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

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

Check if database is healthy

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

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

Compact/vacuum the database