Package org.mockserver.llm.codec

Class BedrockCodec

java.lang.Object

org.mockserver.llm.codec.BedrockCodec

All Implemented Interfaces:

ProviderCodec

public class BedrockCodec
extends Object
implements ProviderCodec

Codec for AWS Bedrock (Anthropic-on-Bedrock) invokeModel API (version bedrock-2023-05-31).

This codec targets the plain Anthropic body wire format used by Bedrock's invokeModel endpoint for Anthropic Claude models. The request and response shapes are essentially identical to native Anthropic Messages API — the key difference is the model identifier format and URL path.

Streaming: Bedrock's InvokeModelWithResponseStream uses the AWS event-stream binary framing (application/vnd.amazon.eventstream). Each streaming chunk is wrapped as a binary message with headers (:event-type=chunk, :content-type=application/json, :message-type=event) and a payload of {"bytes":"<base64(chunkJson)>"}. This codec declares StreamingFormat.AWS_EVENT_STREAM and the downstream write handler (HttpSseResponseActionHandler) encodes each chunk into the binary event-stream format via BedrockEventStreamEncoder.

SigV4 signing: automatic AWS SigV4 request signing for calling real Bedrock is not yet implemented. Callers should supply auth headers via the LlmBackend.headers() escape hatch or a signing proxy. This remains a follow-up.

Constructor Summary

Constructors

Constructor	Description
BedrockCodec()

Method Summary

Modifier and Type	Method	Description
String	apiVersion()
ParsedConversation	decode(HttpRequest request)
HttpResponse	encode(Completion completion, String model)
HttpResponse	encodeEmbedding(EmbeddingResponse embedding, String input)
List<SseEvent>	encodeStreaming(Completion completion, String model, StreamingPhysics physics)	Encode a streaming completion as event-stream chunks.
Provider	provider()
StreamingFormat	streamingFormat()	The wire format this provider uses for streaming responses.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BedrockCodec

public BedrockCodec()

Method Details

provider

public Provider provider()

Specified by:

provider in interface ProviderCodec

apiVersion

public String apiVersion()

Specified by:

apiVersion in interface ProviderCodec

streamingFormat

public StreamingFormat streamingFormat()

Description copied from interface: ProviderCodec

The wire format this provider uses for streaming responses. Defaults to StreamingFormat.SSE; override for providers that use a different format (e.g. Ollama uses NDJSON).

Specified by:

streamingFormat in interface ProviderCodec

encode

public HttpResponse encode(Completion completion,
 String model)

Specified by:

encode in interface ProviderCodec

encodeStreaming

public List<SseEvent> encodeStreaming(Completion completion,
 String model,
 StreamingPhysics physics)

Encode a streaming completion as event-stream chunks.

Delegates to AnthropicCodec.encodeStreaming(org.mockserver.model.Completion, java.lang.String, org.mockserver.model.StreamingPhysics) to produce the Anthropic SSE events, then transforms each event's data payload into a form suitable for event-stream binary wrapping. The downstream write handler performs the actual binary encoding via BedrockEventStreamEncoder.

Each event's data becomes one event-stream chunk whose payload is {"bytes":"<base64(data)>"}.

Specified by:

encodeStreaming in interface ProviderCodec

decode

public ParsedConversation decode(HttpRequest request)

Specified by:

decode in interface ProviderCodec

encodeEmbedding

public HttpResponse encodeEmbedding(EmbeddingResponse embedding,
 String input)

Specified by:

encodeEmbedding in interface ProviderCodec