Coinbase pro client for Rust
Supports SYNC/ASYNC/Websocket-feed data support
Features
- private and public API
- sync and async support
- websocket-feed support
Examples
Cargo.toml:
[dependencies]
coinbase-pro-rs = "0.6.9"
Async
use hyper::rt::Future;
use coinbase_pro_rs::{Public, ASync, SANDBOX_URL};
fn main() {
let client: Public<ASync> = Public::Public::new_with_keep_alive(SANDBOX_URL, false);
// if keep_alive is not disables - tokio::run will hold the connection without exiting the example
let f = client.get_time()
.map_err(|_| ())
.and_then(|time| {
println!("Coinbase.time: {}", time.iso);
Ok(())
});
tokio::run(f); // waiting for tokio
}
Sync
use coinbase_pro_rs::{Public, Sync, SANDBOX_URL};
fn main() {
let client: Public<Sync> = Public::new(SANDBOX_URL);
let time = client.get_time().unwrap();
println!("Coinbase.time: {}", time.iso);
}
Websocket
use futures::{Future, Stream};
use coinbase_pro_rs::{WSFeed, WS_SANDBOX_URL};
use coinbase_pro_rs::structs::wsfeed::*;
fn main() {
let stream = WSFeed::new(WS_SANDBOX_URL,
&["BTC-USD"], &[ChannelType::Heartbeat]);
let f = stream
.take(10)
.for_each(|msg| {
match msg {
Message::Heartbeat {sequence, last_trade_id, time, ..} => println!("{}: seq:{} id{}",
time, sequence, last_trade_id),
Message::Error {message} => println!("Error: {}", message),
Message::InternalError(_) => panic!("internal_error"),
other => println!("{:?}", other)
}
Ok(())
});
tokio::run(f.map_err(|_| panic!("stream fail")));
}
Api supported:
- SYNC
- ASYNC
- Websocket-Feed
API
- Requests
- Pagination
- Types
- Private
- Authentication
- Accounts
- Orders
- Fills
- Deposits
- Withdrawals
- Payment Methods
- Coinbase Accounts
- Reports
- User Account
- Market Data
- Products
- Currencies
- Time
- Websocket Feed
- heartbeat
- ticker
- level2
- user
- matches
- full
FIX API
by request
OrderBook
https://github.com/inv2004/orderbook-rs
Tests
cargo test