pub struct LightClient {
pub client: RpcClient,
pub payer: Keypair,
pub retry_config: RetryConfig,
pub indexer: Option<PhotonIndexer>,
pub state_merkle_trees: Vec<TreeInfo>,
}Fields§
§client: RpcClient§payer: Keypair§retry_config: RetryConfig§indexer: Option<PhotonIndexer>§state_merkle_trees: Vec<TreeInfo>Implementations§
Source§impl LightClient
impl LightClient
pub async fn new_with_retry( config: LightClientConfig, retry_config: Option<RetryConfig>, ) -> Result<Self, RpcError>
pub fn add_indexer(&mut self, url: String)
Source§impl LightClient
impl LightClient
Sourcepub async fn warp_to_slot(&self, slot: Slot) -> Result<Value, RpcError>
pub async fn warp_to_slot(&self, slot: Slot) -> Result<Value, RpcError>
Instantly advances the validator to the given slot using surfpool’s
surfnet_timeTravel RPC method. This is much faster than polling
get_slot in a loop and is intended for testing against surfpool.
Returns the EpochInfo after the time travel, or an error if the
RPC call fails (e.g. when not running against surfpool).
Trait Implementations§
Source§impl Debug for LightClient
impl Debug for LightClient
Source§impl Indexer for LightClient
impl Indexer for LightClient
Source§fn get_validity_proof<'life0, 'async_trait>(
&'life0 self,
hashes: Vec<Hash>,
new_addresses_with_trees: Vec<AddressWithTree>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ValidityProofWithContext>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_validity_proof<'life0, 'async_trait>(
&'life0 self,
hashes: Vec<Hash>,
new_addresses_with_trees: Vec<AddressWithTree>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ValidityProofWithContext>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns a single ZK Proof used by the compression program
to verify that the given accounts are valid and that
the new addresses can be created.
Source§fn get_indexer_slot<'life0, 'async_trait>(
&'life0 self,
config: Option<RetryConfig>,
) -> Pin<Box<dyn Future<Output = Result<u64, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_indexer_slot<'life0, 'async_trait>(
&'life0 self,
config: Option<RetryConfig>,
) -> Pin<Box<dyn Future<Output = Result<u64, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the slot of the last block indexed by the indexer.
Source§fn get_multiple_compressed_account_proofs<'life0, 'async_trait>(
&'life0 self,
hashes: Vec<[u8; 32]>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<MerkleProof>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_multiple_compressed_account_proofs<'life0, 'async_trait>(
&'life0 self,
hashes: Vec<[u8; 32]>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<MerkleProof>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns multiple proofs used by the compression program to verify the accounts’ validity.
Source§fn get_compressed_accounts_by_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<GetCompressedAccountsByOwnerConfig>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<CompressedAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_compressed_accounts_by_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<GetCompressedAccountsByOwnerConfig>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<CompressedAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the owner’s compressed accounts.
Source§fn get_compressed_account<'life0, 'async_trait>(
&'life0 self,
address: Address,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Option<CompressedAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_compressed_account<'life0, 'async_trait>(
&'life0 self,
address: Address,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Option<CompressedAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the compressed account with the given address or hash.
Source§fn get_compressed_account_by_hash<'life0, 'async_trait>(
&'life0 self,
hash: Hash,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Option<CompressedAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_compressed_account_by_hash<'life0, 'async_trait>(
&'life0 self,
hash: Hash,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Option<CompressedAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the compressed account with the given address or hash.
Source§fn get_compressed_balance<'life0, 'async_trait>(
&'life0 self,
address: Option<Address>,
hash: Option<Hash>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<u64>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_compressed_balance<'life0, 'async_trait>(
&'life0 self,
address: Option<Address>,
hash: Option<Hash>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<u64>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the balance for the compressed account with the given address or hash.
Source§fn get_compressed_token_account_balance<'life0, 'async_trait>(
&'life0 self,
address: Option<Address>,
hash: Option<Hash>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<u64>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_compressed_token_account_balance<'life0, 'async_trait>(
&'life0 self,
address: Option<Address>,
hash: Option<Hash>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<u64>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the balance for a given token account.
Source§fn get_multiple_compressed_accounts<'life0, 'async_trait>(
&'life0 self,
addresses: Option<Vec<Address>>,
hashes: Option<Vec<Hash>>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<Option<CompressedAccount>>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_multiple_compressed_accounts<'life0, 'async_trait>(
&'life0 self,
addresses: Option<Vec<Address>>,
hashes: Option<Vec<Hash>>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<Option<CompressedAccount>>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns multiple compressed accounts with the given addresses or hashes.
Source§fn get_compressed_token_balances_by_owner_v2<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<GetCompressedTokenAccountsByOwnerOrDelegateOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<TokenBalance>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_compressed_token_balances_by_owner_v2<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<GetCompressedTokenAccountsByOwnerOrDelegateOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<TokenBalance>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the token balances for a given owner.
Source§fn get_compression_signatures_for_account<'life0, 'async_trait>(
&'life0 self,
hash: Hash,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<SignatureWithMetadata>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_compression_signatures_for_account<'life0, 'async_trait>(
&'life0 self,
hash: Hash,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<SignatureWithMetadata>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the token balances for a given owner.
Source§fn get_multiple_new_address_proofs<'life0, 'async_trait>(
&'life0 self,
merkle_tree_pubkey: [u8; 32],
addresses: Vec<[u8; 32]>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<NewAddressProofWithContext>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_multiple_new_address_proofs<'life0, 'async_trait>(
&'life0 self,
merkle_tree_pubkey: [u8; 32],
addresses: Vec<[u8; 32]>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<NewAddressProofWithContext>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns proofs that the new addresses are not taken already and can be created.
Source§fn get_queue_elements<'life0, 'async_trait>(
&'life0 mut self,
merkle_tree_pubkey: [u8; 32],
options: QueueElementsV2Options,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<QueueElementsResult>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_queue_elements<'life0, 'async_trait>(
&'life0 mut self,
merkle_tree_pubkey: [u8; 32],
options: QueueElementsV2Options,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<QueueElementsResult>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns queue elements with deduplicated nodes for efficient staging tree construction.
Supports output queue, input queue, and address queue.
Source§fn get_queue_leaf_indices<'life0, 'async_trait>(
&'life0 self,
merkle_tree_pubkey: [u8; 32],
limit: u16,
start_index: Option<u64>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<QueueLeafIndex>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_queue_leaf_indices<'life0, 'async_trait>(
&'life0 self,
merkle_tree_pubkey: [u8; 32],
limit: u16,
start_index: Option<u64>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<QueueLeafIndex>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns lightweight (hash, queue_index, leaf_index) tuples for nullifier queue items.
Used by the forester to sort queue items before grouping for multi-nullify.
Source§fn get_queue_info<'life0, 'async_trait>(
&'life0 self,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<QueueInfoResult>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_queue_info<'life0, 'async_trait>(
&'life0 self,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<QueueInfoResult>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns information about all queues in the system.
Includes tree pubkey, queue pubkey, queue type, and queue size for each queue.
fn get_subtrees<'life0, 'async_trait>(
&'life0 self,
merkle_tree_pubkey: [u8; 32],
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<Items<[u8; 32]>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn get_compressed_balance_by_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<u64>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_compressed_balance_by_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<u64>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the total balance of the owner’s compressed accounts.
Source§fn get_compressed_mint_token_holders<'life0, 'life1, 'async_trait>(
&'life0 self,
mint: &'life1 Pubkey,
options: Option<PaginatedOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<OwnerBalance>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_compressed_mint_token_holders<'life0, 'life1, 'async_trait>(
&'life0 self,
mint: &'life1 Pubkey,
options: Option<PaginatedOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<OwnerBalance>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the owner balances for a given mint in descending order.
Source§fn get_compression_signatures_for_address<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 [u8; 32],
options: Option<PaginatedOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<SignatureWithMetadata>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_compression_signatures_for_address<'life0, 'life1, 'async_trait>(
&'life0 self,
address: &'life1 [u8; 32],
options: Option<PaginatedOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<SignatureWithMetadata>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Return the signatures of the transactions that
closed or opened a compressed account with the given address.
Source§fn get_compression_signatures_for_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<PaginatedOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<SignatureWithMetadata>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_compression_signatures_for_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<PaginatedOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<SignatureWithMetadata>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the signatures of the transactions that
have modified an owner’s compressed accounts.
Source§fn get_compression_signatures_for_token_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<PaginatedOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<SignatureWithMetadata>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_compression_signatures_for_token_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<PaginatedOptions>,
config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<SignatureWithMetadata>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the signatures of the transactions that
have modified an owner’s compressed token accounts.
Source§fn get_indexer_health<'life0, 'async_trait>(
&'life0 self,
config: Option<RetryConfig>,
) -> Pin<Box<dyn Future<Output = Result<bool, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_indexer_health<'life0, 'async_trait>(
&'life0 self,
config: Option<RetryConfig>,
) -> Pin<Box<dyn Future<Output = Result<bool, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns an error if the indexer is stale
by more than a configurable number of blocks.
Otherwise, it returns ok.
Source§impl MerkleTreeExt for LightClient
impl MerkleTreeExt for LightClient
fn get_state_merkle_tree_account<'life0, 'async_trait>(
&'life0 mut self,
pubkey: Pubkey,
) -> Pin<Box<dyn Future<Output = Result<ConcurrentMerkleTreeCopy<Poseidon, 26>, MerkleTreeExtError>> + Send + 'async_trait>>where
Self: Send + 'async_trait,
'life0: 'async_trait,
fn get_address_merkle_tree_account<'life0, 'async_trait>(
&'life0 mut self,
pubkey: Pubkey,
) -> Pin<Box<dyn Future<Output = Result<IndexedMerkleTreeCopy<Poseidon, usize, 26, 16>, MerkleTreeExtError>> + Send + 'async_trait>>where
Self: Send + 'async_trait,
'life0: 'async_trait,
Source§impl Rpc for LightClient
impl Rpc for LightClient
Source§fn create_and_send_versioned_transaction<'a, 'async_trait>(
&'a mut self,
instructions: &'a [Instruction],
payer: &'a Pubkey,
signers: &'a [&'a Keypair],
address_lookup_tables: &'a [AddressLookupTableAccount],
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
fn create_and_send_versioned_transaction<'a, 'async_trait>(
&'a mut self,
instructions: &'a [Instruction],
payer: &'a Pubkey,
signers: &'a [&'a Keypair],
address_lookup_tables: &'a [AddressLookupTableAccount],
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
Creates and sends a versioned transaction with address lookup tables.
address_lookup_tables must contain pre-fetched AddressLookupTableAccount values
loaded from the chain. Callers are responsible for resolving these accounts before
calling this method. Unresolved or missing lookup tables will cause compilation to fail.
Returns RpcError::TransactionBuildError on message compilation failure,
RpcError::SigningError on signing failure.
Source§fn get_latest_active_state_trees<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<Vec<TreeInfo>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_latest_active_state_trees<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<Vec<TreeInfo>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Fetch the latest state tree addresses from the cluster.
When the v2 feature is enabled, returns the default V2
batched state trees.
When v2 is disabled, uses V1 lookup-table resolution or
localnet defaults.
Source§fn get_state_tree_infos(&self) -> Vec<TreeInfo>
fn get_state_tree_infos(&self) -> Vec<TreeInfo>
Returns list of state tree infos.
Source§fn get_random_state_tree_info(&self) -> Result<TreeInfo, RpcError>
fn get_random_state_tree_info(&self) -> Result<TreeInfo, RpcError>
Gets a random active state tree.
Source§fn get_random_state_tree_info_v1(&self) -> Result<TreeInfo, RpcError>
fn get_random_state_tree_info_v1(&self) -> Result<TreeInfo, RpcError>
Gets a random v1 state tree. State trees are cached and have to be fetched or set.
fn new<'async_trait>(
config: LightClientConfig,
) -> Pin<Box<dyn Future<Output = Result<Self, RpcError>> + Send + 'async_trait>>where
Self: Sized + 'async_trait,
fn get_payer(&self) -> &Keypair
fn get_url(&self) -> String
fn health<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<(), RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_program_accounts<'life0, 'life1, 'async_trait>(
&'life0 self,
program_id: &'life1 Pubkey,
) -> Pin<Box<dyn Future<Output = Result<Vec<(Pubkey, Account)>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_program_accounts_with_discriminator<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
program_id: &'life1 Pubkey,
discriminator: &'life2 [u8],
) -> Pin<Box<dyn Future<Output = Result<Vec<(Pubkey, Account)>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn process_transaction<'life0, 'async_trait>(
&'life0 mut self,
transaction: Transaction,
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn process_versioned_transaction<'life0, 'async_trait>(
&'life0 mut self,
transaction: VersionedTransaction,
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn process_transaction_with_context<'life0, 'async_trait>(
&'life0 mut self,
transaction: Transaction,
) -> Pin<Box<dyn Future<Output = Result<(Signature, Slot), RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn confirm_transaction<'life0, 'async_trait>(
&'life0 self,
signature: Signature,
) -> Pin<Box<dyn Future<Output = Result<bool, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn get_account<'life0, 'async_trait>(
&'life0 self,
address: Pubkey,
) -> Pin<Box<dyn Future<Output = Result<Option<Account>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_account<'life0, 'async_trait>(
&'life0 self,
address: Pubkey,
) -> Pin<Box<dyn Future<Output = Result<Option<Account>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns an account struct.
Source§fn get_multiple_accounts<'life0, 'life1, 'async_trait>(
&'life0 self,
addresses: &'life1 [Pubkey],
) -> Pin<Box<dyn Future<Output = Result<Vec<Option<Account>>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_multiple_accounts<'life0, 'life1, 'async_trait>(
&'life0 self,
addresses: &'life1 [Pubkey],
) -> Pin<Box<dyn Future<Output = Result<Vec<Option<Account>>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns multiple account structs.
fn get_minimum_balance_for_rent_exemption<'life0, 'async_trait>(
&'life0 self,
data_len: usize,
) -> Pin<Box<dyn Future<Output = Result<u64, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn airdrop_lamports<'life0, 'life1, 'async_trait>(
&'life0 mut self,
to: &'life1 Pubkey,
lamports: u64,
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_balance<'life0, 'life1, 'async_trait>(
&'life0 self,
pubkey: &'life1 Pubkey,
) -> Pin<Box<dyn Future<Output = Result<u64, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_latest_blockhash<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(Hash, u64), RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_block_height<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<u64, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_slot<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<u64, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_transaction<'life0, 'life1, 'async_trait>(
&'life0 self,
transaction: &'life1 Transaction,
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn send_transaction_with_config<'life0, 'life1, 'async_trait>(
&'life0 self,
transaction: &'life1 Transaction,
config: RpcSendTransactionConfig,
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn send_versioned_transaction_with_config<'life0, 'life1, 'async_trait>(
&'life0 self,
transaction: &'life1 VersionedTransaction,
config: RpcSendTransactionConfig,
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_transaction_slot<'life0, 'life1, 'async_trait>(
&'life0 self,
signature: &'life1 Signature,
) -> Pin<Box<dyn Future<Output = Result<u64, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_signature_statuses<'life0, 'life1, 'async_trait>(
&'life0 self,
signatures: &'life1 [Signature],
) -> Pin<Box<dyn Future<Output = Result<Vec<Option<TransactionStatus>>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn create_and_send_transaction_with_event<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait, T>(
&'life0 mut self,
instructions: &'life1 [Instruction],
payer: &'life2 Pubkey,
signers: &'life3 [&'life4 Keypair],
) -> Pin<Box<dyn Future<Output = Result<Option<(T, Signature, u64)>, RpcError>> + Send + 'async_trait>>where
T: BorshDeserialize + Send + Debug + 'async_trait,
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn create_and_send_transaction_with_public_event<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 mut self,
instructions: &'life1 [Instruction],
payer: &'life2 Pubkey,
signers: &'life3 [&'life4 Keypair],
) -> Pin<Box<dyn Future<Output = Result<Option<(PublicTransactionEvent, Signature, Slot)>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn create_and_send_transaction_with_batched_event<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 mut self,
instructions: &'life1 [Instruction],
payer: &'life2 Pubkey,
signers: &'life3 [&'life4 Keypair],
) -> Pin<Box<dyn Future<Output = Result<Option<(Vec<BatchPublicTransactionEvent>, Signature, Slot)>, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn indexer(&self) -> Result<&impl Indexer, RpcError>
fn indexer_mut(&mut self) -> Result<&mut impl Indexer, RpcError>
fn get_address_tree_v1(&self) -> TreeInfo
fn get_address_tree_v2(&self) -> TreeInfo
fn should_retry(&self, error: &RpcError) -> bool
Source§fn get_anchor_account<'life0, 'life1, 'async_trait, T>(
&'life0 self,
pubkey: &'life1 Pubkey,
) -> Pin<Box<dyn Future<Output = Result<Option<T>, RpcError>> + Send + 'async_trait>>where
T: 'async_trait + BorshDeserialize,
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_anchor_account<'life0, 'life1, 'async_trait, T>(
&'life0 self,
pubkey: &'life1 Pubkey,
) -> Pin<Box<dyn Future<Output = Result<Option<T>, RpcError>> + Send + 'async_trait>>where
T: 'async_trait + BorshDeserialize,
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns an a borsh deserialized account.
Deserialization skips the discriminator.
fn create_and_send_transaction<'a, 'async_trait>(
&'a mut self,
instructions: &'a [Instruction],
payer: &'a Pubkey,
signers: &'a [&'a Keypair],
) -> Pin<Box<dyn Future<Output = Result<Signature, RpcError>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
Auto Trait Implementations§
impl !Freeze for LightClient
impl !RefUnwindSafe for LightClient
impl !UnwindSafe for LightClient
impl Send for LightClient
impl Sync for LightClient
impl Unpin for LightClient
impl UnsafeUnpin for LightClient
Blanket Implementations§
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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 more