Documentation
¶
Index ¶
- type BlockingResponsesInterceptor
- func (i *BlockingResponsesInterceptor) CorrelatingToolCallID() *string
- func (i *BlockingResponsesInterceptor) Credential() intercept.CredentialInfo
- func (i *BlockingResponsesInterceptor) ID() uuid.UUID
- func (i *BlockingResponsesInterceptor) Model() string
- func (i *BlockingResponsesInterceptor) ProcessRequest(w http.ResponseWriter, r *http.Request) (outErr error)
- func (i *BlockingResponsesInterceptor) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier)
- func (*BlockingResponsesInterceptor) Streaming() bool
- func (i *BlockingResponsesInterceptor) TraceAttributes(r *http.Request) []attribute.KeyValue
- type RequestPayload
- type StreamingResponsesInterceptor
- func (i *StreamingResponsesInterceptor) CorrelatingToolCallID() *string
- func (i *StreamingResponsesInterceptor) Credential() intercept.CredentialInfo
- func (i *StreamingResponsesInterceptor) ID() uuid.UUID
- func (i *StreamingResponsesInterceptor) Model() string
- func (i *StreamingResponsesInterceptor) ProcessRequest(w http.ResponseWriter, r *http.Request) (outErr error)
- func (i *StreamingResponsesInterceptor) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier)
- func (*StreamingResponsesInterceptor) Streaming() bool
- func (i *StreamingResponsesInterceptor) TraceAttributes(r *http.Request) []attribute.KeyValue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockingResponsesInterceptor ¶
type BlockingResponsesInterceptor struct {
// contains filtered or unexported fields
}
func NewBlockingInterceptor ¶
func NewBlockingInterceptor( id uuid.UUID, reqPayload RequestPayload, providerName string, cfg config.OpenAI, clientHeaders http.Header, authHeaderName string, tracer trace.Tracer, cred intercept.CredentialInfo, ) *BlockingResponsesInterceptor
func (*BlockingResponsesInterceptor) CorrelatingToolCallID ¶ added in v1.1.0
func (i *BlockingResponsesInterceptor) CorrelatingToolCallID() *string
func (*BlockingResponsesInterceptor) Credential ¶ added in v1.1.2
func (i *BlockingResponsesInterceptor) Credential() intercept.CredentialInfo
func (*BlockingResponsesInterceptor) ProcessRequest ¶
func (i *BlockingResponsesInterceptor) ProcessRequest(w http.ResponseWriter, r *http.Request) (outErr error)
func (*BlockingResponsesInterceptor) Setup ¶
func (i *BlockingResponsesInterceptor) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier)
func (*BlockingResponsesInterceptor) Streaming ¶
func (*BlockingResponsesInterceptor) Streaming() bool
func (*BlockingResponsesInterceptor) TraceAttributes ¶
func (i *BlockingResponsesInterceptor) TraceAttributes(r *http.Request) []attribute.KeyValue
type RequestPayload ¶ added in v1.1.2
type RequestPayload []byte
RequestPayload is raw JSON bytes of a Responses API request. Methods provide package-specific reads and rewrites while preserving the original body for upstream pass-through. Note: No changes are made on schema error.
func NewRequestPayload ¶ added in v1.1.2
func NewRequestPayload(raw []byte) (RequestPayload, error)
func (RequestPayload) Stream ¶ added in v1.1.2
func (p RequestPayload) Stream() bool
type StreamingResponsesInterceptor ¶
type StreamingResponsesInterceptor struct {
// contains filtered or unexported fields
}
func NewStreamingInterceptor ¶
func NewStreamingInterceptor( id uuid.UUID, reqPayload RequestPayload, providerName string, cfg config.OpenAI, clientHeaders http.Header, authHeaderName string, tracer trace.Tracer, cred intercept.CredentialInfo, ) *StreamingResponsesInterceptor
func (*StreamingResponsesInterceptor) CorrelatingToolCallID ¶ added in v1.1.0
func (i *StreamingResponsesInterceptor) CorrelatingToolCallID() *string
func (*StreamingResponsesInterceptor) Credential ¶ added in v1.1.2
func (i *StreamingResponsesInterceptor) Credential() intercept.CredentialInfo
func (*StreamingResponsesInterceptor) Model ¶
func (i *StreamingResponsesInterceptor) Model() string
func (*StreamingResponsesInterceptor) ProcessRequest ¶
func (i *StreamingResponsesInterceptor) ProcessRequest(w http.ResponseWriter, r *http.Request) (outErr error)
func (*StreamingResponsesInterceptor) Setup ¶
func (i *StreamingResponsesInterceptor) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier)
func (*StreamingResponsesInterceptor) Streaming ¶
func (*StreamingResponsesInterceptor) Streaming() bool
func (*StreamingResponsesInterceptor) TraceAttributes ¶
func (i *StreamingResponsesInterceptor) TraceAttributes(r *http.Request) []attribute.KeyValue
Source Files
Click to show internal directories.
Click to hide internal directories.