Struct RateLimitedClient 

pub struct RateLimitedClient<C> { /* private fields */ }

A rate-limited wrapper around any KrakenClient implementation.

This wrapper automatically handles:

• Public endpoint rate limits (sliding window)
• Private endpoint rate limits (token bucket, tier-based)
• Trading rate limits with order lifetime penalties

Example

use kraken_api_client::spot::rest::SpotRestClient;
use kraken_api_client::rate_limit::{RateLimitedClient, RateLimitConfig};

let client = SpotRestClient::new();
let rate_limited = RateLimitedClient::new(client, RateLimitConfig::default());

// Requests are automatically rate limited
let time = rate_limited.get_server_time().await?;

Implementations

impl<C> RateLimitedClient<C>

pub fn new(inner: C, config: RateLimitConfig) -> Self

Create a new rate-limited client wrapper.

pub fn with_tier(inner: C, tier: VerificationTier) -> Self

Create a new rate-limited client with a specific verification tier.

pub fn inner(&self) -> &C

Get a reference to the inner client.

pub fn config(&self) -> &RateLimitConfig

Get the current configuration.

pub fn set_enabled(&mut self, enabled: bool)

Enable or disable rate limiting.

Trait Implementations

impl<C: Clone> Clone for RateLimitedClient<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for RateLimitedClient<C>

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

Formats the value using the given formatter.

impl<C: KrakenClient> KrakenClient for RateLimitedClient<C>

async fn get_server_time(&self) -> Result<ServerTime, KrakenError>

Get the server time.

async fn get_system_status(&self) -> Result<SystemStatus, KrakenError>

Get the system status.

async fn get_assets( &self, request: Option<&AssetInfoRequest>, ) -> Result<HashMap<String, AssetInfo>, KrakenError>

Get asset information.

async fn get_asset_pairs( &self, request: Option<&AssetPairsRequest>, ) -> Result<HashMap<String, AssetPair>, KrakenError>

Get tradable asset pairs.

async fn get_ticker( &self, pairs: &str, ) -> Result<HashMap<String, TickerInfo>, KrakenError>

Get ticker information for one or more pairs.

async fn get_ohlc( &self, request: &OhlcRequest, ) -> Result<OhlcResponse, KrakenError>

Get OHLC (candlestick) data.

async fn get_order_book( &self, request: &OrderBookRequest, ) -> Result<HashMap<String, OrderBook>, KrakenError>

Get order book for a pair.

async fn get_recent_trades( &self, request: &RecentTradesRequest, ) -> Result<RecentTradesResponse, KrakenError>

Get recent trades for a pair.

async fn get_recent_spreads( &self, request: &RecentSpreadsRequest, ) -> Result<RecentSpreadsResponse, KrakenError>

Get recent spreads for a pair.

async fn get_account_balance( &self, ) -> Result<HashMap<String, Decimal>, KrakenError>

Get account balance.

async fn get_extended_balance(&self) -> Result<ExtendedBalances, KrakenError>

Get extended balance with hold amounts.

async fn get_trade_balance( &self, request: Option<&TradeBalanceRequest>, ) -> Result<TradeBalance, KrakenError>

Get trade balance (margin account details).

async fn get_open_orders( &self, request: Option<&OpenOrdersRequest>, ) -> Result<OpenOrders, KrakenError>

Get open orders.

async fn get_closed_orders( &self, request: Option<&ClosedOrdersRequest>, ) -> Result<ClosedOrders, KrakenError>

Get closed orders.

async fn query_orders( &self, request: &QueryOrdersRequest, ) -> Result<HashMap<String, Order>, KrakenError>

Query specific orders by ID.

async fn get_trades_history( &self, request: Option<&TradesHistoryRequest>, ) -> Result<TradesHistory, KrakenError>

Get trades history.

async fn get_open_positions( &self, request: Option<&OpenPositionsRequest>, ) -> Result<HashMap<String, Position>, KrakenError>

Get open positions.

async fn get_ledgers( &self, request: Option<&LedgersRequest>, ) -> Result<LedgersInfo, KrakenError>

Get ledger entries.

async fn get_trade_volume( &self, request: Option<&TradeVolumeRequest>, ) -> Result<TradeVolume, KrakenError>

Get trade volume and fee info.

async fn get_deposit_methods( &self, request: &DepositMethodsRequest, ) -> Result<Vec<DepositMethod>, KrakenError>

Get available deposit methods.

async fn get_deposit_addresses( &self, request: &DepositAddressesRequest, ) -> Result<Vec<DepositAddress>, KrakenError>

Get deposit addresses.

async fn get_deposit_status( &self, request: Option<&DepositStatusRequest>, ) -> Result<DepositWithdrawStatusResponse, KrakenError>

Get deposit status.

async fn get_withdraw_methods( &self, request: Option<&WithdrawMethodsRequest>, ) -> Result<Vec<WithdrawMethod>, KrakenError>

Get available withdrawal methods.

async fn get_withdraw_addresses( &self, request: Option<&WithdrawAddressesRequest>, ) -> Result<Vec<WithdrawalAddress>, KrakenError>

Get withdrawal addresses.

async fn get_withdraw_info( &self, request: &WithdrawInfoRequest, ) -> Result<WithdrawInfo, KrakenError>

Get withdrawal info.

async fn withdraw_funds( &self, request: &WithdrawRequest, ) -> Result<ConfirmationRefId, KrakenError>

Withdraw funds.

async fn get_withdraw_status( &self, request: Option<&WithdrawStatusRequest>, ) -> Result<DepositWithdrawStatusResponse, KrakenError>

Get withdrawal status.

async fn withdraw_cancel( &self, request: &WithdrawCancelRequest, ) -> Result<bool, KrakenError>

Cancel a withdrawal.

async fn wallet_transfer( &self, request: &WalletTransferRequest, ) -> Result<ConfirmationRefId, KrakenError>

Transfer funds between wallets.

async fn earn_allocate( &self, request: &EarnAllocateRequest, ) -> Result<bool, KrakenError>

Allocate funds to an earn strategy.

async fn earn_deallocate( &self, request: &EarnAllocateRequest, ) -> Result<bool, KrakenError>

Deallocate funds from an earn strategy.

async fn get_earn_allocation_status( &self, request: &EarnAllocationStatusRequest, ) -> Result<AllocationStatus, KrakenError>

Get earn allocation status.

async fn get_earn_deallocation_status( &self, request: &EarnAllocationStatusRequest, ) -> Result<AllocationStatus, KrakenError>

Get earn deallocation status.

async fn list_earn_strategies( &self, request: Option<&EarnStrategiesRequest>, ) -> Result<EarnStrategies, KrakenError>

List earn strategies.

async fn list_earn_allocations( &self, request: Option<&EarnAllocationsRequest>, ) -> Result<EarnAllocations, KrakenError>

List earn allocations.

async fn add_order( &self, request: &AddOrderRequest, ) -> Result<AddOrderResponse, KrakenError>

Add a new order.

async fn cancel_order( &self, request: &CancelOrderRequest, ) -> Result<CancelOrderResponse, KrakenError>

Cancel an order.

async fn cancel_all_orders(&self) -> Result<CancelOrderResponse, KrakenError>

Cancel all open orders.

async fn get_websocket_token(&self) -> Result<WebSocketToken, KrakenError>

Get a WebSocket authentication token.