Skip to main content

​
Automatic Reconnection

Network connections fail. Havklo handles this automatically with exponential backoff:

​
Configuration

use kraken_sdk::ReconnectConfig;
use std::time::Duration;

let client = KrakenClient::builder(symbols)
    .with_reconnect(ReconnectConfig {
        initial_delay: Duration::from_millis(100),
        max_delay: Duration::from_secs(30),
        multiplier: 2.0,
        max_attempts: Some(10),  // or None for unlimited
    })
    .connect()
    .await?;
ParameterDefaultDescription
initial_delay100msFirst retry delay
max_delay30sMaximum delay cap
multiplier2.0Exponential factor
max_attemptsNoneUnlimited by default
Backoff sequence: 100ms -> 200ms -> 400ms -> 800ms -> … -> 30s (capped)

​
Circuit Breaker

Prevents hammering the API during extended outages: 
use kraken_sdk::CircuitBreakerConfig;

let client = KrakenClient::builder(symbols)
    .with_circuit_breaker(CircuitBreakerConfig {
        failure_threshold: 5,
        reset_timeout: Duration::from_secs(30),
        half_open_timeout: Duration::from_secs(60),
    })
    .connect()
    .await?;

​
Handling Events

match event {
    Event::Connection(ConnectionEvent::Disconnected { reason }) => {
        log::warn!("Lost connection: {:?}", reason);
    }
    Event::Connection(ConnectionEvent::Reconnecting { attempt, delay }) => {
        log::info!("Reconnecting (attempt {}, waiting {:?})", attempt, delay);
    }
    Event::Connection(ConnectionEvent::SubscriptionsRestored { count }) => {
        log::info!("Back online with {} subscriptions", count);
        // Safe to resume normal processing
    }
    Event::Connection(ConnectionEvent::CircuitBreakerOpen { trips }) => {
        log::error!("Circuit breaker open after {} trips", trips);
    }
    _ => {}
}
Treat SubscriptionsRestored as your “all clear” signal. Don’t use stale data from before the disconnect.

​
Disable Reconnection

For testing or single-shot connections: 
let client = KrakenClient::builder(symbols)
    .without_reconnect()
    .connect()
    .await?;