Struct HttpProvider 

pub struct HttpProvider { /* private fields */ }

Shared HTTP transport for OpenAI-compatible providers.

Holds a reqwest::Client, pre-built headers (auth + content-type), and the target endpoint URL.

Implementations

impl HttpProvider

pub fn bearer(client: Client, key: &str, endpoint: &str) -> Result<Self>

Create a provider with Bearer token authentication.

pub fn no_auth(client: Client, endpoint: &str) -> Self

Create a provider without authentication (e.g. Ollama).

pub fn custom_header( client: Client, header_name: &str, header_value: &str, endpoint: &str, ) -> Result<Self>

Create a provider with a custom header for authentication.

Used by providers that don’t use Bearer tokens (e.g. Anthropic uses x-api-key).

pub fn anthropic(client: Client, key: &str, endpoint: &str) -> Result<Self>

Create a provider with Anthropic authentication headers.

Inserts x-api-key and anthropic-version in addition to the standard content-type and accept headers.

pub async fn send(&self, body: &impl Serialize) -> Result<Response>

Send a non-streaming request and deserialize the response as JSON.

pub fn stream_sse( &self, body: &impl Serialize, ) -> impl Stream<Item = Result<StreamChunk>> + Send

Stream an SSE response (OpenAI-compatible format).

Parses data: prefixed lines, skips [DONE] sentinel, and deserializes each chunk as StreamChunk.

pub async fn send_raw(&self, body: &impl Serialize) -> Result<String>

Send a non-streaming request and return the raw response body text.

Unlike send(), the caller is responsible for deserialization. Used by providers whose response schema differs from the OpenAI format (e.g. Anthropic).

pub fn stream_anthropic( &self, body: Value, ) -> impl Stream<Item = Result<StreamChunk>> + Send

Stream an SSE response in Anthropic block-buffer format.

Anthropic uses \n\n-delimited blocks each containing event: and data: lines, unlike OpenAI’s line-by-line data: prefix format. Takes the body as an owned serde_json::Value so the stream can be 'static without capturing a borrow.

pub fn endpoint(&self) -> &str

Get the endpoint URL.

pub fn headers(&self) -> &HeaderMap

Get a reference to the headers.

Trait Implementations

impl Clone for HttpProvider

fn clone(&self) -> HttpProvider

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.