handlers

package
v0.15.1-rc1 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2025 License: MIT Imports: 78 Imported by: 0

Documentation

Index

Constants

View Source 
const DefaultMaxUserThreadTools = 100

Variables

This section is empty.

Functions

func ConvertClient 

func ConvertClient(oauthClient v1.OAuthClient, baseURL, clientSecret string) types.OAuthClient

func ConvertDynamicClient 

func ConvertDynamicClient(oauthClient v1.OAuthClient, baseURL, clientSecret, registrationToken string) types.OAuthClient

func ConvertMCPServer added in v0.14.0 

func ConvertMCPServer(server v1.MCPServer, credEnv map[string]string, serverURL, slug string, components ...types.MCPServer) types.MCPServer

func ConvertMCPServerCatalogEntry added in v0.14.0 

func ConvertMCPServerCatalogEntry(entry v1.MCPServerCatalogEntry) types.MCPServerCatalogEntry

func ConvertMCPServerCatalogEntryWithWorkspace added in v0.14.0 

func ConvertMCPServerCatalogEntryWithWorkspace(entry v1.MCPServerCatalogEntry, powerUserWorkspaceID, powerUserID string) types.MCPServerCatalogEntry

func ConvertMCPServerInstance added in v0.14.0 

func ConvertMCPServerInstance(instance v1.MCPServerInstance, serverURL, slug string) types.MCPServerInstance

func ConvertTaskManifest added in v0.7.0 

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

func DeleteCredential 

func DeleteCredential(req api.Context) error

func DeleteCredentialIfExists added in v0.15.0 

func DeleteCredentialIfExists(ctx context.Context, gptClient *gptscript.GPTScript, credCtxs []string, toolName string) error

DeleteCredentialIfExists removes a credential if it exists. Does not return an error if the credential is not found.

func ListCredentials 

func ListCredentials(req api.Context) error

func MCPIDAndAudienceFromConnectURL added in v0.15.0 

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

MCPIDAndAudienceFromConnectURL returns the MCP server or instance name and audience based on the provided connect URL. The connect URL could have an MCP server ID, server instance ID, or MCP catalog entry ID.

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, jwks string) (v1.MCPServer, mcp.ServerConfig, error)

func ServerForActionWithConnectID added in v0.11.0 

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

func SetEnv 

func SetEnv(req api.Context) error

func SlugForMCPServer added in v0.14.0 

func SlugForMCPServer(ctx context.Context, client kclient.Client, server v1.MCPServer, userID, catalogID, workspaceID string) (string, error)

func SlugForMCPServerInstance added in v0.14.0 

func SlugForMCPServerInstance(ctx context.Context, client kclient.Client, instance v1.MCPServerInstance) (string, error)

func StreamLogs added in v0.15.0 

func StreamLogs(ctx context.Context, w http.ResponseWriter, logs io.ReadCloser, opts StreamLogsOptions) error

StreamLogs streams logs from an io.ReadCloser to an HTTP response as Server-Sent Events. It handles: - SSE header setup (Content-Type, Cache-Control, Connection) - Docker log header stripping (8-byte prefix for stdout/stderr) - Context cancellation - Optional keep-alive pings - Proper SSE event formatting

func ToWorkflowManifest added in v0.7.0 

func ToWorkflowManifest(manifest types.TaskManifest) types.WorkflowManifest

func ValidateClientConfig 

func ValidateClientConfig(oauthClient *v1.OAuthClient, oauthConfig OAuthAuthorizationServerConfig) error

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(dispatcher *dispatcher.Dispatcher, mcpSessionManager *mcp.SessionManager, invoker *invoke.Invoker, serverURL, internalServerURL 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 AppPreferencesHandler added in v0.15.0 

type AppPreferencesHandler struct{}

func NewAppPreferencesHandler added in v0.15.0 

func NewAppPreferencesHandler() *AppPreferencesHandler

func (*AppPreferencesHandler) Get added in v0.15.0 

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

func (*AppPreferencesHandler) Update added in v0.15.0 

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

type AssistantHandler 

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

func NewAssistantHandler 

func NewAssistantHandler(dispatcher *dispatcher.Dispatcher, mcpSessionManager *mcp.SessionManager, 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 AuditLogExportHandler added in v0.13.0 

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

func NewAuditLogExportHandler added in v0.13.0 

func NewAuditLogExportHandler(gptClient *gptscript.GPTScript) *AuditLogExportHandler

func (*AuditLogExportHandler) ConfigureStorageCredentials added in v0.13.0 

func (h *AuditLogExportHandler) ConfigureStorageCredentials(req api.Context) error

ConfigureStorageCredentials configures storage provider credentials

func (*AuditLogExportHandler) CreateAuditLogExport added in v0.13.0 

func (h *AuditLogExportHandler) CreateAuditLogExport(req api.Context) error

CreateAuditLogExport creates a new audit log export

func (*AuditLogExportHandler) CreateScheduledAuditLogExport added in v0.13.0 

func (h *AuditLogExportHandler) CreateScheduledAuditLogExport(req api.Context) error

CreateScheduledAuditLogExport creates a new scheduled audit log export

func (*AuditLogExportHandler) DeleteAuditLogExport added in v0.13.0 

func (h *AuditLogExportHandler) DeleteAuditLogExport(req api.Context) error

DeleteAuditLogExport deletes an audit log export

func (*AuditLogExportHandler) DeleteScheduledAuditLogExport added in v0.13.0 

func (h *AuditLogExportHandler) DeleteScheduledAuditLogExport(req api.Context) error

DeleteScheduledAuditLogExport deletes a scheduled audit log export

func (*AuditLogExportHandler) DeleteStorageCredentials added in v0.13.0 

func (h *AuditLogExportHandler) DeleteStorageCredentials(req api.Context) error

DeleteStorageCredentials deletes the storage provider credentials

func (*AuditLogExportHandler) GetAuditLogExport added in v0.13.0 

func (h *AuditLogExportHandler) GetAuditLogExport(req api.Context) error

GetAuditLogExport gets a specific audit log export

func (*AuditLogExportHandler) GetScheduledAuditLogExport added in v0.13.0 

func (h *AuditLogExportHandler) GetScheduledAuditLogExport(req api.Context) error

GetScheduledAuditLogExport gets a specific scheduled audit log export

func (*AuditLogExportHandler) GetStorageCredentials added in v0.13.0 

func (h *AuditLogExportHandler) GetStorageCredentials(req api.Context) error

GetStorageCredentials gets the storage provider credentials

func (*AuditLogExportHandler) ListAuditLogExports added in v0.13.0 

func (h *AuditLogExportHandler) ListAuditLogExports(req api.Context) error

ListAuditLogExports lists audit log exports

func (*AuditLogExportHandler) ListScheduledAuditLogExports added in v0.13.0 

func (h *AuditLogExportHandler) ListScheduledAuditLogExports(req api.Context) error

ListScheduledAuditLogExports lists scheduled audit log exports

func (*AuditLogExportHandler) TestStorageCredentials added in v0.13.0 

func (h *AuditLogExportHandler) TestStorageCredentials(req api.Context) error

TestStorageCredentials tests storage provider credentials

func (*AuditLogExportHandler) UpdateScheduledAuditLogExport added in v0.13.0 

func (h *AuditLogExportHandler) UpdateScheduledAuditLogExport(req api.Context) error

UpdateScheduledAuditLogExport updates a scheduled audit log export

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 EulaHandler added in v0.15.0 

type EulaHandler struct{}

func NewEulaHandler added in v0.15.0 

func NewEulaHandler() *EulaHandler

func (*EulaHandler) Get added in v0.15.0 

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

Get retrieves the EULA acceptance status for the installation

func (*EulaHandler) Update added in v0.15.0 

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

Update records the EULA acceptance or decline for the installation

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, mcpSessionManager *mcp.SessionManager) *InvokeHandler

func (*InvokeHandler) Invoke 

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

type K8sSettingsHandler added in v0.13.0 

type K8sSettingsHandler struct{}

func NewK8sSettingsHandler added in v0.13.0 

func NewK8sSettingsHandler() *K8sSettingsHandler

func (*K8sSettingsHandler) Get added in v0.13.0 

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

func (*K8sSettingsHandler) Update added in v0.13.0 

func (h *K8sSettingsHandler) Update(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, acrHelper *accesscontrolrule.Helper, jwks system.EncodedJWKS) *MCPCatalogHandler

func (*MCPCatalogHandler) AdminListServersForAllEntriesInCatalog added in v0.12.0 

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

AdminListServersForAllEntriesInCatalog returns all servers for all entries in a catalog.

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) GenerateComponentToolPreviews added in v0.15.0 

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

GenerateComponentToolPreviews generates tool previews for a single component of a composite catalog entry using the manifest snapshot embedded in the composite entry. This is used by the composite \"Configure Tools\" flow so that previews are based on the composite's stored manifest, not on any newer version of the standalone MCP catalog entry.

func (*MCPCatalogHandler) GenerateComponentToolPreviewsOAuthURL added in v0.15.0 

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

GenerateComponentToolPreviewsOAuthURL returns an OAuth URL for a single component of a composite catalog entry, using the component manifest snapshot embedded in the composite.

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) RefreshCompositeComponents added in v0.13.0 

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

RefreshCompositeComponents refreshes the component snapshots in a composite catalog entry

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, jwks system.EncodedJWKS, serverURL string) *MCPHandler

func (*MCPHandler) CheckK8sSettingsStatus added in v0.13.0 

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

CheckK8sSettingsStatus checks if a server needs redeployment with new K8s settings

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) ListServerInstances added in v0.12.0 

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

ListServerInstances returns all instances for all servers within a specific catalog

func (*MCPHandler) ListServersFromAllSources added in v0.11.0 

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

func (*MCPHandler) ListServersNeedingK8sUpdateAcrossWorkspaces added in v0.13.0 

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

ListServersNeedingK8sUpdateAcrossWorkspaces lists all servers across ALL workspaces that need redeployment with new K8s settings

func (*MCPHandler) ListServersNeedingK8sUpdateInCatalog added in v0.13.0 

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

ListServersNeedingK8sUpdateInCatalog lists all servers in a catalog that need redeployment with new K8s settings

func (*MCPHandler) ReadResource added in v0.8.0 

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

func (*MCPHandler) RedeployWithK8sSettings added in v0.13.0 

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

RedeployWithK8sSettings redeploys a server with the current K8s settings

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(req api.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 OAuthAuthorizationServerConfig 

type OAuthAuthorizationServerConfig struct {
	// Issuer is the authorization server's issuer identifier, which is a URL that uses the "https" scheme
	// and has no query or fragment components. REQUIRED.
	Issuer string `json:"issuer"`
	// AuthorizationEndpoint is the URL of the authorization server's authorization endpoint.
	// REQUIRED unless no grant types are supported that use the authorization endpoint.
	AuthorizationEndpoint string `json:"authorization_endpoint"`
	// TokenEndpoint is the URL of the authorization server's token endpoint.
	// REQUIRED unless only the implicit grant type is supported.
	TokenEndpoint string `json:"token_endpoint"`
	// JWKSURI is the URL of the authorization server's JWK Set document.
	// OPTIONAL.
	JWKSURI string `json:"jwks_uri,omitempty"`
	// RegistrationEndpoint is the URL of the authorization server's OAuth 2.0 Dynamic Client Registration endpoint.
	// OPTIONAL.
	RegistrationEndpoint string `json:"registration_endpoint,omitempty"`
	// ScopesSupported is a JSON array containing a list of the OAuth 2.0 scope values that this authorization server supports.
	// RECOMMENDED.
	ScopesSupported []string `json:"scopes_supported,omitempty"`
	// ResponseTypesSupported is a JSON array containing a list of the OAuth 2.0 response_type values that this authorization server supports.
	// REQUIRED.
	ResponseTypesSupported []string `json:"response_types_supported"`
	// ResponseModesSupported is a JSON array containing a list of the OAuth 2.0 response_mode values that this authorization server supports.
	// OPTIONAL. Default is ["query", "fragment"].
	ResponseModesSupported []string `json:"response_modes_supported,omitempty"`
	// GrantTypesSupported is a JSON array containing a list of the OAuth 2.0 grant type values that this authorization server supports.
	// OPTIONAL. Default is ["authorization_code", "implicit"].
	GrantTypesSupported []string `json:"grant_types_supported,omitempty"`
	// TokenEndpointAuthMethodsSupported is a JSON array containing a list of client authentication methods supported by this token endpoint.
	// OPTIONAL. Default is "client_secret_basic".
	TokenEndpointAuthMethodsSupported []string `json:"token_endpoint_auth_methods_supported,omitempty"`
	// TokenEndpointAuthSigningAlgValuesSupported is a JSON array containing a list of the JWS signing algorithms supported by the token endpoint.
	// OPTIONAL. Required if "private_key_jwt" or "client_secret_jwt" authentication methods are specified.
	TokenEndpointAuthSigningAlgValuesSupported []string `json:"token_endpoint_auth_signing_alg_values_supported,omitempty"`
	// ServiceDocumentation is the URL of a page containing human-readable information that developers might want or need to know.
	// OPTIONAL.
	ServiceDocumentation string `json:"service_documentation,omitempty"`
	// UILocalesSupported is a JSON array of language tag values from BCP 47 for the user interface.
	// OPTIONAL.
	UILocalesSupported []string `json:"ui_locales_supported,omitempty"`
	// OPPolicyURI is the URL that the authorization server provides to read about the authorization server's requirements.
	// OPTIONAL.
	OPPolicyURI string `json:"op_policy_uri,omitempty"`
	// OPTosURI is the URL that the authorization server provides to read about the authorization server's terms of service.
	// OPTIONAL.
	OPTosURI string `json:"op_tos_uri,omitempty"`
	// RevocationEndpoint is the URL of the authorization server's OAuth 2.0 revocation endpoint.
	// OPTIONAL.
	RevocationEndpoint string `json:"revocation_endpoint,omitempty"`
	// RevocationEndpointAuthMethodsSupported is a JSON array containing a list of client authentication methods supported by this revocation endpoint.
	// OPTIONAL. Default is "client_secret_basic".
	RevocationEndpointAuthMethodsSupported []string `json:"revocation_endpoint_auth_methods_supported,omitempty"`
	// IntrospectionEndpoint is the URL of the authorization server's OAuth 2.0 introspection endpoint.
	// OPTIONAL.
	IntrospectionEndpoint string `json:"introspection_endpoint,omitempty"`
	// IntrospectionEndpointAuthMethodsSupported is a JSON array containing a list of client authentication methods supported by this introspection endpoint.
	// OPTIONAL.
	IntrospectionEndpointAuthMethodsSupported []string `json:"introspection_endpoint_auth_methods_supported,omitempty"`
	// IntrospectionEndpointAuthSigningAlgValuesSupported is a JSON array containing a list of the JWS signing algorithms supported by the introspection endpoint.
	// OPTIONAL. Required if "private_key_jwt" or "client_secret_jwt" authentication methods are specified.
	IntrospectionEndpointAuthSigningAlgValuesSupported []string `json:"introspection_endpoint_auth_signing_alg_values_supported,omitempty"`
	// CodeChallengeMethodsSupported is a JSON array containing a list of PKCE code challenge methods supported by this authorization server.
	// OPTIONAL. If omitted, the authorization server does not support PKCE.
	CodeChallengeMethodsSupported []string `json:"code_challenge_methods_supported,omitempty"`
}

OAuthAuthorizationServerConfig represents the response from /.well-known/oauth-authorization-server as defined in RFC 8414 (OAuth 2.0 Authorization Server Metadata)

type OAuthClientsHandler 

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

func NewOAuthClientsHandler 

func NewOAuthClientsHandler(oauthServerConfig OAuthAuthorizationServerConfig, serverURL string) *OAuthClientsHandler

func (*OAuthClientsHandler) Create 

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

Create handles the POST /api/oauth-clients endpoint.

func (*OAuthClientsHandler) Delete 

func (h *OAuthClientsHandler) Delete(req api.Context) error

Delete handles the DELETE /api/oauth-clients/{client_id} endpoint.

func (*OAuthClientsHandler) Get 

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

Get handles the GET /api/oauth-clients/{client_id} endpoint.

func (*OAuthClientsHandler) List 

func (h *OAuthClientsHandler) List(req api.Context) error

List handles the GET /api/oauth-clients endpoint.

func (*OAuthClientsHandler) RollClientSecret 

func (h *OAuthClientsHandler) RollClientSecret(req api.Context) error

RollClientSecret handles the POST /api/oauth-clients/{client_id}/roll-secret endpoint.

func (*OAuthClientsHandler) Update 

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

Update handles the PUT /api/oauth-clients/{client_id} endpoint.

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, acrHelper *accesscontrolrule.Helper) *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 (p *PowerUserWorkspaceHandler) ListAllEntries(req api.Context) error

func (*PowerUserWorkspaceHandler) ListAllServerInstances added in v0.12.0 

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

func (*PowerUserWorkspaceHandler) ListAllServers added in v0.11.0 

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

func (*PowerUserWorkspaceHandler) ListAllServersForAllEntries added in v0.12.0 

func (p *PowerUserWorkspaceHandler) ListAllServersForAllEntries(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, mcpOAuthChecker MCPOAuthChecker, jwks system.EncodedJWKS, serverURL, internalServerURL 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, mcpSessionManager *mcp.SessionManager, 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 StreamLogsOptions added in v0.15.0 

type StreamLogsOptions struct {
	// SendKeepAlive enables periodic keep-alive pings to prevent connection timeout.
	SendKeepAlive bool
	// KeepAliveInterval sets the interval for keep-alive pings (default 30s).
	KeepAliveInterval time.Duration
	// SendDisconnect enables sending a disconnect event when the client disconnects.
	SendDisconnect bool
	// SendEnded enables sending an ended event when the log stream ends.
	SendEnded bool
}

StreamLogsOptions configures SSE log streaming behavior.

type SystemMCPServerHandler added in v0.15.0 

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

func NewSystemMCPServerHandler added in v0.15.0 

func NewSystemMCPServerHandler(mcpLoader *mcp.SessionManager) *SystemMCPServerHandler

func (*SystemMCPServerHandler) Configure added in v0.15.0 

func (h *SystemMCPServerHandler) Configure(req api.Context) error

Configure configures environment variables for a system MCP server

func (*SystemMCPServerHandler) Create added in v0.15.0 

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

Create creates a new system MCP server

func (*SystemMCPServerHandler) Deconfigure added in v0.15.0 

func (h *SystemMCPServerHandler) Deconfigure(req api.Context) error

Deconfigure clears configuration for a system MCP server

func (*SystemMCPServerHandler) Delete added in v0.15.0 

func (h *SystemMCPServerHandler) Delete(req api.Context) error

Delete deletes a system MCP server

func (*SystemMCPServerHandler) Get added in v0.15.0 

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

Get returns a specific system MCP server

func (*SystemMCPServerHandler) GetDetails added in v0.15.0 

func (h *SystemMCPServerHandler) GetDetails(req api.Context) error

GetDetails returns deployment details for a system MCP server

func (*SystemMCPServerHandler) GetTools added in v0.15.0 

func (h *SystemMCPServerHandler) GetTools(req api.Context) error

GetTools returns the tools provided by a system MCP server

func (*SystemMCPServerHandler) List added in v0.15.0 

func (h *SystemMCPServerHandler) List(req api.Context) error

List returns all system MCP servers

func (*SystemMCPServerHandler) Logs added in v0.15.0 

func (h *SystemMCPServerHandler) Logs(req api.Context) error

Logs streams logs from a system MCP server

func (*SystemMCPServerHandler) Restart added in v0.15.0 

func (h *SystemMCPServerHandler) Restart(req api.Context) error

Restart restarts a system MCP server deployment

func (*SystemMCPServerHandler) Reveal added in v0.15.0 

func (h *SystemMCPServerHandler) Reveal(req api.Context) error

Reveal returns the configuration values (env vars) for a system MCP server

func (*SystemMCPServerHandler) Update added in v0.15.0 

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

Update updates an existing system MCP server

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(ctx context.Context, gatewayClient *client.Client, emailDomain, postgresDSN, engine string, supportDocker, authEnabled, disableUpdateCheck bool) (*VersionHandler, error)

func (*VersionHandler) GetVersion 

func (v *VersionHandler) GetVersion(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.