Struct Hashiverse 

pub struct Hashiverse { /* private fields */ }

A configured Hashiverse client. Deref into a hashiverse_lib::client::hashiverse_client::HashiverseClient for the full API.

Implementations

impl Hashiverse

pub fn client(&self) -> &Arc<HashiverseClient>

Direct access to the underlying Arc<HashiverseClient>. Use this when you need to share the client between tasks; for one-shot calls you can rely on the Deref impl and call methods on &Hashiverse directly.

Methods from Deref<Target = HashiverseClient>

pub fn client_id(&self) -> &ClientId

pub fn active_pow_jobs(&self) -> Vec<PowJobStatus>

pub async fn client_storage_reset(&self) -> Result<(), Error>

pub async fn submit_post( &self, post: &str, ) -> Result<(Vec<SubmitPostCommitTokenV1>, (EncodedPostV1, Bytes)), Error>

pub fn meta_post_manager(&self) -> &MetaPostManager

pub async fn submit_meta_post(&self) -> Result<(), Error>

pub async fn ensure_meta_post_in_current_bucket(&self) -> Result<(), Error>

pub async fn submit_feedback( &self, bucket_location: BucketLocation, post_id: Id, feedback_type: u8, ) -> Result<(), Error>

pub async fn get_post( &self, bucket_location: BucketLocation, post_id: &Id, ) -> Result<(BucketLocation, EncodedPostV1, Bytes, bool), Error>

pub async fn get_post_feedbacks( &self, bucket_location: BucketLocation, post_id: Id, ) -> Result<[u64; 256], Error>

pub async fn single_timeline_reset(&self) -> Result<(), Error>

pub async fn single_timeline_lock( &self, bucket_type: BucketType, base_id: &Id, ) -> Result<RwLockWriteGuard<'_, Option<SingleTimeline>>, Error>

pub async fn single_timeline_get_more( &self, bucket_type: BucketType, base_id: &Id, ) -> Result<(Vec<(BucketLocation, EncodedPostV1, Bytes, bool)>, TimeMillis), Error>

pub async fn multiple_timeline_reset(&self) -> Result<(), Error>

pub async fn multiple_timeline_lock( &self, bucket_type: BucketType, base_ids: &Vec<Id>, ) -> Result<RwLockWriteGuard<'_, Option<MultipleTimeline>>, Error>

pub async fn multiple_timeline_get_more( &self, bucket_type: BucketType, base_ids: &Vec<Id>, ) -> Result<(Vec<(BucketLocation, EncodedPostV1, Bytes, bool)>, TimeMillis), Error>

pub async fn get_all_known_peers(&self) -> Vec<Peer>

pub async fn fetch_url_preview( &self, url: &str, ) -> Result<FetchUrlPreviewResponseV1, Error>

pub async fn fetch_peer_stats(&self, peer_id: &Id) -> Result<Value, Error>

Issue a PeerStatsRequestV1 to the peer identified by peer_id and return the verified, decompressed stats document.

The signature is verified against the response’s own peer field — callers receive either a verified serde_json::Value or an error. The doc’s schema is open-ended; the server decides what fields to include and at what nesting.

pub async fn fetch_trending_hashtags( &self, limit: u16, ) -> Result<TrendingHashtagsFetchResponseV1, Error>

pub async fn dispatch_command(&self, command: &String) -> Result<(), Error>

Trait Implementations

impl Deref for Hashiverse

type Target = HashiverseClient

The resulting type after dereferencing.

fn deref(&self) -> &HashiverseClient

Dereferences the value.