controllers

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

• type ControllerManager
  • func NewControllerManager(namespace string, cfg *config.ComposeConfig) (*ControllerManager, error)
  • func StartControllerManagerInBackground(namespace string, cfg *config.ComposeConfig) (*ControllerManager, error)
  • func (cm *ControllerManager) GetClient() client.Client
  • func (cm *ControllerManager) IsReady() bool
  • func (cm *ControllerManager) Start(ctx context.Context) error
  • func (cm *ControllerManager) Stop() error
• type MCPMemoryReconciler
  • func (r *MCPMemoryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MCPMemoryReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MCPPostgresReconciler
  • func (r *MCPPostgresReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MCPPostgresReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MCPProxyReconciler
  • func (r *MCPProxyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MCPProxyReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MCPServerReconciler
  • func (r *MCPServerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MCPServerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MCPTaskSchedulerReconciler
  • func (r *MCPTaskSchedulerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MCPTaskSchedulerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MCPToolboxReconciler
  • func (r *MCPToolboxReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MCPToolboxReconciler) SetupWithManager(mgr ctrl.Manager) error

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

func (r *MCPMemoryReconciler) 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 (*MCPMemoryReconciler) SetupWithManager

func (r *MCPMemoryReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type MCPPostgresReconciler

type MCPPostgresReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

MCPPostgresReconciler reconciles a MCPPostgres object

func (*MCPPostgresReconciler) Reconcile

func (r *MCPPostgresReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

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

func (r *MCPProxyReconciler) 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 (*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) Reconcile

func (r *MCPServerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile handles MCPServer resource reconciliation

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