Struct dragonfly_client::storage::Storage

pub struct Storage { /* private fields */ }

Implementations

impl Storage

pub fn new(data_dir: &Path) -> Result<Self>

pub fn download_task_started(&self, id: &str, piece_length: u64) -> Result<()>

pub fn upload_task_finished(&self, id: &str) -> Result<()>

pub fn get_task(&self, id: &str) -> Result<Option<Task>>

pub fn download_piece_started(&self, task_id: &str, number: u32) -> Result<()>

pub async fn download_piece_finished<R: AsyncRead + Unpin>( &self, task_id: &str, offset: u64, digest: &str, reader: &mut R ) -> Result<u64>

pub async fn upload_piece( &self, task_id: &str, number: u32 ) -> Result<impl AsyncRead>

pub fn get_piece(&self, task_id: &str, number: u32) -> Result<Option<Piece>>