Struct UploadStaging 

pub struct UploadStaging { /* private fields */ }

The uploads one connection has begun and not yet committed.

Implementations

impl UploadStaging

pub fn new(budget: Arc<UploadBudget>) -> Self

pub fn begin( &mut self, now: Instant, request: BeginRequest, ) -> Result<String, JsonRpcError>

Stage a new upload and return its id.

pub fn chunk( &mut self, now: Instant, upload_id: &str, offset: u64, chunk: &[u8], ) -> Result<u64, JsonRpcError>

Append one chunk at offset and return the bytes received so far.

pub fn take_complete( &mut self, now: Instant, upload_id: &str, ) -> Result<CompletedUpload, JsonRpcError>

Remove a fully received upload for persistence. An incomplete or mismatched upload stays staged so the client can finish or retry it.

pub fn binding(&self, upload_id: &str) -> Option<UploadTarget>

The session incarnation an upload was begun for, for re-authorization before commit.

Trait Implementations

impl Debug for UploadStaging

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

Formats the value using the given formatter.

impl Default for UploadStaging

fn default() -> Self

Returns the “default value” for a type.