Versions in this module Expand all Collapse all v0 v0.3.0 Sep 7, 2026 v0.2.0 Aug 15, 2026 Changes in this version + type Anthropic struct + func (Anthropic) DecodeRequest(body json.RawMessage, policy llmprotocol.Policy) (RequestResult, error) + func (Anthropic) DecodeResponse(body json.RawMessage, policy llmprotocol.Policy) (ResponseResult, error) + func (Anthropic) DecodeStreamEvent(state *StreamState, wire llmprotocol.WireEvent, policy llmprotocol.Policy) ([]llmprotocol.StreamEvent, []llmprotocol.Diagnostic, error) + func (Anthropic) EncodeRequest(request llmprotocol.Request, policy llmprotocol.Policy) (WireResult, error) + func (Anthropic) EncodeResponse(response llmprotocol.Response, policy llmprotocol.Policy) (WireResult, error) + func (Anthropic) EncodeStreamEvent(state *StreamState, event llmprotocol.StreamEvent, policy llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (Anthropic) FinishStream(state *StreamState, policy llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (Anthropic) Format() llmprotocol.Format + type Bedrock struct + func (Bedrock) DecodeRequest(body json.RawMessage, policy llmprotocol.Policy) (RequestResult, error) + func (Bedrock) DecodeResponse(body json.RawMessage, policy llmprotocol.Policy) (ResponseResult, error) + func (Bedrock) DecodeStreamEvent(state *StreamState, wire llmprotocol.WireEvent, _ llmprotocol.Policy) ([]llmprotocol.StreamEvent, []llmprotocol.Diagnostic, error) + func (Bedrock) EncodeRequest(request llmprotocol.Request, policy llmprotocol.Policy) (WireResult, error) + func (Bedrock) EncodeResponse(response llmprotocol.Response, policy llmprotocol.Policy) (WireResult, error) + func (Bedrock) EncodeStreamEvent(state *StreamState, event llmprotocol.StreamEvent, policy llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (Bedrock) FinishStream(_ *StreamState, _ llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (Bedrock) Format() llmprotocol.Format + type BedrockCohereEmbeddings struct + func (BedrockCohereEmbeddings) DecodeEmbeddingRequest(body json.RawMessage, policy llmprotocol.Policy) (EmbeddingRequestResult, error) + func (BedrockCohereEmbeddings) DecodeEmbeddingResponse(body json.RawMessage, policy llmprotocol.Policy) (EmbeddingResponseResult, error) + func (BedrockCohereEmbeddings) EncodeEmbeddingRequest(request llmprotocol.EmbeddingRequest, policy llmprotocol.Policy) (WireResult, error) + func (BedrockCohereEmbeddings) EncodeEmbeddingResponse(response llmprotocol.EmbeddingResponse, policy llmprotocol.Policy) (WireResult, error) + func (BedrockCohereEmbeddings) Format() llmprotocol.Format + type BedrockTitanEmbeddings struct + func (BedrockTitanEmbeddings) DecodeEmbeddingRequest(body json.RawMessage, policy llmprotocol.Policy) (EmbeddingRequestResult, error) + func (BedrockTitanEmbeddings) DecodeEmbeddingResponse(body json.RawMessage, policy llmprotocol.Policy) (EmbeddingResponseResult, error) + func (BedrockTitanEmbeddings) EncodeEmbeddingRequest(request llmprotocol.EmbeddingRequest, policy llmprotocol.Policy) (WireResult, error) + func (BedrockTitanEmbeddings) EncodeEmbeddingResponse(response llmprotocol.EmbeddingResponse, policy llmprotocol.Policy) (WireResult, error) + func (BedrockTitanEmbeddings) Format() llmprotocol.Format + type Codec interface + DecodeRequest func(json.RawMessage, llmprotocol.Policy) (RequestResult, error) + DecodeResponse func(json.RawMessage, llmprotocol.Policy) (ResponseResult, error) + DecodeStreamEvent func(*StreamState, llmprotocol.WireEvent, llmprotocol.Policy) ([]llmprotocol.StreamEvent, []llmprotocol.Diagnostic, error) + EncodeRequest func(llmprotocol.Request, llmprotocol.Policy) (WireResult, error) + EncodeResponse func(llmprotocol.Response, llmprotocol.Policy) (WireResult, error) + EncodeStreamEvent func(*StreamState, llmprotocol.StreamEvent, llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + FinishStream func(*StreamState, llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + Format func() llmprotocol.Format + type EmbeddingCodec interface + DecodeEmbeddingRequest func(json.RawMessage, llmprotocol.Policy) (EmbeddingRequestResult, error) + DecodeEmbeddingResponse func(json.RawMessage, llmprotocol.Policy) (EmbeddingResponseResult, error) + EncodeEmbeddingRequest func(llmprotocol.EmbeddingRequest, llmprotocol.Policy) (WireResult, error) + EncodeEmbeddingResponse func(llmprotocol.EmbeddingResponse, llmprotocol.Policy) (WireResult, error) + Format func() llmprotocol.Format + type EmbeddingRegistry struct + func NewDefaultEmbeddingRegistry() *EmbeddingRegistry + func NewEmbeddingRegistry(codecs ...EmbeddingCodec) *EmbeddingRegistry + func (r *EmbeddingRegistry) Codec(format llmprotocol.Format) (EmbeddingCodec, error) + func (r *EmbeddingRegistry) Register(value EmbeddingCodec) + func (r *EmbeddingRegistry) TranslateRequest(source, target llmprotocol.Format, body json.RawMessage, ...) (WireResult, error) + func (r *EmbeddingRegistry) TranslateResponse(source, target llmprotocol.Format, body json.RawMessage, ...) (WireResult, error) + type EmbeddingRequestResult struct + Diagnostics []llmprotocol.Diagnostic + Request llmprotocol.EmbeddingRequest + type EmbeddingResponseResult struct + Diagnostics []llmprotocol.Diagnostic + Response llmprotocol.EmbeddingResponse + type Gemini struct + func (Gemini) DecodeRequest(body json.RawMessage, policy llmprotocol.Policy) (RequestResult, error) + func (Gemini) DecodeResponse(body json.RawMessage, policy llmprotocol.Policy) (ResponseResult, error) + func (Gemini) DecodeStreamEvent(state *StreamState, wire llmprotocol.WireEvent, policy llmprotocol.Policy) ([]llmprotocol.StreamEvent, []llmprotocol.Diagnostic, error) + func (Gemini) EncodeRequest(request llmprotocol.Request, policy llmprotocol.Policy) (WireResult, error) + func (Gemini) EncodeResponse(response llmprotocol.Response, policy llmprotocol.Policy) (WireResult, error) + func (Gemini) EncodeStreamEvent(state *StreamState, event llmprotocol.StreamEvent, policy llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (Gemini) FinishStream(_ *StreamState, _ llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (Gemini) Format() llmprotocol.Format + type GeminiEmbeddings struct + func (GeminiEmbeddings) DecodeEmbeddingRequest(body json.RawMessage, policy llmprotocol.Policy) (EmbeddingRequestResult, error) + func (GeminiEmbeddings) DecodeEmbeddingResponse(body json.RawMessage, policy llmprotocol.Policy) (EmbeddingResponseResult, error) + func (GeminiEmbeddings) EncodeEmbeddingRequest(request llmprotocol.EmbeddingRequest, policy llmprotocol.Policy) (WireResult, error) + func (GeminiEmbeddings) EncodeEmbeddingResponse(response llmprotocol.EmbeddingResponse, policy llmprotocol.Policy) (WireResult, error) + func (GeminiEmbeddings) Format() llmprotocol.Format + type OpenAIChat struct + func (OpenAIChat) DecodeRequest(body json.RawMessage, policy llmprotocol.Policy) (RequestResult, error) + func (OpenAIChat) DecodeResponse(body json.RawMessage, policy llmprotocol.Policy) (ResponseResult, error) + func (OpenAIChat) DecodeStreamEvent(state *StreamState, wire llmprotocol.WireEvent, policy llmprotocol.Policy) ([]llmprotocol.StreamEvent, []llmprotocol.Diagnostic, error) + func (OpenAIChat) EncodeRequest(request llmprotocol.Request, policy llmprotocol.Policy) (WireResult, error) + func (OpenAIChat) EncodeResponse(response llmprotocol.Response, policy llmprotocol.Policy) (WireResult, error) + func (OpenAIChat) EncodeStreamEvent(state *StreamState, event llmprotocol.StreamEvent, policy llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (OpenAIChat) FinishStream(state *StreamState, _ llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (OpenAIChat) Format() llmprotocol.Format + type OpenAIEmbeddings struct + func (OpenAIEmbeddings) DecodeEmbeddingRequest(body json.RawMessage, policy llmprotocol.Policy) (EmbeddingRequestResult, error) + func (OpenAIEmbeddings) DecodeEmbeddingResponse(body json.RawMessage, policy llmprotocol.Policy) (EmbeddingResponseResult, error) + func (OpenAIEmbeddings) EncodeEmbeddingRequest(request llmprotocol.EmbeddingRequest, policy llmprotocol.Policy) (WireResult, error) + func (OpenAIEmbeddings) EncodeEmbeddingResponse(response llmprotocol.EmbeddingResponse, policy llmprotocol.Policy) (WireResult, error) + func (OpenAIEmbeddings) Format() llmprotocol.Format + type OpenAIResponses struct + func (OpenAIResponses) DecodeRequest(body json.RawMessage, policy llmprotocol.Policy) (RequestResult, error) + func (OpenAIResponses) DecodeResponse(body json.RawMessage, policy llmprotocol.Policy) (ResponseResult, error) + func (OpenAIResponses) DecodeStreamEvent(state *StreamState, wire llmprotocol.WireEvent, policy llmprotocol.Policy) ([]llmprotocol.StreamEvent, []llmprotocol.Diagnostic, error) + func (OpenAIResponses) EncodeRequest(request llmprotocol.Request, policy llmprotocol.Policy) (WireResult, error) + func (OpenAIResponses) EncodeResponse(response llmprotocol.Response, policy llmprotocol.Policy) (WireResult, error) + func (OpenAIResponses) EncodeStreamEvent(state *StreamState, event llmprotocol.StreamEvent, policy llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (OpenAIResponses) FinishStream(state *StreamState, _ llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (OpenAIResponses) Format() llmprotocol.Format + type Registry struct + func NewDefaultRegistry() *Registry + func NewRegistry(codecs ...Codec) *Registry + func (r *Registry) Codec(format llmprotocol.Format) (Codec, error) + func (r *Registry) FinishStream(state *StreamState, target llmprotocol.Format, policy llmprotocol.Policy) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + func (r *Registry) Register(c Codec) + func (r *Registry) TranslateRequest(source, target llmprotocol.Format, body json.RawMessage, ...) (WireResult, error) + func (r *Registry) TranslateResponse(source, target llmprotocol.Format, body json.RawMessage, ...) (WireResult, error) + func (r *Registry) TranslateStreamEvent(state *StreamState, source, target llmprotocol.Format, ...) ([]llmprotocol.WireEvent, []llmprotocol.Diagnostic, error) + type RequestResult struct + Diagnostics []llmprotocol.Diagnostic + Request llmprotocol.Request + type ResponseResult struct + Diagnostics []llmprotocol.Diagnostic + Response llmprotocol.Response + type StreamState struct + Model string + ResponseID string + Source llmprotocol.Format + Target llmprotocol.Format + Values map[string]any + type WireResult struct + Body json.RawMessage + Diagnostics []llmprotocol.Diagnostic
Go to main page