Struct Kalshi 

pub struct Kalshi { /* private fields */ }

Implementations

impl Kalshi

pub fn new(config: KalshiConfig) -> Result<Kalshi, KalshiError>

pub fn with_default_config() -> Result<Kalshi, KalshiError>

Trait Implementations

impl Exchange for Kalshi

fn id(&self) -> &'static str

fn name(&self) -> &'static str

fn manifest(&self) -> &'static ExchangeManifest

Returns the exchange manifest containing connection and data mapping configuration.

async fn fetch_markets( &self, params: &FetchMarketsParams, ) -> Result<(Vec<Market>, Option<String>), OpenPxError>

Fetch one page of markets from this exchange.

async fn fetch_market(&self, market_id: &str) -> Result<Market, OpenPxError>

async fn fetch_orderbook( &self, req: OrderbookRequest, ) -> Result<Orderbook, OpenPxError>

Fetch L2 orderbook for a market outcome. Uses owned types for async compatibility.

async fn fetch_price_history( &self, req: PriceHistoryRequest, ) -> Result<Vec<Candlestick>, OpenPxError>

Fetch historical OHLCV price history / candlestick data for a market outcome.

async fn fetch_trades( &self, req: TradesRequest, ) -> Result<(Vec<MarketTrade>, Option<String>), OpenPxError>

Fetch recent public trades (“tape”) for a market outcome. Returns (trades, next_cursor) where next_cursor supports pagination.

async fn create_order( &self, market_id: &str, outcome: &str, side: OrderSide, price: f64, size: f64, params: HashMap<String, String>, ) -> Result<Order, OpenPxError>

async fn cancel_order( &self, order_id: &str, _market_id: Option<&str>, ) -> Result<Order, OpenPxError>

async fn fetch_order( &self, order_id: &str, _market_id: Option<&str>, ) -> Result<Order, OpenPxError>

async fn fetch_open_orders( &self, _params: Option<FetchOrdersParams>, ) -> Result<Vec<Order>, OpenPxError>

async fn fetch_positions( &self, market_id: Option<&str>, ) -> Result<Vec<Position>, OpenPxError>

async fn fetch_balance(&self) -> Result<HashMap<String, f64>, OpenPxError>

async fn fetch_fills( &self, market_id: Option<&str>, limit: Option<usize>, ) -> Result<Vec<Fill>, OpenPxError>

Fetch user’s fill (trade execution) history for a market.

async fn fetch_balance_raw(&self) -> Result<Value, OpenPxError>

Fetch raw balance response from exchange API

fn describe(&self) -> ExchangeInfo

async fn refresh_balance(&self) -> Result<(), OpenPxError>

Refresh cached balance/allowance state if supported by the exchange.

async fn fetch_orderbook_history( &self, req: OrderbookHistoryRequest, ) -> Result<(Vec<OrderbookSnapshot>, Option<String>), OpenPxError>

Fetch historical L2 orderbook snapshots for a market. Returns (snapshots, next_cursor) for pagination.

async fn fetch_user_activity( &self, params: FetchUserActivityParams, ) -> Result<Value, OpenPxError>

Fetch user activity (positions, trades, portfolio data) for a given address.