pub struct PinataMethod(/* private fields */);Implementations§
Source§impl PinataMethod
impl PinataMethod
Sourcepub async fn new(config_data: &ConfigData) -> Result<Self>
pub async fn new(config_data: &ConfigData) -> Result<Self>
Initialize a new PinataMethod.
Trait Implementations§
Source§impl ParallelUploader for PinataMethod
impl ParallelUploader for PinataMethod
Source§fn parallel_limit(&self) -> usize
fn parallel_limit(&self) -> usize
Returns the number of files that to be send in parallel.
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§impl Prepare for PinataMethod
impl Prepare for PinataMethod
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,
Verifies that no file is larger than 100MB (upload of files larger than 100MB are not currently supported).
Auto Trait Implementations§
impl Freeze for PinataMethod
impl !RefUnwindSafe for PinataMethod
impl Send for PinataMethod
impl Sync for PinataMethod
impl Unpin for PinataMethod
impl !UnwindSafe for PinataMethod
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.