pub struct TestIndexer {
pub state_merkle_trees: Vec<StateMerkleTreeBundle>,
pub address_merkle_trees: Vec<AddressMerkleTreeBundle>,
pub payer: Keypair,
pub group_pda: Pubkey,
pub compressed_accounts: Vec<CompressedAccountWithMerkleContext>,
pub nullified_compressed_accounts: Vec<CompressedAccountWithMerkleContext>,
pub token_compressed_accounts: Vec<TokenDataWithMerkleContext>,
pub token_nullified_compressed_accounts: Vec<TokenDataWithMerkleContext>,
pub events: Vec<PublicTransactionEvent>,
pub onchain_pubkey_index: HashMap<[u8; 32], usize>,
}Fields§
§state_merkle_trees: Vec<StateMerkleTreeBundle>§address_merkle_trees: Vec<AddressMerkleTreeBundle>§payer: Keypair§group_pda: Pubkey§compressed_accounts: Vec<CompressedAccountWithMerkleContext>§nullified_compressed_accounts: Vec<CompressedAccountWithMerkleContext>§token_compressed_accounts: Vec<TokenDataWithMerkleContext>§token_nullified_compressed_accounts: Vec<TokenDataWithMerkleContext>§events: Vec<PublicTransactionEvent>§onchain_pubkey_index: HashMap<[u8; 32], usize>Index mapping onchain_pubkey to compressed account index.
Implementations§
Source§impl TestIndexer
impl TestIndexer
pub async fn init_from_acounts( payer: &Keypair, env: &TestAccounts, output_queue_batch_size: usize, ) -> Self
pub async fn new( state_merkle_tree_accounts: Vec<StateMerkleTreeAccounts>, address_merkle_tree_accounts: Vec<AddressMerkleTreeAccounts>, payer: Keypair, group_pda: Pubkey, output_queue_batch_size: usize, ) -> Self
Sourcepub fn find_compressed_account_by_onchain_pubkey(
&self,
onchain_pubkey: &[u8; 32],
) -> Option<&CompressedAccountWithMerkleContext>
pub fn find_compressed_account_by_onchain_pubkey( &self, onchain_pubkey: &[u8; 32], ) -> Option<&CompressedAccountWithMerkleContext>
Find a compressed account by its on-chain pubkey. This mirrors Photon’s lookup by onchain_pubkey column.
Sourcepub fn find_multiple_compressed_accounts_by_onchain_pubkeys(
&self,
onchain_pubkeys: &[[u8; 32]],
) -> Vec<Option<&CompressedAccountWithMerkleContext>>
pub fn find_multiple_compressed_accounts_by_onchain_pubkeys( &self, onchain_pubkeys: &[[u8; 32]], ) -> Vec<Option<&CompressedAccountWithMerkleContext>>
Find multiple compressed accounts by their on-chain pubkeys.
Sourcepub fn find_token_account_by_onchain_pubkey(
&self,
onchain_pubkey: &[u8; 32],
) -> Option<&TokenDataWithMerkleContext>
pub fn find_token_account_by_onchain_pubkey( &self, onchain_pubkey: &[u8; 32], ) -> Option<&TokenDataWithMerkleContext>
Find a token compressed account by its on-chain pubkey.
Sourcepub fn find_compressed_account_by_pda_seed(
&self,
pda_pubkey: &[u8; 32],
) -> Option<&CompressedAccountWithMerkleContext>
pub fn find_compressed_account_by_pda_seed( &self, pda_pubkey: &[u8; 32], ) -> Option<&CompressedAccountWithMerkleContext>
Find a compressed account by its PDA pubkey
Sourcepub fn find_token_account_by_pda_seed(
&self,
pda_pubkey: &[u8; 32],
) -> Option<&TokenDataWithMerkleContext>
pub fn find_token_account_by_pda_seed( &self, pda_pubkey: &[u8; 32], ) -> Option<&TokenDataWithMerkleContext>
Find a token compressed account by its PDA pubkey
Sourcepub fn get_state_tree_seq(&self, tree_pubkey: &Pubkey) -> Option<u64>
pub fn get_state_tree_seq(&self, tree_pubkey: &Pubkey) -> Option<u64>
Get the sequence number for a state merkle tree by its pubkey.
pub fn add_address_merkle_tree_bundle( address_merkle_tree_accounts: AddressMerkleTreeAccounts, ) -> Result<AddressMerkleTreeBundle, IndexerError>
Sourcepub fn add_lamport_compressed_accounts(
&mut self,
slot: u64,
event_bytes: Vec<u8>,
)
pub fn add_lamport_compressed_accounts( &mut self, slot: u64, event_bytes: Vec<u8>, )
deserializes an event adds the output_compressed_accounts to the compressed_accounts removes the input_compressed_accounts from the compressed_accounts adds the input_compressed_accounts to the nullified_compressed_accounts
Sourcepub fn get_compressed_balance(&self, owner: &Pubkey) -> u64
pub fn get_compressed_balance(&self, owner: &Pubkey) -> u64
returns the compressed sol balance of the owner pubkey
Sourcepub fn get_compressed_token_balance(&self, owner: &Pubkey, mint: &Pubkey) -> u64
pub fn get_compressed_token_balance(&self, owner: &Pubkey, mint: &Pubkey) -> u64
returns the compressed token balance of the owner pubkey for a token by mint
Trait Implementations§
Source§impl Clone for TestIndexer
impl Clone for TestIndexer
Source§impl Debug for TestIndexer
impl Debug for TestIndexer
Source§impl Indexer for TestIndexer
impl Indexer for TestIndexer
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.
fn get_compressed_token_accounts_by_owner<'life0, 'life1, 'async_trait>(
&'life0 self,
owner: &'life1 Pubkey,
options: Option<GetCompressedTokenAccountsByOwnerOrDelegateOptions>,
_config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<CompressedTokenAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
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_validity_proof<'life0, 'async_trait>(
&'life0 self,
hashes: Vec<[u8; 32]>,
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<[u8; 32]>,
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_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_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_compressed_token_accounts_by_delegate<'life0, 'life1, 'async_trait>(
&'life0 self,
_delegate: &'life1 Pubkey,
_options: Option<GetCompressedTokenAccountsByOwnerOrDelegateOptions>,
_config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<CompressedTokenAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_compressed_token_accounts_by_delegate<'life0, 'life1, 'async_trait>(
&'life0 self,
_delegate: &'life1 Pubkey,
_options: Option<GetCompressedTokenAccountsByOwnerOrDelegateOptions>,
_config: Option<IndexerRpcConfig>,
) -> Pin<Box<dyn Future<Output = Result<Response<ItemsWithCursor<CompressedTokenAccount>>, IndexerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the compressed token accounts that are partially or fully delegated to the given delegate.
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 TestIndexerExtensions for TestIndexer
impl TestIndexerExtensions for TestIndexer
Source§fn add_compressed_accounts_with_token_data(
&mut self,
slot: u64,
event: &PublicTransactionEvent,
)
fn add_compressed_accounts_with_token_data( &mut self, slot: u64, event: &PublicTransactionEvent, )
deserializes an event adds the output_compressed_accounts to the compressed_accounts removes the input_compressed_accounts from the compressed_accounts adds the input_compressed_accounts to the nullified_compressed_accounts deserialiazes token data from the output_compressed_accounts adds the token_compressed_accounts to the token_compressed_accounts
fn get_address_merkle_trees(&self) -> &Vec<AddressMerkleTreeBundle>
fn get_address_merkle_tree( &self, merkle_tree_pubkey: Pubkey, ) -> Option<&AddressMerkleTreeBundle>
fn account_nullified(&mut self, merkle_tree_pubkey: Pubkey, account_hash: &str)
fn address_tree_updated( &mut self, merkle_tree_pubkey: Pubkey, context: &NewAddressProofWithContext, )
fn get_state_merkle_tree_accounts( &self, pubkeys: &[Pubkey], ) -> Vec<StateMerkleTreeAccounts>
fn get_state_merkle_trees(&self) -> &Vec<StateMerkleTreeBundle>
fn get_state_merkle_trees_mut(&mut self) -> &mut Vec<StateMerkleTreeBundle>
fn get_address_merkle_trees_mut(&mut self) -> &mut Vec<AddressMerkleTreeBundle>
fn get_token_compressed_accounts(&self) -> &Vec<TokenDataWithMerkleContext>
fn get_group_pda(&self) -> &Pubkey
fn add_address_merkle_tree_accounts( &mut self, merkle_tree_keypair: &Keypair, queue_keypair: &Keypair, _owning_program_id: Option<Pubkey>, ) -> AddressMerkleTreeAccounts
fn get_compressed_accounts_with_merkle_context_by_owner( &self, owner: &Pubkey, ) -> Vec<CompressedAccountWithMerkleContext>
fn add_state_bundle(&mut self, state_bundle: StateMerkleTreeBundle)
fn add_event_and_compressed_accounts( &mut self, slot: u64, event: &PublicTransactionEvent, ) -> (Vec<CompressedAccountWithMerkleContext>, Vec<TokenDataWithMerkleContext>)
fn get_proof_by_index( &mut self, merkle_tree_pubkey: Pubkey, index: u64, ) -> MerkleProof
Auto Trait Implementations§
impl Freeze for TestIndexer
impl RefUnwindSafe for TestIndexer
impl Send for TestIndexer
impl Sync for TestIndexer
impl Unpin for TestIndexer
impl UnsafeUnpin for TestIndexer
impl UnwindSafe for TestIndexer
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FmtForward for T
impl<T> FmtForward for T
Source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.Source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.Source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.Source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.Source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.Source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.Source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.Source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.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> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self, then passes self.as_ref() into the pipe function.Source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self, then passes self.as_mut() into the pipe
function.Source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self, then passes self.deref() into the pipe function.Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B> of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B> of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R> view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R> view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.Source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref() only in debug builds, and is erased in release
builds.Source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.Source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref() only in debug builds, and is erased in release
builds.