gemini-live 0.1.2

High-performance Rust client for the Gemini Multimodal Live API
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

//! Error types for each architectural layer.
//!
//! Errors are split by layer so callers can match on the granularity they need:
//! - [`CodecError`] — JSON serialization / deserialization failures.
//! - [`ConnectError`] — WebSocket connection establishment failures.
//! - [`SendError`] / [`RecvError`] — frame-level I/O on an established connection.
//! - [`SessionError`] — high-level session lifecycle errors (setup, reconnect, etc.).

use std::time::Duration;

// ── Codec layer ──────────────────────────────────────────────────────────────

/// Failure during JSON ↔ Rust conversion.
#[derive(Debug, thiserror::Error)]
pub enum CodecError {
    #[error("JSON serialization failed: {0}")]
    Serialize(#[source] serde_json::Error),
    #[error("JSON deserialization failed: {0}")]
    Deserialize(#[source] serde_json::Error),
}

// ── Transport layer ──────────────────────────────────────────────────────────

/// Failure while establishing a WebSocket connection.
#[derive(Debug, thiserror::Error)]
pub enum ConnectError {
    #[error("DNS resolution failed: {0}")]
    Dns(#[source] Box<dyn std::error::Error + Send + Sync>),
    #[error("TLS handshake failed: {0}")]
    Tls(#[source] Box<dyn std::error::Error + Send + Sync>),
    #[error("connection timed out after {0:?}")]
    Timeout(Duration),
    #[error("WebSocket handshake rejected: {status}")]
    Rejected { status: u16 },
    #[error("WebSocket error: {0}")]
    Ws(#[source] tokio_tungstenite::tungstenite::Error),
}

/// Failure while sending a WebSocket frame.
#[derive(Debug, thiserror::Error)]
pub enum SendError {
    #[error("connection closed")]
    Closed,
    #[error("WebSocket send failed: {0}")]
    Ws(#[source] tokio_tungstenite::tungstenite::Error),
}

/// Failure while receiving a WebSocket frame.
#[derive(Debug, thiserror::Error)]
pub enum RecvError {
    #[error("connection closed")]
    Closed,
    #[error("WebSocket receive failed: {0}")]
    Ws(#[source] tokio_tungstenite::tungstenite::Error),
}

// ── Session layer ────────────────────────────────────────────────────────────

/// High-level session error covering setup, runtime, and reconnection.
#[derive(Debug, thiserror::Error)]
pub enum SessionError {
    #[error("setup failed: {0}")]
    SetupFailed(String),
    #[error("setup timed out after {0:?}")]
    SetupTimeout(Duration),
    #[error("API error: {0}")]
    Api(String),
    #[error("connection lost and reconnection failed after {attempts} attempts")]
    ReconnectExhausted { attempts: u32 },
    #[error("session closed")]
    Closed,
    #[error(transparent)]
    Transport(#[from] SendError),
    #[error(transparent)]
    Codec(#[from] CodecError),
}