Struct AnthropicMessagesCodec 

pub struct AnthropicMessagesCodec;

Stateless codec for Anthropic’s Messages API.

Construct once at agent build time and reuse — there is no internal state, just static behaviour.

Implementations

impl AnthropicMessagesCodec

pub const fn new() -> Self

Create a fresh codec instance.

Trait Implementations

impl Clone for AnthropicMessagesCodec

fn clone(&self) -> AnthropicMessagesCodec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Codec for AnthropicMessagesCodec

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

Stable codec identifier — "anthropic-messages", "openai-chat", etc. Used in logs and metrics tags.

fn capabilities(&self, _model: &str) -> Capabilities

Capability surface the codec advertises for the given model. Codecs vary by model (small models lacking vision, etc.).

fn auto_output_strategy(&self, _model: &str) -> OutputStrategy

Resolve OutputStrategy::Auto to the codec’s preferred dispatch shape for model. Called once at codec-construction time per request — never per-delta or per-retry, so the resolved strategy is part of the SessionGraph event log’s deterministic-replay surface.

fn encode(&self, request: &ModelRequest) -> Result<EncodedRequest>

Encode IR → wire body for a one-shot (non-streaming) call. Implementors push warnings onto the returned EncodedRequest::warnings for any IR field they had to drop or coerce.

fn encode_streaming(&self, request: &ModelRequest) -> Result<EncodedRequest>

Encode IR → wire body for a streaming call. Default impl delegates to encode and marks the request as streaming; codecs that need a different body shape (e.g. stream: true field) or extra headers (e.g. Accept: text/event-stream) override.

fn decode_stream<'a>( &'a self, bytes: BoxByteStream<'a>, warnings_in: Vec<ModelWarning>, ) -> BoxDeltaStream<'a>

Decode an incremental byte stream → IR StreamDelta stream.

fn decode( &self, body: &[u8], warnings_in: Vec<ModelWarning>, ) -> Result<ModelResponse>

Decode wire body → IR. warnings_in are the encode-time warnings that should be carried forward into ModelResponse::warnings so the caller sees the full advisory list in one place.

fn extract_rate_limit(&self, headers: &HeaderMap) -> Option<RateLimitSnapshot>

Extract a RateLimitSnapshot from response headers, if the vendor exposes rate-limit state in headers. Default returns None — codecs whose providers publish rate-limit headers override this and parse them.

impl Debug for AnthropicMessagesCodec

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

Formats the value using the given formatter.

impl Default for AnthropicMessagesCodec

fn default() -> AnthropicMessagesCodec

Returns the “default value” for a type.

impl Copy for AnthropicMessagesCodec