Struct ClaudeHttpAdapter 

pub struct ClaudeHttpAdapter { /* private fields */ }

HTTP adapter that routes to the Anthropic Messages API.

Construction reads CORTEX_CLAUDE_API_KEY from the environment and validates the model string. The adapter is Send + Sync and may be placed behind an Arc<dyn LlmAdapter>.

The max_sensitivity field enforces the ADR 0048 §3 data-classification gate: prompts containing inline high-sensitivity markers are rejected before any bytes leave the machine when the gate is set below High.

Implementations

impl ClaudeHttpAdapter

pub const ANTHROPIC_API_BASE: &'static str = "https://api.anthropic.com"

The base URL for all Anthropic API requests.

pub const ANTHROPIC_API_KEY_ENV: &'static str = "CORTEX_CLAUDE_API_KEY"

Environment variable that must contain the Anthropic API key.

Construction fails with LlmError::InvalidRequest if this variable is absent or empty.

pub const ANTHROPIC_VERSION_HEADER: &'static str = "2023-06-01"

anthropic-version header value required by the Messages API.

pub fn new( model: String, max_sensitivity: Option<MaxSensitivity>, ) -> Result<Self, LlmError>

Construct a ClaudeHttpAdapter for model with max_sensitivity.

max_sensitivity controls the data-classification gate (ADR 0048 §3). Pass None to use the default of MaxSensitivity::Medium, which blocks high-sensitivity memories from being sent to the remote endpoint.

Returns LlmError::InvalidRequest when:

• CORTEX_CLAUDE_API_KEY is absent or empty.
• model is empty.
• model contains the string "latest" (forbidden to preserve audit-trail identity; see ADR 0044 §3 and ADR 0048).

Trait Implementations

impl Clone for ClaudeHttpAdapter

fn clone(&self) -> ClaudeHttpAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClaudeHttpAdapter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl LlmAdapter for ClaudeHttpAdapter

fn stream_boxed(&self, req: LlmRequest) -> BoxStream<'_>

Override with true Anthropic SSE streaming via POST /v1/messages with "stream": true.

Uses ureq (synchronous) inside spawn_blocking. The blocking reader collects all SSE lines into a Vec before yielding them; the async_stream::stream! block then emits items one by one.

TODO: replace ureq with an async HTTP client to achieve true line-by-line streaming without buffering the entire response.

fn adapter_id(&self) -> &'static str

Stable, lowercase identifier used in audit envelopes (e.g. "claude", "ollama", "replay"). Constants — implementations MUST NOT vary this per call.

fn complete<'life0, 'async_trait>( &'life0 self, req: LlmRequest, ) -> Pin<Box<dyn Future<Output = Result<LlmResponse, LlmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Issue a completion call. The adapter is responsible for honouring req.timeout_ms and returning LlmError::Timeout when exceeded.

fn stream( &self, req: LlmRequest, ) -> impl Stream<Item = Result<StreamChunk, LlmError>> + Send

where Self: Sized,

Stream tokens incrementally. Default implementation calls complete and yields the full response as a single chunk — adapters override this for true streaming.