pub struct PinataMethod(_);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 Deref for PinataMethod
impl Deref for PinataMethod
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 !RefUnwindSafe for PinataMethod
impl Send for PinataMethod
impl Sync for PinataMethod
impl Unpin for PinataMethod
impl !UnwindSafe for PinataMethod
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,
§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> 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>
§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, Global>,
progress: &'life4 ProgressBar,
interrupted: Arc<AtomicBool>
) -> Pin<Box<dyn Future<Output = Result<Vec<UploadError, Global>, Error>> + Send + 'async_trait, Global>>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, Global>, progress: &'life4 ProgressBar, interrupted: Arc<AtomicBool> ) -> Pin<Box<dyn Future<Output = Result<Vec<UploadError, Global>, Error>> + Send + 'async_trait, Global>>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.