adapters

package
v0.171.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 14, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package adapters bridges external SDK surfaces to the shapes the agent consumes.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AnthropicMessages added in v0.154.0 

type AnthropicMessages struct {
	// contains filtered or unexported fields
}

AnthropicMessages is a removable sdk.Client decorator that reroutes agent traffic for the Anthropic provider to the gateway's native /v1/messages endpoint, enabling prompt caching via cache_control breakpoints (system prompt, last tool, and a rolling conversation breakpoint). Anthropic SSE events are translated back into OpenAI-shaped chat-completion chunks, so the agent's streaming pipeline is unaware of the endpoint switch. Every other provider - and every non-generate method - delegates to the wrapped client untouched. To remove the adapter, delete this package, unwrap the client in the container, and drop the TakeCacheCreationTokens read in storeIterationMetrics.

func NewAnthropicMessages added in v0.154.0 

func NewAnthropicMessages(inner sdk.Client) *AnthropicMessages

NewAnthropicMessages wraps the raw SDK client with Anthropic /v1/messages routing.

func (*AnthropicMessages) CreateImage added in v0.156.0 

func (a *AnthropicMessages) CreateImage(ctx context.Context, provider sdk.Provider, request sdk.CreateImageRequest) (*sdk.ImagesResponse, error)

func (*AnthropicMessages) CreateImageEdit added in v0.156.2 

func (a *AnthropicMessages) CreateImageEdit(ctx context.Context, provider sdk.Provider, request sdk.CreateImageEditMultipartBody) (*sdk.ImagesResponse, error)

func (*AnthropicMessages) CreateImageVariation added in v0.156.2 

func (a *AnthropicMessages) CreateImageVariation(ctx context.Context, provider sdk.Provider, request sdk.CreateImageVariationMultipartBody) (*sdk.ImagesResponse, error)

func (*AnthropicMessages) CreateMessage added in v0.154.0 

func (a *AnthropicMessages) CreateMessage(ctx context.Context, provider sdk.Provider, request sdk.CreateMessagesRequest) (*sdk.MessagesResponse, error)

func (*AnthropicMessages) CreateMessageStream added in v0.154.0 

func (a *AnthropicMessages) CreateMessageStream(ctx context.Context, provider sdk.Provider, request sdk.CreateMessagesRequest) (<-chan sdk.SSEvent, error)

func (*AnthropicMessages) GenerateContent added in v0.154.0 

func (a *AnthropicMessages) GenerateContent(ctx context.Context, provider sdk.Provider, model string, messages []sdk.Message) (*sdk.CreateChatCompletionResponse, error)

GenerateContent routes Anthropic requests through /v1/messages and translates the response back into the chat-completions shape.

func (*AnthropicMessages) GenerateContentStream added in v0.154.0 

func (a *AnthropicMessages) GenerateContentStream(ctx context.Context, provider sdk.Provider, model string, messages []sdk.Message) (<-chan sdk.SSEvent, error)

GenerateContentStream routes Anthropic requests through /v1/messages and translates the native Anthropic SSE events into chat-completion chunks.

func (*AnthropicMessages) HealthCheck added in v0.154.0 

func (a *AnthropicMessages) HealthCheck(ctx context.Context) error

func (*AnthropicMessages) ListModels added in v0.154.0 

func (a *AnthropicMessages) ListModels(ctx context.Context, include ...sdk.ListModelsParamsInclude) (*sdk.ListModelsResponse, error)

func (*AnthropicMessages) ListProviderModels added in v0.154.0 

func (a *AnthropicMessages) ListProviderModels(ctx context.Context, provider sdk.Provider, include ...sdk.ListModelsParamsInclude) (*sdk.ListModelsResponse, error)

func (*AnthropicMessages) ListTools added in v0.154.0 

func (a *AnthropicMessages) ListTools(ctx context.Context) (*sdk.ListToolsResponse, error)

func (*AnthropicMessages) TakeCacheCreationTokens added in v0.154.0 

func (a *AnthropicMessages) TakeCacheCreationTokens() int

TakeCacheCreationTokens returns the cache-write token count of the last completed Anthropic request and resets it.

func (*AnthropicMessages) WithAuthToken added in v0.154.0 

func (a *AnthropicMessages) WithAuthToken(token string) sdk.Client

func (*AnthropicMessages) WithHeader added in v0.154.0 

func (a *AnthropicMessages) WithHeader(name, value string) sdk.Client

func (*AnthropicMessages) WithHeaders added in v0.154.0 

func (a *AnthropicMessages) WithHeaders(headers map[string]string) sdk.Client

func (*AnthropicMessages) WithMiddlewareOptions added in v0.154.0 

func (a *AnthropicMessages) WithMiddlewareOptions(options *sdk.MiddlewareOptions) sdk.Client

func (*AnthropicMessages) WithOptions added in v0.154.0 

func (a *AnthropicMessages) WithOptions(options *sdk.CreateChatCompletionRequest) sdk.Client

func (*AnthropicMessages) WithTools added in v0.154.0 

func (a *AnthropicMessages) WithTools(tools *[]sdk.ChatCompletionTool) sdk.Client

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.