Struct StellarClient

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

Client implementation for the Stellar blockchain

Provides high-level access to Stellar blockchain data and operations through HTTP transport.

Implementations

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

pub fn new_with_transport(http_client: T) -> Self

Creates a new Stellar client instance with a specific transport client

impl StellarClient<StellarTransportClient>

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

Creates a new Stellar client instance

Arguments

• network - Network configuration containing RPC endpoints and chain details

Returns

• Result<Self, anyhow::Error> - New client instance or connection error

Trait Implementations

impl<T: Send + Sync + Clone + BlockchainTransport> BlockChainClient for StellarClient<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 with retry functionality

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 blocks within the specified range with retry functionality

Note

If end_block is None, only the start_block will be retrieved

Errors

• Returns BlockChainError::RequestError if start_block > end_block
• Returns BlockChainError::BlockNotFound if a block cannot be retrieved

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

Arguments

• contract_id - The ID of the contract to retrieve the spec for

Returns

• Result<ContractSpec, anyhow::Error> - The contract spec or error

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

type Filter = StellarBlockFilter<StellarClient<T>>

fn filter() -> Self::Filter

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

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Send + Sync + Clone + BlockchainTransport> StellarClientTrait for StellarClient<T>

fn get_transactions<'life0, 'async_trait>( &'life0 self, start_sequence: u32, end_sequence: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<Vec<StellarTransaction>, Error>> + Send + 'async_trait>>

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

Retrieves transactions within a sequence range with pagination

Errors

• Returns anyhow::Error if start_sequence > end_sequence
• Returns anyhow::Error if transaction parsing fails

fn get_events<'life0, 'async_trait>( &'life0 self, start_sequence: u32, end_sequence: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<Vec<StellarEvent>, Error>> + Send + 'async_trait>>

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

Retrieves events within a sequence range with pagination

Errors

• Returns anyhow::Error if start_sequence > end_sequence
• Returns anyhow::Error if event parsing fails