server

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

type ConnectionMetrics struct {
	ServerName          string
	ConnectionType      string
	TotalRequests       int64
	SuccessfulRequests  int64
	FailedRequests      int64
	AverageResponseTime time.Duration
	LastResponseTime    time.Duration
	ConnectionUptime    time.Duration
	CreatedAt           time.Time
	LastUsed            time.Time
	ErrorRate           float64
	// contains filtered or unexported fields
}

type ConnectionStats struct {
	TotalRequests  int64
	FailedRequests int64
	TimeoutErrors  int64
	LastError      time.Time
	LastSuccess    time.Time
	// contains filtered or unexported fields
}

type EnhancedMCPSSEConnection struct {
	ServerName      string
	BaseURL         string
	SSEEndpoint     string
	SessionEndpoint string
	LastUsed        time.Time
	Initialized     bool
	Healthy         bool
	Capabilities    map[string]interface{}
	ServerInfo      map[string]interface{}
	SessionID       string
	// contains filtered or unexported fields
}

type HealthCheckResult struct {
	ServerName   string
	Healthy      bool
	ResponseTime time.Duration
	Error        error
	CheckedAt    time.Time
}

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

type K8sServerInstance struct {
	Name      string
	Config    config.ServerConfig
	Status    string
	StartTime time.Time
	// contains filtered or unexported fields
}

type MCPError struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

type MCPHTTPConnection struct {
	ServerName   string
	BaseURL      string
	LastUsed     time.Time
	Initialized  bool
	Healthy      bool
	Capabilities map[string]interface{}
	ServerInfo   map[string]interface{}
	SessionID    string
	// contains filtered or unexported fields
}

type MCPRequest struct {
	JSONRPC string      `json:"jsonrpc"`
	ID      interface{} `json:"id"`
	Method  string      `json:"method"`
	Params  interface{} `json:"params,omitempty"`
}

type MCPResponse struct {
	JSONRPC string      `json:"jsonrpc"`
	ID      interface{} `json:"id,omitempty"`
	Result  interface{} `json:"result,omitempty"`
	Error   *MCPError   `json:"error,omitempty"`
}

type MCPSSEConnection struct {
	ServerName      string
	BaseURL         string
	SSEEndpoint     string
	SessionEndpoint string
	LastUsed        time.Time
	Initialized     bool
	Healthy         bool
	Capabilities    map[string]interface{}
	ServerInfo      map[string]interface{}
	SessionID       string
	// contains filtered or unexported fields
}

type MCPSTDIOConnection struct {
	ServerName  string
	Host        string
	Port        int
	Connection  net.Conn
	Reader      *bufio.Reader
	Writer      *bufio.Writer
	LastUsed    time.Time
	Initialized bool
	Healthy     bool
	// contains filtered or unexported fields
}

type MCPStreamableHTTPConnection struct {
	ServerName   string
	BaseURL      string
	LastUsed     time.Time
	Initialized  bool
	Healthy      bool
	Capabilities map[string]interface{}
	ServerInfo   map[string]interface{}
	SessionID    string
	// contains filtered or unexported fields
}

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

type ProxyHandler struct {
	// Core K8s components
	ServiceDiscovery  *discovery.K8sServiceDiscovery
	ConnectionManager *discovery.DynamicConnectionManager
	Config            *config.ComposeConfig
	Logger            *logging.Logger

	// Existing functionality maintained
	APIKey          string
	EnableAPI       bool
	ProxyStarted    time.Time
	GlobalRequestID int
	GlobalIDMutex   sync.Mutex

	// Legacy connection management (for compatibility with existing API handlers)
	ServerConnections map[string]*MCPHTTPConnection
	SSEConnections    map[string]*MCPSSEConnection
	SSEMutex          sync.RWMutex
	StdioConnections  map[string]*MCPSTDIOConnection
	StdioMutex        sync.RWMutex
	Manager           *Manager

	// Enhanced SSE connections (for compatibility)
	EnhancedSSEConnections map[string]*EnhancedMCPSSEConnection
	EnhancedSSEMutex       sync.RWMutex

	ConnectionMutex sync.RWMutex
	// contains filtered or unexported fields
}

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

type STDIOBridge struct {
	ProxyURL   string
	ServerName string
	APIKey     string
	// contains filtered or unexported fields
}

type ServerInstance struct {
	Name             string
	Config           config.ServerConfig
	ContainerID      string
	Process          *runtime.Process
	IsContainer      bool
	Status           string
	StartTime        time.Time
	Capabilities     map[string]bool
	ConnectionInfo   map[string]string
	HealthStatus     string
	ResourcesWatcher *ResourcesWatcher
	ProgressManager  *protocol.ProgressManager
	ResourceManager  *protocol.ResourceManager
	SamplingManager  *protocol.SamplingManager
	// contains filtered or unexported fields
}

type Tool struct {
	Name        string                 `json:"name"`
	Description string                 `json:"description"`
	Parameters  map[string]interface{} `json:"parameters"`
}