pub struct AWSMethod {
pub bucket: Arc<Bucket>,
pub directory: String,
pub domain: String,
}Fields§
§bucket: Arc<Bucket>§directory: String§domain: StringImplementations§
Trait Implementations§
Source§impl ParallelUploader for AWSMethod
impl ParallelUploader for AWSMethod
Source§fn upload_asset(
&self,
asset_info: AssetInfo,
) -> JoinHandle<Result<(String, String)>>
fn upload_asset( &self, asset_info: AssetInfo, ) -> JoinHandle<Result<(String, String)>>
Returns a
JoinHandle to the task responsible to upload the specified asset. Read moreSource§fn parallel_limit(&self) -> usize
fn parallel_limit(&self) -> usize
Return the number of concurrent uploads allowed. The default implementation returns
the value PARALLEL_LIMIT.
Source§impl Prepare for AWSMethod
impl Prepare for AWSMethod
Source§fn prepare<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
_sugar_config: &'life1 SugarConfig,
_asset_pairs: &'life2 HashMap<isize, AssetPair>,
_asset_indices: Vec<(DataType, &'life3 [isize])>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn prepare<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
_sugar_config: &'life1 SugarConfig,
_asset_pairs: &'life2 HashMap<isize, AssetPair>,
_asset_indices: Vec<(DataType, &'life3 [isize])>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
Prepare the upload of the specified media/metadata files, e.g.: Read more
Auto Trait Implementations§
impl Freeze for AWSMethod
impl RefUnwindSafe for AWSMethod
impl Send for AWSMethod
impl Sync for AWSMethod
impl Unpin for AWSMethod
impl UnwindSafe for AWSMethod
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> Uploader for Twhere
T: ParallelUploader,
impl<T> Uploader for Twhere
T: ParallelUploader,
Source§fn upload<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
_sugar_config: &'life1 SugarConfig,
cache: &'life2 mut Cache,
data_type: DataType,
assets: &'life3 mut Vec<AssetInfo>,
progress: &'life4 ProgressBar,
interrupted: Arc<AtomicBool>,
) -> Pin<Box<dyn Future<Output = Result<Vec<UploadError>, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
T: 'async_trait,
fn upload<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
_sugar_config: &'life1 SugarConfig,
cache: &'life2 mut Cache,
data_type: DataType,
assets: &'life3 mut Vec<AssetInfo>,
progress: &'life4 ProgressBar,
interrupted: Arc<AtomicBool>,
) -> Pin<Box<dyn Future<Output = Result<Vec<UploadError>, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
T: 'async_trait,
Uploads assets in parallel. It creates [self::parallel_limit()] tasks at a time to avoid
reaching the limit of concurrent files open and it syncs the cache file at every self.parallel_limit() / 2
step.