httpadapter

package
v1.25.4 Latest Latest
Warning

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

Go to latest
Published: Oct 1, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(coreProtocol core.Converter, route protocol.RouteSpec, opts protocol.Options) protocol.Protocol

func NewAnthropic

func NewAnthropic(opts protocol.Options) protocol.Protocol

func NewGemini

func NewGemini(opts protocol.Options) protocol.Protocol

func NewOllama

func NewOllama(opts protocol.Options) protocol.Protocol

func NewOpenAIChat

func NewOpenAIChat(opts protocol.Options) protocol.Protocol

func NewOpenAIResponses

func NewOpenAIResponses(opts protocol.Options) protocol.Protocol

Types

type Adapter

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

func (*Adapter) BuildHTTPRequest

func (a *Adapter) BuildHTTPRequest(ctx context.Context, baseURL, token string, r *ir.Request) (*http.Request, error)

func (*Adapter) BuildRawHTTPRequest added in v1.24.0

func (a *Adapter) BuildRawHTTPRequest(ctx context.Context, baseURL, token, model string, stream bool, source *http.Request, body []byte) (*http.Request, error)

BuildRawHTTPRequest applies transport settings without decoding protocol content.

func (*Adapter) DecodeRequest

func (a *Adapter) DecodeRequest(c *gin.Context) (*ir.Request, error)

func (*Adapter) DecodeRequestBody

func (a *Adapter) DecodeRequestBody(body []byte, path string) (*ir.Request, error)

DecodeRequestBody decodes a source-protocol request without requiring a Gin context. It is used by transports such as the Responses WebSocket endpoint that receive request payloads as WebSocket messages instead of HTTP bodies.

func (*Adapter) DecodeResponse

func (a *Adapter) DecodeResponse(body []byte) (*ir.Response, error)

func (*Adapter) Name

func (a *Adapter) Name() string

func (*Adapter) NewStreamReader

func (a *Adapter) NewStreamReader(resp *http.Response) protocol.StreamReader

func (*Adapter) NewStreamWriter

func (a *Adapter) NewStreamWriter(c *gin.Context) protocol.StreamWriter

func (*Adapter) Route

func (a *Adapter) Route() protocol.RouteSpec

func (*Adapter) WriteResponse

func (a *Adapter) WriteResponse(c *gin.Context, r *ir.Response) error

Source Files

  • adapter.go
  • passthrough.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL