Struct ArkivRoClient 

pub struct ArkivRoClient { /* private fields */ }

A client for interacting with the Arkiv system. Provides methods for account management, entity operations, balance queries, and event subscriptions.

Example Usage

A client builder is provided for both ArkivClient and ArkivRoClient, however, an instance of ArkivClient can be dereferenced to ArkivRoClient like so:

use arkiv_sdk::{ArkivClient, ArkivRoClient, PrivateKeySigner, Url};

let keypath = dirs::config_dir()
    .ok_or("Failed to get config directory")?
    .join("golembase")
    .join("wallet.json");
let signer = PrivateKeySigner::decrypt_keystore(keypath, "password")?;
let url = Url::parse("http://localhost:8545")?;

let client = ArkivClient::builder()
    .wallet(signer)
    .rpc_url(url)
    .build();

let ro_client: &ArkivRoClient = *client;

Implementations

impl ArkivRoClient

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

Gets the total count of entities in Arkiv. Returns the number of entities currently stored.

pub async fn get_all_entity_keys(&self) -> Result<Vec<Hash>, Error>

Gets the entity keys of all entities in Arkiv. Returns a vector of all entity keys.

pub async fn get_entities_of_owner( &self, address: Address, ) -> Result<Vec<Hash>, Error>

Gets the entity keys of all entities owned by the given address. Returns a vector of entity keys for the specified owner.

pub async fn get_storage_value<T: TryFrom<Vec<u8>>>( &self, key: Hash, ) -> Result<T, Error>

where <T as TryFrom<Vec<u8>>>::Error: Display,

Gets the storage value associated with the given entity key. Decodes the value from base64 and attempts to convert it to the requested type.

pub async fn query_entities( &self, query: &str, ) -> Result<Vec<SearchResult>, Error>

Queries entities in Arkiv based on annotations. Returns a vector of SearchResult matching the query string.

pub async fn query_entity_keys(&self, query: &str) -> Result<Vec<Hash>, Error>

Queries entities in Arkiv based on annotations and returns only their keys. Returns a vector of entity keys matching the query string.

pub async fn get_entities_to_expire_at_block( &self, block_number: u64, ) -> Result<Vec<Hash>, Error>

Gets all entity keys for entities that will expire at the given block number. Returns a vector of entity keys expiring at the specified block.

pub async fn get_entity_metadata( &self, key: Hash, ) -> Result<EntityMetaData, Error>

Gets metadata for a specific entity. Returns an EntityMetaData struct for the given entity key.

impl ArkivRoClient

pub fn builder() -> ArkivRoClientBuilder

Creates a new builder for ArkivClient with the given wallet and RPC URL. Initializes the provider and sets up default configuration.

Trait Implementations

impl Clone for ArkivRoClient

fn clone(&self) -> ArkivRoClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.