Documentation
¶
Index ¶
- func DefaultNamespace() string
- func DeleteKubernetesAgent(ctx context.Context, name, version, namespace string) error
- func DeleteKubernetesMCPServer(ctx context.Context, name, namespace string) error
- func DeleteKubernetesRemoteMCPServer(ctx context.Context, name, namespace string) error
- func GetKubeClient() (client.Client, error)
- func ListAgents(ctx context.Context, namespace string) ([]*v1alpha2.Agent, error)
- func ListMCPServers(ctx context.Context, namespace string) ([]*kmcpv1alpha1.MCPServer, error)
- func ListRemoteMCPServers(ctx context.Context, namespace string) ([]*v1alpha2.RemoteMCPServer, error)
- func ValidateRuntime(runtime string) error
- type AgentRegistryRuntime
- type RuntimeValidator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultNamespace ¶ added in v0.1.22
func DefaultNamespace() string
DefaultNamespace returns the namespace from the current kubeconfig context, falling back to "default" if it cannot be determined.
func DeleteKubernetesAgent ¶ added in v0.1.11
DeleteKubernetesAgent deletes a kagent Agent CR by name/version.
func DeleteKubernetesMCPServer ¶ added in v0.1.11
DeleteKubernetesMCPServer deletes a kagent MCPServer CR by name.
func DeleteKubernetesRemoteMCPServer ¶ added in v0.1.11
DeleteKubernetesRemoteMCPServer deletes a kagent RemoteMCPServer CR by name.
func GetKubeClient ¶ added in v0.1.13
controller-runtime client singleton
func ListAgents ¶ added in v0.1.13
ListAgents lists all Agent CRs in the given namespace (or all namespaces if empty)
func ListMCPServers ¶ added in v0.1.13
ListMCPServers lists all MCPServer CRs in the given namespace (or all namespaces if empty)
func ListRemoteMCPServers ¶ added in v0.1.13
func ListRemoteMCPServers(ctx context.Context, namespace string) ([]*v1alpha2.RemoteMCPServer, error)
ListRemoteMCPServers lists all RemoteMCPServer CRs in the given namespace (or all namespaces if empty)
func ValidateRuntime ¶
ValidateRuntime checks if a runtime is valid
Types ¶
type AgentRegistryRuntime ¶
type AgentRegistryRuntime interface {
ReconcileAll(
ctx context.Context,
servers []*registry.MCPServerRunRequest,
agents []*registry.AgentRunRequest,
) error
}
func NewAgentRegistryRuntime ¶
func NewAgentRegistryRuntime( registryTranslator registry.Translator, translator api.RuntimeTranslator, runtimeDir string, verbose bool, ) AgentRegistryRuntime
type RuntimeValidator ¶
RuntimeValidator is a function that validates if a runtime value is supported
var ( // SupportedRuntimes defines the available runtimes SupportedRuntimes = []string{"local", "kubernetes"} // CustomRuntimeValidator allows extending the runtimes CustomRuntimeValidator RuntimeValidator )
Source Files
Directories