Documentation
¶
Overview ¶
internal/controllers/manager.go
internal/controllers/mcpmemory_controller.go
internal/controllers/mcppostgres_controller.go
internal/controllers/mcpserver_controller.go
internal/controllers/mcptaskscheduler_controller.go
internal/controllers/mcptoolbox_controller.go
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ControllerManager ¶
type ControllerManager struct {
// contains filtered or unexported fields
}
ControllerManager manages all MCP controllers
func NewControllerManager ¶
func NewControllerManager(namespace string, cfg *config.ComposeConfig) (*ControllerManager, error)
NewControllerManager creates a new controller manager
func StartControllerManagerInBackground ¶
func StartControllerManagerInBackground(namespace string, cfg *config.ComposeConfig) (*ControllerManager, error)
StartControllerManagerInBackground starts the controller manager in a separate goroutine
func (*ControllerManager) GetClient ¶
func (cm *ControllerManager) GetClient() client.Client
GetClient returns the controller manager's Kubernetes client
func (*ControllerManager) IsReady ¶
func (cm *ControllerManager) IsReady() bool
IsReady checks if the controller manager is ready
func (*ControllerManager) Start ¶
func (cm *ControllerManager) Start(ctx context.Context) error
Start starts the controller manager
func (*ControllerManager) Stop ¶
func (cm *ControllerManager) Stop() error
Stop stops the controller manager
type MCPMemoryReconciler ¶
type MCPMemoryReconciler struct {
client.Client
Scheme *runtime.Scheme
Logger *logging.Logger
Config *config.ComposeConfig
}
MCPMemoryReconciler reconciles a MCPMemory object
func (*MCPMemoryReconciler) Reconcile ¶
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
func (*MCPMemoryReconciler) SetupWithManager ¶
func (r *MCPMemoryReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type MCPPostgresReconciler ¶
MCPPostgresReconciler reconciles a MCPPostgres object
func (*MCPPostgresReconciler) SetupWithManager ¶
func (r *MCPPostgresReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager
type MCPProxyReconciler ¶
type MCPProxyReconciler struct {
client.Client
Scheme *runtime.Scheme
Logger *logging.Logger
// Enhanced service discovery integration
ServiceDiscovery *discovery.K8sServiceDiscovery
ConnectionManager *discovery.DynamicConnectionManager
// Configuration for reliability features
MaxRetries int
RetryDelay time.Duration
CircuitBreaker bool
HealthInterval time.Duration
}
MCPProxyReconciler reconciles a MCPProxy object
func (*MCPProxyReconciler) Reconcile ¶
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
func (*MCPProxyReconciler) SetupWithManager ¶
func (r *MCPProxyReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type MCPServerReconciler ¶
type MCPServerReconciler struct {
client.Client
Scheme *runtime.Scheme
ServiceDiscovery *discovery.K8sServiceDiscovery
ConnectionManager *discovery.DynamicConnectionManager
Config *config.ComposeConfig
}
MCPServerReconciler reconciles MCPServer objects
func (*MCPServerReconciler) SetupWithManager ¶
func (r *MCPServerReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager
type MCPTaskSchedulerReconciler ¶
type MCPTaskSchedulerReconciler struct {
client.Client
Scheme *runtime.Scheme
Logger *logging.Logger
Config *config.ComposeConfig
// contains filtered or unexported fields
}
MCPTaskSchedulerReconciler reconciles a MCPTaskScheduler object
func (*MCPTaskSchedulerReconciler) Reconcile ¶
func (r *MCPTaskSchedulerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
func (*MCPTaskSchedulerReconciler) SetupWithManager ¶
func (r *MCPTaskSchedulerReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type MCPToolboxReconciler ¶
type MCPToolboxReconciler struct {
client.Client
Scheme *runtime.Scheme
Config *config.ComposeConfig
}
MCPToolboxReconciler reconciles MCPToolbox objects
func (*MCPToolboxReconciler) Reconcile ¶
func (r *MCPToolboxReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile handles MCPToolbox resource reconciliation
func (*MCPToolboxReconciler) SetupWithManager ¶
func (r *MCPToolboxReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager
Source Files