server

Documentation

Index

• Constants
• func LogRequest(logger *slog.Logger) openai.MiddlewareFunc
• func SetContentType(ct string) openai.MiddlewareFunc
• type APIError
  • func NewAPIError(message, errorType string) *APIError
  • func NewMustNotBeEmptyError(param string) *APIError
  • func NewNotFoundError(obj db.Storer) *APIError
  • func (e *APIError) Error() string
  • func (e *APIError) String() string
• type Config
• type ExtendedTransformer
• type JobRespondStreamer
• type JobResponder
• type JobRunner
• type MiddlewareFunc
• type Server
  • func NewServer(db *db.DB, kbm *kb.KnowledgeBaseManager) *Server
  • func (s *Server) CancelFineTuningJob(w http.ResponseWriter, _ *http.Request, _ string)
  • func (s *Server) CancelRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)
  • func (s *Server) CreateAssistant(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateAssistantFile(w http.ResponseWriter, r *http.Request, assistantID string)
  • func (s *Server) CreateChatCompletion(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateCompletion(w http.ResponseWriter, _ *http.Request)
  • func (s *Server) CreateEmbedding(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateFile(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateFineTuningJob(w http.ResponseWriter, _ *http.Request)
  • func (s *Server) CreateImage(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateImageEdit(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateImageVariation(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateMessage(w http.ResponseWriter, r *http.Request, threadID string)
  • func (s *Server) CreateModeration(w http.ResponseWriter, _ *http.Request)
  • func (s *Server) CreateRun(w http.ResponseWriter, r *http.Request, threadID string)
  • func (s *Server) CreateSpeech(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateThread(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateThreadAndRun(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateTranscription(w http.ResponseWriter, r *http.Request)
  • func (s *Server) CreateTranslation(w http.ResponseWriter, r *http.Request)
  • func (s *Server) DeleteAssistant(w http.ResponseWriter, r *http.Request, assistantID string)
  • func (s *Server) DeleteAssistantFile(w http.ResponseWriter, r *http.Request, assistantID string, fileID string)
  • func (s *Server) DeleteFile(w http.ResponseWriter, r *http.Request, fileID string)
  • func (s *Server) DeleteModel(w http.ResponseWriter, r *http.Request, modelID string)
  • func (s *Server) DeleteThread(w http.ResponseWriter, r *http.Request, threadID string)
  • func (s *Server) DownloadFile(w http.ResponseWriter, _ *http.Request, _ string)
  • func (s *Server) GetAssistant(w http.ResponseWriter, r *http.Request, assistantID string)
  • func (s *Server) GetAssistantFile(w http.ResponseWriter, r *http.Request, assistantID string, fileID string)
  • func (s *Server) GetMessage(w http.ResponseWriter, r *http.Request, threadID string, messageID string)
  • func (s *Server) GetMessageFile(w http.ResponseWriter, r *http.Request, threadID string, messageID string, ...)
  • func (s *Server) GetRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)
  • func (s *Server) GetRunStep(w http.ResponseWriter, r *http.Request, threadID string, runID string, ...)
  • func (s *Server) GetThread(w http.ResponseWriter, r *http.Request, threadID string)
  • func (s *Server) ListAssistantFiles(w http.ResponseWriter, r *http.Request, assistantID string, ...)
  • func (s *Server) ListAssistants(w http.ResponseWriter, r *http.Request, params openai.ListAssistantsParams)
  • func (s *Server) ListFiles(w http.ResponseWriter, r *http.Request, params openai.ListFilesParams)
  • func (s *Server) ListFineTuningEvents(w http.ResponseWriter, _ *http.Request, _ string, ...)
  • func (s *Server) ListMessageFiles(w http.ResponseWriter, r *http.Request, threadID string, messageID string, ...)
  • func (s *Server) ListMessages(w http.ResponseWriter, r *http.Request, threadID string, ...)
  • func (s *Server) ListModels(w http.ResponseWriter, r *http.Request)
  • func (s *Server) ListPaginatedFineTuningJobs(w http.ResponseWriter, _ *http.Request, ...)
  • func (s *Server) ListRunSteps(w http.ResponseWriter, r *http.Request, threadID string, runID string, ...)
  • func (s *Server) ListRuns(w http.ResponseWriter, r *http.Request, threadID string, ...)
  • func (s *Server) ModifyAssistant(w http.ResponseWriter, r *http.Request, assistantID string)
  • func (s *Server) ModifyMessage(w http.ResponseWriter, r *http.Request, threadID string, messageID string)
  • func (s *Server) ModifyRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)
  • func (s *Server) ModifyThread(w http.ResponseWriter, r *http.Request, threadID string)
  • func (s *Server) RetrieveFile(w http.ResponseWriter, r *http.Request, fileID string)
  • func (s *Server) RetrieveFineTuningJob(w http.ResponseWriter, r *http.Request, fineTuningJobID string)
  • func (s *Server) RetrieveModel(w http.ResponseWriter, r *http.Request, modelID string)
  • func (s *Server) Start(ctx context.Context, wg *sync.WaitGroup, config Config) error
  • func (s *Server) SubmitToolOuputsToRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)
  • func (s *Server) XConfirmRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)
  • func (s *Server) XConfirmToolRun(w http.ResponseWriter, r *http.Request, toolID string)
  • func (s *Server) XCreateTool(w http.ResponseWriter, r *http.Request)
  • func (s *Server) XDeleteTool(w http.ResponseWriter, r *http.Request, toolID string)
  • func (s *Server) XGetTool(w http.ResponseWriter, r *http.Request, toolID string)
  • func (s *Server) XInspectTool(w http.ResponseWriter, r *http.Request)
  • func (s *Server) XListRunStepEvents(w http.ResponseWriter, r *http.Request, threadID string, runID string, ...)
  • func (s *Server) XListThreads(w http.ResponseWriter, r *http.Request, params openai.XListThreadsParams)
  • func (s *Server) XListTools(w http.ResponseWriter, r *http.Request, params openai.XListToolsParams)
  • func (s *Server) XModifyTool(w http.ResponseWriter, r *http.Request, toolID string)
  • func (s *Server) XRunTool(w http.ResponseWriter, r *http.Request)
  • func (s *Server) XStreamRun(w http.ResponseWriter, r *http.Request, threadID string, runID string, ...)
• type Transformer
• type Triggers
  • func (t *Triggers) Complete()

Constants

const (
	InvalidRequestErrorType = "invalid_request_error"
	InternalErrorType       = "internal_error"
)

Functions

func LogRequest

func LogRequest(logger *slog.Logger) openai.MiddlewareFunc

func SetContentType

func SetContentType(ct string) openai.MiddlewareFunc

Types

type APIError

type APIError struct {
	Code    any     `json:"code,omitempty"`
	Message string  `json:"message"`
	Param   *string `json:"param,omitempty"`
	Type    string  `json:"type"`
}

func NewAPIError

func NewAPIError(message, errorType string) *APIError

func NewMustNotBeEmptyError

func NewMustNotBeEmptyError(param string) *APIError

func NewNotFoundError

func NewNotFoundError(obj db.Storer) *APIError

func (*APIError) Error

func (e *APIError) Error() string

func (*APIError) String

func (e *APIError) String() string

type Config

type Config struct {
	ServerURL, Port, APIBase string
	Triggers                 *Triggers
}

type ExtendedTransformer

type ExtendedTransformer interface {
	Transformer
	ToPublicOpenAI() any
}

type JobRespondStreamer

type JobRespondStreamer interface {
	db.Storer
	JobResponder
	GetIndex() int
	GetEvent() string
}

type JobResponder

type JobResponder interface {
	GetRequestID() string
	GetStatusCode() int
	GetErrorString() string
	ToPublic() any
	FromPublic(any) error
	IsDone() bool
}

type JobRunner

type JobRunner interface {
	ToPublic() any
	FromPublic(any) error
	IsDone() bool
}

type MiddlewareFunc

type MiddlewareFunc func(http.Handler) http.Handler

type Server

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

func NewServer

func NewServer(db *db.DB, kbm *kb.KnowledgeBaseManager) *Server

func (*Server) CancelFineTuningJob

func (s *Server) CancelFineTuningJob(w http.ResponseWriter, _ *http.Request, _ string)

func (*Server) CancelRun

func (s *Server) CancelRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)

func (*Server) CreateAssistant

func (s *Server) CreateAssistant(w http.ResponseWriter, r *http.Request)

func (*Server) CreateAssistantFile

func (s *Server) CreateAssistantFile(w http.ResponseWriter, r *http.Request, assistantID string)

func (*Server) CreateChatCompletion

func (s *Server) CreateChatCompletion(w http.ResponseWriter, r *http.Request)

func (*Server) CreateCompletion

func (s *Server) CreateCompletion(w http.ResponseWriter, _ *http.Request)

func (*Server) CreateEmbedding

func (s *Server) CreateEmbedding(w http.ResponseWriter, r *http.Request)

func (*Server) CreateFile

func (s *Server) CreateFile(w http.ResponseWriter, r *http.Request)

func (*Server) CreateFineTuningJob

func (s *Server) CreateFineTuningJob(w http.ResponseWriter, _ *http.Request)

func (*Server) CreateImage

func (s *Server) CreateImage(w http.ResponseWriter, r *http.Request)

func (*Server) CreateImageEdit

func (s *Server) CreateImageEdit(w http.ResponseWriter, r *http.Request)

func (*Server) CreateImageVariation

func (s *Server) CreateImageVariation(w http.ResponseWriter, r *http.Request)

func (*Server) CreateMessage

func (s *Server) CreateMessage(w http.ResponseWriter, r *http.Request, threadID string)

func (*Server) CreateModeration

func (s *Server) CreateModeration(w http.ResponseWriter, _ *http.Request)

func (*Server) CreateRun

func (s *Server) CreateRun(w http.ResponseWriter, r *http.Request, threadID string)

func (*Server) CreateSpeech

func (s *Server) CreateSpeech(w http.ResponseWriter, r *http.Request)

func (*Server) CreateThread

func (s *Server) CreateThread(w http.ResponseWriter, r *http.Request)

func (*Server) CreateThreadAndRun

func (s *Server) CreateThreadAndRun(w http.ResponseWriter, r *http.Request)

func (*Server) CreateTranscription

func (s *Server) CreateTranscription(w http.ResponseWriter, r *http.Request)

func (*Server) CreateTranslation

func (s *Server) CreateTranslation(w http.ResponseWriter, r *http.Request)

func (*Server) DeleteAssistant

func (s *Server) DeleteAssistant(w http.ResponseWriter, r *http.Request, assistantID string)

func (*Server) DeleteAssistantFile

func (s *Server) DeleteAssistantFile(w http.ResponseWriter, r *http.Request, assistantID string, fileID string)

func (*Server) DeleteFile

func (s *Server) DeleteFile(w http.ResponseWriter, r *http.Request, fileID string)

func (*Server) DeleteModel

func (s *Server) DeleteModel(w http.ResponseWriter, r *http.Request, modelID string)

func (*Server) DeleteThread

func (s *Server) DeleteThread(w http.ResponseWriter, r *http.Request, threadID string)

func (*Server) DownloadFile

func (s *Server) DownloadFile(w http.ResponseWriter, _ *http.Request, _ string)

func (*Server) GetAssistant

func (s *Server) GetAssistant(w http.ResponseWriter, r *http.Request, assistantID string)

func (*Server) GetAssistantFile

func (s *Server) GetAssistantFile(w http.ResponseWriter, r *http.Request, assistantID string, fileID string)

func (*Server) GetMessage

func (s *Server) GetMessage(w http.ResponseWriter, r *http.Request, threadID string, messageID string)

func (*Server) GetMessageFile

func (s *Server) GetMessageFile(w http.ResponseWriter, r *http.Request, threadID string, messageID string, fileID string)

func (*Server) GetRun

func (s *Server) GetRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)

func (*Server) GetRunStep

func (s *Server) GetRunStep(w http.ResponseWriter, r *http.Request, threadID string, runID string, stepID string)

func (*Server) GetThread

func (s *Server) GetThread(w http.ResponseWriter, r *http.Request, threadID string)

func (*Server) ListAssistantFiles

func (s *Server) ListAssistantFiles(w http.ResponseWriter, r *http.Request, assistantID string, params openai.ListAssistantFilesParams)

func (*Server) ListAssistants

func (s *Server) ListAssistants(w http.ResponseWriter, r *http.Request, params openai.ListAssistantsParams)

func (*Server) ListFiles

func (s *Server) ListFiles(w http.ResponseWriter, r *http.Request, params openai.ListFilesParams)

func (*Server) ListFineTuningEvents

func (s *Server) ListFineTuningEvents(w http.ResponseWriter, _ *http.Request, _ string, _ openai.ListFineTuningEventsParams)

func (*Server) ListMessageFiles

func (s *Server) ListMessageFiles(w http.ResponseWriter, r *http.Request, threadID string, messageID string, params openai.ListMessageFilesParams)

func (*Server) ListMessages

func (s *Server) ListMessages(w http.ResponseWriter, r *http.Request, threadID string, params openai.ListMessagesParams)

func (*Server) ListModels

func (s *Server) ListModels(w http.ResponseWriter, r *http.Request)

func (*Server) ListPaginatedFineTuningJobs

func (s *Server) ListPaginatedFineTuningJobs(w http.ResponseWriter, _ *http.Request, _ openai.ListPaginatedFineTuningJobsParams)

func (*Server) ListRunSteps

func (s *Server) ListRunSteps(w http.ResponseWriter, r *http.Request, threadID string, runID string, params openai.ListRunStepsParams)

func (*Server) ListRuns

func (s *Server) ListRuns(w http.ResponseWriter, r *http.Request, threadID string, params openai.ListRunsParams)

func (*Server) ModifyAssistant

func (s *Server) ModifyAssistant(w http.ResponseWriter, r *http.Request, assistantID string)

func (*Server) ModifyMessage

func (s *Server) ModifyMessage(w http.ResponseWriter, r *http.Request, threadID string, messageID string)

func (*Server) ModifyRun

func (s *Server) ModifyRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)

func (*Server) ModifyThread

func (s *Server) ModifyThread(w http.ResponseWriter, r *http.Request, threadID string)

func (*Server) RetrieveFile

func (s *Server) RetrieveFile(w http.ResponseWriter, r *http.Request, fileID string)

func (*Server) RetrieveFineTuningJob

func (s *Server) RetrieveFineTuningJob(w http.ResponseWriter, r *http.Request, fineTuningJobID string)

func (*Server) RetrieveModel

func (s *Server) RetrieveModel(w http.ResponseWriter, r *http.Request, modelID string)

func (*Server) Start

func (s *Server) Start(ctx context.Context, wg *sync.WaitGroup, config Config) error

func (*Server) SubmitToolOuputsToRun

func (s *Server) SubmitToolOuputsToRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)

func (*Server) XConfirmRun

func (s *Server) XConfirmRun(w http.ResponseWriter, r *http.Request, threadID string, runID string)

func (*Server) XConfirmToolRun

func (s *Server) XConfirmToolRun(w http.ResponseWriter, r *http.Request, toolID string)

func (*Server) XCreateTool

func (s *Server) XCreateTool(w http.ResponseWriter, r *http.Request)

func (*Server) XDeleteTool

func (s *Server) XDeleteTool(w http.ResponseWriter, r *http.Request, toolID string)

func (*Server) XGetTool

func (s *Server) XGetTool(w http.ResponseWriter, r *http.Request, toolID string)

func (*Server) XInspectTool

func (s *Server) XInspectTool(w http.ResponseWriter, r *http.Request)

func (*Server) XListRunStepEvents

func (s *Server) XListRunStepEvents(w http.ResponseWriter, r *http.Request, threadID string, runID string, stepID string, params openai.XListRunStepEventsParams)

func (*Server) XListThreads

func (s *Server) XListThreads(w http.ResponseWriter, r *http.Request, params openai.XListThreadsParams)

func (*Server) XListTools

func (s *Server) XListTools(w http.ResponseWriter, r *http.Request, params openai.XListToolsParams)

func (*Server) XModifyTool

func (s *Server) XModifyTool(w http.ResponseWriter, r *http.Request, toolID string)

func (*Server) XRunTool

func (s *Server) XRunTool(w http.ResponseWriter, r *http.Request)

func (*Server) XStreamRun

func (s *Server) XStreamRun(w http.ResponseWriter, r *http.Request, threadID string, runID string, params openai.XStreamRunParams)

type Transformer

type Transformer interface {
	db.Storer
	ToPublic() any
	FromPublic(any) error
}

type Triggers

type Triggers struct {
	ChatCompletion, Run, RunStep, RunTool, Image, Embeddings, Audio trigger.Trigger
}

func (*Triggers) Complete

func (t *Triggers) Complete()