pub struct PinataMethod(_);Implementations
sourceimpl 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
sourceimpl Deref for PinataMethod
impl Deref for PinataMethod
sourceimpl ParallelUploader for PinataMethod
impl ParallelUploader for PinataMethod
sourcefn parallel_limit(&self) -> usize
fn parallel_limit(&self) -> usize
Returns the number of files that to be send in parallel.
sourcefn 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 moresourceimpl Prepare for PinataMethod
impl Prepare for PinataMethod
sourcefn 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
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
Self: '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
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
Self: '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<T> AbiExample for T
impl<T> AbiExample for T
default fn example() -> T
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<T> Pointable for T
impl<T> Pointable for T
sourceimpl<T> Uploader for Twhere
T: ParallelUploader,
impl<T> Uploader for Twhere
T: ParallelUploader,
sourcefn 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.