Struct solana_client::rpc_client::RpcClient

pub struct RpcClient { /* fields omitted */ }

A client of a remote Solana node.

RpcClient communicates with a Solana node over JSON-RPC, with the Solana JSON-RPC protocol. It is the primary Rust interface for querying and transacting with the network from external programs.

This type builds on the underlying RPC protocol, adding extra features such as timeout handling, retries, and waiting on transaction commitment levels. Some methods simply pass through to the underlying RPC protocol. Not all RPC methods are encapsulated by this type, but RpcClient does expose a generic send method for making any RpcRequest.

The documentation for most RpcClient methods contains an “RPC Reference” section that links to the documentation for the underlying JSON-RPC method. The documentation for RpcClient does not reproduce the documentation for the underlying JSON-RPC methods. Thus reading both is necessary for complete understanding.

RpcClients generally communicate over HTTP on port 8899, a typical server URL being “http://localhost:8899”.

By default, requests to confirm transactions only succeed once those transactions are finalized, meaning they are definitely permanently committed. Transactions can be confirmed with less finality by creating RpcClient with an explicit CommitmentConfig, or by calling the various _with_commitment methods, like RpcClient::confirm_transaction_with_commitment.

Errors

Methods on RpcClient return client_error::Result, and many of them return the RpcResult typedef, which contains Response<T> on Ok. Both client_error::Result and RpcResult contain ClientError on error. In the case of RpcResult, the actual return value is in the value field, with RPC contextual information in the context field, so it is common for the value to be accessed with ?.value, as in

let signature = rpc_client.send_transaction(&tx)?;
let statuses = rpc_client.get_signature_statuses(&[signature])?.value;

Requests may timeout, in which case they return a ClientError where the ClientErrorKind is ClientErrorKind::Reqwest, and where the interior reqwest::Errors is_timeout method returns true. The default timeout is 30 seconds, and may be changed by calling an appropriate constructor with a timeout parameter.

Implementations

impl RpcClient

pub fn new(url: String) -> Self

Create an HTTP RpcClient.

The URL is an HTTP URL, usually for port 8899, as in “http://localhost:8899”.

The client has a default timeout of 30 seconds, and a default commitment level of Finalized.

Examples

let url = "http://localhost:8899".to_string();
let client = RpcClient::new(url);

pub fn new_with_commitment(
    url: String,
    commitment_config: CommitmentConfig
) -> Self

Create an HTTP RpcClient with specified commitment level.

The URL is an HTTP URL, usually for port 8899, as in “http://localhost:8899”.

The client has a default timeout of 30 seconds, and a user-specified CommitmentLevel via CommitmentConfig.

Examples

let url = "http://localhost:8899".to_string();
let commitment_config = CommitmentConfig::processed();
let client = RpcClient::new_with_commitment(url, commitment_config);

pub fn new_with_timeout(url: String, timeout: Duration) -> Self

Create an HTTP RpcClient with specified timeout.

The URL is an HTTP URL, usually for port 8899, as in “http://localhost:8899”.

The client has and a default commitment level of Finalized.

Examples

let url = "http://localhost::8899".to_string();
let timeout = Duration::from_secs(1);
let client = RpcClient::new_with_timeout(url, timeout);

pub fn new_with_timeout_and_commitment(
    url: String,
    timeout: Duration,
    commitment_config: CommitmentConfig
) -> Self

Create an HTTP RpcClient with specified timeout and commitment level.

The URL is an HTTP URL, usually for port 8899, as in “http://localhost:8899”.

Examples

let url = "http://localhost::8899".to_string();
let timeout = Duration::from_secs(1);
let commitment_config = CommitmentConfig::processed();
let client = RpcClient::new_with_timeout_and_commitment(
    url,
    timeout,
    commitment_config,
);

pub fn new_with_timeouts_and_commitment(
    url: String,
    timeout: Duration,
    commitment_config: CommitmentConfig,
    confirm_transaction_initial_timeout: Duration
) -> Self

Create an HTTP RpcClient with specified timeout and commitment level.

The URL is an HTTP URL, usually for port 8899, as in “http://localhost:8899”.

The confirm_transaction_initial_timeout argument specifies, when confirming a transaction via one of the _with_spinner methods, like RpcClient::send_and_confirm_transaction_with_spinner, the amount of time to allow for the server to initially process a transaction. In other words, setting confirm_transaction_initial_timeout to > 0 allows RpcClient to wait for confirmation of a transaction that the server has not “seen” yet.

Examples

let url = "http://localhost::8899".to_string();
let timeout = Duration::from_secs(1);
let commitment_config = CommitmentConfig::processed();
let confirm_transaction_initial_timeout = Duration::from_secs(10);
let client = RpcClient::new_with_timeouts_and_commitment(
    url,
    timeout,
    commitment_config,
    confirm_transaction_initial_timeout,
);

pub fn new_mock(url: String) -> Self

Create a mock RpcClient.

See the MockSender documentation for an explanation of how it treats the url argument.

Examples

// Create an `RpcClient` that always succeeds
let url = "succeeds".to_string();
let successful_client = RpcClient::new_mock(url);

// Create an `RpcClient` that always fails
let url = "fails".to_string();
let successful_client = RpcClient::new_mock(url);

pub fn new_mock_with_mocks(url: String, mocks: Mocks) -> Self

Create a mock RpcClient.

See the MockSender documentation for an explanation of how it treats the url argument.

Examples

// Create a mock with a custom repsonse to the `GetBalance` request
let account_balance = 50;
let account_balance_response = json!(Response {
    context: RpcResponseContext { slot: 1 },
    value: json!(account_balance),
});

let mut mocks = HashMap::new();
mocks.insert(RpcRequest::GetBalance, account_balance_response);
let url = "succeeds".to_string();
let client = RpcClient::new_mock_with_mocks(url, mocks);

pub fn new_socket(addr: SocketAddr) -> Self

Create an HTTP RpcClient from a SocketAddr.

The client has a default timeout of 30 seconds, and a default commitment level of Finalized.

Examples

let addr = SocketAddr::from(([127, 0, 0, 1], 8899));
let client = RpcClient::new_socket(addr);

pub fn new_socket_with_commitment(
    addr: SocketAddr,
    commitment_config: CommitmentConfig
) -> Self

Create an HTTP RpcClient from a SocketAddr with specified commitment level.

The client has a default timeout of 30 seconds, and a user-specified CommitmentLevel via CommitmentConfig.

Examples

let addr = SocketAddr::from(([127, 0, 0, 1], 8899));
let commitment_config = CommitmentConfig::processed();
let client = RpcClient::new_socket_with_commitment(
    addr,
    commitment_config
);

pub fn new_socket_with_timeout(addr: SocketAddr, timeout: Duration) -> Self

Create an HTTP RpcClient from a SocketAddr with specified timeout.

The client has and a default commitment level of Finalized.

Examples

let addr = SocketAddr::from(([127, 0, 0, 1], 8899));
let timeout = Duration::from_secs(1);
let client = RpcClient::new_socket_with_timeout(addr, timeout);

pub fn commitment(&self) -> CommitmentConfig

Get the configured default commitment level.

The commitment config may be specified during construction, and determines how thoroughly committed a transaction must be when waiting for its confirmation or otherwise checking for confirmation. If not specified, the default commitment level is Finalized.

The default commitment level is overridden when calling methods that explicitly provide a CommitmentConfig, like RpcClient::confirm_transaction_with_commitment.

pub fn confirm_transaction(&self, signature: &Signature) -> ClientResult<bool>

Check the confirmation status of a transaction.

Returns true if the given transaction succeeded and has been committed with the configured commitment level, which can be retrieved with the commitment method.

Note that this method does not wait for a transaction to be confirmed — it only checks whether a transaction has been confirmed. To submit a transaction and wait for it to confirm, use send_and_confirm_transaction.

This method returns false if the transaction failed, even if it has been confirmed.

RPC Reference

This method is built on the getSignatureStatuses RPC method.

Examples

// Transfer lamports from Alice to Bob and wait for confirmation
let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let tx = system_transaction::transfer(&alice, &bob.pubkey(), lamports, recent_blockhash);
let signature = rpc_client.send_transaction(&tx)?;

loop {
    let confirmed = rpc_client.confirm_transaction(&signature)?;
    if confirmed {
        break;
    }
}

pub fn confirm_transaction_with_commitment(
    &self,
    signature: &Signature,
    commitment_config: CommitmentConfig
) -> RpcResult<bool>

Check the confirmation status of a transaction.

Returns an RpcResult with value true if the given transaction succeeded and has been committed with the given commitment level.

Note that this method does not wait for a transaction to be confirmed — it only checks whether a transaction has been confirmed. To submit a transaction and wait for it to confirm, use send_and_confirm_transaction.

This method returns an RpcResult with value false if the transaction failed, even if it has been confirmed.

RPC Reference

This method is built on the getSignatureStatuses RPC method.

Examples

// Transfer lamports from Alice to Bob and wait for confirmation
let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let tx = system_transaction::transfer(&alice, &bob.pubkey(), lamports, recent_blockhash);
let signature = rpc_client.send_transaction(&tx)?;

loop {
    let commitment_config = CommitmentConfig::processed();
    let confirmed = rpc_client.confirm_transaction_with_commitment(&signature, commitment_config)?;
    if confirmed.value {
        break;
    }
}

pub fn send_transaction(
    &self,
    transaction: &Transaction
) -> ClientResult<Signature>

Submits a signed transaction to the network.

Before a transaction is processed, the receiving node runs a “preflight check” which verifies signatures, checks that the node is healthy, and simulates the transaction. If the preflight check fails then an error is returned immediately. Preflight checks can be disabled by calling send_transaction_with_config and setting the skip_preflight field of RpcSendTransactionConfig to true.

This method does not wait for the transaction to be processed or confirmed before returning successfully. To wait for the transaction to be processed or confirmed, use the send_and_confirm_transaction method.

Errors

If the transaction is not signed then an error with kind RpcError is returned, containing an RpcResponseError with code set to JSON_RPC_SERVER_ERROR_TRANSACTION_SIGNATURE_VERIFICATION_FAILURE.

If the preflight transaction simulation fails then an error with kind RpcError is returned, containing an RpcResponseError with code set to JSON_RPC_SERVER_ERROR_SEND_TRANSACTION_PREFLIGHT_FAILURE.

If the receiving node is unhealthy, e.g. it is not fully synced to the cluster, then an error with kind RpcError is returned, containing an RpcResponseError with code set to JSON_RPC_SERVER_ERROR_NODE_UNHEALTHY.

RPC Reference

This method is built on the sendTransaction RPC method.

Examples

// Transfer lamports from Alice to Bob
let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let tx = system_transaction::transfer(&alice, &bob.pubkey(), lamports, recent_blockhash);
let signature = rpc_client.send_transaction(&tx)?;

pub fn send_transaction_with_config(
    &self,
    transaction: &Transaction,
    config: RpcSendTransactionConfig
) -> ClientResult<Signature>

Submits a signed transaction to the network.

Before a transaction is processed, the receiving node runs a “preflight check” which verifies signatures, checks that the node is healthy, and simulates the transaction. If the preflight check fails then an error is returned immediately. Preflight checks can be disabled by setting the skip_preflight field of RpcSendTransactionConfig to true.

This method does not wait for the transaction to be processed or confirmed before returning successfully. To wait for the transaction to be processed or confirmed, use the send_and_confirm_transaction method.

Errors

If preflight checks are enabled, if the transaction is not signed then an error with kind RpcError is returned, containing an RpcResponseError with code set to JSON_RPC_SERVER_ERROR_TRANSACTION_SIGNATURE_VERIFICATION_FAILURE.

If preflight checks are enabled, if the preflight transaction simulation fails then an error with kind RpcError is returned, containing an RpcResponseError with code set to JSON_RPC_SERVER_ERROR_SEND_TRANSACTION_PREFLIGHT_FAILURE.

If the receiving node is unhealthy, e.g. it is not fully synced to the cluster, then an error with kind RpcError is returned, containing an RpcResponseError with code set to JSON_RPC_SERVER_ERROR_NODE_UNHEALTHY.

RPC Reference

This method is built on the sendTransaction RPC method.

Examples

// Transfer lamports from Alice to Bob
let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let tx = system_transaction::transfer(&alice, &bob.pubkey(), lamports, recent_blockhash);
let config = RpcSendTransactionConfig {
    skip_preflight: true,
    .. RpcSendTransactionConfig::default()
};
let signature = rpc_client.send_transaction_with_config(
    &tx,
    config,
)?;

pub fn simulate_transaction(
    &self,
    transaction: &Transaction
) -> RpcResult<RpcSimulateTransactionResult>

Simulates sending a transaction.

If the transaction fails, then the err field of the returned RpcSimulateTransactionResult will be Some. Any logs emitted from the transaction are returned in the logs field.

Simulating a transaction is similar to the “preflight check” that is run by default when sending a transaction.

By default, signatures are not verified during simulation. To verify signatures, call the simulate_transaction_with_config method, with the sig_verify field of RpcSimulateTransactionConfig set to true.

RPC Reference

This method is built on the simulateTransaction RPC method.

Examples

// Transfer lamports from Alice to Bob
let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let tx = system_transaction::transfer(&alice, &bob.pubkey(), lamports, recent_blockhash);
let result = rpc_client.simulate_transaction(&tx)?;
assert!(result.value.err.is_none());

pub fn simulate_transaction_with_config(
    &self,
    transaction: &Transaction,
    config: RpcSimulateTransactionConfig
) -> RpcResult<RpcSimulateTransactionResult>

Simulates sending a transaction.

If the transaction fails, then the err field of the returned RpcSimulateTransactionResult will be Some. Any logs emitted from the transaction are returned in the logs field.

Simulating a transaction is similar to the “preflight check” that is run by default when sending a transaction.

By default, signatures are not verified during simulation. To verify signatures, call the simulate_transaction_with_config method, with the sig_verify field of RpcSimulateTransactionConfig set to true.

This method can additionally query information about accounts by including them in the accounts field of the RpcSimulateTransactionConfig argument, in which case those results are reported in the accounts field of the returned RpcSimulateTransactionResult.

RPC Reference

This method is built on the simulateTransaction RPC method.

Examples

// Transfer lamports from Alice to Bob
let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let tx = system_transaction::transfer(&alice, &bob.pubkey(), lamports, recent_blockhash);
let config = RpcSimulateTransactionConfig {
    sig_verify: true,
    .. RpcSimulateTransactionConfig::default()
};
let result = rpc_client.simulate_transaction_with_config(
    &tx,
    config,
)?;
assert!(result.value.err.is_none());

pub fn get_snapshot_slot(&self) -> ClientResult<Slot>

Returns the highest slot that the node has a snapshot for.

RPC Reference

This method corresponds directly to the getSnapshotSlot RPC method.

Examples

let slot = rpc_client.get_snapshot_slot()?;

pub fn get_signature_status(
    &self,
    signature: &Signature
) -> ClientResult<Option<Result<()>>>

Check if a transaction has been processed with the default commitment level.

If the transaction has been processed with the default commitment level, then this method returns Ok of Some. If the transaction has not yet been processed with the default commitment level, it returns Ok of None.

If the transaction has been processed with the default commitment level, and the transaction succeeded, this method returns Ok(Some(Ok(()))). If the transaction has peen processed with the default commitment level, and the transaction failed, this method returns Ok(Some(Err(_))), where the interior error is type TransactionError.

This function only searches a node’s recent history, including all recent slots, plus up to [MAX_RECENT_BLOCKHASHES][solana_sdk::clock::MAX_RECENT_BLOCKHASHES] rooted slots. To search the full transaction history use the get_signature_statuse_with_commitment_and_history method.

RPC Reference

This method is built on the getSignatureStatuses RPC method.

Examples

let signature = rpc_client.send_transaction(&tx)?;
let status = rpc_client.get_signature_status(&signature)?;

pub fn get_signature_statuses(
    &self,
    signatures: &[Signature]
) -> RpcResult<Vec<Option<TransactionStatus>>>

Gets the statuses of a list of transaction signatures.

The returned vector of TransactionStatus has the same length as the input slice.

For any transaction that has not been processed by the network, the value of the corresponding entry in the returned vector is None. As a result, a transaction that has recently been submitted will not have a status immediately.

To submit a transaction and wait for it to confirm, use send_and_confirm_transaction.

This function ignores the configured confirmation level, and returns the transaction status whatever it is. It does not wait for transactions to be processed.

This function only searches a node’s recent history, including all recent slots, plus up to [MAX_RECENT_BLOCKHASHES][solana_sdk::clock::MAX_RECENT_BLOCKHASHES] rooted slots. To search the full transaction history use the get_signature_statuses_with_history method.

Errors

Any individual TransactionStatus may have triggered an error during processing, in which case its err field will be Some.

RPC Reference

This method corresponds directly to the getSignatureStatuses RPC method.

Examples

// Send lamports from Alice to Bob and wait for the transaction to be processed
let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let tx = system_transaction::transfer(&alice, &bob.pubkey(), lamports, recent_blockhash);
let signature = rpc_client.send_transaction(&tx)?;

let status = loop {
   let statuses = rpc_client.get_signature_statuses(&[signature])?.value;
   if let Some(status) = statuses[0].clone() {
       break status;
   }
   std::thread::sleep(Duration::from_millis(100));
};

assert!(status.err.is_none());

pub fn get_signature_statuses_with_history(
    &self,
    signatures: &[Signature]
) -> RpcResult<Vec<Option<TransactionStatus>>>

Gets the statuses of a list of transaction signatures.

The returned vector of TransactionStatus has the same length as the input slice.

For any transaction that has not been processed by the network, the value of the corresponding entry in the returned vector is None. As a result, a transaction that has recently been submitted will not have a status immediately.

To submit a transaction and wait for it to confirm, use send_and_confirm_transaction.

This function ignores the configured confirmation level, and returns the transaction status whatever it is. It does not wait for transactions to be processed.

This function searches a node’s full ledger history and (if implemented) long-term storage. To search for transactions in recent slots only use the get_signature_statuses method.

Errors

Any individual TransactionStatus may have triggered an error during processing, in which case its err field will be Some.

RPC Reference

This method corresponds directly to the getSignatureStatuses RPC method, with the searchTransactionHistory configuration option set to true.

Examples

// Check if an old transaction exists
let signature = get_old_transaction_signature();
let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let statuses = rpc_client.get_signature_statuses_with_history(&[signature])?.value;
if statuses[0].is_none() {
    println!("old transaction does not exist");
}

pub fn get_signature_status_with_commitment(
    &self,
    signature: &Signature,
    commitment_config: CommitmentConfig
) -> ClientResult<Option<Result<()>>>

Check if a transaction has been processed with the given commitment level.

If the transaction has been processed with the given commitment level, then this method returns Ok of Some. If the transaction has not yet been processed with the given commitment level, it returns Ok of None.

If the transaction has been processed with the given commitment level, and the transaction succeeded, this method returns Ok(Some(Ok(()))). If the transaction has peen processed with the given commitment level, and the transaction failed, this method returns Ok(Some(Err(_))), where the interior error is type TransactionError.

This function only searches a node’s recent history, including all recent slots, plus up to [MAX_RECENT_BLOCKHASHES][solana_sdk::clock::MAX_RECENT_BLOCKHASHES] rooted slots. To search the full transaction history use the get_signature_statuse_with_commitment_and_history method.

RPC Reference

This method is built on the getSignatureStatuses RPC method.

Examples

let signature = rpc_client.send_and_confirm_transaction(&tx)?;
let commitment_config = CommitmentConfig::processed();
let status = rpc_client.get_signature_status_with_commitment(
    &signature,
    commitment_config,
)?;

pub fn get_signature_status_with_commitment_and_history(
    &self,
    signature: &Signature,
    commitment_config: CommitmentConfig,
    search_transaction_history: bool
) -> ClientResult<Option<Result<()>>>

Check if a transaction has been processed with the given commitment level.

If the transaction has been processed with the given commitment level, then this method returns Ok of Some. If the transaction has not yet been processed with the given commitment level, it returns Ok of None.

If the transaction has been processed with the given commitment level, and the transaction succeeded, this method returns Ok(Some(Ok(()))). If the transaction has peen processed with the given commitment level, and the transaction failed, this method returns Ok(Some(Err(_))), where the interior error is type TransactionError.

This method optionally searches a node’s full ledger history and (if implemented) long-term storage.

RPC Reference

This method is built on the getSignatureStatuses RPC method.

Examples

let signature = rpc_client.send_transaction(&tx)?;
let commitment_config = CommitmentConfig::processed();
let search_transaction_history = true;
let status = rpc_client.get_signature_status_with_commitment_and_history(
    &signature,
    commitment_config,
    search_transaction_history,
)?;

pub fn get_slot(&self) -> ClientResult<Slot>

RPC Reference

This method corresponds directly to the getSlot RPC method.

Examples

let slot = rpc_client.get_slot()?;

pub fn get_slot_with_commitment(
    &self,
    commitment_config: CommitmentConfig
) -> ClientResult<Slot>

RPC Reference

This method is built on the getSlot RPC method.

Examples

let commitment_config = CommitmentConfig::processed();
let slot = rpc_client.get_slot_with_commitment(commitment_config)?;

pub fn get_block_height(&self) -> ClientResult<u64>

RPC Reference

This method is corresponds directly to the getBlockHeight RPC method.

Examples

let block_height = rpc_client.get_block_height()?;

pub fn get_block_height_with_commitment(
    &self,
    commitment_config: CommitmentConfig
) -> ClientResult<u64>

RPC Reference

This method is built on the getBlockHeight RPC method.

Examples

let commitment_config = CommitmentConfig::processed();
let block_height = rpc_client.get_block_height_with_commitment(
    commitment_config,
)?;

pub fn get_slot_leaders(
    &self,
    start_slot: Slot,
    limit: u64
) -> ClientResult<Vec<Pubkey>>

RPC Reference

This method corresponds directly to the getSlotLeaders RPC method.

Examples

let start_slot = 1;
let limit = 3;
let leaders = rpc_client.get_slot_leaders(start_slot, limit)?;

pub fn get_block_production(&self) -> RpcResult<RpcBlockProduction>

RPC Reference

This method corresponds directly to the getBlockProduction RPC method.

Get block production for the current epoch.

Examples

let production = rpc_client.get_block_production()?;

pub fn get_block_production_with_config(
    &self,
    config: RpcBlockProductionConfig
) -> RpcResult<RpcBlockProduction>

RPC Reference

This method is built on the getBlockProduction RPC method.

Examples

let leader = rpc_client.get_slot_leaders(start_slot, limit)?;
let leader = leader[0];
let range = RpcBlockProductionConfigRange {
    first_slot: 0,
    last_slot: Some(0),
};
let config = RpcBlockProductionConfig {
    identity: Some(leader.to_string()),
    range: Some(range),
    commitment: Some(CommitmentConfig::processed()),
};
let production = rpc_client.get_block_production_with_config(
    config
)?;

pub fn get_stake_activation(
    &self,
    stake_account: Pubkey,
    epoch: Option<Epoch>
) -> ClientResult<RpcStakeActivation>

RPC Reference

This method corresponds directly to the getStakeActivation RPC method.

Examples

// Find some vote account to delegate to
let vote_accounts = rpc_client.get_vote_accounts()?;
let vote_account = vote_accounts.current.get(0).unwrap_or_else(|| &vote_accounts.delinquent[0]);
let vote_account_pubkey = &vote_account.vote_pubkey;
let vote_account_pubkey = Pubkey::from_str(vote_account_pubkey).expect("pubkey");

// Create a stake account
let stake_account = Keypair::new();
let stake_account_pubkey = stake_account.pubkey();

// Build the instructions to create new stake account,
// funded by alice, and delegate to a validator's vote account.
let instrs = stake::instruction::create_account_and_delegate_stake(
    &alice.pubkey(),
    &stake_account_pubkey,
    &vote_account_pubkey,
    &Authorized::auto(&stake_account_pubkey),
    &Lockup::default(),
    1_000_000,
);

let (recent_blockhash, _) = rpc_client.get_recent_blockhash()?;
let tx = Transaction::new_signed_with_payer(
    &instrs,
    Some(&alice.pubkey()),
    &[&alice, &stake_account],
    recent_blockhash,
);

rpc_client.send_and_confirm_transaction(&tx)?;

let epoch_info = rpc_client.get_epoch_info()?;
let activation = rpc_client.get_stake_activation(
    stake_account_pubkey,
    Some(epoch_info.epoch),
)?;

assert_eq!(activation.state, StakeActivationState::Activating);

pub fn supply(&self) -> RpcResult<RpcSupply>

RPC Reference

This method corresponds directly to the getSupply RPC method.

Examples

let supply = rpc_client.supply()?;

pub fn supply_with_commitment(
    &self,
    commitment_config: CommitmentConfig
) -> RpcResult<RpcSupply>

RPC Reference

This method corresponds directly to the getSupply RPC method.

Examples

let commitment_config = CommitmentConfig::processed();
let supply = rpc_client.supply_with_commitment(
    commitment_config,
)?;

pub fn get_largest_accounts_with_config(
    &self,
    config: RpcLargestAccountsConfig
) -> RpcResult<Vec<RpcAccountBalance>>

RPC Reference

This method corresponds directly to the getLargestAccounts RPC method.

Examples

let commitment_config = CommitmentConfig::processed();
let config = RpcLargestAccountsConfig {
    commitment: Some(commitment_config),
    filter: Some(RpcLargestAccountsFilter::Circulating),
};
let accounts = rpc_client.get_largest_accounts_with_config(
    config,
)?;

pub fn get_vote_accounts(&self) -> ClientResult<RpcVoteAccountStatus>

RPC Reference

This method corresponds directly to the getVoteAccounts RPC method.

Examples

let accounts = rpc_client.get_vote_accounts()?;

pub fn get_vote_accounts_with_commitment(
    &self,
    commitment_config: CommitmentConfig
) -> ClientResult<RpcVoteAccountStatus>

RPC Reference

This method corresponds directly to the getVoteAccounts RPC method.

Examples

let commitment_config = CommitmentConfig::processed();
let accounts = rpc_client.get_vote_accounts_with_commitment(
    commitment_config,
)?;

pub fn get_vote_accounts_with_config(
    &self,
    config: RpcGetVoteAccountsConfig
) -> ClientResult<RpcVoteAccountStatus>

RPC Reference

This method corresponds directly to the getVoteAccounts RPC method with the Commitment option set to processed, the votePubkey option set to new-generated vote_pubkey, the keepUnstakedDelinquents option set to true, the delinquentSlotDistance option set to 10

Examples

let vote_pubkey = vote_keypair.pubkey();
let commitment = CommitmentConfig::processed();
let config = RpcGetVoteAccountsConfig {
    vote_pubkey: Some(vote_pubkey.to_string()),
    commitment: Some(commitment),
    keep_unstaked_delinquents: Some(true),
    delinquent_slot_distance: Some(10),
};
let accounts = rpc_client.get_vote_accounts_with_config(
    config,
)?;

pub fn wait_for_max_stake(
    &self,
    commitment: CommitmentConfig,
    max_stake_percent: f32
) -> ClientResult<()>

pub fn get_cluster_nodes(&self) -> ClientResult<Vec<RpcContactInfo>>

RPC Reference

This method corresponds directly to the getClusterNodes RPC method.

Examples

let cluster_nodes = rpc_client.get_cluster_nodes()?;

pub fn get_block(&self, slot: Slot) -> ClientResult<EncodedConfirmedBlock>

RPC Reference

This method corresponds directly to the getBlock RPC method.

Examples

let block = rpc_client.get_block(slot)?;

pub fn get_block_with_encoding(
    &self,
    slot: Slot,
    encoding: UiTransactionEncoding
) -> ClientResult<EncodedConfirmedBlock>

RPC Reference

This method is built on the getBlock RPC method.

Examples

let encoding = UiTransactionEncoding::Base58;
let block = rpc_client.get_block_with_encoding(
    slot,
    encoding,
)?;

pub fn get_block_with_config(
    &self,
    slot: Slot,
    config: RpcBlockConfig
) -> ClientResult<UiConfirmedBlock>

RPC Reference

This method is built on the getBlock RPC method.

Examples

let config = RpcBlockConfig {
    encoding: Some(UiTransactionEncoding::Base58),
    transaction_details: Some(TransactionDetails::None),
    rewards: Some(true),
    commitment: None,
};
let block = rpc_client.get_block_with_config(
    slot,
    config,
)?;

pub fn get_confirmed_block(
    &self,
    slot: Slot
) -> ClientResult<EncodedConfirmedBlock>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_block() instead

pub fn get_confirmed_block_with_encoding(
    &self,
    slot: Slot,
    encoding: UiTransactionEncoding
) -> ClientResult<EncodedConfirmedBlock>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_block_with_encoding() instead

pub fn get_confirmed_block_with_config(
    &self,
    slot: Slot,
    config: RpcConfirmedBlockConfig
) -> ClientResult<UiConfirmedBlock>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_block_with_config() instead

pub fn get_blocks(
    &self,
    start_slot: Slot,
    end_slot: Option<Slot>
) -> ClientResult<Vec<Slot>>

RPC Reference

This method corresponds directly to the getBlocks RPC method.

Examples

let blocks = rpc_client.get_blocks(start_slot, Some(end_slot))?;

pub fn get_blocks_with_commitment(
    &self,
    start_slot: Slot,
    end_slot: Option<Slot>,
    commitment_config: CommitmentConfig
) -> ClientResult<Vec<Slot>>

RPC Reference

This method is built on the getBlocks RPC method.

Examples

// Method does not support commitment below `confirmed`
let commitment_config = CommitmentConfig::confirmed();
let blocks = rpc_client.get_blocks_with_commitment(
    start_slot,
    Some(end_slot),
    commitment_config,
)?;

pub fn get_blocks_with_limit(
    &self,
    start_slot: Slot,
    limit: usize
) -> ClientResult<Vec<Slot>>

RPC Reference

This method corresponds directly to the getBlocksWithLimit RPC method.

Examples

let limit = 3;
let blocks = rpc_client.get_blocks_with_limit(start_slot, limit)?;

pub fn get_blocks_with_limit_and_commitment(
    &self,
    start_slot: Slot,
    limit: usize,
    commitment_config: CommitmentConfig
) -> ClientResult<Vec<Slot>>

RPC Reference

This method is built on the getBlocksWithLimit RPC method.

Examples

let limit = 3;
let commitment_config = CommitmentConfig::confirmed();
let blocks = rpc_client.get_blocks_with_limit_and_commitment(
    start_slot,
    limit,
    commitment_config,
)?;

pub fn get_confirmed_blocks(
    &self,
    start_slot: Slot,
    end_slot: Option<Slot>
) -> ClientResult<Vec<Slot>>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_blocks() instead

pub fn get_confirmed_blocks_with_commitment(
    &self,
    start_slot: Slot,
    end_slot: Option<Slot>,
    commitment_config: CommitmentConfig
) -> ClientResult<Vec<Slot>>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_blocks_with_commitment() instead

pub fn get_confirmed_blocks_with_limit(
    &self,
    start_slot: Slot,
    limit: usize
) -> ClientResult<Vec<Slot>>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_blocks_with_limit() instead

pub fn get_confirmed_blocks_with_limit_and_commitment(
    &self,
    start_slot: Slot,
    limit: usize,
    commitment_config: CommitmentConfig
) -> ClientResult<Vec<Slot>>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_blocks_with_limit_and_commitment() instead

pub fn get_signatures_for_address(
    &self,
    address: &Pubkey
) -> ClientResult<Vec<RpcConfirmedTransactionStatusWithSignature>>

RPC Reference

This method corresponds directly to the getSignaturesForAddress RPC method.

Examples

let signatures = rpc_client.get_signatures_for_address(
    &alice.pubkey(),
)?;

pub fn get_signatures_for_address_with_config(
    &self,
    address: &Pubkey,
    config: GetConfirmedSignaturesForAddress2Config
) -> ClientResult<Vec<RpcConfirmedTransactionStatusWithSignature>>

RPC Reference

This method is built on the getSignaturesForAddress RPC method.

Examples

let config = GetConfirmedSignaturesForAddress2Config {
    before: None,
    until: None,
    limit: Some(3),
    commitment: Some(CommitmentConfig::confirmed()),
};
let signatures = rpc_client.get_signatures_for_address_with_config(
    &alice.pubkey(),
    config,
)?;

pub fn get_confirmed_signatures_for_address2(
    &self,
    address: &Pubkey
) -> ClientResult<Vec<RpcConfirmedTransactionStatusWithSignature>>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_signatures_for_address() instead

pub fn get_confirmed_signatures_for_address2_with_config(
    &self,
    address: &Pubkey,
    config: GetConfirmedSignaturesForAddress2Config
) -> ClientResult<Vec<RpcConfirmedTransactionStatusWithSignature>>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_signatures_for_address_with_config() instead

pub fn get_transaction(
    &self,
    signature: &Signature,
    encoding: UiTransactionEncoding
) -> ClientResult<EncodedConfirmedTransaction>

RPC Reference

This method corresponds directly to the getTransaction RPC method.

Examples

let signature = rpc_client.send_and_confirm_transaction(&tx)?;

let transaction = rpc_client.get_transaction(
    &signature,
    UiTransactionEncoding::Json,
)?;

pub fn get_transaction_with_config(
    &self,
    signature: &Signature,
    config: RpcTransactionConfig
) -> ClientResult<EncodedConfirmedTransaction>

RPC Reference

This method is built on the getTransaction RPC method.

Examples

let signature = rpc_client.send_and_confirm_transaction(&tx)?;
let config = RpcTransactionConfig {
    encoding: Some(UiTransactionEncoding::Json),
    commitment: Some(CommitmentConfig::confirmed()),
};

let transaction = rpc_client.get_transaction_with_config(
    &signature,
    config,
)?;

pub fn get_confirmed_transaction(
    &self,
    signature: &Signature,
    encoding: UiTransactionEncoding
) -> ClientResult<EncodedConfirmedTransaction>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_transaction() instead

pub fn get_confirmed_transaction_with_config(
    &self,
    signature: &Signature,
    config: RpcConfirmedTransactionConfig
) -> ClientResult<EncodedConfirmedTransaction>

👎 Deprecated since 1.7.0:

Please use RpcClient::get_transaction_with_config() instead

pub fn get_block_time(&self, slot: Slot) -> ClientResult<UnixTimestamp>

RPC Reference

This method corresponds directly to the getBlockTime RPC method.

Examples

let block_time = rpc_client.get_block_time(slot)?;

pub fn get_epoch_info(&self) -> ClientResult<EpochInfo>

RPC Reference

This method corresponds directly to the getEpochInfo RPC method.

Examples

let epoch_info = rpc_client.get_epoch_info()?;

pub fn get_epoch_info_with_commitment(
    &self,
    commitment_config: CommitmentConfig
) -> ClientResult<EpochInfo>

RPC Reference

This method is built on the getEpochInfo RPC method.

Examples

let commitment_config = CommitmentConfig::confirmed();
let epoch_info = rpc_client.get_epoch_info_with_commitment(
    commitment_config,
)?;

pub fn get_leader_schedule(
    &self,
    slot: Option<Slot>
) -> ClientResult<Option<RpcLeaderSchedule>>

RPC Reference

This method corresponds directly to the getLeaderSchedule RPC method.

Examples

let leader_schedule = rpc_client.get_leader_schedule(
    Some(slot),
)?;

pub fn get_leader_schedule_with_commitment(
    &self,
    slot: Option<Slot>,
    commitment_config: CommitmentConfig
) -> ClientResult<Option<RpcLeaderSchedule>>

RPC Reference

This method is built on the getLeaderSchedule RPC method.

Examples

let commitment_config = CommitmentConfig::processed();
let leader_schedule = rpc_client.get_leader_schedule_with_commitment(
    Some(slot),
    commitment_config,
)?;

pub fn get_leader_schedule_with_config(
    &self,
    slot: Option<Slot>,
    config: RpcLeaderScheduleConfig
) -> ClientResult<Option<RpcLeaderSchedule>>

RPC Reference

This method is built on the getLeaderSchedule RPC method.

Examples

let config = RpcLeaderScheduleConfig {
    identity: Some(validator_pubkey_str),
    commitment: Some(CommitmentConfig::processed()),
};
let leader_schedule = rpc_client.get_leader_schedule_with_config(
    Some(slot),
    config,
)?;

pub fn get_epoch_schedule(&self) -> ClientResult<EpochSchedule>

RPC Reference

This method corresponds directly to the getEpochSchedule RPC method.

Examples

let epoch_schedule = rpc_client.get_epoch_schedule()?;

pub fn get_recent_performance_samples(
    &self,
    limit: Option<usize>
) -> ClientResult<Vec<RpcPerfSample>>

RPC Reference

This method corresponds directly to the getRecentPerformanceSamples RPC method.

Examples

let limit = Some(10);
let performance_samples = rpc_client.get_recent_performance_samples(
    limit,
)?;

pub fn get_identity(&self) -> ClientResult<Pubkey>

pub fn get_inflation_governor(&self) -> ClientResult<RpcInflationGovernor>

pub fn get_inflation_rate(&self) -> ClientResult<RpcInflationRate>

pub fn get_inflation_reward(
    &self,
    addresses: &[Pubkey],
    epoch: Option<Epoch>
) -> ClientResult<Vec<Option<RpcInflationReward>>>

pub fn get_version(&self) -> ClientResult<RpcVersionInfo>

pub fn minimum_ledger_slot(&self) -> ClientResult<Slot>

pub fn send_and_confirm_transaction(
    &self,
    transaction: &Transaction
) -> ClientResult<Signature>

pub fn get_account(&self, pubkey: &Pubkey) -> ClientResult<Account>

Note that get_account returns Err(..) if the account does not exist whereas get_account_with_commitment returns Ok(None) if the account does not exist.

pub fn get_account_with_commitment(
    &self,
    pubkey: &Pubkey,
    commitment_config: CommitmentConfig
) -> RpcResult<Option<Account>>

pub fn get_max_retransmit_slot(&self) -> ClientResult<Slot>

pub fn get_max_shred_insert_slot(&self) -> ClientResult<Slot>

pub fn get_multiple_accounts(
    &self,
    pubkeys: &[Pubkey]
) -> ClientResult<Vec<Option<Account>>>

pub fn get_multiple_accounts_with_commitment(
    &self,
    pubkeys: &[Pubkey],
    commitment_config: CommitmentConfig
) -> RpcResult<Vec<Option<Account>>>

pub fn get_multiple_accounts_with_config(
    &self,
    pubkeys: &[Pubkey],
    config: RpcAccountInfoConfig
) -> RpcResult<Vec<Option<Account>>>

pub fn get_account_data(&self, pubkey: &Pubkey) -> ClientResult<Vec<u8>>

pub fn get_minimum_balance_for_rent_exemption(
    &self,
    data_len: usize
) -> ClientResult<u64>

pub fn get_balance(&self, pubkey: &Pubkey) -> ClientResult<u64>

Request the balance of the account pubkey.

pub fn get_balance_with_commitment(
    &self,
    pubkey: &Pubkey,
    commitment_config: CommitmentConfig
) -> RpcResult<u64>

pub fn get_program_accounts(
    &self,
    pubkey: &Pubkey
) -> ClientResult<Vec<(Pubkey, Account)>>

pub fn get_program_accounts_with_config(
    &self,
    pubkey: &Pubkey,
    config: RpcProgramAccountsConfig
) -> ClientResult<Vec<(Pubkey, Account)>>

pub fn get_transaction_count(&self) -> ClientResult<u64>

Request the transaction count.

pub fn get_transaction_count_with_commitment(
    &self,
    commitment_config: CommitmentConfig
) -> ClientResult<u64>

pub fn get_fees(&self) -> ClientResult<Fees>

pub fn get_fees_with_commitment(
    &self,
    commitment_config: CommitmentConfig
) -> RpcResult<Fees>

pub fn get_recent_blockhash(&self) -> ClientResult<(Hash, FeeCalculator)>

pub fn get_recent_blockhash_with_commitment(
    &self,
    commitment_config: CommitmentConfig
) -> RpcResult<(Hash, FeeCalculator, Slot)>

pub fn get_fee_calculator_for_blockhash(
    &self,
    blockhash: &Hash
) -> ClientResult<Option<FeeCalculator>>

pub fn get_fee_calculator_for_blockhash_with_commitment(
    &self,
    blockhash: &Hash,
    commitment_config: CommitmentConfig
) -> RpcResult<Option<FeeCalculator>>

pub fn get_fee_rate_governor(&self) -> RpcResult<FeeRateGovernor>

pub fn get_new_blockhash(
    &self,
    blockhash: &Hash
) -> ClientResult<(Hash, FeeCalculator)>

pub fn get_first_available_block(&self) -> ClientResult<Slot>

pub fn get_genesis_hash(&self) -> ClientResult<Hash>

pub fn get_health(&self) -> ClientResult<()>

pub fn get_token_account(
    &self,
    pubkey: &Pubkey
) -> ClientResult<Option<UiTokenAccount>>

pub fn get_token_account_with_commitment(
    &self,
    pubkey: &Pubkey,
    commitment_config: CommitmentConfig
) -> RpcResult<Option<UiTokenAccount>>

pub fn get_token_account_balance(
    &self,
    pubkey: &Pubkey
) -> ClientResult<UiTokenAmount>

pub fn get_token_account_balance_with_commitment(
    &self,
    pubkey: &Pubkey,
    commitment_config: CommitmentConfig
) -> RpcResult<UiTokenAmount>

pub fn get_token_accounts_by_delegate(
    &self,
    delegate: &Pubkey,
    token_account_filter: TokenAccountsFilter
) -> ClientResult<Vec<RpcKeyedAccount>>

pub fn get_token_accounts_by_delegate_with_commitment(
    &self,
    delegate: &Pubkey,
    token_account_filter: TokenAccountsFilter,
    commitment_config: CommitmentConfig
) -> RpcResult<Vec<RpcKeyedAccount>>

pub fn get_token_accounts_by_owner(
    &self,
    owner: &Pubkey,
    token_account_filter: TokenAccountsFilter
) -> ClientResult<Vec<RpcKeyedAccount>>

pub fn get_token_accounts_by_owner_with_commitment(
    &self,
    owner: &Pubkey,
    token_account_filter: TokenAccountsFilter,
    commitment_config: CommitmentConfig
) -> RpcResult<Vec<RpcKeyedAccount>>

pub fn get_token_supply(&self, mint: &Pubkey) -> ClientResult<UiTokenAmount>

pub fn get_token_supply_with_commitment(
    &self,
    mint: &Pubkey,
    commitment_config: CommitmentConfig
) -> RpcResult<UiTokenAmount>

pub fn request_airdrop(
    &self,
    pubkey: &Pubkey,
    lamports: u64
) -> ClientResult<Signature>

pub fn request_airdrop_with_blockhash(
    &self,
    pubkey: &Pubkey,
    lamports: u64,
    recent_blockhash: &Hash
) -> ClientResult<Signature>

pub fn request_airdrop_with_config(
    &self,
    pubkey: &Pubkey,
    lamports: u64,
    config: RpcRequestAirdropConfig
) -> ClientResult<Signature>

pub fn poll_get_balance_with_commitment(
    &self,
    pubkey: &Pubkey,
    commitment_config: CommitmentConfig
) -> ClientResult<u64>

pub fn wait_for_balance_with_commitment(
    &self,
    pubkey: &Pubkey,
    expected_balance: Option<u64>,
    commitment_config: CommitmentConfig
) -> Option<u64>

pub fn poll_for_signature(&self, signature: &Signature) -> ClientResult<()>

Poll the server to confirm a transaction.

pub fn poll_for_signature_with_commitment(
    &self,
    signature: &Signature,
    commitment_config: CommitmentConfig
) -> ClientResult<()>

Poll the server to confirm a transaction.

pub fn poll_for_signature_confirmation(
    &self,
    signature: &Signature,
    min_confirmed_blocks: usize
) -> ClientResult<usize>

Poll the server to confirm a transaction.

pub fn get_num_blocks_since_signature_confirmation(
    &self,
    signature: &Signature
) -> ClientResult<usize>

pub fn send_and_confirm_transaction_with_spinner(
    &self,
    transaction: &Transaction
) -> ClientResult<Signature>

pub fn send_and_confirm_transaction_with_spinner_and_commitment(
    &self,
    transaction: &Transaction,
    commitment: CommitmentConfig
) -> ClientResult<Signature>

pub fn send_and_confirm_transaction_with_spinner_and_config(
    &self,
    transaction: &Transaction,
    commitment: CommitmentConfig,
    config: RpcSendTransactionConfig
) -> ClientResult<Signature>

pub fn confirm_transaction_with_spinner(
    &self,
    signature: &Signature,
    recent_blockhash: &Hash,
    commitment: CommitmentConfig
) -> ClientResult<()>

pub fn send<T>(&self, request: RpcRequest, params: Value) -> ClientResult<T> where
    T: DeserializeOwned, 

pub fn get_transport_stats(&self) -> RpcTransportStats