Struct KrakenFuturesWebSocketClient 

pub struct KrakenFuturesWebSocketClient { /* private fields */ }

WebSocket client for the Kraken Futures v1 streaming API.

Implementations

impl KrakenFuturesWebSocketClient

pub fn new(url: String, heartbeat_secs: u64, proxy_url: Option<String>) -> Self

Creates a new client with the given URL.

pub fn with_credentials( url: String, heartbeat_secs: u64, credential: Option<KrakenCredential>, auth_timeout_secs: Option<u64>, transport_backend: TransportBackend, proxy_url: Option<String>, ) -> Self

Creates a new client with API credentials for authenticated feeds.

pub fn with_socket_control(self, control: SocketControl) -> Self

Configures socket state reporting and reconnect control.

pub fn has_credentials(&self) -> bool

Returns true if the client has API credentials set.

pub fn url(&self) -> &str

Returns the WebSocket URL.

pub fn is_closed(&self) -> bool

Returns true if the connection is closed.

pub fn is_active(&self) -> bool

Returns true if the connection is active.

pub async fn wait_until_active( &self, timeout_secs: f64, ) -> Result<(), KrakenWsError>

Waits until the WebSocket connection is active or timeout.

pub fn is_authenticated(&self) -> bool

Returns true if the WebSocket is authenticated for private feeds.

pub async fn wait_until_authenticated( &self, timeout_secs: f64, ) -> Result<(), KrakenWsError>

Waits until the WebSocket is authenticated or the timeout elapses.

Returns an error on timeout or explicit auth failure.

pub async fn authenticate(&self) -> Result<(), KrakenWsError>

Authenticates the WebSocket connection for private feeds.

Sends a challenge request and waits for the handler to parse the response, sign it, and mark the AuthTracker successful. Private subscriptions gate on the stored challenge / signed-challenge pair.

pub async fn connect(&mut self) -> Result<(), KrakenWsError>

Connects to the WebSocket server.

pub async fn disconnect(&mut self) -> Result<(), KrakenWsError>

Disconnects from the WebSocket server.

pub async fn close(&mut self) -> Result<(), KrakenWsError>

Closes the WebSocket connection.

pub async fn subscribe_mark_price( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Subscribes to mark price updates for the given instrument.

pub async fn unsubscribe_mark_price( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Unsubscribes from mark price updates for the given instrument.

pub async fn subscribe_index_price( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Subscribes to index price updates for the given instrument.

pub async fn unsubscribe_index_price( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Unsubscribes from index price updates for the given instrument.

pub async fn subscribe_funding_rate( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Subscribes to funding rate updates for the given instrument.

pub async fn unsubscribe_funding_rate( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Unsubscribes from funding rate updates for the given instrument.

pub async fn subscribe_quotes( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Subscribes to quote updates for the given instrument.

Uses the order book channel for low-latency top-of-book quotes.

pub async fn unsubscribe_quotes( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Unsubscribes from quote updates for the given instrument.

pub async fn subscribe_trades( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Subscribes to trade updates for the given instrument.

pub async fn unsubscribe_trades( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Unsubscribes from trade updates for the given instrument.

pub async fn subscribe_book( &self, instrument_id: InstrumentId, _depth: Option<u32>, ) -> Result<(), KrakenWsError>

Subscribes to order book updates for the given instrument.

Note: The depth parameter is accepted for API compatibility with spot client but is not used by Kraken Futures (full book is always returned).

pub async fn unsubscribe_book( &self, instrument_id: InstrumentId, ) -> Result<(), KrakenWsError>

Unsubscribes from order book updates for the given instrument.

pub fn take_output_rx( &mut self, ) -> Option<UnboundedReceiver<KrakenFuturesWsMessage>>

Gets the output receiver for processed messages.

pub async fn set_auth_credentials( &self, original_challenge: String, signed_challenge: String, ) -> Result<(), KrakenWsError>

Set authentication credentials directly (for when challenge is obtained externally).

pub fn sign_challenge(&self, challenge: &str) -> Result<String, KrakenWsError>

Sign a challenge with the API credentials.

Returns the signed challenge on success.

pub async fn authenticate_with_challenge( &self, challenge: &str, ) -> Result<(), KrakenWsError>

Complete authentication with a received challenge.

pub fn set_account_id(&self, account_id: AccountId)

Sets the account ID for execution report parsing.

pub fn account_id(&self) -> Option<AccountId>

Returns the account ID if set.

pub fn account_id_shared(&self) -> &Arc<RwLock<Option<AccountId>>>

Returns a reference to the shared account ID.

pub fn truncated_id_map(&self) -> &Arc<AtomicMap<String, ClientOrderId>>

Returns a reference to the truncated ID map.

pub fn order_instrument_map(&self) -> &Arc<AtomicMap<String, InstrumentId>>

Returns a reference to the order-to-instrument map.

pub fn instruments_shared(&self) -> &Arc<AtomicMap<InstrumentId, InstrumentAny>>

Returns a reference to the shared instruments map.

pub fn subscriptions(&self) -> &SubscriptionState

Returns a reference to the subscription state.

pub fn cache_instrument(&self, instrument: InstrumentAny)

Caches an instrument for execution report parsing.

pub fn cache_instruments(&self, instruments: &[InstrumentAny])

Caches multiple instruments for execution report parsing.

pub fn cache_client_order( &self, client_order_id: ClientOrderId, venue_order_id: Option<VenueOrderId>, instrument_id: InstrumentId, _trader_id: TraderId, _strategy_id: StrategyId, )

Caches a client order for truncated ID resolution and instrument lookup.

Kraken Futures limits client order IDs to 18 characters, so orders with longer IDs are truncated. This method stores the mapping from truncated to full ID, and from venue order ID to instrument ID for cancel messages.

pub async fn subscribe_open_orders(&self) -> Result<(), KrakenWsError>

Subscribes to open orders feed (private, requires authentication).

pub async fn subscribe_fills(&self) -> Result<(), KrakenWsError>

Subscribes to fills feed (private, requires authentication).

pub async fn subscribe_executions(&self) -> Result<(), KrakenWsError>

Subscribes to both open orders and fills (convenience method).

Trait Implementations

impl Clone for KrakenFuturesWebSocketClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KrakenFuturesWebSocketClient

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

Formats the value using the given formatter.