Struct CoinbaseRawHttpClient 

pub struct CoinbaseRawHttpClient { /* private fields */ }

Provides a raw HTTP client for low-level Coinbase Advanced Trade REST API operations.

Handles JWT authentication, request construction, and response parsing. Each request generates a fresh ES256 JWT for authentication.

Implementations

impl CoinbaseRawHttpClient

pub fn new( environment: CoinbaseEnvironment, timeout_secs: u64, proxy_url: Option<String>, retry_config: Option<RetryConfig>, ) -> Result<Self, HttpClientError>

Creates a new CoinbaseRawHttpClient for public endpoints only.

Errors

Returns an error if the HTTP client cannot be created.

pub fn with_credentials( credential: CoinbaseCredential, environment: CoinbaseEnvironment, timeout_secs: u64, proxy_url: Option<String>, retry_config: Option<RetryConfig>, ) -> Result<Self, HttpClientError>

Creates a new CoinbaseRawHttpClient with credentials for authenticated requests.

Errors

Returns an error if the HTTP client cannot be created.

pub fn from_env(environment: CoinbaseEnvironment) -> Result<Self>

Creates an authenticated client from environment variables.

Errors

Returns Error::Auth if required environment variables are not set.

pub fn from_credentials( api_key: &str, api_secret: &str, environment: CoinbaseEnvironment, timeout_secs: u64, proxy_url: Option<String>, retry_config: Option<RetryConfig>, ) -> Result<Self>

Creates a new CoinbaseRawHttpClient with explicit credentials.

Errors

Returns Error::Auth if credentials are invalid.

pub fn cancellation_token(&self) -> &CancellationToken

Returns the cancellation token shared by in-flight requests.

pub fn set_base_url(&self, url: String)

Overrides the base REST URL (for testing with mock servers).

Lock-free; safe to call after the client has been cloned.

pub fn environment(&self) -> CoinbaseEnvironment

Returns the configured environment.

pub fn is_authenticated(&self) -> bool

Returns true if this client has credentials for authenticated requests.

pub async fn get_public(&self, path: &str) -> Result<Value>

Sends a GET request to a public endpoint (no auth required).

pub async fn get_public_with_query( &self, path: &str, query: &str, ) -> Result<Value>

Sends a GET request with query parameters to a public endpoint.

pub async fn get(&self, path: &str) -> Result<Value>

Sends an authenticated GET request.

pub async fn get_with_query(&self, path: &str, query: &str) -> Result<Value>

Sends an authenticated GET request with query parameters appended to the path.

The JWT URI claim covers only {METHOD} {host}{path} without the query string, matching the Coinbase SDK convention. Query parameters are appended to the URL but excluded from the signing input.

pub async fn post(&self, path: &str, body: &Value) -> Result<Value>

Sends an authenticated POST request with a JSON body.

pub async fn delete(&self, path: &str) -> Result<Value>

Sends an authenticated DELETE request.

pub async fn get_products(&self) -> Result<Value>

Gets all available products via the public /market/products endpoint.

pub async fn get_product(&self, product_id: &str) -> Result<Value>

Gets a specific product by ID via the public endpoint.

pub async fn get_candles( &self, product_id: &str, start: &str, end: &str, granularity: &str, ) -> Result<Value>

Gets candles for a product via the public endpoint.

pub async fn get_market_trades( &self, product_id: &str, limit: u32, ) -> Result<Value>

Gets market trades for a product via the public endpoint.

pub async fn get_best_bid_ask(&self, product_ids: &[&str]) -> Result<Value>

Gets best bid/ask for one or more products.

No public /market/ equivalent exists for this endpoint; requires authentication.

pub async fn get_product_book( &self, product_id: &str, limit: Option<u32>, ) -> Result<Value>

Gets the product order book via the public endpoint.

pub async fn get_accounts(&self) -> Result<Value>

Gets all accounts.

pub async fn get_accounts_with_query(&self, query: &str) -> Result<Value>

Gets accounts with a query string (for pagination via cursor / limit).

pub async fn get_account(&self, account_id: &str) -> Result<Value>

Gets a specific account by UUID.

pub async fn get_portfolios(&self) -> Result<Value>

Lists all portfolios visible to the authenticated key.

pub async fn get_orders(&self, query: &str) -> Result<Value>

Gets historical orders.

pub async fn get_order(&self, order_id: &str) -> Result<Value>

Gets a specific order by ID.

pub async fn get_fills(&self, query: &str) -> Result<Value>

Gets fills (trade executions).

pub async fn get_transaction_summary(&self) -> Result<Value>

Gets fee transaction summary.

pub async fn get_cfm_balance_summary(&self) -> Result<CfmBalanceSummaryResponse>

Gets the CFM (Coinbase Financial Markets) futures balance summary.

References

• https://docs.cdp.coinbase.com/api-reference/advanced-trade-api/rest-api/perpetuals/get-fcm-balance-summary

pub async fn get_cfm_positions(&self) -> Result<CfmPositionsResponse>

Gets all CFM futures positions for the account.

References

• https://docs.cdp.coinbase.com/api-reference/advanced-trade-api/rest-api/perpetuals/get-fcm-positions

pub async fn get_cfm_position( &self, product_id: &str, ) -> Result<CfmPositionResponse>

Gets a single CFM futures position by product ID.

References

• https://docs.cdp.coinbase.com/api-reference/advanced-trade-api/rest-api/perpetuals/get-fcm-position

pub async fn fetch_all_accounts(&self) -> Result<Vec<Account>>

Fetches every account, following Coinbase’s cursor pagination.

Returns the deserialized Account vector. Domain callers compose this with parse_account_state to build a Nautilus [AccountState].

pub async fn fetch_all_orders( &self, query: &OrderListQuery, ) -> Result<Vec<Order>>

Fetches every order matching the query, following cursor pagination.

Honors OrderListQuery::client_order_id_filter as a client-side filter applied to each page (the venue endpoint does not accept that parameter directly). Stops once the configured limit is reached.

pub async fn fetch_all_fills(&self, query: &FillListQuery) -> Result<Vec<Fill>>

Fetches every fill matching the query, following cursor pagination.

pub async fn create_order( &self, request: &CreateOrderRequest, ) -> Result<CreateOrderResponse>

Creates a new order via POST /orders.

References

• https://docs.cdp.coinbase.com/api-reference/advanced-trade-api/rest-api/orders/create-order

pub async fn cancel_orders( &self, request: &CancelOrdersRequest, ) -> Result<CancelOrdersResponse>

Cancels one or more orders via POST /orders/batch_cancel.

References

• https://docs.cdp.coinbase.com/api-reference/advanced-trade-api/rest-api/orders/cancel-order

pub async fn edit_order( &self, request: &EditOrderRequest, ) -> Result<EditOrderResponse>

Edits an existing order via POST /orders/edit.

Coinbase restricts edits to GTC orders (LIMIT, STOP_LIMIT, Bracket); other order types require cancel-and-replace.

References

• https://docs.cdp.coinbase.com/api-reference/advanced-trade-api/rest-api/orders/edit-order

Trait Implementations

impl Debug for CoinbaseRawHttpClient

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

Formats the value using the given formatter.