Versions in this module Expand all Collapse all v6 v6.9.3 Mar 25, 2026 Changes in this version + func BuildErrorResponseBody(status int, errText string) []byte + func BuildOpenAIResponsesStreamErrorChunk(status int, errText string, sequenceNumber int) []byte + func FilterUpstreamHeaders(src http.Header) http.Header + func NonStreamingKeepAliveInterval(cfg *config.SDKConfig) time.Duration + func PassthroughHeadersEnabled(cfg *config.SDKConfig) bool + func StreamingBootstrapRetries(cfg *config.SDKConfig) int + func StreamingKeepAliveInterval(cfg *config.SDKConfig) time.Duration + func WithExecutionSessionID(ctx context.Context, sessionID string) context.Context + func WithPinnedAuthID(ctx context.Context, authID string) context.Context + func WithSelectedAuthIDCallback(ctx context.Context, callback func(string)) context.Context + func WriteUpstreamHeaders(dst http.Header, src http.Header) + type APIHandlerCancelFunc func(params ...interface{}) + type BaseAPIHandler struct + AuthManager *coreauth.Manager + Cfg *config.SDKConfig + func NewBaseAPIHandlers(cfg *config.SDKConfig, authManager *coreauth.Manager) *BaseAPIHandler + func (h *BaseAPIHandler) ExecuteCountWithAuthManager(ctx context.Context, handlerType, modelName string, rawJSON []byte, alt string) ([]byte, http.Header, *interfaces.ErrorMessage) + func (h *BaseAPIHandler) ExecuteStreamWithAuthManager(ctx context.Context, handlerType, modelName string, rawJSON []byte, alt string) (<-chan []byte, http.Header, <-chan *interfaces.ErrorMessage) + func (h *BaseAPIHandler) ExecuteWithAuthManager(ctx context.Context, handlerType, modelName string, rawJSON []byte, alt string) ([]byte, http.Header, *interfaces.ErrorMessage) + func (h *BaseAPIHandler) ForwardStream(c *gin.Context, flusher http.Flusher, cancel func(error), data <-chan []byte, ...) + func (h *BaseAPIHandler) GetAlt(c *gin.Context) string + func (h *BaseAPIHandler) GetContextWithCancel(handler interfaces.APIHandler, c *gin.Context, ctx context.Context) (context.Context, APIHandlerCancelFunc) + func (h *BaseAPIHandler) LoggingAPIResponseError(ctx context.Context, err *interfaces.ErrorMessage) + func (h *BaseAPIHandler) StartNonStreamingKeepAlive(c *gin.Context, ctx context.Context) func() + func (h *BaseAPIHandler) UpdateClients(cfg *config.SDKConfig) + func (h *BaseAPIHandler) WriteErrorResponse(c *gin.Context, msg *interfaces.ErrorMessage) + type ErrorDetail struct + Code string + Message string + Type string + type ErrorResponse struct + Error ErrorDetail + type StreamForwardOptions struct + KeepAliveInterval *time.Duration + WriteChunk func(chunk []byte) + WriteDone func() + WriteKeepAlive func() + WriteTerminalError func(errMsg *interfaces.ErrorMessage) v6.9.2-rc1 Mar 25, 2026
Go to main page