94 lines
3.0 KiB
Rust
94 lines
3.0 KiB
Rust
use {
|
|
crate::bench_tps_client::{BenchTpsClient, Result},
|
|
solana_client::thin_client::ThinClient,
|
|
solana_sdk::{
|
|
account::Account,
|
|
client::{AsyncClient, Client, SyncClient},
|
|
commitment_config::CommitmentConfig,
|
|
epoch_info::EpochInfo,
|
|
hash::Hash,
|
|
message::Message,
|
|
pubkey::Pubkey,
|
|
signature::Signature,
|
|
transaction::Transaction,
|
|
},
|
|
};
|
|
|
|
impl BenchTpsClient for ThinClient {
|
|
fn send_transaction(&self, transaction: Transaction) -> Result<Signature> {
|
|
AsyncClient::async_send_transaction(self, transaction).map_err(|err| err.into())
|
|
}
|
|
fn send_batch(&self, transactions: Vec<Transaction>) -> Result<()> {
|
|
AsyncClient::async_send_batch(self, transactions).map_err(|err| err.into())
|
|
}
|
|
fn get_latest_blockhash(&self) -> Result<Hash> {
|
|
SyncClient::get_latest_blockhash(self).map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_latest_blockhash_with_commitment(
|
|
&self,
|
|
commitment_config: CommitmentConfig,
|
|
) -> Result<(Hash, u64)> {
|
|
SyncClient::get_latest_blockhash_with_commitment(self, commitment_config)
|
|
.map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_transaction_count(&self) -> Result<u64> {
|
|
SyncClient::get_transaction_count(self).map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_transaction_count_with_commitment(
|
|
&self,
|
|
commitment_config: CommitmentConfig,
|
|
) -> Result<u64> {
|
|
SyncClient::get_transaction_count_with_commitment(self, commitment_config)
|
|
.map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_epoch_info(&self) -> Result<EpochInfo> {
|
|
SyncClient::get_epoch_info(self).map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_balance(&self, pubkey: &Pubkey) -> Result<u64> {
|
|
SyncClient::get_balance(self, pubkey).map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_balance_with_commitment(
|
|
&self,
|
|
pubkey: &Pubkey,
|
|
commitment_config: CommitmentConfig,
|
|
) -> Result<u64> {
|
|
SyncClient::get_balance_with_commitment(self, pubkey, commitment_config)
|
|
.map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_fee_for_message(&self, message: &Message) -> Result<u64> {
|
|
SyncClient::get_fee_for_message(self, message).map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_minimum_balance_for_rent_exemption(&self, data_len: usize) -> Result<u64> {
|
|
SyncClient::get_minimum_balance_for_rent_exemption(self, data_len).map_err(|err| err.into())
|
|
}
|
|
|
|
fn addr(&self) -> String {
|
|
Client::tpu_addr(self)
|
|
}
|
|
|
|
fn request_airdrop_with_blockhash(
|
|
&self,
|
|
pubkey: &Pubkey,
|
|
lamports: u64,
|
|
recent_blockhash: &Hash,
|
|
) -> Result<Signature> {
|
|
self.rpc_client()
|
|
.request_airdrop_with_blockhash(pubkey, lamports, recent_blockhash)
|
|
.map_err(|err| err.into())
|
|
}
|
|
|
|
fn get_account(&self, pubkey: &Pubkey) -> Result<Account> {
|
|
self.rpc_client()
|
|
.get_account(pubkey)
|
|
.map_err(|err| err.into())
|
|
}
|
|
}
|