handlers

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2025 License: Apache-2.0 Imports: 62 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WebhookTokenHTTPHeader = "X-Obot-Webhook-Token"
	WebhookTokenQueryParam = "token"
)
View Source 
const DefaultMaxUserThreadTools = 5

Variables

This section is empty.

Functions

func AgentAuthorizationName added in v0.5.0 

func AgentAuthorizationName(agentID string, userID string) string

func DeleteCredential 

func DeleteCredential(req api.Context) error

func ListCredentials 

func ListCredentials(req api.Context) error

func MetadataFrom 

func MetadataFrom(obj kclient.Object, linkKV ...string) types.Metadata

func RevealEnv 

func RevealEnv(req api.Context) error

func SetEnv 

func SetEnv(req api.Context) error

Types

type AgentHandler 

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

func NewAgentHandler 

func NewAgentHandler(gClient *gptscript.GPTScript, invoker *invoke.Invoker, serverURL string) *AgentHandler

func (*AgentHandler) ApproveKnowledgeFile 

func (a *AgentHandler) ApproveKnowledgeFile(req api.Context) error

func (*AgentHandler) Authenticate added in v0.5.0 

func (a *AgentHandler) Authenticate(req api.Context) (err error)

func (*AgentHandler) ByID 

func (a *AgentHandler) ByID(req api.Context) error

func (*AgentHandler) Create 

func (a *AgentHandler) Create(req api.Context) error

func (*AgentHandler) CreateKnowledgeSource 

func (a *AgentHandler) CreateKnowledgeSource(req api.Context) error

func (*AgentHandler) DeAuthenticate added in v0.5.0 

func (a *AgentHandler) DeAuthenticate(req api.Context) error

func (*AgentHandler) Delete 

func (a *AgentHandler) Delete(req api.Context) error

func (*AgentHandler) DeleteFile 

func (a *AgentHandler) DeleteFile(req api.Context) error

func (*AgentHandler) DeleteKnowledgeFile 

func (a *AgentHandler) DeleteKnowledgeFile(req api.Context) error

func (*AgentHandler) DeleteKnowledgeSource 

func (a *AgentHandler) DeleteKnowledgeSource(req api.Context) error

func (*AgentHandler) EnsureCredentialForKnowledgeSource 

func (a *AgentHandler) EnsureCredentialForKnowledgeSource(req api.Context) error

func (*AgentHandler) GetFile 

func (a *AgentHandler) GetFile(req api.Context) error

func (*AgentHandler) List 

func (a *AgentHandler) List(req api.Context) error

func (*AgentHandler) ListFiles 

func (a *AgentHandler) ListFiles(req api.Context) error

func (*AgentHandler) ListKnowledgeFiles 

func (a *AgentHandler) ListKnowledgeFiles(req api.Context) error

func (*AgentHandler) ListKnowledgeSources 

func (a *AgentHandler) ListKnowledgeSources(req api.Context) error

func (*AgentHandler) ReIngestKnowledgeFile 

func (a *AgentHandler) ReIngestKnowledgeFile(req api.Context) error

func (*AgentHandler) ReSyncKnowledgeSource 

func (a *AgentHandler) ReSyncKnowledgeSource(req api.Context) error

func (*AgentHandler) Script 

func (a *AgentHandler) Script(req api.Context) error

func (*AgentHandler) SetDefault 

func (a *AgentHandler) SetDefault(req api.Context) error

func (*AgentHandler) Update 

func (a *AgentHandler) Update(req api.Context) error

func (*AgentHandler) UpdateKnowledgeSource 

func (a *AgentHandler) UpdateKnowledgeSource(req api.Context) error

func (*AgentHandler) UploadFile 

func (a *AgentHandler) UploadFile(req api.Context) error

func (*AgentHandler) UploadKnowledgeFile 

func (a *AgentHandler) UploadKnowledgeFile(req api.Context) error

func (*AgentHandler) WatchKnowledgeFile added in v0.5.0 

func (a *AgentHandler) WatchKnowledgeFile(req api.Context) error

type AssistantHandler 

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

func NewAssistantHandler 

func NewAssistantHandler(invoker *invoke.Invoker, events *events.Emitter, gptScript *gptscript.GPTScript, cachedClient kclient.Client) *AssistantHandler

func (*AssistantHandler) Abort 

func (a *AssistantHandler) Abort(req api.Context) error

func (*AssistantHandler) AddTool 

func (a *AssistantHandler) AddTool(req api.Context) (retErr error)

func (*AssistantHandler) DeleteCredential 

func (a *AssistantHandler) DeleteCredential(req api.Context) error

func (*AssistantHandler) DeleteFile 

func (a *AssistantHandler) DeleteFile(req api.Context) error

func (*AssistantHandler) DeleteKnowledge 

func (a *AssistantHandler) DeleteKnowledge(req api.Context) error

func (*AssistantHandler) DeleteTool added in v0.5.0 

func (a *AssistantHandler) DeleteTool(req api.Context) error

func (*AssistantHandler) Events 

func (a *AssistantHandler) Events(req api.Context) error

func (*AssistantHandler) Files 

func (a *AssistantHandler) Files(req api.Context) error

func (*AssistantHandler) Get added in v0.5.0 

func (a *AssistantHandler) Get(req api.Context) error

func (*AssistantHandler) GetEnv added in v0.5.0 

func (a *AssistantHandler) GetEnv(req api.Context) error

func (*AssistantHandler) GetFile 

func (a *AssistantHandler) GetFile(req api.Context) error

func (*AssistantHandler) Invoke 

func (a *AssistantHandler) Invoke(req api.Context) error

func (*AssistantHandler) Knowledge 

func (a *AssistantHandler) Knowledge(req api.Context) error

func (*AssistantHandler) List 

func (a *AssistantHandler) List(req api.Context) error

func (*AssistantHandler) ListCredentials 

func (a *AssistantHandler) ListCredentials(req api.Context) error

func (*AssistantHandler) RemoveTool 

func (a *AssistantHandler) RemoveTool(req api.Context) error

func (*AssistantHandler) SetEnv added in v0.5.0 

func (a *AssistantHandler) SetEnv(req api.Context) error

func (*AssistantHandler) Tools 

func (a *AssistantHandler) Tools(req api.Context) error

func (*AssistantHandler) UploadFile 

func (a *AssistantHandler) UploadFile(req api.Context) error

func (*AssistantHandler) UploadKnowledge 

func (a *AssistantHandler) UploadKnowledge(req api.Context) error

type AuthProviderHandler added in v0.5.0 

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

func NewAuthProviderHandler added in v0.5.0 

func NewAuthProviderHandler(gClient *gptscript.GPTScript, dispatcher *dispatcher.Dispatcher) *AuthProviderHandler

func (*AuthProviderHandler) ByID added in v0.5.0 

func (ap *AuthProviderHandler) ByID(req api.Context) error

func (*AuthProviderHandler) Configure added in v0.5.0 

func (ap *AuthProviderHandler) Configure(req api.Context) error

func (*AuthProviderHandler) Deconfigure added in v0.5.0 

func (ap *AuthProviderHandler) Deconfigure(req api.Context) error

func (*AuthProviderHandler) List added in v0.5.0 

func (ap *AuthProviderHandler) List(req api.Context) error

func (*AuthProviderHandler) Reveal added in v0.5.0 

func (ap *AuthProviderHandler) Reveal(req api.Context) error

type AuthorizationHandler added in v0.5.0 

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

func NewAuthorizationHandler added in v0.5.0 

func NewAuthorizationHandler(userClient *client.Client) *AuthorizationHandler

func (*AuthorizationHandler) AddAgentAuthorization added in v0.5.0 

func (a *AuthorizationHandler) AddAgentAuthorization(req api.Context) error

func (*AuthorizationHandler) ListAgentAuthorizations added in v0.5.0 

func (a *AuthorizationHandler) ListAgentAuthorizations(req api.Context) error

func (*AuthorizationHandler) RemoveAgentAuthorization added in v0.5.0 

func (a *AuthorizationHandler) RemoveAgentAuthorization(req api.Context) error

type AvailableModelsHandler 

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

func NewAvailableModelsHandler 

func NewAvailableModelsHandler(gClient *gptscript.GPTScript, dispatcher *dispatcher.Dispatcher) *AvailableModelsHandler

func (*AvailableModelsHandler) List 

func (a *AvailableModelsHandler) List(req api.Context) error

func (*AvailableModelsHandler) ListForModelProvider 

func (a *AvailableModelsHandler) ListForModelProvider(req api.Context) error

type CronJobHandler 

type CronJobHandler struct{}

func NewCronJobHandler 

func NewCronJobHandler() *CronJobHandler

func (*CronJobHandler) ByID 

func (a *CronJobHandler) ByID(req api.Context) error

func (*CronJobHandler) Create 

func (a *CronJobHandler) Create(req api.Context) error

func (*CronJobHandler) Delete 

func (a *CronJobHandler) Delete(req api.Context) error

func (*CronJobHandler) Execute 

func (a *CronJobHandler) Execute(req api.Context) error

func (*CronJobHandler) List 

func (a *CronJobHandler) List(req api.Context) error

func (*CronJobHandler) Update 

func (a *CronJobHandler) Update(req api.Context) error

type DefaultModelAliasHandler 

type DefaultModelAliasHandler struct{}

func NewDefaultModelAliasHandler 

func NewDefaultModelAliasHandler() *DefaultModelAliasHandler

func (*DefaultModelAliasHandler) Create 

func (d *DefaultModelAliasHandler) Create(req api.Context) error

func (*DefaultModelAliasHandler) Delete 

func (d *DefaultModelAliasHandler) Delete(req api.Context) error

func (*DefaultModelAliasHandler) GetByID 

func (d *DefaultModelAliasHandler) GetByID(req api.Context) error

func (*DefaultModelAliasHandler) List 

func (d *DefaultModelAliasHandler) List(req api.Context) error

func (*DefaultModelAliasHandler) Update 

func (d *DefaultModelAliasHandler) Update(req api.Context) error

type EmailReceiverHandler 

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

func NewEmailReceiverHandler 

func NewEmailReceiverHandler(hostname string) *EmailReceiverHandler

func (*EmailReceiverHandler) ByID 

func (e *EmailReceiverHandler) ByID(req api.Context) error

func (*EmailReceiverHandler) Create 

func (e *EmailReceiverHandler) Create(req api.Context) error

func (*EmailReceiverHandler) Delete 

func (e *EmailReceiverHandler) Delete(req api.Context) error

func (*EmailReceiverHandler) List 

func (e *EmailReceiverHandler) List(req api.Context) error

func (*EmailReceiverHandler) Update 

func (e *EmailReceiverHandler) Update(req api.Context) error

type InvokeHandler 

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

func NewInvokeHandler 

func NewInvokeHandler(invoker *invoke.Invoker) *InvokeHandler

func (*InvokeHandler) Invoke 

func (i *InvokeHandler) Invoke(req api.Context) error

type ModelHandler 

type ModelHandler struct{}

func NewModelHandler 

func NewModelHandler() *ModelHandler

func (*ModelHandler) ByID 

func (a *ModelHandler) ByID(req api.Context) error

func (*ModelHandler) Create 

func (a *ModelHandler) Create(req api.Context) error

func (*ModelHandler) Delete 

func (a *ModelHandler) Delete(req api.Context) error

func (*ModelHandler) List 

func (a *ModelHandler) List(req api.Context) error

func (*ModelHandler) Update 

func (a *ModelHandler) Update(req api.Context) error

type ModelProviderHandler 

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

func NewModelProviderHandler 

func NewModelProviderHandler(gClient *gptscript.GPTScript, dispatcher *dispatcher.Dispatcher, invoker *invoke.Invoker) *ModelProviderHandler

func (*ModelProviderHandler) ByID 

func (mp *ModelProviderHandler) ByID(req api.Context) error

func (*ModelProviderHandler) Configure 

func (mp *ModelProviderHandler) Configure(req api.Context) error

func (*ModelProviderHandler) Deconfigure added in v0.5.0 

func (mp *ModelProviderHandler) Deconfigure(req api.Context) error

func (*ModelProviderHandler) List 

func (mp *ModelProviderHandler) List(req api.Context) error

func (*ModelProviderHandler) RefreshModels 

func (mp *ModelProviderHandler) RefreshModels(req api.Context) error

func (*ModelProviderHandler) Reveal 

func (mp *ModelProviderHandler) Reveal(req api.Context) error

func (*ModelProviderHandler) Validate added in v0.5.0 

func (mp *ModelProviderHandler) Validate(req api.Context) error

type ProjectsHandler added in v0.6.0 

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

func NewProjectsHandler added in v0.6.0 

func NewProjectsHandler(cachedClient kclient.Client) *ProjectsHandler

func (*ProjectsHandler) CreateProject added in v0.6.0 

func (h *ProjectsHandler) CreateProject(req api.Context) error

func (*ProjectsHandler) CreateProjectThread added in v0.6.0 

func (h *ProjectsHandler) CreateProjectThread(req api.Context) error

func (*ProjectsHandler) DeleteProject added in v0.6.0 

func (h *ProjectsHandler) DeleteProject(req api.Context) error

func (*ProjectsHandler) DeleteProjectThread added in v0.6.0 

func (h *ProjectsHandler) DeleteProjectThread(req api.Context) error

func (*ProjectsHandler) ListProjectThreads added in v0.6.0 

func (h *ProjectsHandler) ListProjectThreads(req api.Context) error

func (*ProjectsHandler) ListProjects added in v0.6.0 

func (h *ProjectsHandler) ListProjects(req api.Context) error

type PromptHandler 

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

func NewPromptHandler 

func NewPromptHandler(gClient *gptscript.GPTScript) *PromptHandler

func (*PromptHandler) Prompt 

func (p *PromptHandler) Prompt(req api.Context) error

type RunHandler 

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

func NewRunHandler 

func NewRunHandler(events *events.Emitter) *RunHandler

func (*RunHandler) ByID 

func (a *RunHandler) ByID(req api.Context) error

func (*RunHandler) Debug 

func (a *RunHandler) Debug(req api.Context) error

func (*RunHandler) Delete 

func (a *RunHandler) Delete(req api.Context) error

func (*RunHandler) Events 

func (a *RunHandler) Events(req api.Context) error

func (*RunHandler) List 

func (a *RunHandler) List(req api.Context) error

type ShellHandler added in v0.5.0 

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

func NewShellHandler added in v0.5.0 

func NewShellHandler(invoke *invoke.Invoker) (*ShellHandler, error)

func (*ShellHandler) Shell added in v0.5.0 

func (h *ShellHandler) Shell(req api.Context) error

type TableHandler 

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

func NewTableHandler 

func NewTableHandler(gptScript *gptscript.GPTScript) *TableHandler

func (*TableHandler) GetRows 

func (t *TableHandler) GetRows(req api.Context) error

func (*TableHandler) ListTables 

func (t *TableHandler) ListTables(req api.Context) error

type TaskHandler 

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

func NewTaskHandler 

func NewTaskHandler(invoker *invoke.Invoker, events *events.Emitter) *TaskHandler

func (*TaskHandler) Abort 

func (t *TaskHandler) Abort(req api.Context) error

func (*TaskHandler) AbortRun 

func (t *TaskHandler) AbortRun(req api.Context) error

func (*TaskHandler) Create 

func (t *TaskHandler) Create(req api.Context) error

func (*TaskHandler) Delete 

func (t *TaskHandler) Delete(req api.Context) error

func (*TaskHandler) DeleteRun 

func (t *TaskHandler) DeleteRun(req api.Context) error

func (*TaskHandler) Events 

func (t *TaskHandler) Events(req api.Context) error

func (*TaskHandler) Get 

func (t *TaskHandler) Get(req api.Context) error

func (*TaskHandler) GetRun 

func (t *TaskHandler) GetRun(req api.Context) error

func (*TaskHandler) List 

func (t *TaskHandler) List(req api.Context) error

func (*TaskHandler) ListRuns 

func (t *TaskHandler) ListRuns(req api.Context) error

func (*TaskHandler) Run 

func (t *TaskHandler) Run(req api.Context) error

func (*TaskHandler) Update 

func (t *TaskHandler) Update(req api.Context) error

type TestInput added in v0.5.0 

type TestInput struct {
	Input map[string]string    `json:"input"`
	Tool  *types.AssistantTool `json:"tool"`
	Env   map[string]string    `json:"env,omitempty"`
}

type ThreadHandler 

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

func NewThreadHandler 

func NewThreadHandler(gClient *gptscript.GPTScript, events *events.Emitter) *ThreadHandler

func (*ThreadHandler) Abort 

func (a *ThreadHandler) Abort(req api.Context) error

func (*ThreadHandler) ByID 

func (a *ThreadHandler) ByID(req api.Context) error

func (*ThreadHandler) Delete 

func (a *ThreadHandler) Delete(req api.Context) error

func (*ThreadHandler) DeleteFile 

func (a *ThreadHandler) DeleteFile(req api.Context) error

func (*ThreadHandler) DeleteKnowledge 

func (a *ThreadHandler) DeleteKnowledge(req api.Context) error

func (*ThreadHandler) Events 

func (a *ThreadHandler) Events(req api.Context) error

func (*ThreadHandler) Files 

func (a *ThreadHandler) Files(req api.Context) error

func (*ThreadHandler) GetFile 

func (a *ThreadHandler) GetFile(req api.Context) error

func (*ThreadHandler) Knowledge 

func (a *ThreadHandler) Knowledge(req api.Context) error

func (*ThreadHandler) List 

func (a *ThreadHandler) List(req api.Context) error

func (*ThreadHandler) Update 

func (a *ThreadHandler) Update(req api.Context) error

func (*ThreadHandler) UploadFile 

func (a *ThreadHandler) UploadFile(req api.Context) error

func (*ThreadHandler) UploadKnowledge 

func (a *ThreadHandler) UploadKnowledge(req api.Context) error

func (*ThreadHandler) WorkflowExecutions 

func (a *ThreadHandler) WorkflowExecutions(req api.Context) error

func (*ThreadHandler) Workflows 

func (a *ThreadHandler) Workflows(req api.Context) error

type ToolHandler added in v0.5.0 

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

func NewToolHandler added in v0.5.0 

func NewToolHandler(gptScript *gptscript.GPTScript, invoke *invoke.Invoker) *ToolHandler

func (*ToolHandler) Create added in v0.5.0 

func (t *ToolHandler) Create(req api.Context) error

func (*ToolHandler) Get added in v0.5.0 

func (t *ToolHandler) Get(req api.Context) error

func (*ToolHandler) GetEnv added in v0.5.0 

func (t *ToolHandler) GetEnv(req api.Context) error

func (*ToolHandler) SetEnv added in v0.5.0 

func (t *ToolHandler) SetEnv(req api.Context) error

func (*ToolHandler) Test added in v0.5.0 

func (t *ToolHandler) Test(req api.Context) error

type ToolReferenceHandler 

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

func NewToolReferenceHandler 

func NewToolReferenceHandler(gClient *gptscript.GPTScript) *ToolReferenceHandler

func (*ToolReferenceHandler) ByID 

func (a *ToolReferenceHandler) ByID(req api.Context) error

func (*ToolReferenceHandler) Create 

func (a *ToolReferenceHandler) Create(req api.Context) (err error)

func (*ToolReferenceHandler) Delete 

func (a *ToolReferenceHandler) Delete(req api.Context) error

func (*ToolReferenceHandler) ForceRefresh added in v0.5.0 

func (a *ToolReferenceHandler) ForceRefresh(req api.Context) error

func (*ToolReferenceHandler) List 

func (a *ToolReferenceHandler) List(req api.Context) error

func (*ToolReferenceHandler) Update 

func (a *ToolReferenceHandler) Update(req api.Context) error

type ValidationError added in v0.5.0 

type ValidationError struct {
	Err string `json:"error"`
}

func (*ValidationError) Error added in v0.5.0 

func (ve *ValidationError) Error() string

type VersionHandler 

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

func NewVersionHandler 

func NewVersionHandler(emailDomain string, supportDocker, authEnabled bool) *VersionHandler

func (*VersionHandler) GetVersion 

func (v *VersionHandler) GetVersion(req api.Context) error

type WebhookHandler 

type WebhookHandler struct{}

func NewWebhookHandler 

func NewWebhookHandler() *WebhookHandler

func (*WebhookHandler) ByID 

func (a *WebhookHandler) ByID(req api.Context) error

func (*WebhookHandler) Create 

func (a *WebhookHandler) Create(req api.Context) error

func (*WebhookHandler) Delete 

func (a *WebhookHandler) Delete(req api.Context) error

func (*WebhookHandler) Execute 

func (a *WebhookHandler) Execute(req api.Context) error

func (*WebhookHandler) List 

func (a *WebhookHandler) List(req api.Context) error

func (*WebhookHandler) RemoveToken 

func (a *WebhookHandler) RemoveToken(req api.Context) error

func (*WebhookHandler) Update 

func (a *WebhookHandler) Update(req api.Context) error

type WorkflowHandler 

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

func NewWorkflowHandler 

func NewWorkflowHandler(gClient *gptscript.GPTScript, serverURL string, invoker *invoke.Invoker) *WorkflowHandler

func (*WorkflowHandler) Authenticate 

func (a *WorkflowHandler) Authenticate(req api.Context) error

func (*WorkflowHandler) ByID 

func (a *WorkflowHandler) ByID(req api.Context) error

func (*WorkflowHandler) Create 

func (a *WorkflowHandler) Create(req api.Context) error

func (*WorkflowHandler) DeAuthenticate added in v0.5.0 

func (a *WorkflowHandler) DeAuthenticate(req api.Context) error

func (*WorkflowHandler) Delete 

func (a *WorkflowHandler) Delete(req api.Context) error

func (*WorkflowHandler) EnsureCredentialForKnowledgeSource 

func (a *WorkflowHandler) EnsureCredentialForKnowledgeSource(req api.Context) error

func (*WorkflowHandler) List 

func (a *WorkflowHandler) List(req api.Context) error

func (*WorkflowHandler) Script 

func (a *WorkflowHandler) Script(req api.Context) error

func (*WorkflowHandler) Update 

func (a *WorkflowHandler) Update(req api.Context) error

func (*WorkflowHandler) WorkflowExecutions 

func (a *WorkflowHandler) WorkflowExecutions(req api.Context) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.