Struct DydxGrpcClient 

pub struct DydxGrpcClient { /* private fields */ }

gRPC client for dYdX v4 protocol operations.

This client handles:

• Transaction signing and broadcasting.
• Account query operations.
• Order placement and management via Cosmos SDK messages.
• Connection management and automatic failover to fallback nodes.

Implementations

impl DydxGrpcClient

pub async fn new(grpc_url: String) -> Result<Self, DydxError>

Create a new gRPC client with a single URL.

Errors

Returns an error if the gRPC connection cannot be established.

pub async fn new_with_fallback( grpc_urls: &[impl AsRef<str>], ) -> Result<Self, DydxError>

Create a new gRPC client with fallback support.

Attempts to connect to each URL in the provided list until a successful connection is established. This is useful for DEX environments where nodes can fail and fallback options are needed.

Errors

Returns an error if none of the provided URLs can establish a connection.

pub async fn reconnect_with_fallback( &mut self, grpc_urls: &[impl AsRef<str>], ) -> Result<(), DydxError>

Reconnect to a different gRPC node from the fallback list.

Attempts to establish a new connection to each URL in the provided list until successful. This is useful when the current node fails and you need to failover to a different validator node.

Errors

Returns an error if none of the provided URLs can establish a connection.

pub fn current_url(&self) -> &str

Get the currently connected gRPC node URL.

pub fn channel(&self) -> &Channel

Get the underlying gRPC channel.

This can be used to create custom gRPC service clients.

pub async fn query_address( &mut self, address: &str, ) -> Result<(u64, u64), Error>

Query account information for a given address.

Returns the account number and sequence number needed for transaction signing.

Errors

Returns an error if the query fails or the account does not exist.

pub async fn get_account(&mut self, address: &str) -> Result<BaseAccount, Error>

Query for an account by its address.

Errors

Returns an error if the query fails or the account does not exist.

pub async fn get_account_balances( &mut self, address: &str, ) -> Result<Vec<Coin>, Error>

Query for account balances by address for all denominations.

Errors

Returns an error if the query fails.

pub async fn get_node_info(&mut self) -> Result<GetNodeInfoResponse, Error>

Query for node info.

Errors

Returns an error if the query fails.

pub async fn latest_block(&mut self) -> Result<Block, Error>

Query for the latest block.

Errors

Returns an error if the query fails.

pub async fn latest_block_height(&mut self) -> Result<Height, Error>

Query for the latest block height.

Errors

Returns an error if the query fails.

pub async fn get_perpetuals(&mut self) -> Result<Vec<Perpetual>, Error>

Query for all perpetual markets.

Errors

Returns an error if the query fails.

pub async fn get_clob_pairs(&mut self) -> Result<Vec<ClobPair>, Error>

Query for all CLOB pairs.

Errors

Returns an error if the query fails.

pub async fn get_subaccount( &mut self, address: &str, number: u32, ) -> Result<SubaccountInfo, Error>

Query for subaccount information.

Errors

Returns an error if the query fails.

pub async fn simulate_tx(&mut self, tx_bytes: Vec<u8>) -> Result<u64, Error>

Simulate a transaction to estimate gas usage.

Errors

Returns an error if simulation fails.

pub async fn broadcast_tx(&mut self, tx_bytes: Vec<u8>) -> Result<TxHash, Error>

Broadcast a signed transaction.

Errors

Returns an error if broadcasting fails.

pub async fn get_tx(&mut self, hash: &str) -> Result<Tx, Error>

Query transaction by hash.

Errors

Returns an error if the query fails.

Trait Implementations

impl Clone for DydxGrpcClient

fn clone(&self) -> DydxGrpcClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DydxGrpcClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.