kraken-api-client 0.1.0

An async Rust client library for the Kraken exchange REST and WebSocket v2 APIs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

//! Kraken Spot WebSocket v2 API client.
//!
//! Provides real-time market data and trading via WebSocket connections.
//!
//! # Example
//!
//! ```rust,ignore
//! use kraken_api_client::spot::ws::{SpotWsClient, WsMessageEvent};
//! use kraken_api_client::spot::ws::messages::{SubscribeParams, channels};
//! use futures_util::StreamExt;
//!
//! #[tokio::main]
//! async fn main() -> Result<(), Box<dyn std::error::Error>> {
//!     let client = SpotWsClient::new();
//!     let mut stream = client.connect_public().await?;
//!
//!     // Subscribe to ticker updates
//!     stream.subscribe(SubscribeParams::public(channels::TICKER, vec!["BTC/USD".into()])).await?;
//!
//!     // Process messages
//!     while let Some(msg) = stream.next().await {
//!         match msg? {
//!             WsMessageEvent::ChannelData(data) => {
//!                 println!("Data: {:?}", data);
//!             }
//!             WsMessageEvent::Status(status) => {
//!                 println!("Status: {:?}", status);
//!             }
//!             WsMessageEvent::Disconnected => {
//!                 println!("Disconnected!");
//!                 break;
//!             }
//!             _ => {}
//!         }
//!     }
//!
//!     Ok(())
//! }
//! ```

mod client;
pub mod messages;
mod stream;

pub use client::{SpotWsClient, WsConfig, WsConfigBuilder};
pub use stream::{KrakenStream, WsMessageEvent};