opendeviationbar-client 13.64.0

Client library for consuming open deviation bar data via SSE
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

# opendeviationbar-client

Client library for consuming open deviation bar data via SSE from the ODB sidecar.

## Usage

```rust
use opendeviationbar_client::{OdbSseClient, OdbSseConfig, OdbSseEvent};
use futures::StreamExt;

let client = OdbSseClient::new(OdbSseConfig {
    host: "127.0.0.1".into(),
    port: 8081,
    symbols: vec!["BTCUSDT".into()],
    thresholds: vec![250],
});

let mut stream = std::pin::pin!(client.connect());
while let Some(event) = stream.next().await {
    match event {
        OdbSseEvent::Bar(bar) => println!("{} @{}: {}", bar.symbol, bar.threshold, bar.close),
        OdbSseEvent::Connected => println!("connected"),
        OdbSseEvent::Heartbeat => {},
        OdbSseEvent::DeserializationError { error, .. } => eprintln!("bad bar: {error}"),
        OdbSseEvent::Disconnected(reason) => println!("disconnected: {reason}"),
    }
}
```

## Features

- **SSE protocol**: Full RFC compliance via [`eventsource-client`](https://crates.io/crates/eventsource-client)
- **Reconnection**: Built-in exponential backoff + jitter, server `retry:` directive honoring
- **Typed bars**: `OdbBar` with OHLCV, microstructure features, and `#[serde(flatten)]` for forward compatibility
- **Transport**: Pluggable reqwest-based HTTP transport (no hyper dependency)

## License

MIT