transformer

Jun 20, 2026

Changes in this version

type StreamHandler

+ func (h *StreamHandler) EmitMessageResponse(w http.ResponseWriter, resp *types.MessageResponse) error

Jun 20, 2026

Changes in this version

+ var ErrStreamReadCanceled = errors.New("stream read canceled by context")

+ func NewCtxReadCloser(ctx context.Context, rc io.ReadCloser) io.ReadCloser

+ func NewCtxReader(ctx context.Context, r io.Reader) io.Reader

Jun 19, 2026

Changes in this version

+ var ErrClientDisconnected = fmt.Errorf("client disconnected")

+ var ErrStreamIdle = fmt.Errorf("upstream stream idle")

+ func GeminiToNormalized(geminiResp *types.GeminiResponse, modelID string) *core.NormalizedResponse

+ func HasThinkingBlocks(messages []types.Message) bool

+ func IsIdleTimeout(err error) bool

+ func NormalizedToAnthropic(req *core.NormalizedRequest, model config.ModelConfig) *types.MessageRequest

+ func NormalizedToGemini(req *core.NormalizedRequest, model config.ModelConfig) *types.GeminiRequest

+ func NormalizedToResponses(req *core.NormalizedRequest, model config.ModelConfig) *types.ResponsesRequest

+ func OpenAIResponseToNormalized(openaiResp *types.ChatCompletionResponse, modelID string) *core.NormalizedResponse

+ func ResponsesToNormalized(responsesResp *types.ResponsesResponse, modelID string) *core.NormalizedResponse

+ func StartIdleWatchdog(ctx context.Context, cancel context.CancelFunc, idleTimeout time.Duration) func()

+ func TransformErrorResponse(statusCode int, message string) map[string]interface

+ func TransformRequestFromNormalized(req *core.NormalizedRequest, model config.ModelConfig) *types.ChatCompletionRequest

+ type RequestTransformer struct

+ func NewRequestTransformer() *RequestTransformer

+ func (t *RequestTransformer) TransformRequest(anthropicReq *types.MessageRequest, model config.ModelConfig) (*types.ChatCompletionRequest, error)

+ func (t *RequestTransformer) TransformToGemini(anthropicReq *types.MessageRequest, model config.ModelConfig) (*types.GeminiRequest, error)

+ func (t *RequestTransformer) TransformToResponses(anthropicReq *types.MessageRequest, model config.ModelConfig) (*types.ResponsesRequest, error)

+ type ResponseTransformer struct

+ func NewResponseTransformer() *ResponseTransformer

+ func (t *ResponseTransformer) TransformGeminiResponse(geminiResp *types.GeminiResponse, originalModel string) (*types.MessageResponse, error)

+ func (t *ResponseTransformer) TransformResponse(openaiResp *types.ChatCompletionResponse, originalModel string) (*types.MessageResponse, error)

+ func (t *ResponseTransformer) TransformResponsesResponse(responsesResp *types.ResponsesResponse, originalModel string) (*types.MessageResponse, error)

+ type StreamHandler struct

+ func NewStreamHandler() *StreamHandler

+ func (h *StreamHandler) ProxyGeminiStream(w http.ResponseWriter, geminiResp io.ReadCloser, originalModel string, ...) error

+ func (h *StreamHandler) ProxyResponsesStream(w http.ResponseWriter, responsesResp io.ReadCloser, originalModel string, ...) error

+ func (h *StreamHandler) ProxyStream(w http.ResponseWriter, openaiResp io.ReadCloser, originalModel string, ...) error