Struct SolanaClient

pub struct SolanaClient<T: Send + Sync + Clone> { /* private fields */ }

Client implementation for the Solana blockchain

Provides high-level access to Solana blockchain data and operations through HTTP transport. Supports optimized block fetching when monitored addresses are configured.

Implementations

impl<T: Send + Sync + Clone> SolanaClient<T>

pub fn new_with_transport(http_client: T) -> Self

Creates a new Solana client instance with a specific transport client

pub fn with_monitored_addresses(self, addresses: Vec<String>) -> Self

Configures the client with addresses to monitor

When addresses are set, get_blocks will use the optimized getSignaturesForAddress approach instead of fetching all blocks.

Arguments

• addresses - Program IDs or addresses to monitor

pub fn set_monitored_addresses(&mut self, addresses: Vec<String>)

Sets the monitored addresses (mutable version)

pub fn monitored_addresses(&self) -> &[String]

Returns the currently monitored addresses

impl SolanaClient<SolanaTransportClient>

pub async fn new(network: &Network) -> Result<Self, Error>

Creates a new Solana client instance

Trait Implementations

impl<T: Send + Sync + Clone + BlockchainTransport> BlockChainClient for SolanaClient<T>

fn get_latest_block_number<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the latest block number from the blockchain

fn get_blocks<'life0, 'async_trait>( &'life0 self, start_block: u64, end_block: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<BlockType>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves a range of blocks from the blockchain

fn get_contract_spec<'life0, 'life1, 'async_trait>( &'life0 self, contract_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ContractSpec, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves the contract spec for a given contract ID

fn get_blocks_for_addresses<'life0, 'life1, 'async_trait>( &'life0 self, _addresses: &'life1 [String], start_block: u64, end_block: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<BlockType>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves blocks containing only transactions relevant to the specified addresses

impl<T: Send + Sync + Clone + BlockchainTransport> BlockFilterFactory<SolanaClient<T>> for SolanaClient<T>

type Filter = SolanaBlockFilter<SolanaClient<T>>

fn filter() -> Self::Filter

impl<T: Clone + Send + Sync + Clone> Clone for SolanaClient<T>

fn clone(&self) -> SolanaClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Send + Sync + Clone + BlockchainTransport> SolanaClientTrait for SolanaClient<T>

fn get_transactions<'life0, 'async_trait>( &'life0 self, slot: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<SolanaTransaction>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves transactions for a specific slot

fn get_transaction<'life0, 'async_trait>( &'life0 self, signature: String, ) -> Pin<Box<dyn Future<Output = Result<Option<SolanaTransaction>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves a single transaction by signature

fn get_signatures_for_address_with_info<'life0, 'async_trait>( &'life0 self, address: String, limit: Option<usize>, min_slot: Option<u64>, until_signature: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Vec<SignatureInfo>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves signatures with full info (slot, err, block_time) for an address Optionally filter by slot range

fn get_all_signatures_for_address<'life0, 'async_trait>( &'life0 self, address: String, start_slot: u64, end_slot: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<SignatureInfo>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves all signatures for an address within a slot range with automatic pagination This method handles pagination internally and returns all signatures up to a safety limit

fn get_transactions_for_addresses<'life0, 'life1, 'async_trait>( &'life0 self, addresses: &'life1 [String], start_slot: u64, end_slot: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<SolanaTransaction>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves transactions for multiple addresses within a slot range This is the optimized method that uses getSignaturesForAddress instead of getBlock

fn get_account_info<'life0, 'async_trait>( &'life0 self, pubkey: String, ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves account info for a given public key

fn get_program_accounts<'life0, 'async_trait>( &'life0 self, program_id: String, ) -> Pin<Box<dyn Future<Output = Result<Vec<Value>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves program accounts for a given program ID

fn get_blocks_for_addresses<'life0, 'life1, 'async_trait>( &'life0 self, addresses: &'life1 [String], start_slot: u64, end_slot: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<BlockType>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves blocks containing only transactions relevant to the specified addresses This is the main optimization: instead of fetching all blocks, we fetch only transactions that involve the monitored addresses and group them into virtual blocks