handlers

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2025 License: Apache-2.0 Imports: 78 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func ConvertTaskManifest added in v0.7.0 

func ConvertTaskManifest(manifest *types.WorkflowManifest) types.TaskManifest

func DeleteCredential 

func DeleteCredential(req api.Context) error

func ListCredentials 

func ListCredentials(req api.Context) error

func MCPIDFromConnectURL added in v0.11.0 

func MCPIDFromConnectURL(req api.Context, id string) (string, error)

func MetadataFrom 

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

func RecreateAllCredentials added in v0.7.0 

func RecreateAllCredentials(req api.Context) error

func RevealEnv 

func RevealEnv(req api.Context) error

func ServerForAction added in v0.11.0 

func ServerForAction(req api.Context, id string) (v1.MCPServer, mcp.ServerConfig, error)

func ServerForActionWithConnectID added in v0.11.0 

func ServerForActionWithConnectID(req api.Context, id string) (string, v1.MCPServer, mcp.ServerConfig, error)

func SetEnv 

func SetEnv(req api.Context) error

func ToWorkflowManifest added in v0.7.0 

func ToWorkflowManifest(manifest types.TaskManifest) types.WorkflowManifest

Types

type AccessControlRuleHandler added in v0.8.0 

type AccessControlRuleHandler struct{}

func NewAccessControlRuleHandler added in v0.8.0 

func NewAccessControlRuleHandler() *AccessControlRuleHandler

func (*AccessControlRuleHandler) Create added in v0.8.0 

func (h *AccessControlRuleHandler) Create(req api.Context) error

Create creates a new access control rule for a catalog or workspace.

func (*AccessControlRuleHandler) Delete added in v0.8.0 

func (*AccessControlRuleHandler) Delete(req api.Context) error

Delete deletes an access control rule for a catalog or workspace.

func (*AccessControlRuleHandler) Get added in v0.8.0 

func (*AccessControlRuleHandler) Get(req api.Context) error

Get returns a specific access control rule by ID for a catalog or workspace.

func (*AccessControlRuleHandler) List added in v0.8.0 

func (*AccessControlRuleHandler) List(req api.Context) error

List returns all access control rules for a catalog or workspace.

func (*AccessControlRuleHandler) Update added in v0.8.0 

func (h *AccessControlRuleHandler) Update(req api.Context) error

Update updates an existing access control rule for a catalog or workspace.

type AgentHandler 

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

func NewAgentHandler 

func NewAgentHandler(tokenService *ephemeral.TokenService, dispatcher *dispatcher.Dispatcher, mcpSessionManager *mcp.SessionManager, 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) GetKnowledgeFile added in v0.7.0 

func (a *AgentHandler) GetKnowledgeFile(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(dispatcher *dispatcher.Dispatcher, invoker *invoke.Invoker, events *events.Emitter, cachedClient kclient.WithWatch) *AssistantHandler

func (*AssistantHandler) Abort 

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

func (*AssistantHandler) DeleteCredential 

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

func (*AssistantHandler) DeleteKnowledge 

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

func (*AssistantHandler) Events 

func (a *AssistantHandler) Events(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) GetKnowledgeFile added in v0.7.0 

func (a *AssistantHandler) GetKnowledgeFile(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) SetTools added in v0.7.0 

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

func (*AssistantHandler) Tools 

func (a *AssistantHandler) Tools(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(dispatcher *dispatcher.Dispatcher, postgresDSN string) *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 AvailableModelsHandler 

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

func NewAvailableModelsHandler 

func NewAvailableModelsHandler(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 FileScannerProviderHandler added in v0.8.0 

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

func NewFileScannerProviderHandler added in v0.8.0 

func NewFileScannerProviderHandler(dispatcher *dispatcher.Dispatcher, invoker *invoke.Invoker) *FileScannerProviderHandler

func (*FileScannerProviderHandler) ByID added in v0.8.0 

func (f *FileScannerProviderHandler) ByID(req api.Context) error

func (*FileScannerProviderHandler) Configure added in v0.8.0 

func (f *FileScannerProviderHandler) Configure(req api.Context) error

func (*FileScannerProviderHandler) Deconfigure added in v0.8.0 

func (f *FileScannerProviderHandler) Deconfigure(req api.Context) error

func (*FileScannerProviderHandler) List added in v0.8.0 

func (f *FileScannerProviderHandler) List(req api.Context) error

func (*FileScannerProviderHandler) Reveal added in v0.8.0 

func (f *FileScannerProviderHandler) Reveal(req api.Context) error

func (*FileScannerProviderHandler) Validate added in v0.8.0 

func (f *FileScannerProviderHandler) Validate(req api.Context) error

type FilesHandler added in v0.7.0 

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

func NewFilesHandler added in v0.7.0 

func NewFilesHandler(dispatcher *dispatcher.Dispatcher) *FilesHandler

func (*FilesHandler) DeleteFile added in v0.7.0 

func (f *FilesHandler) DeleteFile(req api.Context) error

func (*FilesHandler) Files added in v0.7.0 

func (f *FilesHandler) Files(req api.Context) error

func (*FilesHandler) GetFile added in v0.7.0 

func (f *FilesHandler) GetFile(req api.Context) error

func (*FilesHandler) UploadFile added in v0.7.0 

func (f *FilesHandler) UploadFile(req api.Context) error

type ImageHandler added in v0.7.0 

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

func NewImageHandler added in v0.7.0 

func NewImageHandler(geminiClient *gemini.Client) *ImageHandler

func (*ImageHandler) GenerateImage added in v0.7.0 

func (h *ImageHandler) GenerateImage(req api.Context) error

func (*ImageHandler) GetImage added in v0.7.0 

func (h *ImageHandler) GetImage(req api.Context) error

func (*ImageHandler) UploadImage added in v0.7.0 

func (h *ImageHandler) UploadImage(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 MCPCatalogHandler added in v0.8.0 

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

func NewMCPCatalogHandler added in v0.8.0 

func NewMCPCatalogHandler(defaultCatalogPath string, serverURL string, sessionManager *mcp.SessionManager, oauthChecker MCPOAuthChecker, gatewayClient *gclient.Client) *MCPCatalogHandler

func (*MCPCatalogHandler) AdminListServersForEntryInCatalog added in v0.8.0 

func (h *MCPCatalogHandler) AdminListServersForEntryInCatalog(req api.Context) error

func (*MCPCatalogHandler) CreateEntry added in v0.8.0 

func (h *MCPCatalogHandler) CreateEntry(req api.Context) error

CreateEntry creates a new entry for a catalog or workspace.

func (*MCPCatalogHandler) DeleteEntry added in v0.8.0 

func (h *MCPCatalogHandler) DeleteEntry(req api.Context) error

func (*MCPCatalogHandler) GenerateToolPreviews added in v0.9.0 

func (h *MCPCatalogHandler) GenerateToolPreviews(req api.Context) error

GenerateToolPreviews launches a temporary instance of an MCP server from a catalog entry to generate tool preview data, then cleans up the instance.

func (*MCPCatalogHandler) GenerateToolPreviewsOAuthURL added in v0.9.0 

func (h *MCPCatalogHandler) GenerateToolPreviewsOAuthURL(req api.Context) error

func (*MCPCatalogHandler) Get added in v0.8.0 

func (*MCPCatalogHandler) Get(req api.Context) error

Get returns a specific catalog by ID.

func (*MCPCatalogHandler) GetEntry added in v0.8.0 

func (h *MCPCatalogHandler) GetEntry(req api.Context) error

GetEntry returns a specific entry from a catalog or workspace.

func (*MCPCatalogHandler) GetServerFromEntry added in v0.11.0 

func (h *MCPCatalogHandler) GetServerFromEntry(req api.Context) error

GetServerFromEntry returns a specific entry from a catalog or workspace.

func (*MCPCatalogHandler) List added in v0.8.0 

func (*MCPCatalogHandler) List(req api.Context) error

List returns all catalogs.

func (*MCPCatalogHandler) ListCategoriesForCatalog added in v0.9.0 

func (h *MCPCatalogHandler) ListCategoriesForCatalog(req api.Context) error

ListCategoriesForCatalog returns all unique categories from entries in a catalog

func (*MCPCatalogHandler) ListEntries added in v0.11.0 

func (h *MCPCatalogHandler) ListEntries(req api.Context) error

ListEntries lists all entries for a catalog or workspace.

func (*MCPCatalogHandler) ListServersForEntry added in v0.11.0 

func (h *MCPCatalogHandler) ListServersForEntry(req api.Context) error

ListServersForEntry returns a specific entry from a catalog or workspace.

func (*MCPCatalogHandler) Refresh added in v0.8.0 

func (h *MCPCatalogHandler) Refresh(req api.Context) error

Refresh refreshes a catalog to sync its entries.

func (*MCPCatalogHandler) Update added in v0.8.0 

func (h *MCPCatalogHandler) Update(req api.Context) error

Update updates a catalog (admin only, default catalog only).

func (*MCPCatalogHandler) UpdateEntry added in v0.8.0 

func (h *MCPCatalogHandler) UpdateEntry(req api.Context) error

type MCPHandler added in v0.8.0 

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

func NewMCPHandler added in v0.8.0 

func NewMCPHandler(mcpLoader *mcp.SessionManager, acrHelper *accesscontrolrule.Helper, mcpOAuthChecker MCPOAuthChecker, serverURL string) *MCPHandler

func (*MCPHandler) CheckOAuth added in v0.8.0 

func (m *MCPHandler) CheckOAuth(req api.Context) error

func (*MCPHandler) ClearOAuthCredentials added in v0.8.0 

func (m *MCPHandler) ClearOAuthCredentials(req api.Context) error

func (*MCPHandler) ConfigureServer added in v0.8.0 

func (m *MCPHandler) ConfigureServer(req api.Context) error

func (*MCPHandler) CreateServer added in v0.8.0 

func (m *MCPHandler) CreateServer(req api.Context) error

func (*MCPHandler) DeconfigureServer added in v0.8.0 

func (m *MCPHandler) DeconfigureServer(req api.Context) error

func (*MCPHandler) DeleteServer added in v0.8.0 

func (m *MCPHandler) DeleteServer(req api.Context) error

func (*MCPHandler) GetEntryFromAllSources added in v0.11.0 

func (m *MCPHandler) GetEntryFromAllSources(req api.Context) error

func (*MCPHandler) GetOAuthURL added in v0.8.0 

func (m *MCPHandler) GetOAuthURL(req api.Context) error

func (*MCPHandler) GetPrompt added in v0.8.0 

func (m *MCPHandler) GetPrompt(req api.Context) error

func (*MCPHandler) GetPrompts added in v0.8.0 

func (m *MCPHandler) GetPrompts(req api.Context) error

func (*MCPHandler) GetResources added in v0.8.0 

func (m *MCPHandler) GetResources(req api.Context) error

func (*MCPHandler) GetServer added in v0.8.0 

func (m *MCPHandler) GetServer(req api.Context) error

func (*MCPHandler) GetServerDetails added in v0.8.0 

func (m *MCPHandler) GetServerDetails(req api.Context) error

func (*MCPHandler) GetServerFromAllSources added in v0.11.0 

func (m *MCPHandler) GetServerFromAllSources(req api.Context) error

func (*MCPHandler) GetTools added in v0.8.0 

func (m *MCPHandler) GetTools(req api.Context) error

func (*MCPHandler) LaunchServer added in v0.8.0 

func (m *MCPHandler) LaunchServer(req api.Context) error

func (*MCPHandler) ListEntriesFromAllSources added in v0.11.0 

func (m *MCPHandler) ListEntriesFromAllSources(req api.Context) error

func (*MCPHandler) ListServer added in v0.8.0 

func (m *MCPHandler) ListServer(req api.Context) error

func (*MCPHandler) ListServersFromAllSources added in v0.11.0 

func (m *MCPHandler) ListServersFromAllSources(req api.Context) error

func (*MCPHandler) ReadResource added in v0.8.0 

func (m *MCPHandler) ReadResource(req api.Context) error

func (*MCPHandler) RestartServerDeployment added in v0.9.0 

func (m *MCPHandler) RestartServerDeployment(req api.Context) error

func (*MCPHandler) Reveal added in v0.8.0 

func (m *MCPHandler) Reveal(req api.Context) error

func (*MCPHandler) SetTools added in v0.8.0 

func (m *MCPHandler) SetTools(req api.Context) error

func (*MCPHandler) StreamServerLogs added in v0.8.0 

func (m *MCPHandler) StreamServerLogs(req api.Context) error

func (*MCPHandler) TriggerUpdate added in v0.8.0 

func (m *MCPHandler) TriggerUpdate(req api.Context) error

func (*MCPHandler) UpdateServer added in v0.11.0 

func (m *MCPHandler) UpdateServer(req api.Context) error

UpdateServer updates the manifest of an MCPServer. This can only be used by the admin (for things in the default catalog) and PowerUserPlusses, for things in their workspaces.

func (*MCPHandler) UpdateServerAlias added in v0.8.0 

func (m *MCPHandler) UpdateServerAlias(req api.Context) error

func (*MCPHandler) UpdateURL added in v0.8.0 

func (m *MCPHandler) UpdateURL(req api.Context) error

type MCPOAuthChecker added in v0.8.0 

type MCPOAuthChecker interface {
	CheckForMCPAuth(ctx context.Context, server v1.MCPServer, config mcp.ServerConfig, userID, mcpID, oauthAppAuthRequestID string) (string, error)
}

MCPOAuthChecker will check the OAuth status for an MCP server. This interface breaks an import cycle.

type MCPWebhookValidationHandler added in v0.8.0 

type MCPWebhookValidationHandler struct{}

func NewMCPWebhookValidationHandler added in v0.8.0 

func NewMCPWebhookValidationHandler() *MCPWebhookValidationHandler

func (*MCPWebhookValidationHandler) Create added in v0.8.0 

func (m *MCPWebhookValidationHandler) Create(req api.Context) error

func (*MCPWebhookValidationHandler) Delete added in v0.8.0 

func (m *MCPWebhookValidationHandler) Delete(req api.Context) error

func (*MCPWebhookValidationHandler) Get added in v0.8.0 

func (m *MCPWebhookValidationHandler) Get(req api.Context) error

func (*MCPWebhookValidationHandler) List added in v0.8.0 

func (m *MCPWebhookValidationHandler) List(req api.Context) error

func (*MCPWebhookValidationHandler) RemoveSecret added in v0.8.0 

func (m *MCPWebhookValidationHandler) RemoveSecret(req api.Context) error

func (*MCPWebhookValidationHandler) Update added in v0.8.0 

func (m *MCPWebhookValidationHandler) Update(req api.Context) error

type MemoryHandler added in v0.8.0 

type MemoryHandler struct {
}

func NewMemoryHandler added in v0.8.0 

func NewMemoryHandler() *MemoryHandler

func (*MemoryHandler) CreateMemory added in v0.8.0 

func (*MemoryHandler) CreateMemory(req api.Context) error

func (*MemoryHandler) DeleteMemories added in v0.8.0 

func (*MemoryHandler) DeleteMemories(req api.Context) error

func (*MemoryHandler) ListMemories added in v0.8.0 

func (*MemoryHandler) ListMemories(req api.Context) error

func (*MemoryHandler) UpdateMemory added in v0.8.0 

func (*MemoryHandler) UpdateMemory(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(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 PowerUserWorkspaceHandler added in v0.11.0 

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

func NewPowerUserWorkspaceHandler added in v0.11.0 

func NewPowerUserWorkspaceHandler(serverURL string) *PowerUserWorkspaceHandler

func (*PowerUserWorkspaceHandler) Get added in v0.11.0 

func (*PowerUserWorkspaceHandler) Get(req api.Context) error

Get returns a specific power user workspace by ID.

func (*PowerUserWorkspaceHandler) List added in v0.11.0 

func (*PowerUserWorkspaceHandler) List(req api.Context) error

List returns power user workspaces. Admins see all, non-admins see only their own.

func (*PowerUserWorkspaceHandler) ListAllAccessControlRules added in v0.11.0 

func (p *PowerUserWorkspaceHandler) ListAllAccessControlRules(req api.Context) error

func (*PowerUserWorkspaceHandler) ListAllEntries added in v0.11.0 

func (*PowerUserWorkspaceHandler) ListAllEntries(req api.Context) error

func (*PowerUserWorkspaceHandler) ListAllServers added in v0.11.0 

func (p *PowerUserWorkspaceHandler) ListAllServers(req api.Context) error

type ProjectInvitationHandler added in v0.8.0 

type ProjectInvitationHandler struct{}

func NewProjectInvitationHandler added in v0.8.0 

func NewProjectInvitationHandler() *ProjectInvitationHandler

func (*ProjectInvitationHandler) AcceptInvitation added in v0.8.0 

func (h *ProjectInvitationHandler) AcceptInvitation(req api.Context) error

func (*ProjectInvitationHandler) CreateInvitationForProject added in v0.8.0 

func (h *ProjectInvitationHandler) CreateInvitationForProject(req api.Context) error

func (*ProjectInvitationHandler) DeleteInvitationForProject added in v0.8.0 

func (h *ProjectInvitationHandler) DeleteInvitationForProject(req api.Context) error

func (*ProjectInvitationHandler) GetInvitation added in v0.8.0 

func (h *ProjectInvitationHandler) GetInvitation(req api.Context) error

func (*ProjectInvitationHandler) ListInvitationsForProject added in v0.8.0 

func (h *ProjectInvitationHandler) ListInvitationsForProject(req api.Context) error

func (*ProjectInvitationHandler) RejectInvitation added in v0.8.0 

func (h *ProjectInvitationHandler) RejectInvitation(req api.Context) error

type ProjectMCPHandler added in v0.8.0 

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

func NewProjectMCPHandler added in v0.8.0 

func NewProjectMCPHandler(mcpLoader *mcp.SessionManager, acrHelper *accesscontrolrule.Helper, tokenService *ephemeral.TokenService, mcpOAuthChecker MCPOAuthChecker, serverURL string) *ProjectMCPHandler

func (*ProjectMCPHandler) CheckOAuth added in v0.8.0 

func (p *ProjectMCPHandler) CheckOAuth(req api.Context) error

func (*ProjectMCPHandler) CreateServer added in v0.8.0 

func (p *ProjectMCPHandler) CreateServer(req api.Context) error

func (*ProjectMCPHandler) DeleteServer added in v0.8.0 

func (p *ProjectMCPHandler) DeleteServer(req api.Context) error

func (*ProjectMCPHandler) GetOAuthURL added in v0.8.0 

func (p *ProjectMCPHandler) GetOAuthURL(req api.Context) error

func (*ProjectMCPHandler) GetPrompt added in v0.8.0 

func (p *ProjectMCPHandler) GetPrompt(req api.Context) error

func (*ProjectMCPHandler) GetPrompts added in v0.8.0 

func (p *ProjectMCPHandler) GetPrompts(req api.Context) error

func (*ProjectMCPHandler) GetResources added in v0.8.0 

func (p *ProjectMCPHandler) GetResources(req api.Context) error

func (*ProjectMCPHandler) GetServer added in v0.8.0 

func (p *ProjectMCPHandler) GetServer(req api.Context) error

func (*ProjectMCPHandler) GetTools added in v0.8.0 

func (p *ProjectMCPHandler) GetTools(req api.Context) error

func (*ProjectMCPHandler) LaunchServer added in v0.8.0 

func (p *ProjectMCPHandler) LaunchServer(req api.Context) error

func (*ProjectMCPHandler) ListServer added in v0.8.0 

func (p *ProjectMCPHandler) ListServer(req api.Context) error

func (*ProjectMCPHandler) ReadResource added in v0.8.0 

func (p *ProjectMCPHandler) ReadResource(req api.Context) error

func (*ProjectMCPHandler) SetTools added in v0.8.0 

func (p *ProjectMCPHandler) SetTools(req api.Context) error

type ProjectShareHandler added in v0.7.0 

type ProjectShareHandler struct {
}

func NewProjectShareHandler added in v0.7.0 

func NewProjectShareHandler() *ProjectShareHandler

func (*ProjectShareHandler) CreateProjectFromShare added in v0.7.0 

func (h *ProjectShareHandler) CreateProjectFromShare(req api.Context) error

func (*ProjectShareHandler) CreateShare added in v0.7.0 

func (h *ProjectShareHandler) CreateShare(req api.Context) error

func (*ProjectShareHandler) DeleteShare added in v0.7.0 

func (h *ProjectShareHandler) DeleteShare(req api.Context) error

func (*ProjectShareHandler) GetShare added in v0.7.0 

func (h *ProjectShareHandler) GetShare(req api.Context) error

func (*ProjectShareHandler) GetShareFromShareID added in v0.8.0 

func (h *ProjectShareHandler) GetShareFromShareID(req api.Context) error

func (*ProjectShareHandler) ListShares added in v0.7.0 

func (h *ProjectShareHandler) ListShares(req api.Context) error

func (*ProjectShareHandler) SetFeatured added in v0.7.0 

func (h *ProjectShareHandler) SetFeatured(req api.Context) error

func (*ProjectShareHandler) UpdateShare added in v0.7.0 

func (h *ProjectShareHandler) UpdateShare(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, invoker *invoke.Invoker) *ProjectsHandler

func (*ProjectsHandler) Authenticate added in v0.7.0 

func (h *ProjectsHandler) Authenticate(req api.Context) (err error)

func (*ProjectsHandler) CopyProject added in v0.7.0 

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

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) DeAuthenticate added in v0.7.0 

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

func (*ProjectsHandler) DeleteMember added in v0.8.0 

func (h *ProjectsHandler) DeleteMember(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) GetDefaultModelForProject added in v0.8.0 

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

func (*ProjectsHandler) GetProject added in v0.7.0 

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

func (*ProjectsHandler) GetProjectThread added in v0.7.0 

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

func (*ProjectsHandler) ListCredentials added in v0.7.0 

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

func (*ProjectsHandler) ListLocalCredentials added in v0.7.0 

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

func (*ProjectsHandler) ListMembers added in v0.8.0 

func (h *ProjectsHandler) ListMembers(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

func (*ProjectsHandler) LocalAuthenticate added in v0.7.0 

func (h *ProjectsHandler) LocalAuthenticate(req api.Context) (err error)

func (*ProjectsHandler) LocalDeAuthenticate added in v0.7.0 

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

func (*ProjectsHandler) UpdateProject added in v0.7.0 

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

func (*ProjectsHandler) UpgradeFromTemplate added in v0.11.0 

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

UpgradeFromTemplate upgrades a project to the latest snapshot of a project if the snapshot has changed since the project was created or the last time the project was upgraded.

type PromptHandler 

type PromptHandler struct{}

func NewPromptHandler 

func NewPromptHandler() *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 ServerInstancesHandler added in v0.8.0 

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

func NewServerInstancesHandler added in v0.8.0 

func NewServerInstancesHandler(acrHelper *accesscontrolrule.Helper, serverURL string) *ServerInstancesHandler

func (*ServerInstancesHandler) ClearOAuthCredentials added in v0.8.0 

func (h *ServerInstancesHandler) ClearOAuthCredentials(req api.Context) error

func (*ServerInstancesHandler) CreateServerInstance added in v0.8.0 

func (h *ServerInstancesHandler) CreateServerInstance(req api.Context) error

func (*ServerInstancesHandler) DeleteServerInstance added in v0.8.0 

func (h *ServerInstancesHandler) DeleteServerInstance(req api.Context) error

func (*ServerInstancesHandler) GetServerInstance added in v0.8.0 

func (h *ServerInstancesHandler) GetServerInstance(req api.Context) error

func (*ServerInstancesHandler) ListServerInstances added in v0.8.0 

func (h *ServerInstancesHandler) ListServerInstances(req api.Context) error

func (*ServerInstancesHandler) ListServerInstancesForServer added in v0.11.0 

func (h *ServerInstancesHandler) ListServerInstancesForServer(req api.Context) error

type SessionStore added in v0.8.0 

type SessionStore string
const (
	SessionStoreDB     SessionStore = "db"
	SessionStoreCookie SessionStore = "cookie"
)

type SlackEvent added in v0.8.0 

type SlackEvent struct {
	Type      string `json:"type"`
	Challenge string `json:"challenge"`
	TeamID    string `json:"team_id"`
	APIAppID  string `json:"api_app_id"`
	Event     struct {
		Type        string `json:"type"`
		User        string `json:"user"`
		Text        string `json:"text"`
		ThreadTS    string `json:"thread_ts"`
		ChannelType string `json:"channel_type"`
		Channel     string `json:"channel"`
		EventTS     string `json:"event_ts"`
		TS          string `json:"ts"`
	} `json:"event"`
}

type SlackEventHandler added in v0.8.0 

type SlackEventHandler struct{}

func NewSlackEventHandler added in v0.8.0 

func NewSlackEventHandler() *SlackEventHandler

func (*SlackEventHandler) HandleEvent added in v0.8.0 

func (h *SlackEventHandler) HandleEvent(req api.Context) error

type SlackHandler added in v0.8.0 

type SlackHandler struct{}

func NewSlackHandler added in v0.8.0 

func NewSlackHandler() *SlackHandler

func (*SlackHandler) Create added in v0.8.0 

func (s *SlackHandler) Create(req api.Context) error

func (*SlackHandler) Delete added in v0.8.0 

func (s *SlackHandler) Delete(req api.Context) error

func (*SlackHandler) Get added in v0.8.0 

func (s *SlackHandler) Get(req api.Context) error

func (*SlackHandler) Update added in v0.8.0 

func (s *SlackHandler) Update(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) AbortFromScope added in v0.7.0 

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

func (*TaskHandler) AbortRun 

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

func (*TaskHandler) AbortRunFromScope added in v0.7.0 

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

func (*TaskHandler) CreateFromScope added in v0.7.0 

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

func (*TaskHandler) Delete 

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

func (*TaskHandler) DeleteFromScope added in v0.7.0 

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

func (*TaskHandler) DeleteRun 

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

func (*TaskHandler) DeleteRunFromScope added in v0.7.0 

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

func (*TaskHandler) Events 

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

func (*TaskHandler) EventsFromScope added in v0.7.0 

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

func (*TaskHandler) Get 

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

func (*TaskHandler) GetFromScope added in v0.7.0 

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

func (*TaskHandler) GetRunFromScope added in v0.7.0 

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

func (*TaskHandler) List 

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

func (*TaskHandler) ListFromScope added in v0.7.0 

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

func (*TaskHandler) ListRuns 

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

func (*TaskHandler) ListRunsFromScope added in v0.7.0 

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

func (*TaskHandler) Run 

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

func (*TaskHandler) RunFromScope added in v0.7.0 

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

func (*TaskHandler) Update 

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

func (*TaskHandler) UpdateFromScope added in v0.7.0 

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

type TemplateHandler added in v0.8.0 

type TemplateHandler struct{}

func NewTemplateHandler added in v0.8.0 

func NewTemplateHandler() *TemplateHandler

func (*TemplateHandler) CopyTemplate added in v0.8.0 

func (h *TemplateHandler) CopyTemplate(req api.Context) error

func (*TemplateHandler) CreateProjectTemplate added in v0.8.0 

func (h *TemplateHandler) CreateProjectTemplate(req api.Context) error

func (*TemplateHandler) DeleteProjectTemplate added in v0.8.0 

func (h *TemplateHandler) DeleteProjectTemplate(req api.Context) error

func (*TemplateHandler) GetProjectTemplate added in v0.8.0 

func (h *TemplateHandler) GetProjectTemplate(req api.Context) error

func (*TemplateHandler) GetTemplate added in v0.8.0 

func (h *TemplateHandler) GetTemplate(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(dispatcher *dispatcher.Dispatcher, 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) DeleteKnowledge 

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

func (*ThreadHandler) Events 

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

func (*ThreadHandler) GetDefaultModelForThread added in v0.8.0 

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

func (*ThreadHandler) GetKnowledgeFile added in v0.7.0 

func (a *ThreadHandler) GetKnowledgeFile(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) UploadKnowledge 

func (a *ThreadHandler) UploadKnowledge(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(invoke *invoke.Invoker) *ToolHandler

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

type ToolReferenceHandler 

type ToolReferenceHandler struct{}

func NewToolReferenceHandler 

func NewToolReferenceHandler() *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 UserDefaultRoleSettingHandler added in v0.11.0 

type UserDefaultRoleSettingHandler struct{}

func NewUserDefaultRoleSettingHandler added in v0.11.0 

func NewUserDefaultRoleSettingHandler() *UserDefaultRoleSettingHandler

func (*UserDefaultRoleSettingHandler) Get added in v0.11.0 

func (h *UserDefaultRoleSettingHandler) Get(req api.Context) error

func (*UserDefaultRoleSettingHandler) Set added in v0.11.0 

func (h *UserDefaultRoleSettingHandler) Set(req api.Context) error

type VersionHandler 

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

func NewVersionHandler 

func NewVersionHandler(emailDomain, postgresDSN 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{}

func NewWorkflowHandler 

func NewWorkflowHandler() *WorkflowHandler

func (*WorkflowHandler) ByID 

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

func (*WorkflowHandler) Delete 

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

func (*WorkflowHandler) List 

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

func (*WorkflowHandler) Update 

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

Source Files

View all Source files

Directories

Path Synopsis
oauth

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.