Struct PolyNodeClient 

pub struct PolyNodeClient { /* private fields */ }

Main PolyNode client.

Implementations

impl PolyNodeClient

pub fn new(api_key: impl Into<String>) -> Result<Self>

Create a client with defaults.

pub fn builder(api_key: impl Into<String>) -> ClientBuilder

Create a builder for full configuration.

pub async fn healthz(&self) -> Result<String>

Liveness probe. No auth required.

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

Readiness check. No auth required.

pub async fn status(&self) -> Result<StatusResponse>

System status with metrics.

pub async fn create_key(&self, name: Option<&str>) -> Result<ApiKeyResponse>

Generate a new API key. No auth required.

pub async fn markets(&self, count: Option<u64>) -> Result<MarketsResponse>

Top markets sorted by 24h volume.

pub async fn market(&self, token_id: &str) -> Result<Value>

Market detail by token ID.

pub async fn market_by_slug(&self, slug: &str) -> Result<Value>

Market detail by URL slug.

pub async fn market_by_condition(&self, condition_id: &str) -> Result<Value>

Market detail by condition ID.

pub async fn list_markets( &self, params: &ListMarketsParams, ) -> Result<MarketsListResponse>

Filtered, paginated market listing.

pub async fn search( &self, query: &str, limit: Option<u64>, include_inactive: Option<bool>, ) -> Result<SearchResponse>

Full-text search across market questions.

pub async fn candles( &self, token_id: &str, resolution: Option<CandleResolution>, limit: Option<u64>, ) -> Result<CandlesResponse>

OHLCV candles for a token.

pub async fn stats(&self, token_id: &str) -> Result<Value>

Market statistics.

pub async fn recent_settlements( &self, count: Option<u64>, ) -> Result<SettlementsResponse>

Most recent decoded settlements.

pub async fn token_settlements( &self, token_id: &str, count: Option<u64>, ) -> Result<SettlementsResponse>

Settlements for a specific token ID.

pub async fn wallet_settlements( &self, address: &str, count: Option<u64>, ) -> Result<SettlementsResponse>

Settlements for a specific wallet address.

pub async fn wallet(&self, address: &str) -> Result<Value>

Wallet activity summary.

pub async fn wallet_positions_data( &self, address: &str, limit: Option<u64>, offset: Option<u64>, ) -> Result<WalletPositionsResponse>

Positions for a wallet (proxied from Polymarket data-api). Returns full P&L, current values.

pub async fn wallet_onchain_positions( &self, address: &str, ) -> Result<WalletOnchainPositionsResponse>

Onchain positions from the PNL subgraph. Returns ALL positions (open + closed) with accurate realized P&L.

pub async fn wallet_trades( &self, address: &str, limit: Option<u64>, offset: Option<u64>, ) -> Result<WalletTradesResponse>

Trades for a wallet. Used by the cache for backfill.

pub async fn market_trades( &self, id: &str, limit: Option<u64>, offset: Option<u64>, side: Option<&str>, user: Option<&str>, ) -> Result<MarketTradesResponse>

Trades for a market (by condition ID or slug).

pub async fn orderbook_rest( &self, token_id: &str, ) -> Result<OrderbookRestResponse>

Full orderbook snapshot from the CLOB.

pub async fn midpoint(&self, token_id: &str) -> Result<MidpointResponse>

Midpoint price for a token.

pub async fn spread(&self, token_id: &str) -> Result<SpreadResponse>

Bid-ask spread for a token.

pub async fn leaderboard( &self, period: Option<&str>, sort: Option<&str>, ) -> Result<LeaderboardResponse>

Top traders leaderboard.

pub async fn trending(&self) -> Result<TrendingResponse>

Trending markets (carousel, breaking, hot topics, featured, movers).

pub async fn activity(&self) -> Result<ActivityResponse>

Recent global trading activity.

pub async fn movers(&self) -> Result<MoversResponse>

Markets with largest 24h price moves.

pub async fn trader_profile(&self, wallet: &str) -> Result<TraderProfile>

Trader profile with stats.

pub async fn trader_pnl( &self, wallet: &str, period: Option<&str>, ) -> Result<TraderPnlResponse>

Trader P&L time series.

pub async fn event(&self, slug: &str) -> Result<EventDetailResponse>

Event detail by slug (includes all markets within the event).

pub async fn search_events( &self, query: &str, limit: Option<u64>, ) -> Result<EventSearchResponse>

Search events by query string.

pub async fn markets_by_category( &self, category: &str, ) -> Result<MarketsListResponse>

Markets filtered by category. Delegates to /v1/markets/list with a category filter.

pub async fn rpc_call(&self, method: &str, params: Value) -> Result<Value>

Send a JSON-RPC request through the PolyNode RPC endpoint (rpc.polynode.dev).

pub async fn stream(&self, options: StreamOptions) -> Result<WsStream>

Open a WebSocket connection, returning a stream of messages.

pub fn short_form(&self, interval: ShortFormInterval) -> ShortFormBuilder<'_>

Subscribe to short-form crypto markets (5m, 15m, 1h) with auto-rotation.

Returns a builder to configure coins and options before starting.

Example

let mut stream = client
    .short_form(polynode::ShortFormInterval::FifteenMin)
    .coins(&[polynode::Coin::Btc, polynode::Coin::Eth])
    .start()
    .await?;

pub async fn orderbook_stream( &self, options: ObStreamOptions, ) -> Result<ObStream>

Open an orderbook WebSocket stream from ob.polynode.dev.