pub struct BundlrMethod {
pub client: Arc<Bundlr<Ed25519Signer>>,
pub sugar_tag: Tag,
/* private fields */
}Fields§
§client: Arc<Bundlr<Ed25519Signer>>§sugar_tag: TagImplementations§
Source§impl BundlrMethod
impl BundlrMethod
pub async fn new( sugar_config: &SugarConfig, _config_data: &ConfigData, ) -> Result<Self>
Sourcepub async fn get_bundlr_balance(
http_client: &HttpClient,
address: &str,
node: &str,
) -> Result<u64>
pub async fn get_bundlr_balance( http_client: &HttpClient, address: &str, node: &str, ) -> Result<u64>
Return the Bundlr balance.
Trait Implementations§
Source§impl ParallelUploader for BundlrMethod
impl ParallelUploader for BundlrMethod
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 BundlrMethod
impl Prepare for BundlrMethod
Source§fn prepare<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
sugar_config: &'life1 SugarConfig,
assets: &'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,
assets: &'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 BundlrMethod
impl !RefUnwindSafe for BundlrMethod
impl Send for BundlrMethod
impl Sync for BundlrMethod
impl Unpin for BundlrMethod
impl !UnwindSafe for BundlrMethod
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.