Documentation
¶
Index ¶
- func ConfigurationHasDrifted(ctx context.Context, gatewayClient *gateway.Client, server *v1.MCPServer, ...) (bool, error)
- type Handler
- func (h *Handler) CleanupNestedCompositeServers(req router.Request, _ router.Response) error
- func (h *Handler) DeleteServersForAnonymousUser(req router.Request, _ router.Response) error
- func (h *Handler) DeleteServersWithoutRuntime(req router.Request, _ router.Response) error
- func (h *Handler) DetectDrift(req router.Request, _ router.Response) error
- func (h *Handler) DetectK8sSettingsDrift(req router.Request, _ router.Response) error
- func (h *Handler) EnsureCompositeComponents(req router.Request, _ router.Response) error
- func (h *Handler) EnsureMCPCatalogID(req router.Request, _ router.Response) error
- func (h *Handler) EnsureMCPNetworkPolicy(req router.Request, _ router.Response) error
- func (*Handler) EnsureMCPServerInstanceUserCount(req router.Request, _ router.Response) error
- func (h *Handler) EnsureMCPServerSecretInfo(req router.Request, _ router.Response) error
- func (h *Handler) MigrateSharedWithinMCPCatalogName(req router.Request, _ router.Response) error
- func (h *Handler) SetNonDeployServerStatus(req router.Request, _ router.Response) error
- func (h *Handler) ShutdownIdleServers(req router.Request, resp router.Response) error
- func (h *Handler) SyncOAuthCredentialStatus(req router.Request, _ router.Response) error
- func (h *Handler) SyncOAuthMetadata(req router.Request, _ router.Response) error
- func (h *Handler) SyncThirdPartyAuthStatus(req router.Request, _ router.Response) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigurationHasDrifted ¶ added in v0.23.0
func ConfigurationHasDrifted(ctx context.Context, gatewayClient *gateway.Client, server *v1.MCPServer, entryManifest types.MCPServerCatalogEntryManifest, defaultDenyAllEgress bool) (bool, error)
ConfigurationHasDrifted compares runtime config, env, resources, and multi-user config between a server and a catalog entry manifest. Static values omitted from the persisted server manifest are restored from its gateway credential before comparison.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func New ¶
func New(gatewayClient *gateway.Client, mcpSessionManager *mcp.SessionManager, tokenStore mcp.GlobalTokenStore, networkPolicyProviderEnabled, defaultDenyAllEgress bool, singleUserIdleShutdownDelay, multiUserIdleShutdownDelay, agentIdleShutdownDelay time.Duration, baseURL string, mcpRuntimeBackend string, mcpImagePullSecrets []string) *Handler
func (*Handler) CleanupNestedCompositeServers ¶ added in v0.15.0
CleanupNestedCompositeServers removes component servers with composite runtimes from composite MCP servers. This handler cleans up servers that were created before API validation to prevent nested composite servers.
func (*Handler) DeleteServersForAnonymousUser ¶ added in v0.15.0
func (*Handler) DeleteServersWithoutRuntime ¶
func (*Handler) DetectDrift ¶
func (*Handler) DetectK8sSettingsDrift ¶ added in v0.16.0
DetectK8sSettingsDrift detects when a server needs redeployment with new K8s settings, including managed image pull secrets. PSA compliance checking is handled separately in the deployment handler since it requires access to the actual Deployment object to inspect container security contexts.
func (*Handler) EnsureCompositeComponents ¶ added in v0.16.0
func (*Handler) EnsureMCPCatalogID ¶ added in v0.15.0
func (*Handler) EnsureMCPNetworkPolicy ¶ added in v0.21.0
func (*Handler) EnsureMCPServerInstanceUserCount ¶
EnsureMCPServerInstanceUserCount ensures that mcp server instance user count for multi-user MCP servers is up to date.
func (*Handler) EnsureMCPServerSecretInfo ¶ added in v0.15.0
func (*Handler) MigrateSharedWithinMCPCatalogName ¶ added in v0.11.0
func (*Handler) SetNonDeployServerStatus ¶ added in v0.24.0
SetNonDeployServerStatus sets the deployment status for servers that don't have a corresponding deployment.
func (*Handler) ShutdownIdleServers ¶ added in v0.19.0
func (*Handler) SyncOAuthCredentialStatus ¶ added in v0.17.0
SyncOAuthCredentialStatus syncs the OAuthCredentialConfigured status from the catalog entry. This replaces the push-based propagation logic with a pull-based approach where each MCP server is responsible for syncing its own status from its parent catalog entry.
Source Files