llm-connector 1.1.2

Next-generation Rust library for LLM protocol abstraction with native multi-modal support. Supports 12+ providers (OpenAI, Anthropic, Google, Aliyun, Zhipu, Ollama, Tencent, Volcengine, LongCat, Moonshot, DeepSeek, Xiaomi) with clean Protocol/Provider separation, type-safe interface, and universal streaming.
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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167

//! # llm-connector
//!
//! Next-generation Rust library for LLM protocol abstraction.
//!
//! Supports 5 protocols: OpenAI, Anthropic, Aliyun, Zhipu, Ollama.
//! Clean architecture with clear Protocol/Provider separation.
//!
//! ## Quick Start
//!
//! ### OpenAI Protocol
//! ```rust,no_run
//! use llm_connector::{LlmClient, types::{ChatRequest, Message, Role}};
//!
//! #[tokio::main]
//! async fn main() -> Result<(), Box<dyn std::error::Error>> {
//!     // OpenAI
//!     let client = LlmClient::openai("sk-...", "https://api.openai.com/v1")?;
//!
//!     let request = ChatRequest {
//!         model: "gpt-4".to_string(),
//!         messages: vec![Message::text(Role::User, "Hello!")],
//!         ..Default::default()
//!     };
//!
//!     let response = client.chat(&request).await?;
//!     println!("Response: {}", response.content);
//!     Ok(())
//! }
//! ```
//!
//! ### Anthropic Protocol
//! ```rust,no_run
//! use llm_connector::{LlmClient, types::{ChatRequest, Message, Role}};
//!
//! #[tokio::main]
//! async fn main() -> Result<(), Box<dyn std::error::Error>> {
//!     let client = LlmClient::anthropic("sk-ant-...", "https://api.anthropic.com")?;
//!     let request = ChatRequest {
//!         model: "claude-3-5-sonnet-20241022".to_string(),
//!         messages: vec![Message::text(Role::User, "Hello!")],
//!         ..Default::default()
//!     };
//!
//!     let response = client.chat(&request).await?;
//!     println!("Response: {}", response.content);
//!     Ok(())
//! }
//! ```
//!
//! ### Aliyun Protocol (DashScope)
//! ```rust,no_run
//! use llm_connector::{LlmClient, types::{ChatRequest, Message, Role}};
//!
//! #[tokio::main]
//! async fn main() -> Result<(), Box<dyn std::error::Error>> {
//!     let client = LlmClient::aliyun("sk-...", "https://dashscope.aliyuncs.com")?;
//!     let request = ChatRequest {
//!         model: "qwen-turbo".to_string(),
//!         messages: vec![Message::text(Role::User, "Hello!")],
//!         ..Default::default()
//!     };
//!
//!     let response = client.chat(&request).await?;
//!     println!("Response: {}", response.content);
//!     Ok(())
//! }
//! ```
//!
//! ### Ollama Protocol (Local)
//! ```rust,no_run
//! use llm_connector::{LlmClient, Provider, types::{ChatRequest, Message, Role}};
//!
//! #[tokio::main]
//! async fn main() -> Result<(), Box<dyn std::error::Error>> {
//!     // Default: localhost:11434
//!     // Default: localhost:11434
//!     let client = LlmClient::ollama("http://localhost:11434")?;
//!
//!     // Custom URL
//!     let client = LlmClient::ollama("http://192.168.1.100:11434")?;
//!
//!     let request = ChatRequest {
//!         model: "llama3.2".to_string(),
//!         messages: vec![Message::text(Role::User, "Hello!")],
//!         ..Default::default()
//!     };
//!
//!     let response = client.chat(&request).await?;
//!     println!("Response: {}", response.content);
//!
//!     // Ollama special features
//!     if let Some(ollama) = client.as_ollama() {
//!         let models = ollama.models().await?;
//!         println!("Available models: {:?}", models);
//!     }
//!
//!     Ok(())
//! }
//! ```
//!
//! ## Installation
//!
//! Add to your `Cargo.toml`:
//!
//! ```toml
//! [dependencies]
//! llm-connector = "0.2"
//! tokio = { version = "1", features = ["full"] }
//! ```
//!
//! Optional features:
//! ```toml
//! llm-connector = { version = "0.2", features = ["streaming"] }
//! ```

// Core modules (V2 Architecture - Default)
pub mod builder;
pub mod client;
pub mod config;
pub mod core;
pub mod error;
pub mod protocols;
pub mod providers;
pub mod types;

// Server-Sent Events (SSE) utilities
pub mod sse;

// Re-exports for convenience (V2 Architecture)
pub use client::LlmClient;
pub use config::ProviderConfig;
pub use error::LlmConnectorError;
pub use types::{
    ChatRequest, ChatResponse, Choice, FunctionCall, JsonSchemaSpec, Message, ResponseFormat, Role,
    Tool, ToolCall, ToolChoice, Usage,
};

// Re-export core traits
pub use core::{GenericProvider, HttpClient, Protocol, Provider};

// Re-export protocols
pub use protocols::{
    AliyunProtocol, AnthropicProtocol, GoogleProtocol, OllamaProtocol, OpenAIProtocol,
    ZhipuProtocol,
};

// Re-export providers
pub use providers::{
    AliyunProvider,
    AnthropicProvider,
    OllamaProvider,
    OpenAIProvider,
    ZhipuProvider,
    aliyun,
    anthropic,
    ollama,
    // Convenience functions
    openai,
    zhipu,
};

#[cfg(feature = "streaming")]
pub use types::{
    ChatStream, Delta, OllamaChatStream, OllamaMessage, OllamaStreamChunk, StreamChunk,
    StreamFormat, StreamingChoice, StreamingConfig, StreamingFormat, StreamingResponse,
    UniversalChatStream,
};